MyBatis框架针对每一种数据库的操作都大同小异,本节将用示例的方式演示 Oracle数据库 的CURD操作。

1.准备开发环境

(1)创建数据表。

创建userinfo数据表,表结构如图1-23所示。

图1-23 userinfo数据表结构

（2) 准备generatorConfig.xmli向配置文件。

(3)创建名称为mybatis_curd_oracle的Web项目。

（4)创建Userinfo. Java 实体类,实体类Userinfo.java类结构如图1-24所示。

图1-24 Userinfo.java类结构

（5）项目结构如图1-25所示。

图1-25 Eclipse中的orm包中有实体

(6)在Web项目mybatis_curd_oracle中的src路径下创建连接数据库的配置文件 mybatis -config.xml,代码如下。

 <?xml version="1.0" encoding="UTF-8" ?> 
<!DOCTYPE  configuration 
PUBLIC "-//mybatis.org// dtd  Config 3.0//EN"
 "mybatis-3-config.dtd"> 
<configuration> 
<environments default="development"> 
<environment id="development"> 
<transactionManager type="JDBC" /> 
<dataSource type="POOLED"> 
<property name="driver" value="oracle.jdbc.driver.OracleDriver" /> 
<property name="url" value="jdbc:oracle:thin:@localhost:1522:accp11g" /> 
<property name=" username " value="ghy" /> 
<property name="password" value="123" /> 
</dataSource> 
</environment> 
</environments> 
<mappers> 
<mapper resource="userinfoMapping.xml" /> 
</mappers> 
</configuration>  

其中userinfoMapping.xml映射文件内容如下。

 <?xml version="1.0" encoding="UTF-8" ?> 
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd"> 
<mapper  namespace ="mybatis.testcurd">
<insert id="insertUserinfo" parameterType="orm.Userinfo">
 <selectKey resultType="java.lang. Long " keyProperty="id" 
order="BEFORE">
select idauto.nextval from dual
</selectKey>
insert into
userinfo(id,username,password,age,insertDate) values(#{id},#{username},#{password},#{age},#{insertdate})
</insert>
<select id="getUserinfoById" parameterType="int" resultType="orm.Userinfo">
select * from
userinfo where id=#{id} 
</select>
<delete id="deleteUserinfoById" parameterType="int">
delete from
userinfo where id=#{id} 
</delete>
<select id="getAllUserinfo" resultType="orm.Userinfo">
select * from userinfo
</select>
<update id="updateUserinfoById" parameterType="orm.Userinfo">
update userinfo
set
username=#{username},password=#{password},age=#{age},insertDate=#{insertdate} 
where id=#{id} 
</update>
</mapper>  

需要特别说明的是，如果SQL语句有一些特殊符号，则必须使用如下的格式进行设计SQL语句。

 <![CDATA[ sql语句 ]]>  

其中配置代码如下所示。

 <selectKey resultType="java.lang.Long" keyProperty="id" 
order="BEFORE">
select idauto.nextval from dual
</selectKey>  

标记<selectkey>的order=”BEFORE”属性含义是select语句比insert语句先执行, resultType属性值为”java.lang.Long”是将序列返回的数字转成Long类型, keyProperty=”id”的作用是将这个Long值放入parameterType的Userinfo的id属性里面。此段配置的主要功能是根据序列对象生成一个主键d值,并且此值还可以在代码中获取,也就是插入一条记录后使用程序代码就可以获取刚才插入记录的id值。

属性parameterType定义参数类型,属性resultType定义返回值的类型。继续创建测试用的 Servlet 对象,完整的项目结构如图1-26所示。

图1-26 完整项目结构

在图中可以发现src路径下有两个dtd文件,这是为了在开发XML配置或XML映射文件时实现代码自动提示功能。

2．创建获取SqlSession对象工具类

核心代码如下。

 package dbtools;
import java.io.IOException;
import java.io.InputStream;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
public abstract class GetSqlSession {
public static SqlSession getSqlSession() throws IOException {
String resource = "mybatis-config.xml";
InputStream inputStream = Resources.getResourceAsStream(resource);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()
.build(inputStream); SqlSession sqlSsession = sqlSessionFactory.openSession();
return sqlSsession;
}
}  

3.插入多条记录

创建Servlet，核心代码如下。

 public class insertUserinfo extends HttpServlet {
public  void  doGet(HttpServletRequest request, HttpServletResponse response) 
throws ServletException, IOException {
try {
Userinfo userinfo = new Userinfo();
userinfo.setUsername("高洪岩");
userinfo.setPassword("岩洪高");
userinfo.setAge(100L);
userinfo.setInsertdate(new Date());
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.insert("mybatis.testcurd.insertUserinfo", userinfo);
System.out.println(userinfo.getId());
sqlSession.commit();
sqlSession. close ();
} catch (Exception e) {
// TODO Auto-generated catch block 
e.printStackTrace();
}
}
}  

变量SqlSession的insert方法的第1个参数是userinfoMapping.xml映射文件<insert>标签的id值,还要加上namespace命名空间的前缀,映射文件部分代码如下。

 <?xml version="1.0" encoding="UTF-8" ?> 
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd"> 
<mapper namespace="mybatis.testcurd"> 
<insert id="insertUserinfo" ……>  

在代码中可以看到获取已经插入数据表中记录的主键值。

执行Servlet后在控制台输出如图1-27所示。

图1-27 插入多条记录

Oracle数据库中的userinfo数据表内容如图1-28所示。

图1-28 出现3条数据记录

4. 根据id值查询记录

创建Servlet，核心代码如下。

 public class getUserinfoById extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
Userinfo userinfo = sqlSession.selectOne(
"mybatis.testcurd.getUserinfoById", 7);
System.out.println(userinfo.getId());
System.out.println(userinfo.getUsername());
System.out.println(userinfo.getPassword());
System.out.println(userinfo.getAge());
System.out.println(userinfo.getInsertdate().toLocaleString());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}  

程序运行后的效果如图1-29所示。

图1-29 打印id是7的信息

5. 查询所有记录

创建Servlet，核心代码如下。

 public class getAllUserinfo extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response) 
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
List<Userinfo> listUserinfo = sqlSession
.selectList("mybatis.testcurd.getAllUserinfo");
for (int i = 0; i < listUserinfo.size(); i++) {
Userinfo userinfo = listUserinfo.get(i);
System.out.println(userinfo.getId() + " " 
+ userinfo.getUsername() + " " + userinfo.getPassword() 
+ " " + userinfo.getAge() + " " 
+ userinfo.getInsertdate().toLocaleString());
}
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block 
e.printStackTrace();
}
}
}  

程序运行后打印出3条记录，如图1-30所示。

图1-30 打印3条记录信息

6. 更新记录

7. 创建Servlet，核心代码如下。

 public class updateUserinfoById extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
Userinfo userinfo = sqlSession.selectOne(
"mybatis.testcurd.getUserinfoById", 7);
userinfo.setUsername("最新版高洪岩");
sqlSession.update("mybatis.testcurd.updateUserinfoById", userinfo);
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block 
e.printStackTrace();
}
}
}  

程序运行后数据表userinfo中的记录被更新，如图1-31所示。

图1-31 userinfo数据表内容被更新

8. 删除记录

创建Servlet，核心代码如下。

 public class deleteUserinfoById extends HttpServlet {
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
try {
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.delete("mybatis.testcurd.deleteUserinfoById", 6);
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
// TODO Auto-generated catch block 
e.printStackTrace();
}
}
}  

程序运行后，将id为6的记录删除了，如图1-32所示。

图1-32 不存在id为6的记录

自此，针对Oracle数据库的CURD操作到此结束。

1.3.2 针对 MySQL 的CURD

本章节也将从零开始,使用MyBatis操作MySQL数据库。

1.准备开发环境

(1)在Eclipse中创建名称为mybatis_curd_mysql的项目。

(2)创建Userinfo.java实体类。

（3)创建mybatis-config.xml配置文件,代码如下。

 <?xml version="1.0" encoding="UTF-8" ?> 
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"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:3307/ghydb" /> 
<property name="username" value="root" /> 
<property name="password" value="123" /> 
</dataSource> 
</environment> 
</environments> 
<mappers> 
<mapper resource="userinfoMapping.xml" /> 
</mappers> 
</configuration>  

(4)创建SQL映射文件userinfoMapping.xml，代码如下。

 <?xml version="1.0" encoding="UTF-8" ?> 
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "mybatis-3-mapper.dtd"> 
<mapper namespace="mybatis.testcurd">
<insert id="insertUserinfo" parameterType="orm.Userinfo" 
useGeneratedKeys="true" keyProperty="id">
insert into
userinfo(username,password,age,insertDate)
values(#{username},#{password},#{age},#{insertdate})
</insert>
<select id="getUserinfoById" parameterType="int" resultType="orm.Userinfo">
select * from
userinfo where id=#{id} 
</select>
<delete id="deleteUserinfoById" parameterType="int">
delete from
userinfo where id=#{id} 
</delete>
<select id="getAllUserinfo" resultType="orm.Userinfo">
select * from userinfo
</select>
<update id="updateUserinfoById" parameterType="orm.Userinfo">
update userinfo
set
username=#{username},password=#{password},age=#{age},insertDate=#{insertdate} 
where id=#{id} 
</update>
</mapper>  

MySQL的主键是自增的,所以不需要序列这种机制。

2.增加一条记录并且返回主键值

创建Servlet对象,插入记录的代码和Oracle数据库对应的Servlet代码一致,运行后在控制台打印4条记录的主键D值,效果如图1-33所示。

图1-33 向MySQL数据库中插入4条记录

数据表userinfo中的内容如图1-34所示。

图1-34数据表userinfo中的4条记录

3.其他业务方法的测试

其他的业务方法代码和操作Oracle数据库的大体一致,并且已经成功运行,详细代码请参看随书下载的源代码。

1.3.3 SQL映射文件中namespace命名空间的作用

当多个SQL映射文件中的id值一样时,在使用SqlSession操作数据库时会出现异常。

创建测试用的namespaceError项目,创建userinfoMapping.xml映射文件代码如下。

 <mapper namespace="AAAAA">
<insert id="insertUserinfo" parameterType="orm.Userinfo">
<selectKey resultType="java.lang.Long" keyProperty="id" 
order="BEFORE">
select idauto.nextval from dual
</selectKey>
insert into
userinfo(id,username,password,age)
values(#{id},#{username},#{password},#{age})
</insert>
</mapper>  

再创建名称为userinfoMappingZZZZZZZZ.xml映射文件,代码如下。

 <mapper namespace="BBBBB">
<insert id="insertUserinfo" parameterType="orm.Userinfo">
<selectKey resultType="java.lang.Long" keyProperty="id" 
order="BEFORE">
select idauto.nextval from dual
</selectKey>
insert into
userinfo(id,username,password,age)
values(#{id},#{username},#{password},#{age})
</insert>
</mapper>  

将这2个SQL映射文件使用<mapper>标签注册到mybatis-config.xml配置文件中,代码如下。

 <configuration> 
<environments default="development"> 
<environment id="development"> 
<transactionManager type="JDBC" /> 
<dataSource type="POOLED"> 
<property name="driver" value="oracle.jdbc.driver.OracleDriver" /> 
<property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl" /> 
<property name="username" value="y2" /> 
<property name="password" value="123" /> 
</dataSource> 
</environment> 
</environments> 
<mappers> 
<mapper resource="userinfoMapping.xml" /> 
<mapper resource="userinfoMappingZZZZZZZZ.xml" /> 
</mappers> 
</configuration>  

在2个SQL映射文件中都有insert的id属性值为insertUserinfo的配置代码,执行如下Java代码。

 public class insertUserinfo {
public static void main(String[] args) {
try {
Userinfo userinfo = new Userinfo();
userinfo.setUsername("高洪岩");
userinfo.setPassword("岩洪高");
userinfo.setAge(100L);
userinfo.setInsertdate(new Date());
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.insert("insertUserinfo", userinfo);
System.out.println(userinfo.getId());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}  

执行后出现了异常，异常信息如下。

 java.lang.IllegalArgumentException: insertUserinfo is ambiguous in Mapped Statements collection (try using the full name including the namespace, or rename one of the entries)  

异常信息提示insertUserinfo并不是确定的名字,是模糊的,可以尝试使用全名称的方式来调用此SQL映射,所谓的”全名称方式就是指sqlld之前写上namspace命名空间,对namespace命名空间的命名可以写上表的名称,或者是业务的名称,这样有助于区分重复的sqlld。

更改后的Java代码如下。

 public class insertUserinfoOK {
public static void main(String[] args) {
try {
Userinfo userinfo = new Userinfo();
userinfo.setUsername("高洪岩");
userinfo.setPassword("岩洪高");
userinfo.setAge(100L);
SqlSession sqlSession = GetSqlSession.getSqlSession();
sqlSession.insert("BBBBB.insertUserinfo", userinfo);
System.out.println(userinfo.getId());
sqlSession.commit();
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}  

执行insert()方法时在第1个参数加上了命名空间BBBBB ,使用小数点(.)做为间隔,再执行程序就不会出现异常了。

本文节选自《Java EE核心框架实战（第2版）》

本书基于MyBatis3+Hibernate5+Struts2+Spring4MVC+Spring4，融合了作者多年软件开发和培训的经验，面向实战，通过丰富且有参考价值的案例，展现了JavaEE开发领域中最核心、最实用的开发技术，帮助读者全面提升开发技能。