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 configurationPUBLIC "-//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 intouserinfo(id,username,password,age,insertDate) values(#{id},#{username},#{password},#{age},#{insertdate})</insert><select id="getUserinfoById" parameterType="int" resultType="orm.Userinfo">select * fromuserinfo where id=#{id} </select><delete id="deleteUserinfoById" parameterType="int">delete fromuserinfo where id=#{id} </delete><select id="getAllUserinfo" resultType="orm.Userinfo">select * from userinfo</select><update id="updateUserinfoById" parameterType="orm.Userinfo">update userinfosetusername=#{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;}}

创建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 blocke.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 configurationPUBLIC "-//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 intouserinfo(username,password,age,insertDate)values(#{username},#{password},#{age},#{insertdate})</insert><select id="getUserinfoById" parameterType="int" resultType="orm.Userinfo">select * fromuserinfo where id=#{id} </select><delete id="deleteUserinfoById" parameterType="int">delete fromuserinfo where id=#{id} </delete><select id="getAllUserinfo" resultType="orm.Userinfo">select * from userinfo</select><update id="updateUserinfoById" parameterType="orm.Userinfo">update userinfosetusername=#{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 intouserinfo(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 intouserinfo(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开发领域中最核心、最实用的开发技术，帮助读者全面提升开发技能。