从 01 开始
2023-04-25
目录

Mybatis 实现 CRUD

# 70.Mybatis 实现 CRUD

之前我们讲过了 Mybatis 如何实现查询功能，本文我们讲解 Mybatis 实现更新、删除等操作。本文基于 demo1 分支的版本来开发；读者也可以自己再搭建一次环境，作为练手。

‍

# insert

# 修改 IUserDao

我们在接口中，新增一个 setUser 方法，用来存储一个新增的用户信息

package com.peterjxl.dao;

import com.peterjxl.domain.User;
import org.apache.ibatis.annotations.Select;

import java.util.List;

public interface IUserDao {

    /**
     * 查询所有用户
     * @return
     */

    @Select("select * from user")
    List<User> findAll();

    /**
     * 保存新增的用户
     * @param user
     */
    void saveUser(User user);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

‍

# 修改 IUserDao.xml

我们在 IUserDao.xml 里增加一个 insert 标签

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.peterjxl.dao.IUserDao">
    <!-- 配置查询所有用户，id要写方法名称-->
    <select id="findAll" resultType="com.peterjxl.domain.User">
        select * from user
    </select>

    <insert id="saveUser" parameterType="com.peterjxl.domain.User">
        insert into user(username, address, sex, birthday) values (#{username}, #{address}, #{sex}, #{birthday})
    </insert>
</mapper>
1
2
3
4
5
6
7
8
9
10
11
12
13
14

‍

insert 标签里，我们需要指定传入的参数的类型，这里是 User 类；然后 values 里使用 Mybatis 的值传入参数 #{变量名}。由于我们的 getter 和 setter 是 IDEA 自动生成的，因此我们可以直接写属性名。如果你自定义了 getterXXX 方法，则需要传入 XXX 的值。

‍

# 测试

老规矩，新增一个测试方法，然后我们调用 saveUser 方法。

 public void testSave() throws IOException {
    User user = new User();
    user.setUsername("mybatis saveuser");
    user.setAddress("广州市番禺区");
    user.setSex("男");
    user.setBirthday(new Date());

    // 1. 读取配置文件
    InputStream in = Resources.getResourceAsStream("SqlMapConfig.xml");

    // 2. 创建SqlSessionFactory工厂
    SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
    SqlSessionFactory factory = builder.build(in);

    // 3. 使用工厂生成SqlSession对象
    SqlSession session = factory.openSession();

    // 4. 使用SqlSession创建Dao接口的代理对象
    IUserDao userDao = session.getMapper(IUserDao.class);

    // 5. 使用代理对象执行方法
    userDao.saveUser(user);
    session.commit();
  
    // 6. 释放资源
    session.close();
    in.close();
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

‍

‍

特别注意，要调用 commit 方法，否则是不会提交的，如下图，设置了 autocommit 会 false，然后由于没提交，又回滚了：

‍

调用 commit 方法后，才会提交

‍

# 获取自增长 ID

我们 insert 的时候，由于是自增长的，我们没有给 ID 赋值；但如果我们就是想要呢？

在 MySQL 中，有一个语句可以获取最近 insert 的 ID：

select last_insert_id();
1

注意，得执行了 insert 后一段时间执行该查询语句，才能查询到，不然查询到的是 0；

‍

在 Mybatis 中，也支持获取 insert 后的 ID，用 selectKey 标签：

<insert id="saveUser" parameterType="com.peterjxl.domain.User">
    <selectKey keyProperty="id" keyColumn="id" order="AFTER" resultType="int">
        select last_insert_id();
    </selectKey>
    insert into user(username, address, sex, birthday) 
    values (#{username}, #{address}, #{sex}, #{birthday})
</insert>
1
2
3
4
5
6
7

keyProperty 对应属性名称，keyColumn 表示数据库列名，order 表示在 insert 之前还是之后执行，resultType 表示返回的类型，

‍

获取 ID：

System.out.println("保存操作之前：: " + user);
userDao.saveUser(user);
System.out.println("保存操作之前：: " + user);
1
2
3

‍

可以看到 id 已经有值了

‍

# 优化测试类

我们目前的两个测试方法，有很多的重复，例如读取配置文件、创建工厂、释放资源等，我们可以抽取处理，并用 Junit 的注解完成初始化和释放资源。

package com.peterjxl.test;

import com.peterjxl.dao.IUserDao;
import com.peterjxl.domain.User;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;

public class MybatisTest {

    private InputStream in;
    private SqlSessionFactoryBuilder builder;
    private SqlSessionFactory factory;
    private SqlSession session;
    private IUserDao userDao;

    @Before
    public void init() throws IOException {
        // 1. 读取配置文件
        in = Resources.getResourceAsStream("SqlMapConfig.xml");

        // 2. 创建SqlSessionFactory工厂
        builder = new SqlSessionFactoryBuilder();
        factory = builder.build(in);

        // 3. 使用工厂生成SqlSession对象
        session = factory.openSession();

        // 4. 使用SqlSession创建Dao接口的代理对象
        userDao = session.getMapper(IUserDao.class);
    }

    @After
    public void destory() throws IOException {
        // 6. 释放资源
        session.close();
        in.close();
    }


    @Test
    public void helloMybatis() throws Exception{
        // 5. 使用代理对象执行方法
        List<User> users = userDao.findAll();
        for(User user : users){
            System.out.println(user);
        }
    }

    @Test
    public void testSave() throws IOException {
        User user = new User();
        user.setUsername("mybatis saveuser");
        user.setAddress("广州市番禺区");
        user.setSex("男");
        user.setBirthday(new Date());

        // 5. 使用代理对象执行方法
        userDao.saveUser(user);
        session.commit();
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73

‍

然后我们可以测试两个方法，看看是否正常运行。

‍

# update

# 修改 IUserDao

我们增加 updateUser 方法

package com.peterjxl.dao;
import com.peterjxl.domain.User;
import java.util.List;

public interface IUserDao {

    /**
     * 查询所有用户
     * @return
     */


    List<User> findAll();

    /**
     * 保存新增的用户
     * @param user
     */
    void saveUser(User user);

    /**
     * 更新用户
     * @param user
     */
    void updateUser(User user);
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

‍

‍

# 修改 IUserDao.xml

我们在 IUserDao.xml 里增加一个 update 标签

<update id="updateUser" parameterType="com.peterjxl.domain.User">
    update user
    set username=#{username}, address=#{address}, sex=#{sex}, birthday=#{birthday}
    where id=#{id}
</update>
1
2
3
4
5

‍

‍

# 测试

老规矩，新增一个测试方法，然后我们调用 updateUser 方法：

@Test
public void testUpdate(){
    User user = new User();
    user.setId(41); //张三的数据
    user.setUsername("mybatis update user");
    user.setAddress("广州市番禺区");
    user.setSex("男");
    user.setBirthday(new Date());

    // 5. 使用代理对象执行方法
    userDao.updateUser(user);
    session.commit();
}
1
2
3
4
5
6
7
8
9
10
11
12
13

‍

‍

# delete

# 修改 IUserDao

增加删除方法：

void deleteUser(Integer userId);
1

‍

‍

# 修改 IUserDao.xml

<delete id="deleteUser" parameterType="Integer">
    delete from user where id = #{uid}
</delete>
1
2
3

由于我们只有一个参数，我们随便写一个占位符即可，例如叫 uid；

‍

关于 parameterType 的取值：可以写 int，INT，Integer，INTEGER（不区分大小写），java.lang.Integer 等，后续我们讲为什么支持这么多写法

‍

# 测试

@Test
public void testDelete(){
    // 5. 使用代理对象执行方法
    userDao.deleteUser(50);
    session.commit();
}
1
2
3
4
5
6

‍

注意：我们先不删除 初始化数据库时的数据，例如张三李四这些，因为有外键约束。我们删除本文 insert 的数据

‍

‍

# 查询一个

# 修改 IUserDao

增加方法：

/**
 * 根据id查询用户信息
 * @param userId
 * @return
 */
User findById(Integer userId);
1
2
3
4
5
6

‍

‍

# 修改 IUserDao.xml

<!-- 根据ID查询用户 -->
<select id="findById" parameterType="INT" resultType="com.peterjxl.domain.User">
    select * from user where id = #{uid}
</select>
1
2
3
4

‍

‍

# 测试

@Test
public void testFindOne(){
    // 5. 使用代理对象执行方法
    User user = userDao.findById(41);
    System.out.println(user);
}
1
2
3
4
5
6

‍

注意：我们先不删除 初始化数据库时的数据，例如张三李四这些，因为有外键约束。我们删除本文 insert 的数据

‍

‍

# 模糊查询

# 修改 IUserDao

增加方法：

/**
 * 根据名称模糊查询用户信息
 * @param name
 * @return
 */
List<User> findByName(String name);
1
2
3
4
5
6

‍

‍

# 修改 IUserDao.xml

<!-- 根据名称查询用户 -->
<select id="findByName" parameterType="string" resultType="com.peterjxl.domain.User">
    select * from user where username like #{name}
</select>
1
2
3
4

‍

‍

‍

说明：其实还有第二种写法，如下：

<select id="findByName" parameterType="string" resultType="com.peterjxl.domain.User">
    select * from user  where username like '%${value}%'
</select>
1
2
3

注意，占位符一定是要 value，源码是这样规定的。

‍

此外，第二种写法使用的是字符串拼接的方式（Statement）：控制台日志输出如下

‍

‍

第一种则是使用占位符（PreparedStatement），如下图：

‍

所以一般推荐使用第一种写法

‍

‍

‍

# 测试

@Test
public void testFindByName(){
    List<User> users = userDao.findByName("mybatis%");
    for(User user : users){
        System.out.println(user);
    }
}
1
2
3
4
5
6
7

‍

# 聚合函数

# 修改 IUserDao

增加方法：

/**
 * 查询总用户数
 * @return
 */
int findTotal();
1
2
3
4
5

‍

‍

# 修改 IUserDao.xml

<!-- 获取用户的总记录条数 -->
<select id="findTotal" resultType="int">
    select count(*) from user
</select>
1
2
3
4

‍

‍

# 测试

@Test
public void testFindTotal(){
    int total = userDao.findTotal();
    System.out.println("total: " + total);
}
1
2
3
4
5

‍

‍

# 源码

所有代码已上传到了 GitHub (opens new window) 和 Gitee (opens new window) 上，并且创建了分支 demo7，读者可以通过切换分支来查看本文的示例代码。

‍

上次更新: 2024/10/1 21:14:36
实现一个微型的 Mybatis-注解版
Mybatis 中传递对象参数

← Mybatis 中传递对象参数→

最近更新
01
2024 年 12 月记
12-25
02
【三国杀 OL 武将攻略】神孙权
12-23
03
我们这代人存不下钱的原因是什么？ - 知乎 转载
12-13
更多文章>
Theme by Vdoing | Copyright © 2022-2024 | 粤 ICP 备 2022067627 号 -1 | 粤公网安备 44011302003646 号 | 点击查看十年之约