3. 使用Mybatis完成CRUD

基于入门案例的查询工程继续实现增删查改

1、增加用户

原有的UserDao接口中新填

    /**
     * 添加用户
     * @param user
     * @return 影响数据库记录的行数
     */
    void insertUser(User user);

UserDao.xml中添加对应配置信息

    <!--增加用户-->
    <insert id="insertUser" parameterType="com.neuedu.domain.User">
        insert into user(username,address,sex,birthday) values(#{userName},#{address},#{sex},#{birthday});
    </insert>

说明：
1）parameterType属性：代表参数的类型，因为我们要传入的是一个类的对象，所以类型就写类的全名称。
2）sql语句中使用#{}字符：它代表占位符，相当于原来jdbc部分所学的?，都是用于执行语句时替换实际的数据。 具体的数据是由#{}里面的内容决定的。
3）#{}中内容的写法： 由于我们保存方法的参数是 一个User对象，此处要写User对象中的属性名称。 它用的是ognl表达式。
4）ognl表达式： 它是apache提供的一种表达式语言，全称是： Object Graphic Navigation Language 对象图导航语言 它是按照一定的语法格式来获取数据的。 语法格式就是使用 #{对象.对象}的方式。
5）#{user.username}它会先去找user对象，然后在user对象中找到username属性，并调用getUsername()方法把值取出来。但是我们在parameterType属性上指定了实体类名称，所以可以省略user.而直接写username。

整合测试文件
MyBatisTest.java
添加新增用户测试代码

    @Test
    public void testInsert(){
        User user = new User();
        user.setUsername("哈哈");
        user.setAddress("沈阳浑南新区");
        user.setSex("男");
        user.setBirthday(new Date());
        //执行保存方法
        userDao.insertUser(user);
    }

原有测试代码整合为：

    private InputStream in;
    private SqlSession sqlSession;
    private UserDao userDao;

    @Before//用于在测试方法执行之前执行
    public void init() throws Exception{
        //1.读取配置文件，生成字节输入流
        in = Resources.getResourceAsStream("SqlMapConfig.xml");
        //2.获取SqlSessionFactory
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(in);
        //3.获取SqlSession对象
        sqlSession = factory.openSession();
        //4.获取dao的代理对象
        userDao = sqlSession.getMapper(UserDao.class);
    }

    @After//用于在测试方法执行之后执行
    public void destroy() throws Exception{
        //提交事务
        sqlSession.commit();
        //6.释放资源
        sqlSession.close();
        in.close();
    }

image.png image.png

---

2、用户更新

在持久层接口中添加更新方法

    /**
     * 更新用户
     * @param user
     */
    void updateUser(User user);

在用户的映射配置文件中配置

    <!-- 更新用户 -->
    <update id="updateUser" parameterType="com.neuedu.domain.User">
        update user set username=#{userName},address=#{address},sex=#{sex},birthday=#{birthday} where id=#{id}
    </update>

    /**
     * 测试更新操作
     */
    @Test
    public void testUpdate(){
        User user = new User();
        user.setId(49);
        user.setUserName("呵呵");
        user.setAddress("大连市金州区");
        user.setSex("女");
        user.setBirthday(new Date());

        //5.执行保存方法
        userDao.updateUser(user);
    }

image.png image.png

---

3、用户删除

在持久层接口中添加删除方法

    /**
     * 根据Id删除用户
     * @param userId
     */
    void deleteUser(Integer userId);

在用户的映射配置文件中配置

    <!-- 删除用户-->
    <delete id="deleteUser" parameterType="Integer">
        delete from user where id = #{id}
    </delete>

加入删除的测试方法

    /**
     * 测试删除操作
     */
    @Test
    public void testDelete(){
        //5.执行删除方法
        userDao.deleteUser(49);
    }

image.png
image.png

---

4、用户模糊查询

在持久层接口中添加模糊查询方法

    /**
     * 根据名称模糊查询用户信息
     * @param username
     * @return
     */
    List<User> findByName(String userName);

加入模糊查询的测试方法

    /**
     * 测试模糊查询操作
     */
    @Test
    public void testFindByName(){
        //执行查询一个方法
        List<User> users = userDao.findByName("%王%");
        for(User user : users){
            System.out.println(user);
        }
    }

image.png

我们在配置文件中没有加入%来作为模糊查询的条件，所以在传入字符串实参时，就需要给定模糊查询的标识%。配置文件中的#{userN ame}也只是一个占位符，所以SQL语句显示为“？”。

模糊查询的另一种配置方式

1、修改SQL语句的配置，配置如下：

    <!-- 根据名称模糊查询 -->
    <select id="findByName" parameterType="string" resultType="com.neuedu.domain.User">
        select * from user where username like '%${value}%'
    </select>

我们在上面将原来的#{}占位符，改成了{value}的写法就是固定的，不能写成其它名字。
2、测试代码修改如下

    /**
     * 测试模糊查询操作
     */
    @Test
    public void testFindByName(){
        //执行查询一个方法
        List<User> users = userDao.findByName("王");
        for(User user : users){
            System.out.println(user);
        }
    }

可以发现，我们在程序代码中就不需要加入模糊查询的匹配符%了，这两种方式的实现效果是一样的，但执行的语句是不一样的。

注意：#{}与${}的区别

1）#{}表示一个占位符号

通过#{}可以实现preparedStatement向占位符中设置值，自动进行java类型和jdbc类型转换，
#{}可以有效防止sql注入。 #{}可以接收简单类型值或pojo属性值。 
如果parameterType传输单个简单类型值，#{}括号中可以是value或其它名称。 

2）${}表示拼接sql串

通过${}可以将parameterType 传入的内容拼接在sql中且不进行jdbc类型转换， 
${}可以接收简单类型值或pojo属性值，如果parameterType传输单个简单类型值，${}括号中只能是value。

---

5、查询使用聚合函数

在持久层接口中添加模糊查询方法

    /**
     * 查询总用户数
     * @return
     */
    int findTotal();

在用户的映射配置文件中配置

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

加入聚合查询的测试方法

    /**
     * 测试查询总记录条数
     */
    @Test
    public void testFindTotal(){
        //5.执行查询一个方法
        int count = userDao.findTotal();
        System.out.println(count);
    }

image.png

---

6、扩展：新增用户 id 的返回值

新增用户后，同时还要返回当前新增用户的 id 值，因为 id 是由数据库的自动增长来实现的，所以就相
当于我们要在新增后将自动增长 auto_increment 的值返回。

<insert id="insertUser" parameterType="com.neuedu.domain.User">
    <!-- 配置保存时获取插入的 id -->
    <selectKey keyColumn="id" keyProperty="id" resultType="int" order="AFTER">
          select last_insert_id();
    </selectKey>
          insert into user(username,birthday,sex,address) values(#{username},#{birthday},#{sex},#{address})
</insert>

说明：
keyColumn：对应表中的列的
keyProperty：对应实体类属性
resultType：结果集的类型
order：插入前/后获取结果

测试代码：

    @Test
    public void testInsert(){
        User user = new User();
        user.setUsername("哈哈");
        user.setAddress("沈阳浑南新区");
        user.setSex("男");
        user.setBirthday(new Date());
        System.out.println("保存操作之前："+user);
        //执行保存方法
        userDao.insertUser(user);

        System.out.println("保存操作之后："+user);
    }

image.png