MyBatis实战——自动回复机器人

案例分析

基本功能

• 接收发送指令
• 根据指令自动回复对应内容

模块划分

• 回复内容维护
• 对话功能
• 回复内容列表
• 回复内容删除

MyBatis的下载和核心架构的搭建

　　下载地址：https://github.com/mybatis/mybatis-3/releases/tag/mybatis-3.2.8

　　　　下载需要的jar包和源码包。在源码包中提供了官方的示例教程，核心配置文件在mybatis-3-mybatis-3.2.8\src\test\java\org\apache\ibatis\submitted\complex_property\Configuration.xml,在src目录下新建一个config目录，存放此配置文件：

　　打开此配置文件，可以发现它将原来的JDBC中的驱动等配置到了这个文件中，我们只需要仿照它的格式配置我们自己的jdbc相关信息：

 <?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>

 <!--

   <settings>

     <setting name="useGeneratedKeys" value="false"/>

     <setting name="useColumnLabel" value="true"/>

   </settings>

   <typeAliases>

     <typeAlias alias="UserAlias" type="org.apache.ibatis.submitted.complex_property.User"/>

   </typeAliases>

 -->

   <environments default="development">

     <environment id="development">

       <transactionManager type="JDBC">

         <property name="" value=""/>

       </transactionManager>

       <!--

       <dataSource type="UNPOOLED">

         <property name="driver" value="org.hsqldb.jdbcDriver"/>

         <property name="url" value="jdbc:hsqldb:mem:complexprop"/>

         <property name="username" value="sa"/>

       </dataSource>

       -->

       <!-- 替换成我们自己的JDBC驱动、URL、用户名和密码 -->

       <dataSource type="UNPOOLED">

         <property name="driver" value="org.gjt.mm.mysql.Driver"/>

         <property name="url" value="jdbc:mysql://localhost:3306/mybatisrobot?characterEncoding=utf8"/>

         <property name="username" value="root"/>

         <property name="password" value="mysqladmin"/>

       </dataSource>

     </environment>

   </environments>

 <!--

   <mappers>

     <mapper resource="org/apache/ibatis/submitted/complex_property/User.xml"/>

   </mappers>

 -->

 </configuration>

　　以上的配置文件就已经修改完毕。

　　Mybaits向DAO层提供的一个核心的对象是SqlSession。SqlSession的作用：

1. 向SQL语句传入参数（向PreparedStatement的占位符中传入参数）。
2. 执行SQL语句。
3. 获取SQL语句执行的结果。
4. 对事务的控制

如何获得SQLSession？

1. 通过配置文件获取数据库连接的相关信息；
2. 通过配置信息构建SqlSessionFactory；
3. 通过SqlSessionFactory打开数据库会话（SqlSession就是和数据库进行交互的一次会话）。

在数据库层，我们新建一个DBAccess类：

 package org.gpf.db;

 import java.io.IOException;

 import java.io.Reader;

 import org.apache.ibatis.io.Resources;

 import org.apache.ibatis.session.SqlSession;

 import org.apache.ibatis.session.SqlSessionFactory;

 import org.apache.ibatis.session.SqlSessionFactoryBuilder;

 /**

  * 数据库访问层

  * @author gaopengfei

  * @date 2015-5-24 下午4:47:29

  */

 public class DBAccess {

     public SqlSession getSqlSession() throws IOException{

         // 通过配置文件获取数据库连接信息(路径从src的第一级子目录开始)

         Reader reader = Resources.getResourceAsReader("org/gpf/config/Configuration.xml");

         // 通过配置信息构建一个SqlSessionFactory

         SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(reader);

         // 通过SqlSessionFactory打开一个数据库会话

         SqlSession sqlSession = factory.openSession();

         return sqlSession;

     }

 }

　　在DAO层，我们实例化DBAccess的一个实例。测试是否取得SqlSession。

 package org.gpf.dao;

 import java.io.IOException;

 import java.util.List;

 import org.apache.ibatis.session.SqlSession;

 import org.gpf.bean.Message;

 import org.gpf.db.DBAccess;

 /**

  * 和message表相关的操作

  * @author gaopengfei

  * @date 2015-5-25 上午10:52:19

  */

 public class MessageDAO {

     /**

      * 根据条件查询消息列表

      * @param command

      * @param description

      * @return

      */

     public List<Message> queryMessagesList(String command,String description){

         DBAccess dbAccess = new DBAccess();

         SqlSession sqlSession = null;                // 放在外面，在finally中

         try {

             sqlSession = dbAccess.getSqlSession();    // 在DAO层进行异常处理

             // 通过SqlSession执行SQL语句

         } catch (IOException e) {

             e.printStackTrace();

         }finally{

             if (sqlSession != null)

                 sqlSession.close();

         }

         return null;

     }

     /**

      * 测试是否取得SqlSession

      * @param args

      */

     public static void main(String[] args) {

         MessageDAO messageDAO = new MessageDAO();

         messageDAO.queryMessagesList("", "");

     }

 }

　　MyBatis和JDBC不一样，它不是将SQL语句写死在代码里面，也不是用Java代码来动态拼接SQL语句。MyBatis大部分的工作是在配置文件中。在官方的核心配置文件的同一目录下有一个配置SQL的配置文件User.xml.该配置文件的目的是将此文件中配置的SQL语句传递给SqlSession让它执行。拷贝该配置文件到我们自己的项目，重命名为Message.xml,删除不必要的部分，添加我们自己的SQL语句。

 <?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="User">

   <resultMap type="UserAlias" id="UserResult">

     <id column="id" jdbcType="INTEGER" property="id"/>

     <result column="username" jdbcType="VARCHAR" property="username"/>

     <result column="password" jdbcType="VARCHAR" property="password.encrypted"/>

     <result column="administrator" jdbcType="BOOLEAN" property="administrator"/>

   </resultMap>

   <select id="find" parameterType="long" resultMap="UserResult">

     SELECT id,command,description,content FROM message

   </select>

 </mapper>