廣州網(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)題);