本文共 8672 字，大约阅读时间需要 28 分钟。

　　上一篇博文中我们讲了如何使用Mybatis查询users表中的数据，算是对MyBatis有一个初步的入门了，今天讲解一下如何使用MyBatis对users表执行CRUD操作。本文中使用到的测试环境是上一篇博文中的测试环境。

一、使用MyBatis对表执行CRUD操作——基于XML的实现

1、定义sql映射xml文件

　　userMapper.xml文件的内容如下：

   
   
       
        
        
            select * from users where id=#{id}            
        
    
             insert into users(name,age) values(#{name},#{age})    
            
        
    
             delete from users where id=#{id}    
            
        
    
             update users set name=#{name},age=#{age} where id=#{id}    
            
        
            select * from users        
   

　单元测试类代码如下：

package me.gacl.test;import java.util.List;import me.gacl.domain.User;import me.gacl.util.MyBatisUtil;import org.apache.ibatis.session.SqlSession;import org.junit.Test;public class TestCRUDByXmlMapper {    @Test    public void testAdd(){        //SqlSession sqlSession = MyBatisUtil.getSqlSession(false);        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);        /**         * 映射sql的标识字符串，         * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，         * addUser是insert标签的id属性值，通过insert标签的id属性值就可以找到要执行的SQL         */        String statement = "me.gacl.mapping.userMapper.addUser";//映射sql的标识字符串        User user = new User();        user.setName("用户奋斗的小虾米");        user.setAge(20);        //执行插入操作        int retResult = sqlSession.insert(statement,user);        //手动提交事务        //sqlSession.commit();        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(retResult);    }        @Test    public void testUpdate(){        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);        /**         * 映射sql的标识字符串，         * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，         * updateUser是update标签的id属性值，通过update标签的id属性值就可以找到要执行的SQL         */        String statement = "me.gacl.mapping.userMapper.updateUser";//映射sql的标识字符串        User user = new User();        user.setId(3);        user.setName("奋斗的小虾米");        user.setAge(25);        //执行修改操作        int retResult = sqlSession.update(statement,user);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(retResult);    }        @Test    public void testDelete(){        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);        /**         * 映射sql的标识字符串，         * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，         * deleteUser是delete标签的id属性值，通过delete标签的id属性值就可以找到要执行的SQL         */        String statement = "me.gacl.mapping.userMapper.deleteUser";//映射sql的标识字符串        //执行删除操作        int retResult = sqlSession.delete(statement,5);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(retResult);    }        @Test    public void testGetAll(){        SqlSession sqlSession = MyBatisUtil.getSqlSession();        /**         * 映射sql的标识字符串，         * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，         * getAllUsers是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL         */        String statement = "me.gacl.mapping.userMapper.getAllUsers";//映射sql的标识字符串        //执行查询操作，将查询结果自动封装成List
   
    返回        List
    
      lstUsers = sqlSession.selectList(statement);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(lstUsers);    }}
    
   

二、使用MyBatis对表执行CRUD操作——基于注解的实现

　　1、定义sql映射的接口

　　UserMapperI接口的代码如下：

package me.gacl.mapping;import java.util.List;import me.gacl.domain.User;import org.apache.ibatis.annotations.Delete;import org.apache.ibatis.annotations.Insert;import org.apache.ibatis.annotations.Select;import org.apache.ibatis.annotations.Update;/** * @author gacl * 定义sql映射的接口，使用注解指明方法要执行的SQL */public interface UserMapperI {    //使用@Insert注解指明add方法要执行的SQL    @Insert("insert into users(name, age) values(#{name}, #{age})")    public int add(User user);        //使用@Delete注解指明deleteById方法要执行的SQL    @Delete("delete from users where id=#{id}")    public int deleteById(int id);        //使用@Update注解指明update方法要执行的SQL    @Update("update users set name=#{name},age=#{age} where id=#{id}")    public int update(User user);        //使用@Select注解指明getById方法要执行的SQL    @Select("select * from users where id=#{id}")    public User getById(int id);        //使用@Select注解指明getAll方法要执行的SQL    @Select("select * from users")    public List
   
     getAll();}
   

需要说明的是，我们不需要针对UserMapperI接口去编写具体的实现类代码，这个具体的实现类由MyBatis帮我们动态构建出来，我们只需要直接拿来使用即可。

　　2、在conf.xml文件中注册这个映射接口

单元测试类的代码如下：

package me.gacl.test;import java.util.List;import me.gacl.domain.User;import me.gacl.mapping.UserMapperI;import me.gacl.util.MyBatisUtil;import org.apache.ibatis.session.SqlSession;import org.junit.Test;public class TestCRUDByAnnotationMapper {    @Test    public void testAdd(){        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);        //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来        UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);        User user = new User();        user.setName("用户xdp");        user.setAge(20);        int add = mapper.add(user);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(add);    }        @Test    public void testUpdate(){        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);        //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来        UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);        User user = new User();        user.setId(3);        user.setName("奋斗的小虾米_xdp");        user.setAge(26);        //执行修改操作        int retResult = mapper.update(user);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(retResult);    }        @Test    public void testDelete(){        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);        //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来        UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);        //执行删除操作        int retResult = mapper.deleteById(7);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(retResult);    }        @Test    public void testGetUser(){        SqlSession sqlSession = MyBatisUtil.getSqlSession();        //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来        UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);        //执行查询操作，将查询结果自动封装成User返回        User user = mapper.getById(8);        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(user);    }        @Test    public void testGetAll(){        SqlSession sqlSession = MyBatisUtil.getSqlSession();        //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来        UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);        //执行查询操作，将查询结果自动封装成List
   
    返回        List
    
      lstUsers = mapper.getAll();        //使用SqlSession执行完SQL之后需要关闭SqlSession        sqlSession.close();        System.out.println(lstUsers);    }}
    
   

用到的MyBatisUtil工具类代码如下：

package me.gacl.util;import java.io.InputStream;import org.apache.ibatis.session.SqlSession;import org.apache.ibatis.session.SqlSessionFactory;import org.apache.ibatis.session.SqlSessionFactoryBuilder;public class MyBatisUtil {    /**     * 获取SqlSessionFactory     * @return SqlSessionFactory     */    public static SqlSessionFactory getSqlSessionFactory() {        String resource = "conf.xml";        InputStream is = MyBatisUtil.class.getClassLoader().getResourceAsStream(resource);        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);        return factory;    }        /**     * 获取SqlSession     * @return SqlSession     */    public static SqlSession getSqlSession() {        return getSqlSessionFactory().openSession();    }        /**     * 获取SqlSession     * @param isAutoCommit      *         true 表示创建的SqlSession对象在执行完SQL之后会自动提交事务     *         false 表示创建的SqlSession对象在执行完SQL之后不会自动提交事务，这时就需要我们手动调用sqlSession.commit()提交事务     * @return SqlSession     */    public static SqlSession getSqlSession(boolean isAutoCommit) {        return getSqlSessionFactory().openSession(isAutoCommit);    }}

　 以上的相关代码是全部测试通过的，关于使用MyBatis对表执行CRUD操作的内容就这么多。