Spring 为编程式的事务管理, 提供了相应的模板类 org.springframework.transaction.support.TransactionTemplate, 可以应对一些特殊场合的需要.
TransactionTemplate 是线程安全的, 所以可以在多个类中共享 TransactionTemplate 实例, 实现事务管理 .
TransactionTemplate 继承了 DefaultTransactionDefinition, 所以也拥有多种设置事务属性的方法:
TransactionTemplate 类的主要方法:
方法 | 说明 |
---|---|
public void setTransactionManager(PlatformTransactionManager transactionManager) | 设置事务管理器。 |
public | 在 TransactionCallback 回调接口中,编写需要以事务方式执行的数据访问逻辑代码。 |
TransactionCallback 接口只定义了一个方法 doInTransaction(TransactionStatus status).Spring 还定义了一个抽象类 TransactionCallbackWithoutResult, 用于只执行, 但不需要返回结果的场景.
Spring 配置文件:
- <?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:p="http://www.springframework.org/schema/p"
- xmlns:context="http://www.springframework.org/schema/context"
- xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
- http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd">
- <!-- 扫描包含注解定义的类包 -->
- <context:component-scan base-package="net.deniro.xxx.transaction"/>
- <!-- 数据源 -->
- <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
- destroy-method="close"
- p:driverClassName="com.mysql.jdbc.Driver"
- p:url="jdbc:mysql://127.0.0.1:3306/xxx"
- p:username="root"
- p:password="xxx"/>
- <!-- JDBC 模板 -->
- <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"
- p:dataSource-ref="dataSource"
- />
- <!-- 事务管理器 -->
- <bean id="transactionManager"
- class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
- p:dataSource-ref="dataSource"/>
- <!-- 事务模板 -->
- <bean id="TransactionTemplate"
- class="org.springframework.transaction.support.TransactionTemplate"
- p:transactionManager-ref="transactionManager"/>
- </beans>
User 类:
- public class User {
- private long id;
- private String name;
- public User(String name) {
- this.name = name;
- }
- public long getId() {
- return id;
- }
- public void setId(long id) {
- this.id = id;
- }
- public String getName() {
- return name;
- }
- public void setName(String name) {
- this.name = name;
- }
- }
UserDao 类:
- @Repository
- public class UserDao {
- @Autowired
- private JdbcTemplate jdbcTemplate;
- /**
- * 保存账号
- *
- * @param user
- * @throws SQLException
- */
- public void save(User user) {
- String sql = "insert into t_user(user_name) values(?)";
- jdbcTemplate.update(sql, user.getName());
- String sql2 = "insert into t_log(user_name) values(?)";
- jdbcTemplate.update(sql2, user.getName());
- }
- }
为了实验事务是否生效, 这里的第一个 SQL 是正确的, 而第二个 SQL 是错误的 (找不到表).
UserService 类:
- @Service
- public class UserService {
- @Autowired
- private UserDao userDao;
- @Autowired
- private TransactionTemplate template;
- public void save(final User user) {
- template.execute(new TransactionCallbackWithoutResult() {
- @Override
- protected void doInTransactionWithoutResult(TransactionStatus status) {
- userDao.save(user);
- }
- });
- }
- }
单元测试:
- public class UserServiceTest {
- ApplicationContext context;
- @BeforeMethod
- public void setUp() throws Exception {
- context = new ClassPathXmlApplicationContext("spring.xml");
- }
- @Test
- public void test() {
- UserService userService = (UserService) context.getBean("userService");
- final User user = new User("deniro");
- userService.save(user);
- }
- }
为了看到 Spring 的事务日志, 我们可以修改 log4j 事务配置, 级别改为 DEBUG:
- log4j.logger.org.springframework.jdbc.datasource.DataSourceTransactionManager=DEBUG
- log4j.logger.org.springframework.transaction.interceptor=DEBUG
- log4j.logger.org.springframework.transaction=DEBUG
运行结果分析:
Spring 首先创建一个新的事务.
在执行到第二个 SQL 语句时, 抛出异常; Spring 执行回滚操作. 说明事务生效咯 O(∩_∩)O~
来源: http://www.jianshu.com/p/20a37a412a47