Spring和Mybatis的整合
spring和mybatis的整合,回顾之前的笔记
持久层整合
第一章、为什么
1.Spring为什么要与持久层整合
1. JavaEE开发,需要持久层,来访问操作数据库。
2. JDBC Hibernate MyBatis等,进行持久开发过程,存在大量的代码冗余
3. Spring,基于模板设计模式,对于上述的持久层技术,进行了封装
2. Spring可以与那些持久层整合
1. JDBC
|- Spring提供了JdbcTemplate
2. Hibernate (JPA)
|- Spring提供了HibernateTemplate
3. MyBatis
|- Spring提供了SqlSessionFactoryBean,MapperScannerConfigure
第二章、Spring与MyBatis整合
1. 原生MyBatis开发步骤(7步走)
首先需要配置开发环境,引入相关的两个依赖
其次,需要引入框架对应的配置文件,mybatis-config.xml和映射文件XXXMapper.xml
配置完成之后,就可以按七步编程来开发了。
- 实体User,创建实体类,构造,getset
- 实体别名,在mybatis-config.xml中,为User添加别名,这样在Mapper映射文件中,我们就可以不用写实体的全限定名,用别名就行了。
- 表,需要在数据库中创建user表,表中应有与实体属性对应的字段
- 创建DAO接口,UserDao,save方法用于一个对象的保存
- 实现Mapper文件,UserMapper.xml对UserDao进行相关的实现
- 注册Mapper文件,在mybatis-config.xml中进行注册,因为此时UserMapper在resources根下面,所以可以直接这样写
- MybatisAPI调用
2. Mybatis在开发过程中存在问题
上面的七步,虽然不是很难,但是很烦,配置繁琐,代码冗余
1. 实体
2. 实体别名---》配置繁琐,每个实体都需要写一次别名
3. 表
4. 创建DAO接口
5. 实现Mapper文件
6. 注册Mapper文件---》配置繁琐,每一个mapper文件都要做一次注册映射
7. MybatisAPI调用---》代码冗余,创建sqlsession的代码是固定的,
得到Dao的实现也是冗余的,每个Dao都要调一次
所以Spring在整合Mybatis的过程中,就把这三步配置繁琐和代码冗余的问题解决了,这样就简化了mybatis的开发。
3. Spring与Mybatis整合思路分析
Spring主要对以下四行代码进行了封装
SqlSessionFactoryBean
Spring首先创建了SqlSessionFactoryBean这个类,用来封装前两行代码,用来创建sqlSessionFactory对象。
按照spring的写法,即在applicationContext.xml中对SqlSessionFactoryBean进行声明配置。
<bean class="org.mybatis.spring.SqlSessionFactoryBean" id="sqlSessionFactory"/>
这里注意个细节,在原生mybatis开发中,创建sqlSessionFactory对象是需要mybatis-config.xml的,我们回顾,该配置文件中主要书写了三部分信息:
mybatis-config.xml
1.dataSource 记载数据库的连接信息
2.typeAliases 配置实体别名
3.mapper映射文件的注册
同理,使用SqlSessionFactoryBean来创建sqlSessionFactory对象,也需要这部分信息,需要这些,即依赖这些,就可以通过注入属性的方式得到这些信息。我们采用set注入的方式。
上面的三部分信息对应着SqlSessionFactoryBean的三个属性
1.dataSource–》指向数据库连接的配置
2.typeAliasesPackage–》指向实体类的包,可为该包下的所有类创建和类名相同的别名
3.mapperLocations–》值为通配符表达式,对所有匹配上的Mapper文件进行注册
此时mybatis-config.xml中的所有信息都通过注入的方式写到spring的配置文件中去了,所以mybatis-config.xml就可以不用了。
MapperScannerConfigurer
spring提供MapperScannerConfigurer类来封装第二部分代码,用于生成userDao对象。
在原生开发步骤中,我们需要是用sqlSessionFactory对象来获得sqlSession对象,再指定XXXDao的class,进而获得对应的dao对象。
在spring的封装下,我们只需要在配置文件中对MapperScannerConfigurer进行配置,
sqlSessionFactoryBeanName-》sqlSessionFactory对象需要被注入
basePackage-》指定DAO接口所在的包
4. Spring与Mybatis整合编码
-
搭建开发环境(pom依赖)
-
Spring配置文件的配置
-
编码
1. 实体 2. 表 3. DAO接口 4. Mapper文件配置 这四步和上面一样
-
测试
5. Spring与Mybatis整合细节
-
问题:Spring与Mybatis整合后,为什么DAO不提交事务,但是数据能够插入数据库中?
这个问题的核心是连接对象Connection,因为他控制了事务;
谁控制了连接对象,就变相控制了事务tx;
是spring控制了连接对象吗?
在刚才测试的启动日志中,表明了connection对象没有被spring管理
是mybatis控制了?实际上上控制连接对象(Connection)的是连接池(DataSource)
- 在原生开发中,使用的Mybatis提供的连接池对象—>创建Connection
他在创建连接对象时,Connection.setAutoCommit(false) 设置手工控制事务,所以操作完成后,需要手工提交; - 在sp整合mb后,引入Druid(C3P0 DBCP)作为连接池 —> 创建Connection
Connection.setAutoCommit(true) true是默认值,保持自动控制事务,一条sql 自动提交
答案:因为Spring与Mybatis整合时,引入了外部连接池对象,保持自动的事务提交这个机制(Connection.setAutoCommit(true)),不需要手工进行事务的操作,也能进行事务的提交
注意:实战中,还会手工控制事务(多条sql一起成功,一起失败),不会使用自动提交,后续Spring通过事务控制解决这个问题。
- 在原生开发中,使用的Mybatis提供的连接池对象—>创建Connection
第三章、Spring的事务处理
1. 什么是事务?
概念:保证业务操作完整性(一个业务中的多个操作,一起成功或一起失败,且不会产生相互嗯影响)的一种数据库机制(是数据库来实现的,我们只是通过java代码来调用这种机制)
事务的4特点: A C I D
1. A 原子性
2. C 一致性
3. I 隔离性
4. D 持久性
2. 如何控制事务
不同的持久化方式对事务的控制不同,但都是三个操作,开启,提交,回滚
JDBC: 核心是依附连接对象connection
Connection.setAutoCommit(false);
Connection.commit();
Connection.rollback();
Mybatis:sqlSession其实也封装了connection
Mybatis自动开启事务
sqlSession(Connection).commit();
sqlSession(Connection).rollback();
结论:控制事务的底层 都是Connection对象完成的。
3.Spring如何控制事务
tx是业务层中的额外功能,
Spring是通过AOP的方式进行事务开发
1. 原始对象
即一个个的业务类
public class XXXUserServiceImpl{
private xxxDAO xxxDAO
set get
注意细节:
1. 原始对象的原始方法,是做核心功能 (即业务处理+DAO调用)
2. 需要DAO,即依赖DAO,将DAO作为Service的成员变量,依赖注入的方式进行赋值
}
2. 额外功能
方式1. MethodInterceptor
public Object invoke(MethodInvocation invocation){
try{
Connection.setAutoCommit(false);
Object ret = invocation.proceed();
Connection.commit();
}catch(Exception e){
Connection.rollback();
}
return ret;
}
方式2. @Aspect
@Around 加在书写额外功能的方法上
这种代码你写我写都一样,那spring也封装好了
所以spring提供了org.springframework.jdbc.datasource.DataSourceTransactionManager类,来控制事务,封装上面的代码;
注意细节:
控制事务是需要Connection对象的,连接来自于连接池,
所以需要注入DataSource
3. 切入点
@Transactional
指定事务的额外功能加入给哪些业务方法。
该注解加入的位置:
1. 类上:类中所有的方法都会加入事务
2. 方法上:这个方法会加入事务
4 组装切面
1. 切入点
2. 额外功能
通过配置文件中的,一个标签来完成
<tx:annotation-driven transaction-manager=""/>
transaction-manager获取额外功能,切入点自动去扫描@Transactional注解
4. Spring控制事务的编码
-
搭建开发环境 (jar)
<dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>5.1.14.RELEASE</version> </dependency>
-
编码
1.原始对象
创建接口
创建实现类
需要对dao接口调用,所以依赖dao,但此时dao是空的,还需要在配置文件中进行属性注入
配置原始对象,注入dao
此时可能回想,注入的dao哪里来的?我们没有对dao进行bean的配置啊?
我们回想,sp在和mb整合时,sp提供了两个类,一个用来创建connection对象,一个去实现dao接口生成对象(通过指定dao所在的包,动态生成类名首字母小写的dao对象),
所以此时,我们只需要指定dao接口的类名首字母小写即可注入对应的dao对象。
2.额外功能
额外功能-即事务,交给sp的DataSourceTransactionManager来管理了,注意需要注入连接池dataSource
3.切入点
我们只需要在业务类(或指定业务方法)上加上@Transactional注解即可
4.组装切面
通过该标签来组装切面,注意引入的命名空间应该是tx结尾的
事务功能,在dataSourceTransactionManager管理,切入点,sp会去扫描@Transactional注解,即可组装好切面。
启动测试即可
-
如何判断此时确实使用了sp的事务呢?
1.可以通过控制台日志打印来体现
2.也可以在业务方法中手动抛出异常,sp事务即会捕获,回滚事务。 -
细节
<tx:annotation-driven transaction-manager="dataSourceTransactionManager" proxy-target-class="true"/> proxy-target-class进行动态代理底层实现的切换 默认是false,使用JDK动态代理 改为true,则使用Cglib
第四章、 Spring中的事务属性(Transaction Attribute)
1. 什么是事务属性
属性:即描述物体特征的一系列值
性别 身高 体重 ...
事务属性:描述事务特征的一系列值
1. 隔离属性
2. 传播属性
3. 只读属性
4. 超时属性
5. 异常属性
2. 如何添加事务属性
@Transactional(isloation=,propagation=,readOnly=,timeout=,rollbackFor=,noRollbackFor=,)
3. 事务属性详解
1. 隔离属性 (ISOLATION)
-
隔离属性的概念
概念:他描述了事务解决并发问题的特征 1. 什么是并发 多个事务(用户)在同一时间,访问操作了相同的数据 同一时间:0.000几秒 微小前 微小后 2. 并发会产生那些问题 1. 脏读 2. 不可重复读 3. 幻影读 3. 并发问题如何解决 通过隔离属性解决,隔离属性中设置不同的值,解决并发处理过程中的问题。
-
事务并发产生的问题
-
脏读
一个事务,读取了另一个事务中没有提交的数据。会在本事务中产生数据不一致的问题 解决方案,事务的隔离级别设为,读已提交 @Transactional(isolation=Isolation.READ_COMMITTED)
-
不可重复读
一个事务中,多次读取相同的数据,但是读取结果不一样。会在本事务中产生数据不一致的问题 注意:1 不是脏读 2 一个事务中 解决方案:隔离级别设为可重复读 @Transactional(isolation=Isolation.REPEATABLE_READ) 本质: 一把行锁
-
幻影读
比如tx1对整表进行统计,tx2在此时插入了一条,tx1再次统计的时候,产生了幻影读。(可重复读只是加了行锁,不能对已有数据修改,但tx2是可以插入数据的)
一个事务中,多次对整表进行查询统计,但是结果不一样,会在本事务中产生数据不一致的问题 解决方案:隔离级别,串行化 @Transactional(isolation=Isolation.SERIALIZABLE) 本质:表锁
-
总结
并发安全: SERIALIZABLE>REPEATABLE_READ>READ_COMMITTED 运行效率: READ_COMMITTED>REPEATABLE_READ>SERIALIZABLE
-
-
数据库对于隔离属性的支持
隔离属性的值 MySQL Oracle ISOLATION_READ_COMMITTED ✅ ✅ IOSLATION_REPEATABLE_READ ✅ ❎ ISOLATION_SERIALIZABLE ✅ ✅ Oracle不支持REPEATABLE_READ值 如何解决不可重复读? 采用的是多版本比对(版本号)的方式,解决不可重复读的问题
-
默认隔离属性
ISOLATION_DEFAULT:会调用不同数据库所设置的默认隔离属性 MySQL : REPEATABLE_READ 可重复读 Oracle: READ_COMMITTED 读已提交
-
查看数据库默认隔离属性
-
MySQL
select @@tx_isolation;
-
Oracle
SELECT s.sid, s.serial#, CASE BITAND(t.flag, POWER(2, 28)) WHEN 0 THEN 'READ COMMITTED' ELSE 'SERIALIZABLE' END AS isolation_level FROM v$transaction t JOIN v$session s ON t.addr = s.taddr AND s.sid = sys_context('USERENV', 'SID');
-
-
-
隔离属性在实战中的建议
推荐使用Spring指定的ISOLATION_DEFAULT,即使用默认的即可 1. MySQL repeatable_read 2. Oracle read_commited 未来实战中,并发访问情况 很低 如果真遇到并发问题,用乐观锁;乐观锁是应用锁,不会过多影响系统的效率,隔离属性是物理锁,对效率影响很大。 Hibernate(JPA) 通过Version,多版本 MyBatis 需要我们通过mybatis拦截器自定义,来完成版本的比对,进而完成乐观锁。
2. 传播属性(PROPAGATION)
-
传播属性的概念
概念:他描述了事务解决嵌套问题的特征 什么叫做事务的嵌套:他指的是一个大的事务中,包含了若干个小的事务 问题:大事务中融入了很多小的事务,他们彼此影响,最终就会导致外部大的事务,丧失了事务的原子性
-
传播属性的值及其用法
传播属性的值 外部不存在事务 外部存在事务 用法 备注 REQUIRED 开启新的事务 融合到外部事务中 @Transactional(propagation = Propagation.REQUIRED) 增删改方法 SUPPORTS 不开启事务 融合到外部事务中 @Transactional(propagation = Propagation.SUPPORTS) 查询方法 REQUIRES_NEW 开启新的事务 挂起外部事务,创建新的事务 @Transactional(propagation = Propagation.REQUIRES_NEW) 日志记录方法中 NOT_SUPPORTED 不开启事务 挂起外部事务 @Transactional(propagation = Propagation.NOT_SUPPORTED) 及其不常用 NEVER 不开启事务 抛出异常 @Transactional(propagation = Propagation.NEVER) 及其不常用 MANDATORY 抛出异常 融合到外部事务中 @Transactional(propagation = Propagation.MANDATORY) 及其不常用 -
默认的传播属性
REQUIRED是传播属性的默认值
-
推荐传播属性的使用方式
增删改 方法:直接使用默认值REQUIRED 查询 操作:显示指定传播属性的值为SUPPORTS
3. 只读属性(readOnly)
针对于只进行查询操作的业务方法,可以加入只读属性,提供运行效率
默认值:false
4. 超时属性(timeout)
指定了事务等待的最长时间
1. 为什么事务进行等待?
当前事务访问数据时,有可能访问的数据被别的事务进行加锁的处理,那么此时本事务就必须进行等待。
2. 等待时间单位 秒
3. 如何应用? @Transactional(timeout=2)
4. 超时属性的默认值 -1
最终由对应的数据库来决定超时时间
5. 异常属性
Spring事务处理过程中
默认 对于RuntimeException及其子类 采用的是回滚的策略
默认 对于Exception及其子类 采用的是提交的策略
rollbackFor = {java.lang.Exception,xxx,xxx}
noRollbackFor = {java.lang.RuntimeException,xxx,xx}
@Transactional(rollbackFor = {java.lang.Exception.class},noRollbackFor = {java.lang.RuntimeException.class})
建议:实战中使用RuntimeExceptin及其子类 使用事务异常属性的默认值
4. 事务属性常见配置总结
1. 隔离属性 默认值
2. 传播属性 Required(默认值) 增删改 Supports 查询操作
3. 只读属性 readOnly false 增删改 true 查询操作
4. 超时属性 默认值 -1
5. 异常属性 默认值
增删改操作 @Transactional
查询操作 @Transactional(propagation=Propagation.SUPPORTS,readOnly=true)
5. 基于标签的事务配置方式(事务开发的第二种形式)
基于注解 @Transaction的事务配置回顾(四步)
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
<property name="userDAO" ref="userDAO"/>
</bean>
<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
@Transactional(isolation=,propagation=,...)
public class UserServiceImpl implements UserService {
private UserDAO userDAO;
<tx:annotation-driven transaction-manager="dataSourceTransactionManager"/>
基于标签的事务配置(原始动态代理额外功能)
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl">
<property name="userDAO" ref="userDAO"/>
</bean>
<!--DataSourceTransactionManager-->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"/>
</bean>
事务属性
<tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager">
<tx:attributes>
<tx:method name="register" isoloation="",propagation=""></tx:method>
<tx:method name="login" .....></tx:method>
等效于
@Transactional(isolation=,propagation=,)
public void register(){
}
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut id="pc" expression="execution(* com.baizhiedu.service.UserServiceImpl.register(..))"></aop:pointcut>
<aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor>
</aop:config>
-
基于标签的事务配置在实战中的应用方式
<bean id="userService" class="com.baizhiedu.service.UserServiceImpl"> <property name="userDAO" ref="userDAO"/> </bean> <!--DataSourceTransactionManager--> <bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> 编程时候 service中负责进行增删改操作的方法 都以modify开头 查询操作 命名无所谓 <tx:advice id="txAdvice" transacation-manager="dataSourceTransactionManager"> <tx:attributes> <tx:method name="register"></tx:method> <tx:method name="modify*"></tx:method> <tx:method name="*" propagation="SUPPORTS" read-only="true"></tx:method> </tx:attributes> </tx:advice> 应用的过程中,service放置到service包中 <aop:config> <aop:pointcut id="pc" expression="execution(* com.baizhiedu.service..*.*(..))"></aop:pointcut> <aop:advisor advice-ref="txAdvice" pointcut-ref="pc"></aop:advisor> </aop:config>
开放原子开发者工作坊旨在鼓励更多人参与开源活动,与志同道合的开发者们相互交流开发经验、分享开发心得、获取前沿技术趋势。工作坊有多种形式的开发者活动,如meetup、训练营等,主打技术交流,干货满满,真诚地邀请各位开发者共同参与!
更多推荐
所有评论(0)