MyBatis入门学习教程 MyBatis快速入门1-8(2)

野性酷女 2022-10-02 03:54 33阅读 0赞

[2019独角兽企业重金招聘Python工程师标准>>> ][2019_Python_] ![hot3.png][]

**上一章**：[http://my.oschina.net/u/2608629/admin/edit-blog?blog=71542][http_my.oschina.net_u_2608629_admin_edit-blog_blog_71542]2

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

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

1、定义sql映射xml文件

userMapper.xml文件的内容如下：

<?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="me.gacl.mapping.userMapper">
       
       
       <select id="getUser" parameterType="int" 
           resultType="me.gacl.domain.User">
           select * from users where id=#{id}
       </select>
       
       
       <insert id="addUser" parameterType="me.gacl.domain.User">
           insert into users(name,age) values(#{name},#{age})
       </insert>
       
       
       <delete id="deleteUser" parameterType="int">
           delete from users where id=#{id}
       </delete>
       
       
       <update id="updateUser" parameterType="me.gacl.domain.User">
           update users set name=#{name},age=#{age} where id=#{id}
       </update>
       
       
       <select id="getAllUsers" resultType="me.gacl.domain.User">
           select * from users
       </select>
       
    </mapper>

单元测试类代码如下：

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<User>返回
           List<User> 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<User> getAll();
    }

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

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

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">
    <configuration>
       <environments default="development">
           <environment id="development">
               <transactionManager type="JDBC" />
               
               <dataSource type="POOLED">
                   <property name="driver" value="com.mysql.jdbc.Driver" />
                   <property name="url" value="jdbc:mysql://localhost:3306/mybatis" />
                   <property name="username" value="root" />
                   <property name="password" value="XDP" />
               </dataSource>
           </environment>
       </environments>
       
       <mappers>
           
           <mapper resource="me/gacl/mapping/userMapper.xml"/>
           
           <mapper class="me.gacl.mapping.UserMapperI"/>
       </mappers>
       
    </configuration>

单元测试类的代码如下：

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<User>返回
           List<User> 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操作的内容就这么多。

转载于:https://my.oschina.net/zhangyafei/blog/715444

[2019_Python_]: https://my.oschina.net/u/2663968/blog/3061697
[hot3.png]: /images/20220113/c5599a86de11465ca204b19bc5fa3b6b.png
[http_my.oschina.net_u_2608629_admin_edit-blog_blog_71542]: http://my.oschina.net/u/2608629/admin/edit-blog?blog=715422