1、通過PlatformTransactionManager控制事務

package com.tx;import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.TransactionStatus; import org.springframework.transaction.support.DefaultTransactionDefinition;import java.util.List; import java.util.Map;public class TestTransaction {public static void main(String[] args) {//1、定義數據源org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();dataSource.setDriverClassName("com.mysql.cj.jdbc.Driver");dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/work_db?characterEncoding=UTF-8&serverTimezone=UTC");dataSource.setInitialSize(10);dataSource.setUsername("root");dataSource.setPassword("root");//2、定義JdbcTemplate，執行數據庫操作語句JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);//3、定義【事務管理器】，并指定數據源PlatformTransactionManager transactionManager = new DataSourceTransactionManager(dataSource);//4、定義【事務屬性】，TransactionDefinition，它可用來配置事務的屬性信息，比如事務隔離級別、事務超時時間、事務傳播方式、是否是只讀事務等TransactionDefinition transactionDefinition = new DefaultTransactionDefinition();//5.【開啟事務】，返回事務狀態(TransactionStatus)對象TransactionStatus transactionStatus = transactionManager.getTransaction(transactionDefinition);//6.執行業務操作try {List<Map<String, Object>> list = jdbcTemplate.queryForList("SELECT * from b_user");System.out.println("插入數據前:" + list);jdbcTemplate.update("insert into b_user (name) values (?)", "李清華最聰明2");jdbcTemplate.update("insert into b_user (name) values (?)", "張北大最智慧2");//制造異常，觸發回滾int num = 1 / 0;//7.【提交事務】,注意：事務的提交放在try最后一行transactionManager.commit(transactionStatus);} catch (Exception e) {//8.【回滾事務】，捕獲異常回滾事務transactionManager.rollback(transactionStatus);}List<Map<String, Object>> list = jdbcTemplate.queryForList("SELECT * from b_user");System.out.println("插入數據后:" + list);}}

2、通過TransactionTemplate控制事務

package com.tx;import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.lang.Nullable; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.TransactionStatus; import org.springframework.transaction.support.DefaultTransactionDefinition; import org.springframework.transaction.support.TransactionCallback; import org.springframework.transaction.support.TransactionTemplate;import java.util.function.Consumer;public class TestTransaction2 {public static void main(String[] args) {//定義數據源org.apache.tomcat.jdbc.pool.DataSource dataSource = new org.apache.tomcat.jdbc.pool.DataSource();dataSource.setDriverClassName("com.mysql.jdbc.Driver");dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/work_db?characterEncoding=UTF-8&serverTimezone=UTC");dataSource.setInitialSize(10);dataSource.setPassword("root");dataSource.setUsername("root");//定義JdbcTemplateJdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);//1.定義事務管理器PlatformTransactionManager platformTransactionManager = new DataSourceTransactionManager(dataSource);//2.定義事務屬性DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition();transactionDefinition.setTimeout(10);//如：設置超時時間10s//3.創建TransactionTemplate對象TransactionTemplate transactionTemplate = new TransactionTemplate(platformTransactionManager, transactionDefinition);//無返回值的，需傳遞一個Consumer對象，在accept方法中做業務操作transactionTemplate.executeWithoutResult(new Consumer<TransactionStatus>() {@Overridepublic void accept(TransactionStatus transactionStatus) {jdbcTemplate.update("insert into b_user (name) values (?)", "張三無返回");}});//有返回值的，需要傳遞一個TransactionCallback對象，在doInTransaction方法中做業務操作Integer result = transactionTemplate.execute(new TransactionCallback<Integer>() {@Nullable@Overridepublic Integer doInTransaction(TransactionStatus status) {int result = jdbcTemplate.update("insert into b_user (name) values (?)", "張三有返回");return result;}});System.out.println("執行返回數據：" + result);System.out.println("最終查詢結果:" + jdbcTemplate.queryForList("SELECT * from b_user"));}}

3、pom引入

<properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><!-- 配置maven編譯的時候采用的編譯器版本 --><maven.compiler.compilerVersion>1.8</maven.compiler.compilerVersion><!-- 指定源代碼是什么版本的，如果源碼和這個版本不符將報錯，maven中執行編譯的時候會用到這個配置，默認是1.5，這個相當于javac命令后面的-source參數 --><maven.compiler.source>1.8</maven.compiler.source><!-- 該命令用于指定生成的class文件將保證和哪個版本的虛擬機進行兼容，maven中執行編譯的時候會用到這個配置，默認是1.5，這個相當于javac命令后面的-target參數 --><maven.compiler.target>1.8</maven.compiler.target><spring.version>5.2.6.RELEASE</spring.version><lombok.version>1.18.10</lombok.version><junit.version>4.13</junit.version><logback.version>1.2.3</logback.version><aspectj.version>1.9.5</aspectj.version><redisson.version>3.13.3</redisson.version><mysql.version>8.0.19</mysql.version><tomcat.version>8.5.34</tomcat.version></properties>------------------------------------------------------------------------------------<dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>${spring.version}</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-tx</artifactId><version>${spring.version}</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>${mysql.version}</version></dependency><dependency><groupId>org.apache.tomcat</groupId><artifactId>tomcat-jdbc</artifactId><version>${tomcat.version}</version></dependency>

總結

以上是生活随笔為你收集整理的Spring 编程式事务实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。