mybatis

    科技2022-07-13  143

    mybatis_plus的使用

    1创建数据库

    DROP TABLE IF EXISTS user; CREATE TABLE user ( id BIGINT(20) NOT NULL COMMENT '主键ID', name VARCHAR(30) NULL DEFAULT NULL COMMENT '姓名', age INT(11) NULL DEFAULT NULL COMMENT '年龄', email VARCHAR(50) NULL DEFAULT NULL COMMENT '邮箱', PRIMARY KEY (id) ); INSERT INTO user (id, name, age, email) VALUES (1, 'Jone', 18, 'test1@baomidou.com'), (2, 'Jack', 20, 'test2@baomidou.com'), (3, 'Tom', 28, 'test3@baomidou.com'), (4, 'Sandy', 21, 'test4@baomidou.com'), (5, 'Billie', 24, 'test5@baomidou.com');

    2、编写项目,初始化项目!使用SpringBoot初始化! 3、导入依赖

    <!-- 数据库驱动 --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> </dependency> <!-- lombok --> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> </dependency> <!-- mybatis-plus --> <!-- mybatis-plus 是自己开发,并非官方的! --> <dependency> <groupId>com.baomidou</groupId> <artifactId>mybatis-plus-boot-starter</artifactId> <version>3.0.5</version> </dependency>

    4连接数据库!

    #mysql8 驱动需要增加时区配置 serverTimezone=GMT%2B8 spring.datasource.username=root spring.datasource.password=123456 spring.datasource.url=jdbc:mysql://localhost:3306/mybatis_plus?useSSL=fals3&useUnicode=true&charaterEncoding=utf-8&serverTimezone=GMT%2B8 spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

    (传统方式pojo-dao连接mybatis,配置mapper.xml文件-service-controller) 使用了mybatis-plus 之后 pojo

    @Data @AllArgsConstructor @NoArgsConstructor public class User { private Long id; private String name; private Integer age; private String email; }

    mapper接口

    package com.kuang.mapper; import com.baomidou.mybatisplus.core.mapper.BaseMapper; import com.kuang.pojo.User; import org.springframework.stereotype.Repository; // 在对应的Mapper上面继承基本的类 BaseMapper @Repository // 代表持久层 public interface UserMapper extends BaseMapper<User> { // 所有的CRUD操作都已经编写完成了 // 你不需要像以前的配置一大堆文件了! }

    测试类中测试

    @SpringBootTest class MybatisPlusApplicationTests { // 继承了BaseMapper,所有的方法都来自己父类 // 我们也可以编写自己的扩展方法! @Autowired private UserMapper userMapper; @Test void contextLoads() { // 参数是一个 Wrapper ,条件构造器,这里我们先不用 null // 查询全部用户 List<User> users = userMapper.selectList(null); users.forEach(System.out::println); } }

    CRUD操作

    class MybatisPlusApplicationTests { //继承了BaseMapper,所有的方法都来自父类 //也可写自己的扩展方法 @Autowired private UserMapper userMapper; @Test void contextLoads() { // 参数是一个 Wrapper ,条件构造器,这里我们先不用 null // 查询全部用户 List<User> users = userMapper.selectList(null); users.forEach(System.out::println); } // // 查询name不为空的用户,并且邮箱不为空的用户,年龄大于等于12 // QueryWrapper<User> wrapper = new QueryWrapper<>(); // wrapper // .isNotNull("name") // .isNotNull("email") // .ge("age",12); // userMapper.selectList(wrapper).forEach(System.out::println); // } // 测试插入 @Test public void testInsert () { User user = new User(); Scanner sc =new Scanner(System.in); System.out.println("姓名"); String name=sc.next(); System.out.println("年龄"); int age =sc.nextInt(); System.out.println("邮箱"); String email=sc.nextLine(); user.setName("name"); user.setAge(age); user.setEmail("email"); int result = userMapper.insert(user); // 帮我们自动生成id System.out.println(result); // 受影响的行数 System.out.println(user); // 发现,id会自动回填 } // 测试更新 @Test public void testUpdate () { User user = new User(); // 通过条件自动拼接动态sql // user.setId(6L); user.setName("张三"); user.setAge(18); // 注意:updateById 但是参数是一个 对象! int i = userMapper.updateById(user); System.out.println(i); } // 测试查询 @Test public void testSelectById () { User user = userMapper.selectById(1L); System.out.println(user); } // 测试批量查询! // @Test public void testSelectByBatchId(){ // List<User> users = userMapper.selectBatchIds(Arrays.asList(1, 2, 3)); // users.forEach(System.out::println); // } // 按条件查询之一使用map操作 // @Test // public void testSelectByBatchIds(){ // HashMap<String, Object> map = new HashMap<>(); // 自定义要查询 // map.put("name","mhy"); // map.put("age",18); // List<User> users = userMapper.selectByMap(map); // users.forEach(System.out::println); } // 测试分页查询 @Test public void testPage () { // 参数一:当前页 // 参数二:页面大小 // 使用了分页插件之后,所有的分页操作也变得简单的! Page<User> page = new Page<>(2, 5); userMapper.selectPage(page, null); page.getRecords().forEach(System.out::println); System.out.println(page.getTotal()); } // 测试删除 @Test public void testDeleteById () { userMapper.deleteById(1240620674645544965L); } // 通过id批量删除 @Test public void testDeleteBatchId () { userMapper.deleteBatchIds(Arrays.asList(1240620674645544961L, 1240620674645544962L)); } // 通过map删除 @Test public void testDeleteMap () { HashMap<String, Object> map = new HashMap<>(); map.put("name", "jone"); userMapper.deleteByMap(map); }

    代码自动生成

    package com.mhy; import com.baomidou.mybatisplus.annotation.DbType; import com.baomidou.mybatisplus.annotation.FieldFill; import com.baomidou.mybatisplus.annotation.IdType; import com.baomidou.mybatisplus.annotation.TableField; import com.baomidou.mybatisplus.generator.AutoGenerator; import com.baomidou.mybatisplus.generator.config.DataSourceConfig; import com.baomidou.mybatisplus.generator.config.GlobalConfig; import com.baomidou.mybatisplus.generator.config.PackageConfig; import com.baomidou.mybatisplus.generator.config.StrategyConfig; import com.baomidou.mybatisplus.generator.config.po.TableFill; import com.baomidou.mybatisplus.generator.config.rules.DateType; import com.baomidou.mybatisplus.generator.config.rules.NamingStrategy; import java.util.ArrayList; // 代码自动生成器 public class MhyCode { public static void main(String[] args) { // 需要构建一个 代码自动生成器 对象 AutoGenerator mpg = new AutoGenerator(); // 配置策略 // 1、全局配置 GlobalConfig gc = new GlobalConfig(); String projectPath = System.getProperty("user.dir"); gc.setOutputDir(projectPath+"/src/main/java"); gc.setAuthor("Mhy"); gc.setOpen(false); gc.setFileOverride(false); // 是否覆盖 gc.setServiceName("%sService"); // 去Service的I前缀 gc.setIdType(IdType.ID_WORKER); gc.setDateType(DateType.ONLY_DATE); gc.setSwagger2(true); mpg.setGlobalConfig(gc); //2、设置数据源 DataSourceConfig dsc = new DataSourceConfig(); dsc.setUrl("jdbc:mysql://localhost:3306/mybatis_plus? useSSL=false&useUnicode=true&characterEncoding=utf-8&serverTimezone=GMT+8"); dsc.setDriverName("com.mysql.cj.jdbc.Driver"); dsc.setUsername("root"); dsc.setPassword("123456"); dsc.setDbType(DbType.MYSQL); mpg.setDataSource(dsc); //3、包的配置 PackageConfig pc = new PackageConfig(); pc.setModuleName("blog"); pc.setParent("com.mhy"); pc.setEntity("entity"); pc.setMapper("mapper"); pc.setService("service"); pc.setController("controller"); mpg.setPackageInfo(pc); //4、策略配置 StrategyConfig strategy = new StrategyConfig(); strategy.setInclude("user"); // 设置要映射的表名 strategy.setNaming(NamingStrategy.underline_to_camel); strategy.setColumnNaming(NamingStrategy.underline_to_camel); strategy.setEntityLombokModel(true); // 自动lombok; strategy.setLogicDeleteFieldName("deleted"); // 自动填充配置 TableFill gmtCreate = new TableFill("gmt_create", FieldFill.INSERT); TableFill gmtModified = new TableFill("gmt_modified", FieldFill.INSERT_UPDATE); ArrayList<TableFill> tableFills = new ArrayList<>(); tableFills.add(gmtCreate); tableFills.add(gmtModified); strategy.setTableFillList(tableFills); // 乐观锁 strategy.setVersionFieldName("version"); strategy.setRestControllerStyle(true); strategy.setControllerMappingHyphenStyle(true); // localhost:8080/hello_id_2 mpg.setStrategy(strategy); mpg.execute(); //执行 } }
    Processed: 0.010, SQL: 8