【MyBatis框架】mybatis和spring整合

你的名字 2021-09-25 23:08 377阅读 0赞

spring和mybatis整合  
  
1.整合思路  
  
需要spring通过单例方式管理SqlSessionFactory。  
spring和mybatis整合生成代理对象，使用SqlSessionFactory创建SqlSession。（spring和mybatis整合自动完成）  
持久层的mapper都需要由spring进行管理。  
  
2.整合环境  
创建一个新的java工程（接近实际开发的工程结构）  
  
jar包：  
mybatis3.2.7的jar包  
spring3.2.0的jar包  
mybatis和spring的整合包：早期ibatis和spring整合是由spring官方提供，mybatis和spring整合由mybatis提供。jar包名mybatis-spring-1.2.2.jar  
  
下面加入MyBatis与Spring整合的全部jar包

如图

![Center][]

工程结构：

如图

![Center 1][]

3.sqlSessionFactory  
在applicationContext.xml配置sqlSessionFactory和数据源  
  
sqlSessionFactory在mybatis和spring的整合包下。

**\[html\]**  [view plain][]  [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  **<****beans** xmlns="http://www.springframework.org/schema/beans"  
3.      xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:mvc="http://www.springframework.org/schema/mvc"  
4.      xmlns:context="http://www.springframework.org/schema/context"  
5.      xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"  
6.      xsi:schemaLocation="http://www.springframework.org/schema/beans   
7.          http://www.springframework.org/schema/beans/spring-beans-3.2.xsd   
8.          http://www.springframework.org/schema/mvc   
9.          http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd   
10.         http://www.springframework.org/schema/context   
11.         http://www.springframework.org/schema/context/spring-context-3.2.xsd   
12.         http://www.springframework.org/schema/aop   
13.         http://www.springframework.org/schema/aop/spring-aop-3.2.xsd   
14.         http://www.springframework.org/schema/tx   
15.         http://www.springframework.org/schema/tx/spring-tx-3.2.xsd "**>**  
16.   
17.   
18.       
19.     **<****context:property-placeholder** location="classpath:db.properties" **/>**  
20.   
21.   
22.       
23.     **<****bean** id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"  
24.         destroy-method="close"**>**  
25.         **<****property** name="driverClassName" value="$\{jdbc.driver\}" **/>**  
26.         **<****property** name="url" value="$\{jdbc.url\}" **/>**  
27.         **<****property** name="username" value="$\{jdbc.username\}" **/>**  
28.         **<****property** name="password" value="$\{jdbc.password\}" **/>**  
29.         **<****property** name="maxActive" value="10" **/>**  
30.         **<****property** name="maxIdle" value="5" **/>**  
31.     **</****bean****>**  
32.   
33.   
34.   
35.   
36.       
37.     **<****bean** id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"**>**  
38.           
39.         **<****property** name="configLocation" value="mybatis/SqlMapConfig.xml" **/>**  
40.           
41.         **<****property** name="dataSource" ref="dataSource" **/>**  
42.     **</****bean****>**  
43. **</****beans****>**

4.原始dao开发（和spring整合后）  
4.1User.xml

**\[html\]**  [view plain][]  [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  <!DOCTYPE mapper  
3.  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"  
4.  "http://mybatis.org/dtd/mybatis-3-mapper.dtd"**>**  
5.    
6.    
7.    
11.       
12.       
13.     <!-- 通过select执行数据库查询，  
14.          id:标示映射文件中的sql，成为Statement的id   
15.          将sql语句封装到mappedStatement对象中，所以将id称为statement的id,  
16.            
17.          parameterType:指定输入参数的类型，  
18.            
19.          \#\{\}标示一个占位符,  
20.            
21.          \#\{id\}其中id表示接收输入参数的名称，如果输入参数是简单类型，那么\#\{\}中的值可以任意(如value)。  
22.            
23.          resultType：指定sql输出结果的映射的java对象类型，  
24.          select指定resultType表示将单条记录映射成java对象--**>**     
25.     **<****select** id="findUserById" parameterType="int" resultType="cn.edu.hpu.ssm.po.User"**>**  
26.       SELECT \* FROM USER WHERE id=\#\{id\}  
27.     **</****select****>**  
28.       
29. **</****mapper****>**

在SqlMapconfig.xml中加载User.xml

**\[html\]**  [view plain][]  [copy][view plain]

1.    
2.  **<****mappers****>**  
3.        
4.      **<****mapper** resource="sqlmap/User.xml"**/>**  
5.        
6.        
7.      **<****package** name="cn.edu.hpu.ssm.mapper"**/>**  
8.  **</****mappers****>**

4.2dao(实现类继承SqlSessionDaoSupport)

dao接口实现类需要注入SqlSessoinFactory，通过spring进行注入。  
这里spring声明配置方式，配置dao的bean：  
  
让UserDaoImpl实现类继承SqlSessionDaoSupport  
  
4.3配置dao  
首先创建UserDao接口和UserDaoImpl接口实现  
UserDao.java:

**\[java\]**  [view plain][]  [copy][view plain]

1.  **package** cn.edu.hpu.ssm.dao;  
2.    
3.  **import** cn.edu.hpu.ssm.po.User;  
4.    
5.  //用户管理的Dao接口  
6.  **public** **interface** UserDao\{  
7.        
8.      //根据Id查询用户信息  
9.      **public** User findUserById(**int** id) **throws** Exception;  
10. \}

UserDaoImpl.java:

**\[java\]**  [view plain][]  [copy][view plain]

1.  **package** cn.edu.hpu.ssm.dao;  
2.    
3.  **import** org.apache.ibatis.session.SqlSession;  
4.  **import** org.apache.ibatis.session.SqlSessionFactory;  
5.    
6.  **import** cn.edu.hpu.ssm.po.User;  
7.    
8.  **public** **class** UserDaoImpl **implements** UserDao\{  
9.    
10.   
11.     //需要向dao实现类中注入SqlSessionFactory工厂  
12.     //这里我们暂时没用spring，我们通过构造方法注入  
13.     **private** SqlSessionFactory sqlSessionFactory;  
14.     **public** UserDaoImpl(SqlSessionFactory sqlSessionFactory)\{  
15.         **this**.sqlSessionFactory=sqlSessionFactory;  
16.     \}  
17.   
18.   
19.     **public** User findUserById(**int** id) **throws** Exception \{  
20.         SqlSession sqlSession=sqlSessionFactory.openSession();  
21.           
22.         User user=sqlSession.selectOne("test.findUserById",id);  
23.           
24.         //释放资源  
25.         sqlSession.close();  
26.         **return** user;  
27.     \}  
28. \}

在applicationContext.xml中配置dao。

**\[html\]**  [view plain][]  [copy][view plain]

让UserDaoImpl去继承SqlSessionDaoSupport类，在SqlSessionDaoSupport类中提供了set和getsqlSessionFactory的方法。

**\[java\]**  [view plain][]  [copy][view plain]

1.  **package** cn.edu.hpu.ssm.dao;  
2.    
3.  **import** org.apache.ibatis.session.SqlSession;  
4.  **import** org.mybatis.spring.support.SqlSessionDaoSupport;  
5.    
6.    
7.  **import** cn.edu.hpu.ssm.po.User;  
8.    
9.    
10. **public** **class** UserDaoImpl **extends** SqlSessionDaoSupport **implements** UserDao\{  
11.   
12.   
13.     **public** User findUserById(**int** id) **throws** Exception \{  
14.         //继承SqlSessionDaoSupport类，通过this.getSqlSession()得到sqlSession  
15.         SqlSession sqlSession=**this**.getSqlSession();  
16.           
17.         User user=sqlSession.selectOne("test.findUserById",id);  
18.           
19.         **return** user;  
20.     \}  
21. \}

4.4测试程序

**\[java\]**  [view plain][]  [copy][view plain]

1.  **package** cn.edu.hpu.ssm.test;  
2.    
3.  **import** org.junit.Before;  
4.  **import** org.junit.Test;  
5.  **import** org.springframework.context.ApplicationContext;  
6.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
7.    
8.    
9.  **import** cn.edu.hpu.ssm.dao.UserDao;  
10. **import** cn.edu.hpu.ssm.po.User;  
11.   
12.   
13. **public** **class** UserDaoImplTest \{  
14.       
15.     **private** ApplicationContext applicationContext;  
16.       
17.     //注解Before是在执行本类所有测试方法之前先调用这个方法  
18.     @Before  
19.     **public** **void** setup() **throws** Exception\{  
20.         applicationContext=**new** ClassPathXmlApplicationContext("classpath:spring/applicationContext.xml");  
21.           
22.     \}  
23.       
24.     @Test  
25.     **public** **void** testFindUserById() **throws** Exception\{  
26.         UserDao userDao=(UserDao)applicationContext.getBean("userDao");  
27.           
28.         //调用UserDao的方法  
29.         User user=userDao.findUserById(1);  
30.         //输出用户信息  
31.         System.out.println(user.getId()+":"\+user.getUsername());  
32.     \}  
33.       
34. \}

测试结果和输出日志:

**\[plain\]**  [view plain][]  [copy][view plain]

1.  DEBUG \[main\] - Creating a new SqlSession  
2.  DEBUG \[main\] - SqlSession \[org.apache.ibatis.session.defaults.DefaultSqlSession@8dcd5d\] was not registered for synchronization because synchronization is not active  
3.  DEBUG \[main\] - Fetching JDBC Connection from DataSource  
4.  DEBUG \[main\] - JDBC Connection \[jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8, UserName=root@localhost, MySQL-AB JDBC Driver\] will not be managed by Spring  
5.  DEBUG \[main\] - ==> Preparing: SELECT \* FROM USER WHERE id=?   
6.  DEBUG \[main\] - ==> Parameters: 1(Integer)  
7.  DEBUG \[main\] - <== Total: 1  
8.  DEBUG \[main\] - Closing non transactional SqlSession \[org.apache.ibatis.session.defaults.DefaultSqlSession@8dcd5d\]  
9.  DEBUG \[main\] - Returning JDBC Connection to DataSource  
10. 1:张明明

5.mapper代理开发  
5.1mapper.xml和mapper.java  
UserMapper.xml:

**\[html\]**  [view plain][]  [copy][view plain]

1.  **<?****xml** version="1.0" encoding="UTF-8"**?>**  
2.  <!DOCTYPE mapper  
3.  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"  
4.  "http://mybatis.org/dtd/mybatis-3-mapper.dtd"**>**  
5.    
6.    
7.  **<****mapper** namespace="cn.edu.hpu.ssm.mapper.UserMapper"**>**  
8.        
9.      **<****select** id="findUserById" parameterType="int" resultType="cn.edu.hpu.mybatis.po.User"**>**  
10.       SELECT \* FROM USER WHERE id=\#\{id\}  
11.     **</****select****>**  
12.       
13. **</****mapper****>**

UserMapper.java:

**\[java\]**  [view plain][]  [copy][view plain]

1.  **package** cn.edu.hpu.ssm.mapper;  
2.    
3.  **import** cn.edu.hpu.ssm.po.User;  
4.    
5.  //用户管理的Dao接口  
6.  **public** **interface** UserMapper \{  
7.        
8.      //根据Id查询用户信息  
9.      **public** User findUserById(**int** id) **throws** Exception;  
10. \}

5.2通过MapperFactoryBean创建代理对象

**\[html\]**  [view plain][]  [copy][view plain]

1.    
5.          **<****property** name="mapperInterface" value="cn.edu.hpu.ssm.mapper.UserMapper"**/>**  
6.          **<****property** name="sqlSessionFactory" ref="sqlSessionFactory"**/>**  
7.      **</****bean****>**

此方法问题：  
需要针对每个mapper进行配置，麻烦。所以要通过MapperScannerConfigurer进行mapper扫描。  
  
5.3通过MapperScannerConfigurer进行mapper扫描（建议使用）

**\[html\]**  [view plain][]  [copy][view plain]

1.  <!-- mapper批量扫描，从mapper包中扫描出mapper接口，自动创建代理对象并且在spring容器中注入   
2.      遵循规范:将mapper.java和mapper.xml映射文件名称保持一致，且在一个目录中.  
3.      自动扫描出来的mapper的bean的id为mapper类名(首字母小写)--**>**  
4.  **<****bean** class="org.mybatis.spring.mapper.MapperScannerConfigurer"**>**  
5.      <!-- 指定扫描的包名  
6.      如果扫描多个包，每个包中间使用半角逗号分隔 --**>**  
7.      **<****property** name="basePackage" value="cn.edu.hpu.ssm.mapper"**/>**  
8.      **<****property** name="sqlSessionFactoryBeanName" value="sqlSessionFactory"**>****</****property****>**  
9.  **</****bean****>**

sqlMapperConfig.xml中的mapper扫描就可以不要了

**\[html\]**  [view plain][]  [copy][view plain]

1.    
2.  **<****mappers****>**  
3.        
4.      **<****mapper** resource="sqlmap/User.xml"**/>**  
5.        
6.        
10. **</****mappers****>**

5.4测试代码

**\[java\]**  [view plain][]  [copy][view plain]

1.  **package** cn.edu.hpu.ssm.test;  
2.    
3.  **import** org.junit.Before;  
4.  **import** org.junit.Test;  
5.  **import** org.springframework.context.ApplicationContext;  
6.  **import** org.springframework.context.support.ClassPathXmlApplicationContext;  
7.    
8.    
9.  **import** cn.edu.hpu.ssm.mapper.UserMapper;  
10. **import** cn.edu.hpu.ssm.po.User;  
11.   
12.   
13. **public** **class** UserMapperTest \{  
14.   
15.   
16. **private** ApplicationContext applicationContext;  
17.       
18.     //注解Before是在执行本类所有测试方法之前先调用这个方法  
19.     @Before  
20.     **public** **void** setup() **throws** Exception\{  
21.         applicationContext=**new** ClassPathXmlApplicationContext("classpath:spring/applicationContext.xml");  
22.           
23.     \}  
24.       
25.     @Test  
26.     **public** **void** testFindUserById() **throws** Exception \{  
27.         UserMapper userMapper=(UserMapper)applicationContext.getBean("userMapper");  
28.         User user=userMapper.findUserById(1);  
29.         System.out.println(user.getId()+":"\+user.getUsername());  
30.           
31.     \}  
32.   
33.   
34. \}

测试结果及输出日志：

**\[plain\]**  [view plain][]  [copy][view plain]

1.  DEBUG \[main\] - Returning cached instance of singleton bean 'userMapper'  
2.  DEBUG \[main\] - Creating a new SqlSession  
3.  DEBUG \[main\] - SqlSession \[org.apache.ibatis.session.defaults.DefaultSqlSession@13b5a3a\] was not registered for synchronization because synchronization is not active  
4.  DEBUG \[main\] - Fetching JDBC Connection from DataSource  
5.  DEBUG \[main\] - JDBC Connection \[jdbc:mysql://localhost:3306/mybatis?characterEncoding=utf-8, UserName=root@localhost, MySQL-AB JDBC Driver\] will not be managed by Spring  
6.  DEBUG \[main\] - ==>  Preparing: SELECT \* FROM USER WHERE id=?   
7.  DEBUG \[main\] - ==> Parameters: 1(Integer)  
8.  DEBUG \[main\] - <==      Total: 1  
9.  DEBUG \[main\] - Closing non transactional SqlSession \[org.apache.ibatis.session.defaults.DefaultSqlSession@13b5a3a\]  
10. DEBUG \[main\] - Returning JDBC Connection to DataSource  
11. 1:张明明

[Center]: /images/20210923/ba4099c7e3ee47af86b696a6ed428518.png
[Center 1]: /images/20210923/4d46681ade164b978348eeac14ce7d8d.png
[view plain]: http://blog.csdn.net/acmman/article/details/46906717#