Mybatis增删改查

V哥官网：http://www.vgxit.com
本文对应视频教程：http://www.vgxit.com/course/22

1，概述：

我们上节课学了一下Mybatis的基本入门，这节课我们学习一下Mybatis的增删改查功能。而查询我们之前都讲过了，这里就过在赘述，我们重点讲添加修改删除。

2，封装获取SqlSession的工具类：

package com.vgxit.learn.vgmybatis.ktdm.tool;

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 java.io.IOException;
import java.io.Reader;

/**
 * Mybatis工具类
 */
public class MybatisTool {
    /**
     * SqlSessionFactory单例
     */
    private static SqlSessionFactory SQL_SESSION_FACTORY;

    /**
     * 获取对应的SqlSession
     * @return
     * @throws IOException
     */
    public static SqlSession getSqlSession() throws IOException {
        if (SQL_SESSION_FACTORY == null) {
            synchronized (MybatisTool.class) {
                if (SQL_SESSION_FACTORY == null) {
                    SqlSessionFactoryBuilder sessionFactoryBuilder = new SqlSessionFactoryBuilder();
                    //2,加载对应的配置文件
                    try (Reader configReader = Resources.getResourceAsReader("mybatis-config.xml")) {
                        //3,创建SqlSessionFactory,SqlSessionFactory在系统中必须是单例的
                        SQL_SESSION_FACTORY = sessionFactoryBuilder.build(configReader);
                    }
                }
            }
        }
        return SQL_SESSION_FACTORY.openSession();
    }
}

3，添加数据

1，在mapper里面定义对应的方法

int addUser(User user);

2，编写对应的映射器->xml文件：

<insert id="addUser" parameterType="com.vgxit.learn.vgmybatis.ktdm.po.User">
        insert into user values (null, #{name}, #{gender}, #{age});
    </insert>

3，具体调用

private static void add() {
        //1,构造用户对象
        User user = User.builder()
                .name("蔡萝莉")
                .gender((short) 2)
                .age(21)
                .build();
        try (SqlSession sqlSession = MybatisTool.getSqlSession()) {
            UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
            int result = userMapper.addUser(user);
            System.out.println("添加了" + result + "行数据");
            //在mybatis里面默认就是开启了事务的，我们做查询的时候没有影响，但是如果我们做添加，修改删除这种写操作的时候，必须提交事务
            sqlSession.commit();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

4，修改数据

1，在mapper里面定义对应的方法

int updateUser(User user);

2，编写对应的映射器->xml文件

<update id="updateUser" parameterType="com.vgxit.learn.vgmybatis.ktdm.po.User">
        update user set name=#{name}, gender=#{gender}, age=#{age} where id=#{id}
    </update>

3，具体调用

private static void update() {
        //获取sqlSession
        try (SqlSession sqlSession = MybatisTool.getSqlSession()) {
            UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
            User user = userMapper.getUserById(19);
            user.setName("林俊杰");
            user.setAge(39);
            userMapper.updateUser(user);
            sqlSession.commit();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

5，删除数据

1，在mapper里面定义对应的方法

int deleteUser(int id);

2，编写对应的映射器->xml文件

<delete id="deleteUser" parameterType="int">
        delete from user where id=#{id}
    </delete>

3，具体调用

private static void delete() {
        //获取sqlSession
        try (SqlSession sqlSession = MybatisTool.getSqlSession()) {
            UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
            System.out.println(userMapper.deleteUser(10));
            sqlSession.commit();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }