MyBatis学习教程(二)—如何使用MyBatis对users表执行CRUD操作

摘要：上一篇文章MyBatis入门学习教程(一)-MyBatis快速入门中我们讲了如何使用Mybatis查询users表中的数据，算是对MyBat...

上一篇文章MyBatis入门学习教程(一)-MyBatis快速入门中我们讲了如何使用Mybatis查询users表中的数据，算是对MyBatis有一个初步的入门了，今天讲解一下如何使用MyBatis对users表执行CRUD操作。在没奔主题之前，先给大家补充点有关mybatis和crud的基本知识。

什么是 MyBatis？

MyBatis 是支持普通 SQL 查询，存储过程和高级映射的优秀持久层框架。 MyBatis 消除了几乎所有的 JDBC 代码和参数的手工设置以及对结果集的检索。MyBatis 可以使用简单的XML 或注解用于配置和原始映射，将接口和 Java 的 POJO（Plain Old Java Objects，普通的Java对象）映射成数据库中的记录。

MyBatis下载：https://github.com/mybatis/mybatis-3/releases

crud的意思

CRUD是指在做计算处理时的增加(Create)、重新取得数据(Retrieve)、更新(Update)和删除(Delete)几个单词的首字母简写。主要被用在描述软件系统中数据库或者持久层的基本操作功能。

步入正题，本文中使用到的测试环境是上一篇文中的测试环境。

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

1、定义sql映射xml文件

userMapper.xml文件的内容如下：

<" encoding="UTF-" ?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper .//EN" "http://mybatis.org/dtd/mybatis--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(); //执行插入操作 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(); user.setName("孤傲苍狼"); user.setAge(); //执行修改操作 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,); //使用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文件中注册这个映射接口

<" encoding="UTF-"?> <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config .//EN" "http://mybatis.org/dtd/mybatis--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:/mybatis" /> <property name="username" value="root" /> <property name="password" value="XDP" /> </dataSource> </environment> </environments> <mappers>  <mapper resource="me/gacl/mapping/userMapper.xml"/> <> <mapper/> </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(); 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(); user.setName("孤傲苍狼_xdp"); user.setAge(); //执行修改操作 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(); //使用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(); //使用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学习教程(二)—如何使用MyBatis对users表执行CRUD操作，希望对大家有所帮助，如果大家有任何疑问请给我们留言，小编会及时回复大家的。在此也非常感谢大家对查字典教程网的支持！

【MyBatis学习教程(二)—如何使用MyBatis对users表执行CRUD操作】相关文章：

★ java中计算字符串长度的方法及u4E00与u9FBB的认识

★ Java中一些基础概念的使用详解

★ java 键盘输入的多种实现方法

★ java调用Oracle存储过程的方法实例

★ java读取文件显示进度条的实现方法

★ JAVA实现caesar凯撒加密算法

★ 全面解析Java中的GC与幽灵引用

★ 解析web.xml中在Servlet中获取context-param和init-param内的参数

★ Java创建文件夹及文件实例代码

★ 基于java TCP网络通信的实例详解

上一篇： java基于servlet实现文件上传功能解析

下一篇：详解Java中的迭代迭代器Iterator与枚举器Enumeration

学习工具