从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，读者可以通过切换分支来查看本文的示例代码。

‍

在GitHub上编辑此页 (opens new window)
上次更新: 2023/5/15 16:02:46
实现一个微型的Mybatis-注解版
Mybatis中传递对象参数

← Mybatis中传递对象参数→

Theme by Vdoing | Copyright © 2022-2023 粤ICP备2022067627号-1 粤公网安备 44011302003646号