1、通過PlatformTransactionManager控制事務(wù)

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、定義數(shù)據(jù)源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，執(zhí)行數(shù)據(jù)庫操作語句JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);//3、定義【事務(wù)管理器】，并指定數(shù)據(jù)源PlatformTransactionManager transactionManager = new DataSourceTransactionManager(dataSource);//4、定義【事務(wù)屬性】，TransactionDefinition，它可用來配置事務(wù)的屬性信息，比如事務(wù)隔離級(jí)別、事務(wù)超時(shí)時(shí)間、事務(wù)傳播方式、是否是只讀事務(wù)等TransactionDefinition transactionDefinition = new DefaultTransactionDefinition();//5.【開啟事務(wù)】，返回事務(wù)狀態(tài)(TransactionStatus)對(duì)象TransactionStatus transactionStatus = transactionManager.getTransaction(transactionDefinition);//6.執(zhí)行業(yè)務(wù)操作try {List<Map<String, Object>> list = jdbcTemplate.queryForList("SELECT * from b_user");System.out.println("插入數(shù)據(jù)前:" + list);jdbcTemplate.update("insert into b_user (name) values (?)", "李清華最聰明2");jdbcTemplate.update("insert into b_user (name) values (?)", "張北大最智慧2");//制造異常，觸發(fā)回滾int num = 1 / 0;//7.【提交事務(wù)】,注意：事務(wù)的提交放在try最后一行transactionManager.commit(transactionStatus);} catch (Exception e) {//8.【回滾事務(wù)】，捕獲異常回滾事務(wù)transactionManager.rollback(transactionStatus);}List<Map<String, Object>> list = jdbcTemplate.queryForList("SELECT * from b_user");System.out.println("插入數(shù)據(jù)后:" + list);}}

2、通過TransactionTemplate控制事務(wù)

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) {//定義數(shù)據(jù)源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.定義事務(wù)管理器PlatformTransactionManager platformTransactionManager = new DataSourceTransactionManager(dataSource);//2.定義事務(wù)屬性DefaultTransactionDefinition transactionDefinition = new DefaultTransactionDefinition();transactionDefinition.setTimeout(10);//如：設(shè)置超時(shí)時(shí)間10s//3.創(chuàng)建TransactionTemplate對(duì)象TransactionTemplate transactionTemplate = new TransactionTemplate(platformTransactionManager, transactionDefinition);//無返回值的，需傳遞一個(gè)Consumer對(duì)象，在accept方法中做業(yè)務(wù)操作transactionTemplate.executeWithoutResult(new Consumer<TransactionStatus>() {@Overridepublic void accept(TransactionStatus transactionStatus) {jdbcTemplate.update("insert into b_user (name) values (?)", "張三無返回");}});//有返回值的，需要傳遞一個(gè)TransactionCallback對(duì)象，在doInTransaction方法中做業(yè)務(wù)操作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("執(zhí)行返回?cái)?shù)據(jù)：" + result);System.out.println("最終查詢結(jié)果:" + jdbcTemplate.queryForList("SELECT * from b_user"));}}

3、pom引入

<properties><project.build.sourceEncoding>UTF-8</project.build.sourceEncoding><!-- 配置maven編譯的時(shí)候采用的編譯器版本 --><maven.compiler.compilerVersion>1.8</maven.compiler.compilerVersion><!-- 指定源代碼是什么版本的，如果源碼和這個(gè)版本不符將報(bào)錯(cuò)，maven中執(zhí)行編譯的時(shí)候會(huì)用到這個(gè)配置，默認(rèn)是1.5，這個(gè)相當(dāng)于javac命令后面的-source參數(shù) --><maven.compiler.source>1.8</maven.compiler.source><!-- 該命令用于指定生成的class文件將保證和哪個(gè)版本的虛擬機(jī)進(jìn)行兼容，maven中執(zhí)行編譯的時(shí)候會(huì)用到這個(gè)配置，默認(rèn)是1.5，這個(gè)相當(dāng)于javac命令后面的-target參數(shù) --><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>

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。