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

上一篇文章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下载：

crud的意思

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

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

一、使用mybatis对表执行crud操作——基于xml的实现

1、定义sql映射xml文件

　　usermapper.xml文件的内容如下：

<?xml version="." encoding="utf-" ?>
<!doctype mapper public "-//mybatis.org//dtd mapper .//en" "http://mybatis.org/dtd/mybatis--mapper.dtd">
<!-- 为这个mapper指定一个唯一的namespace，namespace的值习惯上设置成包名+sql映射文件名，这样就能够保证namespace的值是唯一的
例如namespace="me.gacl.mapping.usermapper"就是me.gacl.mapping(包名)+usermapper(usermapper.xml文件去除后缀)
-->
<mapper namespace="me.gacl.mapping.usermapper">
<!-- 在select标签中编写查询的sql语句， 设置select标签的id属性为getuser，id属性值必须是唯一的，不能够重复
使用parametertype属性指明查询时使用的参数类型，resulttype属性指明查询返回的结果集类型
resulttype="me.gacl.domain.user"就表示将查询结果封装成一个user类的对象返回
user类就是users表所对应的实体类
-->
<!-- 
根据id查询得到一个user对象
-->
<select id="getuser" parametertype="int" 
resulttype="me.gacl.domain.user">
select * from users where id=#{id}
</select>
<!-- 创建用户(create) -->
<insert id="adduser" parametertype="me.gacl.domain.user">
insert into users(name,age) values(#{name},#{age})
</insert>
<!-- 删除用户(remove) -->
<delete id="deleteuser" parametertype="int">
delete from users where id=#{id}
</delete>
<!-- 修改用户(update) -->
<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文件中注册这个映射接口

<?xml version="." 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>
<!-- 注册usermapper.xml文件， 
usermapper.xml位于me.gacl.mapping这个包下，所以resource写成me/gacl/mapping/usermapper.xml-->
<mapper resource="me/gacl/mapping/usermapper.xml"/>
<!-- 注册usermapper映射接口-->
<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();
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操作，希望对大家有所帮助