Go语言视频零基础入门到精通

admin

  MyBatis是一个优秀的“不完全的”ORM框架，因为它需要程序员手动写SQL，而相对于Hibernate来说更加的灵活。它完成了关系模型到对象模型的映射，话不多说，直奔主题。

  最近公司有一个项目在使用MyBatis作为开发的ORM，所以顺便就来说一点使用MyBatis开发的方式，为了更为纯净，所以此处做与相关框架的整合（如：Spring）：

首先，看一下MyBatis的基本框架：


另外一个图示（来自百度）：




  
说明：
1.      SqlMapConfig.xml 文件时MyBatis的核心配置文件，可以配置数据源（链接池）、事务…
2.      mapper.xml （名字根据需要来定，只要mapper到SqlMapConfig.xml文件中即可）是MyBatis的一个重要的配置文件，用于对javaBean（POJO）做映射。
3.      SqlSession 会话——面向程序员的接口。用于对数据库的CRUD
4.      Executor 执行器，底层实现，SqlSession内部是通过Executor来操作数据库的，Executor是一个底层封装对象，用户看不到。Executor需要Mapped Statement中封装的数据信息来操作数据库（mapper.xml中配置的信息+POJO）
5.      Mapped Statement  是MyBatis的一个封装对象，封装了SQL语句、传入的SQL语句的参数，将SQL查询结果映射（即输出）成的Java对象。


  
下面，通过三个程序来观察：
1.      简单MyBatis的入门程序
2.      使用Dao 与 DaoImpl 的方法的MyBatis程序
3.      使用动态代理对象的MyBatis
   
三个程序实现，循序渐进，以为基础：
1、简单MyBatis的入门程序
首先建立一个Java工程，导入MyBatis的核心jar包与依赖jar包：
   
说明：我使用的MyBatis的版本是： mybatis-3.2.8
   
jar包准备：






  
lib中为MyBatis的依赖jar包：





  
导入数据库驱动jar包（使用MySQL）





  
新建Java Project：MyBatis_Accessor，在项目下新建一个source folder（相当于CLASSPATH）: myBatis_config 以及一个folder： lib ，然后将准备好的jar包Paste到lib中去，然后 Add to Build Path






  
在myBatis_config中添加相关配置文件：
添加一个log4j的properties 文件（如果你不需要日志，可以不配置，同时可以不导入相关jar包）：






  

1. </pre><p></p><p align="left"> </p><p align="left">log4j. properties 配置代码如下：</p><p align="left"></p><pre name="code" class="java"># Global logging configuration
2. log4j.rootLogger=DEBUG, stdout
3. # Console output..
4. log4j.appender.stdout=org.apache.log4j.ConsoleAppender
5. log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
6. log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

复制代码

  
log4j的具体配置如有不明之处，自行Google or  Baidu
   
配置MyBatis的核心配置文件： SqlMapConfig.xml  
   
  

1. <?xml version="1.0"encoding="UTF-8"?>
2. <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTDConfig 3.0//EN"
3. "http://mybatis.org/dtd/mybatis-3-config.dtd">
4. <configuration>
5.    <!-- 注意：在与Spring整合后，此文件将被废除 -->
6.    <environments default="development">
7.         <environment id="development">
8.             <transactionManager type="JDBC" />
9.             <!-- 配置连接池 -->
10.             <dataSource type="POOLED">
11.                 <property name="driver"value="com.mysql.jdbc.Driver" />
12.                 <property name="url"
13.                value="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull"/>
14.                 <property name="username"value="root" />
15.                 <property name="password"value="Jasber0619" />
16.             </dataSource>
17.         </environment>
18.    </environments>
19.    
20. </configuration>

复制代码

  
   
接下来，在数据库test里面建一张表user_ 并插入几条数据：






  
  

1. </pre>现在，创建一个POJO类，在其里面重写了toString()方法以便观察 User：<p></p><p align="left"></p><pre name="code" class="java">package cn.jasberyon.mybatis.pojo;
3. import java.util.Date;
5. /**
6. *
7. * @author Jasber-Yon
8. * @date 2015-04-18
9. */
10. public classUser {
12.    private Integer id;
13.    private String username;
14.    private String pwd;
15.    private String sex;
16.    private Date birthday;
17.   
18.    public Integer getId() {
19.       return id;
20.    }
21.    public void setId(Integer id) {
22.       this.id = id;
23.    }
24.    public String getUsername() {
25.       return username;
26.    }
27.    public void setUsername(String username) {
28.       this.username = username;
29.    }
30.    public String getPwd() {
31.       return pwd;
32.    }
33.    public void setPwd(String pwd) {
34.       this.pwd = pwd;
35.    }
36.    public String getSex() {
37.       return sex;
38.    }
39.    public void setSex(String sex) {
40.       this.sex = sex;
41.    }
42.    public Date getBirthday() {
43.       return birthday;
44.    }
45.    public void setBirthday(Date birthday) {
46.       this.birthday = birthday;
47.    }
48.   
49.    @Override
50.    public String toString() {
51.       return "User [id="+ id + ", username="+ username+ ", pwd="+ pwd+ ", sex="
52.             +sex+ ", birthday=" + birthday+ "]";
53.    }
54. }

复制代码

  
   
   
然后，我们创建一个Mapper配置文件：user_mapper.xml ，即对刚才的POJO类User与user_表进行映射:
   
  

1. <?xml version="1.0"encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTDMapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <mapper namespace="test">
5.    <select id="findUserByName" parameterType="string"
6.     resultType="cn.jasberyon.mybatis.pojo.User">
7.         SELECT * FROM user_ WHERE username=#{id}
8.    </select>
9. </mapper>

复制代码

  


说明：
1.  mapper标签中的 namespace命名空间表示为你的这个mapper命名，在后面测试代码中使用sqlsession.selectOne(“namespace名.select标签中id指定的值”,用户sql查询的参数)
2.  select：将select标签内容称为 statement。
3.      id：是user_mapper.xml映射文件中唯一标识，statement的id
4.  parameterType：指定向SQL（向statement中）中传入参数的类型，注意：string，及参数是MyBatis的方言。
5.  #{}：表示一个占位符，{}中的，id表示传入变量名，当传入单个值时，{}中的变量名可以随意。
6.  resultType：将SQL查询结果集映射成java对象的类型，注意：其映射成结果集时，不管sql查询的结果是多少条，其类型是代表其中的一条数据的类型，即POJO类型（这在后边的第三种方式中将体现）。
   
现在，将user_mapper.xml 在 SqlMapConfig.xml 里面进行配置：
  

1. <!-- 加载映射文件 -->
2.    <mappers>
3.       <mapper resource="sql_mapper/user_mapper.xml"/>
4. </mappers>

复制代码

  
   
如图：






  
好了，现在我们开始编写查询程序（测试） MyBatisTest.java ：
   
  

1. package cn.jasberyon.mybatis.test;
3. import java.io.IOException;
4. import java.io.InputStream;
6. import org.apache.ibatis.io.Resources;
7. import org.apache.ibatis.session.SqlSession;
8. import org.apache.ibatis.session.SqlSessionFactory;
9. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
11. import cn.jasberyon.mybatis.pojo.User;
14. /**
15. *
16. * @author Jasber-Yon<br>
17. * @date 2015-04-18<br>
18. */
19. public classMyBatisTest {
21.    public static void main(String[] args) throws IOException {
22.       //MyBatis的配置文件
23.       Stringresource= "SqlMapConfig.xml";
24.       InputStreaminputStream= Resources.getResourceAsStream(resource);
25.        //创建会话工厂
26.       SqlSessionFactorysqlSessionFactory= newSqlSessionFactoryBuilder().build(inputStream);
27.       //从会话工厂中得到会话
28.       SqlSessionsqlSession= sqlSessionFactory.openSession();
29.       Useruser= sqlSession.selectOne("test.findUserByName","jasber");
30.    System.out.println("-------------------------------------result-----------------------------------");
31.       System.out.println(user);
32.    System.out.println("------------------------------------------------------------------------------");
33.       //关闭session
34.       sqlSession.close();
36.    }
38. }

复制代码

  
   
说明：
        User user =  sqlSession.selectOne("test.findUserByName","jasber");
一句中“test”为user_mapper.xml文件中mapper标签的namespace指定的命名空间名。“findUserByName”是select标签的唯一标识（指定要执行那一条语句），"jasber"就是我们指定的需要传入查询的参数。
   
   
   
看一下，我们现在的开发环境的项目结构：






  
那么，现在我们来总结一下，使用MyBatis的基本开发步骤：
1.      建立Java项目，导入相关jar包
2.      配置log4j.properties 文件（可忽略）
3.      配置MyBatis的核心配置文件 SqlMapConfig.xml（文件名可自定义）文件，在此文件中配置数据库的连接数据源、事务、数据库连接池等。
4.      创建一个POJO类：User，其类成员属性与数据库中表字段名一致。生成getter和setter方法，如需要可重写toSting()方法。
5.      编写POJO类与数据库表的映射文件user_mapper.xml（文件名可自定义）。
6.      将映射文件user_mapper.xml配置到SqlMapConfig.xml（是被映射，托管给MyBatis）。
7.      编写查询程序（测试）
   
现在，在已有的基础上，作插入数据（删除、更新同理，详见MyBatis的API）的操作：
①  到user_mapper.xml 映射配置文件中去配置一条插入语句：
   
  

1. <insert id="inserUser"parameterType="cn.jasberyon.mybatis.pojo.User">
2.    <!-- user_ 是对应的表名，设置参数时，#{}内的值要与User中的属性名一致。因为设置了user_表的id自增，所以插入时就不用管它了 -->
3.    <!-- 注意SQL结束时不要加分号 -->
4.       insert into user_(username,pwd, sex, birthday) values(#{username},#{pwd},#{sex},#{birthday})
5. </insert>

复制代码

  
   
截图：






  
②  编写插入测试（在原操作代码基础上）：






  

1. User user2= newUser();
2.       user2.setUsername("MyBatis插入演示");
3.       user2.setPwd("ggggg123");
4.       user2.setSex("1");
5.       user2.setBirthday(new Date());
6.       //插入数据
7.       sqlSession.insert("test.inserUser",user2);
8.       //CUD操作需要事务，提交事务
9.       sqlSession.commit();

复制代码

  
   
运行成功：






  
查询验证：







  
好了，我们已经有了一个大体的了解了，现在来演示一下，另外的两种开发方式：企业中使用MyBatis开发Dao方法：
1．使用Dao 与 DaoImpl 的方法的MyBatis程序
2．使用动态代理对象的MyBatis的Dao实现
   
1．使用Dao 与 DaoImpl 的方法的MyBatis程序
我们需要编写Dao接口以及Dao接口的实现类：DaoImpl。
开发步骤：
①  UserDao.java
②  UserDaoImpl.java
③  user_mapper.xml 映射文件
   
①  UserDao.java ：

  

1. package cn.jasberyon.mybatis.dao;
3. import cn.jasberyon.mybatis.pojo.User;
5. /**
6. *
7. * @author Jasber-Yon<br>
8. * @date 2015-04-18<br>
9. */
10. public interfaceUserDao {
12.    /**
13.     * 查询一个用户
14.     * @param selectId
15.     * @param username
16.     * @return
17.     * @throws Exception
18.     */
19.    public UserfindUserByName(String selectId, String username)throwsException;
20. }

复制代码

②  UserDaoImpl.java  ：
需要注入SqlSesstionFactory，SqlSesstionFactory生成SqlSesstion，如果是MyBatis和Spring进行整合，那么则让Spring管理（IOC）SqlSesstionFactory，将SqlSesstionFactory在Spring容器中以单例方法存在。因为SqlSesstionFactory创建SqlSesstion的方法是线程安全的。

1. package cn.jasberyon.mybatis.dao.impl;
3. import org.apache.ibatis.session.SqlSession;
4. import org.apache.ibatis.session.SqlSessionFactory;
6. import cn.jasberyon.mybatis.dao.UserDao;
7. import cn.jasberyon.mybatis.pojo.User;
9. public classUserDaoImpl implements UserDao{
11.    private SqlSessionFactory sqlSessionFactory;
12.   
13.    publicUserDaoImpl(SqlSessionFactory sqlSessionFactory) {
14.       // TODO Auto-generated constructor stub
15.       this.sqlSessionFactory= sqlSessionFactory;
16.    }
17.   
18.    @Override
19.    public UserfindUserByName(String selectId, String username)throwsException {
20.       // TODO Auto-generated method stub
21.       //从会话工厂得到会话 SqlSession
22.       SqlSessionsession= this.sqlSessionFactory.openSession();
23.       Useruser= session.selectOne(selectId, username);
24.       session.close();
25.       return user;
26.    }
27.   
28. }

复制代码

③  user_mapper.xml 映射文件
  

1. <?xml version="1.0"encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTDMapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <mapper namespace="test">
5.    <select id="findUserByName" parameterType="string"
6.     resultType="cn.jasberyon.mybatis.pojo.User">
7.         SELECT * FROM user_ WHERE username=#{id}
8.    </select>
9. </mapper>

复制代码

测试（使用JUnit，Eclipse EE 已集成）：
测试类：UserDaoImplTest
   

1. package cn.jasberyon.mybatis.dao.impl.j_unit_test;
4. import java.io.InputStream;
6. import org.apache.ibatis.io.Resources;
7. import org.apache.ibatis.session.SqlSessionFactory;
8. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
9. import org.junit.After;
10. import org.junit.Before;
11. import org.junit.Test;
13. import cn.jasberyon.mybatis.dao.UserDao;
14. import cn.jasberyon.mybatis.dao.impl.UserDaoImpl;
15. import cn.jasberyon.mybatis.pojo.User;
17. public classUserDaoImplTest {
19.    private SqlSessionFactory sqlSessionFactory;
20.   
21.    @Before
22.    public void setUp() throws Exception {
23.       //MyBatis的配置文件
24.       Stringresource= "SqlMapConfig.xml";
25.       InputStreaminputStream= Resources.getResourceAsStream(resource);
26.        //创建会话工厂
27.       this.sqlSessionFactory= newSqlSessionFactoryBuilder().build(inputStream);
28.    }
29.   
30.    @Test
31.    public void test() throws Exception {
32.       UserDaouserDao= newUserDaoImpl(sqlSessionFactory);
33.       Useruser= userDao.findUserByName("test.findUserByName","neo");
34.    System.out.println("-------------------------------------result-----------------------------------");
35.       System.out.println(user);
36.    System.out.println("------------------------------------------------------------------------------");
37.    }
38.   
39.    @After
40.    public void tearDown() throws Exception {
41.       System.out.println("Testing is Over");
42.    }
44. }

复制代码

测试通过：









  
这个操作的关键点，是要在XxxDaoImpl.java中注入SqlSessionFactory
此时的项目结构（使用到的用红线标注）







  
下面是另一种方法，也是我推荐的。
2．使用动态代理对象的MyBatis
        使用动态代理对象实现，我们只需要编写mapper接口（即Dao接口），不需要再编写其实现类了。
开发步骤：
①  userMapper.xml 映射文件
②  UserMapper.java （相当于UserDao接口）
   
①  UserMapper.java （相当于UserDao接口）

1. package cn.jasberyon.mybatis.mapper;
3. import cn.jasberyon.mybatis.pojo.User;
5. /**
6. *
7. * @author Jasber-Yon<br>
8. * @date 2015-04-18<br>
9. */
10. public interfaceUserMapper {
12.    public User findUserByName(String suername) throws Exception;
13. }

复制代码

   
②  userMapper.xml 映射文件

1. <?xml version="1.0"encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTDMapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <!-- 注意：此时 namespace是mapper接口的全限定名 -->
4. <mapper namespace="cn.jasberyon.mybatis.mapper.UserMapper">
6.    <select id="findUserByName" parameterType="string"
7.     resultType="cn.jasberyon.mybatis.pojo.User">
8.         SELECT * FROM user_ WHERE username=#{id}
9.    </select>
10.    
11. </mapper>

复制代码

  


③  在SqlMapConfig.xml 文件中加载 userMapper.xml文件
   

1. <!-- 加载映射文件 -->
2.    <mappers>
3.       <mapper resource="sql_mapper/userMapper.xml" />
4.     </mappers>

复制代码

④  测试：
  

1. package cn.jasberyon.mybatis.dao.impl.j_unit_test;
4. import java.io.InputStream;
6. import org.apache.ibatis.io.Resources;
7. import org.apache.ibatis.session.SqlSession;
8. import org.apache.ibatis.session.SqlSessionFactory;
9. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
10. import org.junit.After;
11. import org.junit.Before;
12. import org.junit.Test;
14. import cn.jasberyon.mybatis.mapper.UserMapper;
15. import cn.jasberyon.mybatis.pojo.User;
17. public classUserMapperTest {
19.    private SqlSessionFactory sqlSessionFactory;
20.   
21.    @Before
22.    public void setUp() throws Exception {
23.       //MyBatis的配置文件
24.       Stringresource= "SqlMapConfig.xml";
25.       InputStreaminputStream= Resources.getResourceAsStream(resource);
26.        //创建会话工厂
27.       this.sqlSessionFactory= newSqlSessionFactoryBuilder().build(inputStream);
28.    }
30.    @After
31.    public void tearDown() throws Exception {
32.       System.out.println("Testing is Over");
33.    }
35.    @Test
36.    public voidtestFindUserByUsername() throws Exception {
37.       //得到 SqlSession
38.       SqlSessionsqlSession= this.sqlSessionFactory.openSession();
39.       //通过 sqlSession得到UserMapper的代理对象
40.       UserMapperuserMapper= sqlSession.getMapper(UserMapper.class);
41.       //调用UserMapper的查询方法
42.       Useruser= userMapper.findUserByName("克雷格");
43.    System.out.println("-------------------------------------result-----------------------------------");
44.       System.out.println(user);
45.    System.out.println("------------------------------------------------------------------------------");
46.    }
48. }

复制代码

测试通过：








  
那么在演示一个查询用户列表的代码：
①  编写（修改一下下，这样该的原因见最后总结）userMapper.xml 文件：
  

1. <?xml version="1.0"encoding="UTF-8"?>
2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTDMapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
3. <!-- 注意：此时 namespace是mapper接口的全限定名 -->
4. <mapper namespace="cn.jasberyon.mybatis.mapper.UserMapper">
6.    <select id="findUserList" resultType="cn.jasberyon.mybatis.pojo.User">
7.         SELECT * FROM user_
8.    </select>
9.    
10. </mapper>

复制代码

  
②  在UserMapper.java中添加一个方法：public List<User> findUserList()throws Exception;

1. package cn.jasberyon.mybatis.mapper;
3. import java.util.List;
5. import cn.jasberyon.mybatis.pojo.User;
7. /**
8. *
9. * @author Jasber-Yon<br>
10. * @date 2015-04-18<br>
11. */
12. public interfaceUserMapper {
14.    public UserfindUserByName(String username) throwsException;
15.   
16.    public List<User>findUserList() throwsException;
17. }

复制代码

③  测试：

1. package cn.jasberyon.mybatis.dao.impl.j_unit_test;
3. import java.io.InputStream;
4. import java.util.List;
6. import org.apache.ibatis.io.Resources;
7. import org.apache.ibatis.session.SqlSession;
8. import org.apache.ibatis.session.SqlSessionFactory;
9. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
10. import org.junit.After;
11. import org.junit.Before;
12. import org.junit.Test;
14. import cn.jasberyon.mybatis.mapper.UserMapper;
15. import cn.jasberyon.mybatis.pojo.User;
17. public classUserMapperTest {
19.    private SqlSessionFactory sqlSessionFactory;
20.   
21.    @Before
22.    public void setUp() throws Exception {
23.       //MyBatis的配置文件
24.       Stringresource= "SqlMapConfig.xml";
25.       InputStreaminputStream= Resources.getResourceAsStream(resource);
26.        //创建会话工厂
27.       this.sqlSessionFactory= newSqlSessionFactoryBuilder().build(inputStream);
29.    }
31.   
32.    @Test
33.    public void testFindUserList() throws Exception {
34.       //得到 SqlSession
35.       SqlSessionsqlSession= this.sqlSessionFactory.openSession();
36.       //通过 sqlSession得到UserMapper的代理对象
37.       UserMapperuserMapper= sqlSession.getMapper(UserMapper.class);
38.       //调用UserMapper的查询方法
39.       List<User>list= userMapper.findUserList();
40.    System.out.println("-------------------------------------result-----------------------------------");
41.       System.out.println(list.size());
42.    System.out.println("------------------------------------------------------------------------------");
43.      
44.       sqlSession.close();
45.    }
46.   
48.    @After
49.    public void tearDown() throws Exception {
50.       System.out.println("Testing is Over");
51.    }
53. }

复制代码

测试通过：








  
再看一下此时的程序结构（红色标识使用的）：





  
最后我们来总结一下：
除了前面的小结之外，动态代理对象，开发规则：
1.      userMapper.xml 的 namespace是UserMapper的（全限定）路径
2.      userMapper.xml中的statement的id是 UserMapper.java 中的方法名，必须要一致（但是第一种Dao和DaoImpl的方式则不是这样，因为它是在实现方法中限定的，具体请见代码部分）。
3.      userMapper.xml中的statement的parameterType的类型和UserMapper.java 中的方法形参类型一致
4.      userMapper.xml 中的statement的resultType的类型和UserMapper.java中的方法返回的值的类型一致（如果返回的是多条，List <User> 那么就是User的全限定路径），resultType的类型应该是查询结果一条记录映射的java对象类型。
5.      是返回一个List还是单个对象，由UserMapper接口的方法返回值类型来决定。
6.      如果返回的是一个List集合，生成的代理对象内部调用 sqlSession.selectList() 方法获取一个集合。
7.      如果返回的是单个对象（一个User），生成的代理对象内部调用 sqlSession.selectOne() 方法获取单个对象。
   
   
因为时间关系，没有进行详尽的叙述，尚有不足。