MybatisPlus核心功能——實現CRUD增刪改查操作 (包含條件構造器)

CRUD

官方文檔://baomidou.com/
(建議多看看官方文檔,每種功能裡面都有講解)【本文章使用的mybatisplus版本為3.5.2】

條件構造器

一般都是用service層的方法,因為比mapper層的全。十分重要:Wrapper 記住查看輸出的SQL進行分析

相當於創建一個構造器對象,然後講需要查詢or更新的條件寫在裡面,最後打包給mapper or service層的插入、更新方法

下圖是Wapper的子類,QueryWrapper和UpdateWrapper是一般的Wrapper,AbstractLambdaWrapper 是lambda語法糖的鏈式操作(兩者選擇一種使用即可)

image

下圖是wrapper的條件方法,就不一一介紹了,下面舉了六個就基本例子
image

1、測試一

@Test
public void testWrapper1() {
    //參數是一個wrapper ,條件構造器,和剛才的map對比學習!
    //查詢name不為空,email不為空,age大於18的用戶
    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper
        .isNotNull("name")
        .isNotNull("email")
        .ge("age",18);
    List<User> userList = userMapper.selectList(wrapper);
    userList.forEach(System.out::println);
}

測試二

@Test
public void testWrapper2() {
    //查詢name=wsk的用戶
    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper.eq("name","wsk");
    //查詢一個數據selectOne,若查詢出多個會報錯
    //Expected one result (or null) to be returned by selectOne(), but found: *
    //若出現多個結果使用list或map
    User user = userMapper.selectOne(wrapper);//查詢一個數據,若出現多個結果使用list或map
    System.out.println(user);
}

測試三

@Test
public void testWrapper3() {
    //查詢age在10-20之間的用戶
    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper.between("age", 10, 20);//區間
    Integer count = userMapper.selectCount(wrapper);//輸出查詢的數量selectCount
    System.out.println(count);
}

測試四

@Test
public void testWrapper4() {
    //模糊查詢
    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper
        .notLike("name","s")
        .likeRight("email","qq");//qq%  左和右?
    List<Map<String, Object>> maps = userMapper.selectMaps(wrapper);
    maps.forEach(System.out::println);
}

測試五

@Test
public void testWrapper5() {
    //模糊查詢
    // SELECT id,name,age,email,version,deleted,create_time,update_time 
    //FROM user 
    //WHERE deleted=0 AND id IN 
    //(select id from user where id<5)
    QueryWrapper<User> wrapper = new QueryWrapper<>();
    //id 在子查詢中查出來
    wrapper.inSql("id","select id from user where id<5");
    List<Object> objects = userMapper.selectObjs(wrapper);
    objects.forEach(System.out::println);
}

測試六

@Test
public void testWrapper6() {
    QueryWrapper<User> wrapper = new QueryWrapper<>();
    //通過id進行降序排序
    wrapper.orderByDesc("id");
    List<User> userList = userMapper.selectList(wrapper);
    userList.forEach(System.out::println);
}

CRUD介面

基本配置:

0、創建資料庫

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 '郵箱',
    version INT(10) NOT NULL DEFAULT 1 COMMIT '樂觀鎖版本號',
    DELETED INT(10) NOT NULL DEFAULT 0 COMMIT '邏輯刪除',
    CREATE_TIME DATE COMMIT '創建時間',
    modify_time DATE COMMIT '更新時間',
    PRIMARY KEY (id)
);

DELETE FROM user;

INSERT INTO user (id, name, age, email) VALUES
(1, '工藤新一','[email protected]'),
(2, '毛利蘭','[email protected]'),
(3, '柯南', 28, '[email protected]'),
(4, '灰原哀', 21, '[email protected]'),
(5, '工藤有希子', 24, '[email protected]');

1、創建項目,導入依賴

		<!--spring-boot-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!--SpringBootTest-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
        <!--lombok-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
        </dependency>
        <!--mysql 驅動-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>8.0.26</version>
        </dependency>
        <!--mybatis-plus-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.5.2</version>
        </dependency>

2、yaml

#設置開發環境
spring:
  datasource:
    username: root
    password: 123456
    driver-class-name: com.p6spy.engine.spy.P6SpyDriver
    url: jdbc:p6spy:mysql://localhost:3306/mybatis_plus?serverTimezone=UTC&useUnicode=true&characterEncoding=utf

#配置日誌  log-impl:日誌實現
mybatis-plus:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

3、創建實體類

@Data
@AllArgsConstructor
@NoArgsConstructor
@TableName("user")
public class User {
    @TableId(type = IdType.AUTO)
    Long id;
    String name;
    int age;
    String email;
    @Version//樂觀鎖version註解
    private Integer version;
    private Integer isDelete;

    @TableField(fill = FieldFill.INSERT)
    private Date cTime;
    @TableField(fill = FieldFill.INSERT_UPDATE)
    private Date upTime;
}

4、寫Mapper

@Repository
public interface UserMapper extends BaseMapper<User> {

}

5、寫Service介面和實現類

//Service介面
public interface UserService extends IService<User> {	//別忘了繼承這個父類

}

//實現類
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {	//記得繼承父類

}

6、之後就可以測試了

Mapper CRUD介面

顧名思義這個只有mapper層對象才有的方法

Insert

寫資料庫的時候id設置了主鍵自增的話,插入的時候不需要加入id,因為MP會自動添加並且自增的。

註:資料庫寫了id自增的話,在實體類設置主鍵生成策略是沒用的,因為資料庫設置了自增,資料庫優先順序高於程式碼

@Test//測試插入
public void insertTest(){
    User user = new User();
    user.setName("wsk");
    user.setAge(18);
    user.setEmail("[email protected]");
    Integer result = userMapper.insert(user); //會幫我們自動生成id
    System.out.println(result); //受影響的行數
    System.out.println(user); //通過日誌發現id會自動回填(id是由雪花演算法生成的,在主鍵生成策略部分有講到)
}

image

資料庫插入的id的默認值為:全局的唯—id

Update

@Test//測試更新
public void updateTest(){
    User user = new User();
    user.setId(2L);//怎麼改id??
    //通過條件自動拼接動態Sql
    user.setName("root");
    user.setAge(12);
    user.setEmail("[email protected]");
    int i = userMapper.updateById(user);//updateById,但是參數是個user
    System.out.println(i);
}

image

Select

  • 通過id查詢單個用戶
@Test//通過id查詢單個用戶
public void testSelectById(){
    User user = userMapper.selectById(1L);
    System.out.println(user);
}

image

  • 通過id查詢多個用戶
@Test//通過id查詢多個用戶
public void testSelectBatchIds(){
    List<User> users = userMapper.selectBatchIds(Arrays.asList(1L, 2L, 3L));
    users.forEach(System.out::println);
    //System.out.println(users);
}

image

image

  • 條件查詢 通過map封裝
@Test//通過條件查詢之一  map(這裡的map,相當於where後面的 name="conan"等條件)
public void testMap(){
    HashMap<String, Object> map = new HashMap<>();
    //自定義要查詢的
    map.put("name","www");	//查詢名字是www的數據
    map.put("name","111");	//查詢名字是111的數據	最後的結果是取兩者交集
    map.put("age",18);
    List<User> users = userMapper.selectByMap(map);
    users.forEach(System.out::println);
}

image

image

Delete

基本的刪除任務:

image

@Test
public void testDeleteById(){
    userMapper.deleteById(1359507762519068681L);
}
@Test
public void testDeleteBatchIds(){
  userMapper.deleteBatchIds(Arrays.asList(1359507762519068675L,1359507762519068676L));
}
@Test
public void testD(){
    HashMap<String, Object> map = new HashMap<>();
    map.put("age","18");
    map.put("name","lol");
    userMapper.deleteByMap(map);
}

Service CRUD介面

顧名思義這是Service層才有的方法

Save

為了區分mapper層和service層的方法,所以service層的插入方法取名為save

@Test
void test(){
    User user = new User();
    user.setName("Conan");
    user.setAge(18);
    user.setEmail("毛利偵探事務所");
    //插入單條數據
    userService.save(user);
    // 插入(批量)
    userService.saveBatch(Arrays.asList(user));
}

Remove

service層刪除方法取名為remove

 @Test
    void test(){
        User user = new User();
        user.setName("Conan");
        user.setAge(18);
        user.setEmail("毛利偵探事務所");

        HashMap<String,Object> map = new HashMap<>();
        map.put("name","Conan");

        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.eq("name","毛利小五郎");

        userService.remove(wrapper);    //根據條件構造器刪除數據
        userService.removeById(16L);    //根據id刪除數據,也可以根據實體類對象刪除數據
        userService.removeByMap(map);   //根據map的條件刪除記錄
        userService.removeBatchByIds(Arrays.asList(user));  //批量刪除 
    }

Update

@Test
    void test(){
        User user = new User();
        user.setName("Conan");
        user.setAge(18);
        user.setEmail("毛利偵探事務所");

        HashMap<String,Object> map = new HashMap<>();
        map.put("name","Conan");

        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.eq("name","毛利小五郎")
                .ge("age",18);


        userService.update(wrapper);    //根據條件構造器更新
        userService.updateById(user);   //根據傳入的實體類id確定需要更新的數據,更新為傳入的實體類對象
        userService.updateBatchById(Arrays.asList(user));   //批量更新
    }

Get

該方法只能查詢一條數據,所以不推薦。查詢用list方法

@Test
    void test(){
        User user = new User();
        user.setName("Conan");
        user.setAge(18);
        user.setEmail("毛利偵探事務所");

        HashMap<String,Object> map = new HashMap<>();
        map.put("name","Conan");

        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.eq("name","毛利小五郎")
                .ge("age",18);


        userService.getById(12L);   //根據id查詢一條數據
        userService.getMap(wrapper);    //根據構造器查詢一條數據,返回Mapper集合
    }

List

查詢多條數據

@Test
void test(){
    User user = new User();
    user.setName("Conan");
    user.setAge(18);
    user.setEmail("毛利偵探事務所");

    HashMap<String,Object> map = new HashMap<>();
    map.put("name","Conan");

    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper.eq("name","毛利小五郎")
        .ge("age",18);


    userService.list(); //查詢全部數據
    userService.listMaps(); //查詢全部數據,以map形式返回
    userService.listByMap(map); //根據map查詢數據
    userService.listByIds(Arrays.asList(10L,15L));   //根據id查詢數據
}

SaveOrUpdate

運行邏輯:直接更新,更新0行的話;就select,查詢出來是0行;則就插入

有傳入id的情況會優先更新,如果更新不了,則會插入新的數據

記得在實體類寫上@TableId!!!

@Test
void test(){
    User user = new User();
    user.setName("Conan");
    user.setAge(18);
    user.setEmail("毛利偵探事務所");

    HashMap<String,Object> map = new HashMap<>();
    map.put("name","Conan");

    UpdateWrapper<User> wrapper = new UpdateWrapper<>();
    wrapper.eq("name","毛利小五郎")
        .ge("age",18);


    userService.saveOrUpdate(user); //傳入的對象id存在則更新,否則插入新數據
    userService.saveOrUpdate(user,wrapper); //根據更新條件構造器,更細數據
    userService.saveOrUpdateBatch(Arrays.asList(user)); //批量修改插入
}

Count

統計符合條件的數據的數量

@Test
    void test(){
        User user = new User();
        user.setName("Conan");
        user.setAge(18);
        user.setEmail("毛利偵探事務所");

        HashMap<String,Object> map = new HashMap<>();
        map.put("name","Conan");

        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.eq("name","毛利小五郎")
                .ge("age",18);
        
        userService.count();
        userService.count();
    }

Chain

鏈式調用,可以不用條件構造器完成 條件設置和增刪改查。推薦!因為優雅!

Query
@Test
void test(){
    User user = new User();
    user.setName("Conan");
    user.setAge(18);
    user.setEmail("毛利偵探事務所");

    HashMap<String,Object> map = new HashMap<>();
    map.put("name","Conan");

    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper.eq("name","毛利小五郎")
        .ge("age",18);

    List<User> userList = userService.query()
        .eq("name", "工藤新一")
        .gt("age", 17)
        .list();
    for(User  user01: userList) {
        System.out.println(user);
    }
}
Update
@Test
void test(){
    User user = new User();
    user.setName("Conan");
    user.setAge(18);
    user.setEmail("毛利偵探事務所");

    HashMap<String,Object> map = new HashMap<>();
    map.put("name","Conan");

    QueryWrapper<User> wrapper = new QueryWrapper<>();
    wrapper.eq("name","毛利小五郎")
        .ge("age",18);

    userService.update()
        .eq("name", "工藤新一")
        .gt("age", 17)
        .update();
}