1.07 Spring编程式事务管理

  • Z时代
  • 2024-01-10
  • 分类：综合

本文内容纲要：

- 1.07 Spring编程式事务管理
- 实现事务管理的两种方式
- 事务管理的步骤

1.07 Spring编程式事务管理

实现事务管理的两种方式

  • 基于XML实现事务管理

  • 基于注解实现事务管理

事务管理的步骤

  • 定义事务开始

  • 正常执行后事务提交

  • 异常时事务回滚

示例demo：

位于DAO的实现类当中：

   @Override
    public void saveUser(User user) { TransactionDefinition def = new DefaultTransactionDefinition(); // getTransaction()用于启动事务，返回TransactionStatus实例对象 TransactionStatus status = transactionManager.getTransaction(def); try { this.jdbcTemplate.update("INSERT INTO USER(NAME,age) VALUES (?,?)", user.getName(), user.getAge()); transactionManager.commit(status); System.out.println("commit!"); } catch (Exception e) { System.out.println("Error in creating record, rolling back"); transactionManager.rollback(status); throw e; } } @Override public List<User> listUser() { List<User> users = this.jdbcTemplate.query("SELECT NAME,age FROM USER", new RowMapper<User>() { public User mapRow(ResultSet rs, int rowNum) throws SQLException { User user = new User(); user.setName(rs.getString("name")); user.setAge(rs.getInt("age")); return user; } }); return users; }

配置Beans.xml：

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <!-- 配置数据源 --> <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource"> <!-- 数据库驱动 --> <property name="driverClassName" value="com.mysql.jdbc.Driver" /> <!-- 连接数据库url --> <property name="url" value="jdbc:mysql://localhost/test" /> <!-- 用户名 --> <property name="username" value="root" /> <!-- 密码 --> <property name="password" value="root" /> </bean>

基于XML实现事务管理

Spring声明式事务管理的特点：

本质：

对方法前后进行拦截

具体过程：

  • 在目标方法开始之前创建或加入一个事务

  • 在执行完目标方法之后根据执行情况提交或回滚事务

优点：

分离业务逻辑代码和事务管理代码

位于Dao层接口的实现类当中：

   @Override
    public void createUserTable() { this.jdbcTemplate.execute("CREATE TABLE `user` (\r\n" + " `id` int(11) NOT NULL AUTO_INCREMENT,\r\n" + " `name` varchar(50) DEFAULT NULL,\r\n" + " `age` int(4) DEFAULT NULL,\r\n" + " PRIMARY KEY (`id`)\r\n" + ") ENGINE=InnoDB DEFAULT CHARSET=utf8;"); } @Override public void saveUser(User user) { try { this.jdbcTemplate.update("INSERT INTO USER(NAME,age) VALUES (?,?)", user.getName(), user.getAge()); throw new RuntimeException("simulate Error condition"); } catch (Exception e) { System.out.println("Error in creating record, rolling back"); throw e; } } @Override public List<User> listUser() { List<User> users = this.jdbcTemplate.query("SELECT NAME,age FROM USER", new RowMapper<User>() { public User mapRow(ResultSet rs, int rowNum) throws SQLException { User user = new User(); user.setName(rs.getString("name")); user.setAge(rs.getInt("age")); return user; } }); return users; }

配置Bean.xml：

<?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: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-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd"> <!-- 配置数据源 --> <!-- 传统的配置驱动、url、用户名、密码 --> <beans> <bean> <!-- 编写通知：对事务进行增强（通知），需要编写切入点和具体执行事务的细节 --> <tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <!-- 给切入点方法添加事务详情，name表示方法名称，*表示任意方法名称，propagation用于设置传播行为，read-only表示隔离级别，是否只读 --> <tx:method name="*" propagation="SUPPORTS" readOnly = "false"/> </tx:attributes> </tx:advice> <!-- aop编写，让Spring自动对目标生成代理，需要使用AspectJ的表达式 --> <aop:config> <!-- 切入点，execution 定义的表达式表示net.biencheng包下的所有类所有方法都应用该是事务 --> <aop:pointcut id="createOperation" expression="execution(* net.biancheng.*.*(..))" /> <aop:advisor advice-ref="txAdvice" pointcut-ref="createOperation" /> </aop:config> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource" /> </bean> <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate"> <property name="dataSource" ref="dataSource" /> </bean> <bean id="userdao" class="net.biancheng.UserDaoImpl"> <property name="dataSource" ref="dataSource" /> <property name="jdbcTemplate" ref="jdbcTemplate" /> </bean> </beans>

Spring基于注解实现事务

在代码当中使用Annotation注解实现事务管理

注册驱动：

<tx:annotation-driven transaction-manager="txManager"/>

添加注解、配置参数：

@Transactional参数：

常用属性说明：

  • propagation：设置事务的传播行为；

  • isolation：设置事务的隔离级别；

  • readOnly：设置是读写事务还是只读事务；

  • timeout：事务超时事件（单位：s）。

在UserDaoImpl类下使用该注释：

@Transactional(propagation = Propagation.REQUIRED, isolation = Isolation.DEFAULT, readOnly = false) public class UserDaoImpl imlements UserDao { @Override public void createUserTable() { this.jdbcTemplate.execute("CREATE TABLE `user` (\r\n" + " `id` int(11) NOT NULL AUTO_INCREMENT,\r\n" + " `name` varchar(50) DEFAULT NULL,\r\n" + " `age` int(4) DEFAULT NULL,\r\n" + " PRIMARY KEY (`id`)\r\n" + ") ENGINE=InnoDB DEFAULT CHARSET=utf8;"); } @Override public void saveUser(User user) { try { this.jdbcTemplate.update("INSERT INTO USER(NAME,age) VALUES (?,?)", user.getName(), user.getAge()); this.jdbcTemplate.update("INSERT INTO USER(NAME,age) VALUES (?,?)", "google", 16); throw new RuntimeException("simulate Error condition"); } catch (Exception e) { System.out.println("Error in creating record, rolling back"); throw e; } } @Override public List<User> listUser() { List<User> users = this.jdbcTemplate.query("SELECT NAME,age FROM USER", new RowMapper<User>() { public User mapRow(ResultSet rs, int rowNum) throws SQLException { User user = new User(); user.setName(rs.getString("name")); user.setAge(rs.getInt("age")); return user; } }); return users; } }

注意：

@Transactional注解的参数之间用“，”进行分隔

本文内容总结：1.07 Spring编程式事务管理，实现事务管理的两种方式，事务管理的步骤，

原文链接：https://www.cnblogs.com/JunkingBoy/p/15819336.html

以上是 1.07 Spring编程式事务管理 的全部内容， 来源链接： utcz.com/z/362787.html

回到顶部