廣州網(wǎng)站優(yōu)化渠道北京網(wǎng)站搭建哪家好
目錄
前言：
事務(wù)的相關(guān)問(wèn)題
1、什么是事務(wù)？
2、事務(wù)的特點(diǎn)（ACID）
3、什么時(shí)候想到使用事務(wù)？
4、通常使用JDBC訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)，還是mybatis訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)，怎么處理事務(wù)？
5、問(wèn)題中事務(wù)處理的方式有什么不足？
6、怎么解決不足？
7、處理事務(wù)，需要怎么做，做什么？
8、事務(wù)的隔離級(jí)別
9、事務(wù)的超時(shí)時(shí)間
10、事務(wù)的傳播行為
spring boot中配置事務(wù)以及使用：
1、進(jìn)行配置類(lèi)的處理
2、創(chuàng)建數(shù)據(jù)資源配置類(lèi)：
3、實(shí)際代碼里面調(diào)用實(shí)踐：
總結(jié)：
前言：
目前大多數(shù)的項(xiàng)目都是通過(guò)spring或者springboot來(lái)開(kāi)發(fā)的，并且項(xiàng)目里面操作數(shù)據(jù)庫(kù)常用的有mybatis\mybatis-plus等，在操作數(shù)據(jù)庫(kù)的時(shí)候，經(jīng)常會(huì)使用事務(wù)的處理，因?yàn)樵诓僮鲾?shù)據(jù)庫(kù)的時(shí)候，如果出現(xiàn)異常的話(huà)，所有的數(shù)據(jù)庫(kù)操作都能夠回滾操作，避免造成一些異常數(shù)據(jù)的問(wèn)題。目前網(wǎng)絡(luò)上搜索的都是原始的配置方式，比如說(shuō)使用xml進(jìn)行bean的配置，或者說(shuō)直接在方法頭上面進(jìn)行添加注解的方式進(jìn)行調(diào)用的，本文主要介紹通過(guò)配置類(lèi)進(jìn)行管理實(shí)務(wù)的方式，統(tǒng)一的管理、統(tǒng)一的處理方式。
事務(wù)的相關(guān)問(wèn)題
1、什么是事務(wù)？
事務(wù)是指一組SQL語(yǔ)句的集合，集合中有多條SQL語(yǔ)句，可以是insert、update、select、delete，希望這些SQL語(yǔ)句執(zhí)行是一致的，作為一個(gè)整體執(zhí)行。要么都成功，要么都失敗。
2、事務(wù)的特點(diǎn)（ACID）
原子性（Atomicity）：事務(wù)是一個(gè)原子操作，由一系列動(dòng)作組成。事務(wù)的原子性確保動(dòng)作要么全部完成，要么完全不起作用。
一致性（Consistency）：一旦事務(wù)完成（不管成功還是失敗），系統(tǒng)必須確保它所建模的業(yè)務(wù)處于一致的狀態(tài)，而不會(huì)是部分完成部分失敗。在現(xiàn)實(shí)中的數(shù)據(jù)不應(yīng)該被破壞。
隔離性（Isolation）：可能有許多事務(wù)會(huì)同時(shí)處理相同的數(shù)據(jù)，因此每個(gè)事務(wù)都應(yīng)該與其他事務(wù)隔離開(kāi)來(lái)，防止數(shù)據(jù)損壞。
持久性（Durability）：一旦事務(wù)完成，無(wú)論發(fā)生什么系統(tǒng)錯(cuò)誤，它的結(jié)果都不應(yīng)該受到影響，這樣就能從任何系統(tǒng)崩潰中恢復(fù)過(guò)來(lái)。通常情況下，事務(wù)的結(jié)果被寫(xiě)到持久化存儲(chǔ)器中。
3、什么時(shí)候想到使用事務(wù)？
（1）當(dāng)操作設(shè)計(jì)多個(gè)表，或者是多個(gè)SQL語(yǔ)句的insert、update、delete。需要保證這些語(yǔ)句都是成功才能完成功能，或者都失敗是符合要求的。（要么都成功，要么都失敗）
（2）事務(wù)在java開(kāi)發(fā)中如何運(yùn)用？
1、事務(wù)放在service類(lèi)的業(yè)務(wù)方法中，因?yàn)闃I(yè)務(wù)方法會(huì)調(diào)用多個(gè)dao，執(zhí)行多條SQL語(yǔ)句
4、通常使用JDBC訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)，還是mybatis訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)，怎么處理事務(wù)？
（1）jdbc訪(fǎng)問(wèn)數(shù)據(jù)，處理事務(wù)。Connection conn；conn.commit();conn.rollback();
（2）mybatis訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)，處理事務(wù)。SqlSession.commit() ;SqlSession.rollback();
（3）hibernate訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)，處理事務(wù)，Session.commit(); Session.rollback();
5、問(wèn)題中事務(wù)處理的方式有什么不足？
（1）不同數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)技術(shù)，處理事務(wù)的對(duì)象、方法不同。需要了解不同數(shù)據(jù)庫(kù)使用事務(wù)的原理。
（2）需要掌握多種數(shù)據(jù)庫(kù)事務(wù)的處理邏輯，什么時(shí)候提交事務(wù)，什么時(shí)候回滾事務(wù)。
（3）處理事務(wù)的方法種類(lèi)多。
總結(jié)：就是多種數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)技術(shù)，不同的事務(wù)處理的機(jī)制、對(duì)象、方法。較難掌握。
6、怎么解決不足？
spring提供了處理事務(wù)的統(tǒng)一模型，能夠使用統(tǒng)一的步驟、方式完成多種不同數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)技術(shù)的事務(wù)處理。使用spring的事務(wù)處理機(jī)制可以完成mybatis、hibernate訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)的事務(wù)處理。
7、處理事務(wù)，需要怎么做，做什么？
spring處理事務(wù)的模型，使用的步驟都是固定的。把事務(wù)要使用的信息都提供給spring就可以了。
（1）事務(wù)內(nèi)部提交、回滾事務(wù)使用的是事務(wù)管理器對(duì)象，代替手動(dòng)commit、rollback。事務(wù)管理器是一個(gè)接口和其眾多的實(shí)現(xiàn)類(lèi)。
接口：PlatformTransactionManager，定義了事務(wù)的重要方法 commit、rollback
實(shí)現(xiàn)類(lèi)：spring把每一種數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)技術(shù)對(duì)應(yīng)的事務(wù)處理累都創(chuàng)建好了。
a、mybatis訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)—spring創(chuàng)建好的是DataSourceTransactionManager
b、hibernate訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)—spring創(chuàng)建好的是HibernateTransactionManager
怎么使用？
只需告訴spring使用哪種數(shù)據(jù)庫(kù)的訪(fǎng)問(wèn)技術(shù)（框架），聲明數(shù)據(jù)庫(kù)訪(fǎng)問(wèn)技術(shù)對(duì)應(yīng)的事務(wù)管理器的實(shí)現(xiàn)類(lèi)，在spring的配置文件中使用<bean>聲明就可以了。例如使用mybatis訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)：
<bean id = "xxx" class = "...DataSourceTransactionManager"/>
1
（2）業(yè)務(wù)方法需要什么樣的事務(wù)？說(shuō)明需要事務(wù)的類(lèi)型。
8、事務(wù)的隔離級(jí)別
有 5 個(gè)值，其中一個(gè)是默認(rèn)。這些常量均是以ISOLATION_開(kāi)頭，即形如：ISOLATION_XXX。
1、DEFAULT：采用DB默認(rèn)的事務(wù)隔離級(jí)別。MySQL的默認(rèn)隔離級(jí)別：REPEATABLE_READ（可重復(fù)讀）；Oracle默認(rèn)的隔離級(jí)別：READ_COMMITTED（讀已提交）
2、READ_UNCOMMITTED：讀未提交，未解決任何并發(fā)問(wèn)題。
3、READ_COMMITTED：讀已提交。解決度臟數(shù)據(jù)，存在不可重復(fù)讀與幻讀。
4、REPEATABLE_READ：可重復(fù)度。解決臟讀、不可重復(fù)讀，存在幻讀。
5、SERIALIZABLE：串行化。不存在并發(fā)問(wèn)題。
9、事務(wù)的超時(shí)時(shí)間
表示一個(gè)方法最長(zhǎng)的執(zhí)行時(shí)間，如果方法執(zhí)行時(shí)超過(guò)了這個(gè)時(shí)間，事務(wù)就回滾。單位是秒，整數(shù)值，默認(rèn)是：-1（表示沒(méi)有限制最長(zhǎng)時(shí)間）。
10、事務(wù)的傳播行為
控制業(yè)務(wù)方法是不是有事務(wù)的，是什么樣的事務(wù)的。共有 7 個(gè)傳播行為。（標(biāo)紅常用需掌握）
（1）PROPAGATION_REQUIRED：指定的方法必須在事務(wù)內(nèi)執(zhí)行。若當(dāng)前存在事務(wù)，就加入當(dāng)前事務(wù)中；若當(dāng)前沒(méi)有事務(wù)，則創(chuàng)建一個(gè)新事務(wù)。這種創(chuàng)博行為時(shí)最常見(jiàn)的選擇，也是spring默認(rèn)的事務(wù)傳播行為。
（2）PROPAGATION_REQUIRES_NEW：總是新建一個(gè)事務(wù)，若當(dāng)前存在事務(wù)，就將當(dāng)前事務(wù)掛起，知道新事物執(zhí)行完畢。
（3）PROPAGATION_SUPPORTS：指定方法支持當(dāng)前事務(wù)，但若當(dāng)前沒(méi)有事務(wù)，也可以以非事務(wù)的方式執(zhí)行。
（4）PROPAGATION_MANDATORY
（5）PROPAGATION_NESTED
（6）PROPAGATION_NEVER
（7）PROPAGATION_NOT_SUPPORTED
spring boot中配置事務(wù)以及使用：
1、進(jìn)行配置類(lèi)的處理
#transaction setting###############################################
spring.transaction.aop.aop-pointcut-expression=execution(* com...*ServiceImpl.*(..))
spring.transaction.aop.tx-method-timeout=3600
spring.transaction.aop.require-rule=insert*,update*,delete*,do*
spring.transaction.aop.read-only-rule=query*
spring.transaction.aop.indep-transaction-rule=indep*第一個(gè)配置：該方法主要是為了在操作的時(shí)候，掃描包的路徑，不是所有的方法都是走事務(wù)處理的。
第二個(gè)配置：配置處理的時(shí)間大小36秒
第三個(gè)配置：為了限制規(guī)則，比如說(shuō)方法的名稱(chēng)必須是什么開(kāi)頭的，只有這些方法名稱(chēng)開(kāi)頭的才會(huì)走事務(wù)的處理
第四個(gè)配置：讀取的規(guī)則的方法名稱(chēng)開(kāi)頭的命名
第五個(gè)配置：事務(wù)的處理規(guī)則
2、創(chuàng)建數(shù)據(jù)資源配置類(lèi)：
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.SqlSessionTemplate;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.aop.Advisor;
import org.springframework.aop.aspectj.AspectJExpressionPointcut;
import org.springframework.aop.support.DefaultPointcutAdvisor;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
import org.springframework.transaction.interceptor.RollbackRuleAttribute;
import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute;
import org.springframework.transaction.interceptor.TransactionAttribute;
import org.springframework.transaction.interceptor.TransactionInterceptor;@Configuration
public class SpringBootDatasourceConfig {private Logger LOGGER = LoggerFactory.getLogger(SpringBootDatasourceConfig.class);@Value("${spring.transaction.aop.tx-method-timeout}")private int TX_METHOD_TIMEOUT = 60;@Value("${spring.transaction.aop.aop-pointcut-expression}")private String AOP_POINTCUT_EXPRESSION;@Value("#{'${spring.transaction.aop.require-rule}'.split(',')}")private List<String> requireRuleList;@Value("#{'${spring.transaction.aop.read-only-rule}'.split(',')}")private List<String> readOnlyRuleList;@Value("#{'${spring.transaction.aop.indep-transaction-rule}'.split(',')}")private List<String> indepTransactionRuleList;@Value("${mybatis.mapper-locations}")private String MYBATIS_MAPPER_LOCATIONS;@Value("${mybatis.config-location}")private String MYBATIS_CONFIG_LOCATION;@Value("${mybatis.jdbc.dialect.type}")private String MYBATIS_JDBC_DIALECT_TYPE;public SpringBootDatasourceConfig() {}@Primary@Bean({"db1DataSourceProperties"})@ConfigurationProperties(prefix = "spring.datasource.db1")public DataSourceProperties dataSourceProperties() {DataSourceProperties dataSourceProperties = new DataSourceProperties();return dataSourceProperties;}@Primary@Bean({"db1DataSource"})@ConfigurationProperties(prefix = "spring.datasource.db1.tomcat")public DataSource db1DataSource(@Qualifier("db1DataSourceProperties") DataSourceProperties dataSourceProperties) {DataSource dataSource = dataSourceProperties.initializeDataSourceBuilder().build();return dataSource;}@Primary@Bean(name = {"db1SqlSessionFactory"})public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource datasource) throws Exception {SqlSessionFactoryBean bean = new SqlSessionFactoryBean();bean.setDataSource(datasource);bean.setMapperLocations((new PathMatchingResourcePatternResolver()).getResources(this.MYBATIS_MAPPER_LOCATIONS));bean.setConfigLocation((new PathMatchingResourcePatternResolver()).getResource(this.MYBATIS_CONFIG_LOCATION));PageInterceptor pageInterceptor = new PageInterceptor();Properties properties = new Properties();properties.setProperty("dialect", this.MYBATIS_JDBC_DIALECT_TYPE);pageInterceptor.setProperties(properties);Interceptor[] plugins = new Interceptor[]{pageInterceptor};bean.setPlugins(plugins);return bean.getObject();}@Bean({"sqlSessionTemplate"})public SqlSessionTemplate db1SqlsessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sessionfactory) {SqlSessionTemplate sqlSessionTemplate = new SqlSessionTemplate(sessionfactory);if (sqlSessionTemplate != null) {Connection connection = null;try {connection = sqlSessionTemplate.getConnection();} catch (Exception var13) {this.LOGGER.error("SqlSessionTemplate初始化連接池失敗", var13);} finally {if (connection != null) {try {connection.close();} catch (SQLException var12) {this.LOGGER.error("關(guān)閉連接失敗", var12);}}}}return sqlSessionTemplate;}@Bean({"txmanager"})public DataSourceTransactionManager txManager(@Qualifier("db1DataSource") DataSource dataSource) {DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();dataSourceTransactionManager.setDataSource(dataSource);return dataSourceTransactionManager;}@Bean({"txAdvice"})public TransactionInterceptor txAdvice(@Qualifier("txmanager") DataSourceTransactionManager dataSourceTransactionManager) {RuleBasedTransactionAttribute readOnlyRule = new RuleBasedTransactionAttribute();readOnlyRule.setReadOnly(true);readOnlyRule.setPropagationBehavior(4);RuleBasedTransactionAttribute requireRule = new RuleBasedTransactionAttribute();requireRule.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(RuntimeException.class)));requireRule.setPropagationBehavior(0);requireRule.setIsolationLevel(2);requireRule.setTimeout(this.TX_METHOD_TIMEOUT);RuleBasedTransactionAttribute indepTransactionRule = new RuleBasedTransactionAttribute();indepTransactionRule.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(RuntimeException.class)));indepTransactionRule.setPropagationBehavior(3);indepTransactionRule.setIsolationLevel(2);indepTransactionRule.setTimeout(this.TX_METHOD_TIMEOUT);Map<String, TransactionAttribute> txMap = new HashMap();int i;String indepTransacdtionAopRule;for(i = 0; i < this.requireRuleList.size(); ++i) {indepTransacdtionAopRule = (String)this.requireRuleList.get(i);txMap.put(indepTransacdtionAopRule.trim(), requireRule);}for(i = 0; i < this.readOnlyRuleList.size(); ++i) {indepTransacdtionAopRule = (String)this.readOnlyRuleList.get(i);txMap.put(indepTransacdtionAopRule.trim(), readOnlyRule);}for(i = 0; i < this.indepTransactionRuleList.size(); ++i) {indepTransacdtionAopRule = (String)this.indepTransactionRuleList.get(i);txMap.put(indepTransacdtionAopRule.trim(), indepTransactionRule);}NameMatchTransactionAttributeSource nameMatchTransactionAttributeSource = new NameMatchTransactionAttributeSource();nameMatchTransactionAttributeSource.setNameMap(txMap);TransactionInterceptor txAdvice = new TransactionInterceptor(dataSourceTransactionManager, nameMatchTransactionAttributeSource);return txAdvice;}@Beanpublic Advisor txAdviceAdvisor(@Qualifier("txAdvice") TransactionInterceptor transactionInterceptor) {AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();pointcut.setExpression(this.AOP_POINTCUT_EXPRESSION);return new DefaultPointcutAdvisor(pointcut, transactionInterceptor);}
}3、實(shí)際代碼里面調(diào)用實(shí)踐：
第一種：添加異常方法，直接調(diào)用接口，就可以看到相關(guān)的效果，只不過(guò)需要在數(shù)據(jù)庫(kù)變更的后面，添加相關(guān)的異常拋出，讓整個(gè)方法異常，然后看一下這個(gè)數(shù)據(jù)庫(kù)的記錄沒(méi)有變化，已經(jīng) 回滾了；
第二種：去除異常方法，讓整個(gè)方法正常執(zhí)行下去，通過(guò) 數(shù)據(jù)庫(kù)查詢(xún)一下記錄，看一下數(shù)據(jù)是更新是成功落庫(kù)的；
總結(jié)：
目前網(wǎng)絡(luò)上面搜索到的都是直接使用的注解進(jìn)行事務(wù)的處理，而不是根據(jù)配置文件進(jìn)行配置規(guī)則、以及事務(wù)的統(tǒng)一管理處理，比如說(shuō)方法名稱(chēng)進(jìn)行切面的處理，那些方法是會(huì)進(jìn)行mybatis（數(shù)據(jù)庫(kù)的更新處理會(huì)走事務(wù)處理），比如說(shuō)，目前的很多大型公司，或者說(shuō)需要保持事務(wù)一致性的公司都會(huì)用到，整個(gè)的調(diào)用鏈比較長(zhǎng)，如果中途出現(xiàn)了問(wèn)題，會(huì)進(jìn)行事務(wù)的回滾處理，避免了很多的問(wèn)題（數(shù)據(jù)庫(kù)里面存在垃圾數(shù)據(jù)的問(wèn)題）；