前言
本文主要涉及如下知识点:
SpringJDBC模板实战
Spring基于XML配置实现事务管理
Spring基于注解配置实现事务管理
SpringJDBC模板 · 当还未接触到SpringJDBC模板以及Mybatis等框架时,我们一直在使用DButils来对JDBC进行封装操作,SpringJDBC模板和DButils的操作可以说是十分相似。所以我们操作起来几乎没有难度,相比DBUtils需要额外引入连接池才可以使用,Spring自己内置了连接池(DriverManagerDataSource ),可以说是十分方便。 · 使用SpringJDBC模板需要的jar包是:spring-jdbc · 与数据库交互需要使用:mysql-connection-java
使用SpringJDBC模板 · 使用SpringJDBC模板特别简单,只需要两个步骤:
配置DriverManagerDataSource连接池,并注入jdbcTemplate对象
使用JdbcTemplate对象来进行数据库的交互
JdbcTemplate的使用几乎和dbutils一样,查询用query,增删改用update,参数也是差不多。其中查询操作,DButils使用的返回值接口是ResultSetHandle< T >,而Spring所用的接口是RowMapper< T >,我们一般用其实现类BeanPropertyRowMaper< T >
前期准备
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 <dependencies > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-context</artifactId > <version > 5.0.2.RELEASE</version > </dependency > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-test</artifactId > <version > 5.0.2.RELEASE</version > </dependency > <dependency > <groupId > org.testng</groupId > <artifactId > testng</artifactId > <version > 7.0.0</version > </dependency > <dependency > <groupId > org.springframework</groupId > <artifactId > spring-jdbc</artifactId > <version > 5.0.2.RELEASE</version > </dependency > <dependency > <groupId > mysql</groupId > <artifactId > mysql-connector-java</artifactId > <version > 5.1.6</version > </dependency > </dependencies >
把DataSource和jdbcTemplate交给SpringIOC去管理(非自己定义的bean用xml创建),同时开启组件扫描,xml完整配置如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns ="http://www.springframework.org/schema/beans" xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xmlns:contxt ="http://www.springframework.org/schema/context" xsi:schemaLocation ="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd" > <contxt:component-scan base-package ="com.memoforward" /> <bean id ="dataSource" class ="org.springframework.jdbc.datasource.DriverManagerDataSource" > <property name ="driverClassName" value ="com.mysql.jdbc.Driver" /> <property name ="url" value ="jdbc:mysql:///springaop" /> <property name ="username" value ="root" /> <property name ="password" value ="123" /> </bean > <bean id ="jdbcTemplate" class ="org.springframework.jdbc.core.JdbcTemplate" > <property name ="dataSource" ref ="dataSource" /> </bean > </beans >
创建数据库springaop,并创建客户表t_account
id
aname
money
1
cxy
2000.0
2
lhw
2000.0
编写Account端的操作,只编写通过客户姓名查询以及更新客户的操作(因为事务管理要用)
//AccountDao
1 2 3 4 5 6 7 8 9 10 11 package com.memoforward.dao;import com.memoforward.domain.Account;public interface AccountDao { public Account findAccountByName (String accountName) ; public void update (Account account) ; }
//AccountDaoImpl
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 package com.memoforward.dao.impl;import ...;import java.util.List;@Repository ("accountDao" )public class AccountDaoImpl implements AccountDao { @Autowired JdbcTemplate jdbcTemplate; @Override public Account findAccountByName (String accountName) { List<Account> aList = jdbcTemplate.query("select * from t_account where aname = ?" , new BeanPropertyRowMapper<Account>(Account.class ), accountName ) ; if (aList.size() != 1 ) throw new RuntimeException("查询失败..." ); return aList.get(0 ); } @Override public void update (Account account) { jdbcTemplate.update("update t_account set aname=?,money=? where id = ?" ,account.getAname(),account.getMoney(),account.getId()); } }
` 可见,SpringTemplate还是相当简单的,没有什么特殊的思想,对开发来说并没有方便很多,这里就不进行测试了。 · 这里注意一下: JDBC实现了threadLocal,所以即使它是单例的,也是线程安全的 (说实话我不是很懂….,以后成长起来再来解释一下),它会根据当前的线程去取数据库的连接。
Spring实现事务管理 · 有关事务管理的内容,不是本博客的重点,本篇文章只是略微介绍一下Spring事务管理的使用(因为这个是相当的方便)。Spring事务管理是基于AOP的,用来增强业务层的业务逻辑,有兴趣可以参考我关于AOP的教程:SpringAOP实战 。
进行事务管理的原因 · 虽然不着重讲事务管理的细节,但是这里给出一个特别经典的案例:转帐案例 ,来表明事务管理的重要性。 · 我们在业务层实现一个转账方法,并设置一点小细节:模拟在转账过程中的停电事件,停电的时间点在:甲方已经转账成功,但乙方还未收到钱。停电事件用一个flag控制。 业务层实现如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 package com.memoforward.service.impl;import ...;@Service ("accountService" )public class AccountServiceImpl implements AccountService { @Autowired AccountDao accountDao; @Override public void transfer (String sourceName, String targetName, Double money, boolean flag) { Account source = accountDao.findAccountByName(sourceName); Account target = accountDao.findAccountByName(targetName); source.setMoney(source.getMoney() - money); target.setMoney((target.getMoney() + money)); accountDao.update(source); if (flag) throw new RuntimeException("断电了...." ); accountDao.update(target); } }
如果我们设置flag为true,并进行转账:
1 2 3 4 @Test public void testTranser () { accountService.transfer("cxy" ,"lhw" ,1000.0 ,true ); }
数据库里的金额就变成了:可见1号的钱少了,结果2号的钱没多。
id
aname
money
1
cxy
1000.0
2
lhw
2000.0
造成这种现象的原因很简单,因为:业务层会调用持久层(DAO)的方法,默认情况是:每次dao层的方法执行结束之后,事务都被自动提交了。 · 因此,就需要对这个转账方法进行事务的管理:开启事务,如果异常就回滚,不异常就用提交,最后是释放连接。我在之前的文章里,用动态代理实现了事务管理,有兴趣可以参考一下:Java两种动态代理实战+动态代理死循环的解释 。 · 因为Spring中声明事务管理是基于aop的,所以很显然,事务管理的内容必然就是一个advice通知。而相比普通的切面,事务管理很常用,因此spring就自己把其封装了。
xml的事务管理配置
首先还是要引入相应的jar包:spring-tx和aspectjweaver ,一个是事务管理的依赖,一个是用于识别切入点表达式。
1 2 3 4 5 6 7 8 9 10 <dependency > <groupId > org.springframework</groupId > <artifactId > spring-tx</artifactId > <version > 5.0.2.RELEASE</version > </dependency > <dependency > <groupId > org.aspectj</groupId > <artifactId > aspectjweaver</artifactId > <version > 1.9.2</version > </dependency >
配置事务管理器(DataSourceTransactionManagement)并注入Datasource。(事务管理器的接口是PlatformTransactionManagement)
配置事务通知< tx:advice >并将事务管理器添加至标签属性
配置aop,写切入点表达式并用< aop: advisor >引入事务通知
在事务通知下配置子标签< tx:attributes > ,在< tx:attrributes >标签下用< tx:method >配置业务方法(只有配置了切入点才能知道增强哪个包的方法,因此这步在最后)
xml配置如下:注意事务管理是业务层的和持久层没有关系。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns ="http://www.springframework.org/schema/beans" xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xmlns:contxt ="http://www.springframework.org/schema/context" xmlns:tx ="http://www.springframework.org/schema/tx" xmlns:aop ="http://www.springframework.org/schema/aop" xsi:schemaLocation ="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd" > <contxt:component-scan base-package ="com.memoforward" /> <bean id ="txManagement" class ="org.springframework.jdbc.datasource.DataSourceTransactionManager" > <property name ="dataSource" ref ="dataSource" /> </bean > <tx:advice id ="txAdvice" transaction-manager ="txManagement" > <tx:attributes > <tx:method name ="find*" propagation ="SUPPORTS" read-only ="true" /> <tx:method name ="*" propagation ="REQUIRED" /> </tx:attributes > </tx:advice > <aop:config > <aop:pointcut id ="pt1" expression ="execution(* com.memoforward.service.impl.*.*(..))" /> <aop:advisor advice-ref ="txAdvice" pointcut-ref ="pt1" /> </aop:config > <bean id ="dataSource" class ="org.springframework.jdbc.datasource.DriverManagerDataSource" > <property name ="driverClassName" value ="com.mysql.jdbc.Driver" /> <property name ="url" value ="jdbc:mysql:///springaop" /> <property name ="username" value ="root" /> <property name ="password" value ="123" /> </bean > <bean id ="jdbcTemplate" class ="org.springframework.jdbc.core.JdbcTemplate" > <property name ="dataSource" ref ="dataSource" /> </bean > </beans >
关于< tx:method >的属性:这个标签是针对不同的方法进行不用的事务增强而设计出来的,spring为其提供了6种属性:
属性
含义
isolation
用于指定事务的隔离级别。默认是数据库的默认隔离级别。
propagation
用于指定事务的传播行为。默认值是:REQUIRED,表示一定会开启事务。也有SUPPORTS表示支持当前事务(如果当面没有事务,则不开启事务),一般用于查询方法。
read-only
用于指定事务是否只读。只有查询方法才能是true。
timeout
用于指定事务的超时时间,默认是-1,表示永不超时。设置的单位级别是秒。
rollback-for
用于指定一个异常,当产生该异常时,事务回滚,产生其他异常,事物不回滚。不设置则所有异常都回滚 。
no-rollback-for
用于指定一个异常,当产生该异常时,事务不回滚,产生其他异常,事物回滚。不设置则所有异常都回滚 。
结果:这就不进行测试了,因为非常简单。当配置了如上的事务后,在“转账”操作未结束的时候,所有的dao方法都不会提交,因此保证了转账的安全性。
注解配置 · Spring事务管理同样也可以进行注解配置,注解配置比较简单,但是有不方便的地方。 · Spring进行注解配置的步骤是:
配置事务管理器
开启Spring对注解配置事务的支持(< tx:annotation-driven >),纯注解配置的话在配置类上用@EnableTransactionManagement来开启。
在需要事务支持的地方使用@Transactional,其属性就是上述标签< tx:method > 的属性。这个注解用在类上表示此种事务对该类的所有方法都生效;用在方法上表示:此种事务仅对该方法生效。注意: 我还不太清楚如果使用该注解对不同的事务管理器进行操作。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns ="http://www.springframework.org/schema/beans" xmlns:xsi ="http://www.w3.org/2001/XMLSchema-instance" xmlns:contxt ="http://www.springframework.org/schema/context" xmlns:tx ="http://www.springframework.org/schema/tx" xmlns:aop ="http://www.springframework.org/schema/aop" xsi:schemaLocation ="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd" > <contxt:component-scan base-package ="com.memoforward" /> <bean id ="txManagement" class ="org.springframework.jdbc.datasource.DataSourceTransactionManager" > <property name ="dataSource" ref ="dataSource" /> </bean > <tx:annotation-driven transaction-manager ="txManagement" /> <bean id ="dataSource" class ="org.springframework.jdbc.datasource.DriverManagerDataSource" > <property name ="driverClassName" value ="com.mysql.jdbc.Driver" /> <property name ="url" value ="jdbc:mysql:///springaop" /> <property name ="username" value ="root" /> <property name ="password" value ="123" /> </bean > <bean id ="jdbcTemplate" class ="org.springframework.jdbc.core.JdbcTemplate" > <property name ="dataSource" ref ="dataSource" /> </bean > </beans >
其业务层改为如下:
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 package com.memoforward.service.impl;import ...;@Service ("accountService" )@Transactional (readOnly = true , propagation = Propagation.SUPPORTS)public class AccountServiceImpl implements AccountService { @Autowired AccountDao accountDao; @Override @Transactional (readOnly = false , propagation = Propagation.REQUIRED) public void transfer (String sourceName, String targetName, Double money, boolean flag) { Account source = accountDao.findAccountByName(sourceName); Account target = accountDao.findAccountByName(targetName); source.setMoney(source.getMoney() - money); target.setMoney((target.getMoney() + money)); accountDao.update(source); if (flag) throw new RuntimeException("断电了...." ); accountDao.update(target); } }
结论 · Spring声明式事务管理十分有用,用起来很方便,就是需要记忆的部分有点多,不过孰能生巧,多练多写才是王道。这里Spring有关业务层的内容就全部结束。我最近也变的很忙,关于java后台的学习笔记也要稍微停滞一段时间。闲暇之余可能会更新一些有关深度学习的内容(为了毕业),加油吧。
交流
请联系邮箱:chenxingyu@bupt.edu.cn