亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

SpringBoot手動開啟事務(wù):DataSourceTransactionManager問題

 更新時間：2023年07月06日 16:52:58   作者：cying2029  
這篇文章主要介紹了SpringBoot手動開啟事務(wù):DataSourceTransactionManager問題，具有很好的價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

DataSourceTransactionManager

添加事務(wù)：

  • 傳統(tǒng)JDBC事務(wù)管理，使用DataSource從數(shù)據(jù)源中獲取connection
  • 通過api進(jìn)行CRUD，之后手動commit、rollback。
  • 應(yīng)用spring提供的編程式的事務(wù)管理
  • 使用spring的聲明式事務(wù)處理

Spring的事務(wù)處理中，通用的事務(wù)處理流程是由抽象事務(wù)管理器AbstractPlatformTransactionManager來提供的，而具體的底層事務(wù)處理實(shí)現(xiàn)，由PlatformTransactionManager的具體實(shí)現(xiàn)類來實(shí)現(xiàn)，如 DataSourceTransactionManager 、JtaTransactionManager和 HibernateTransactionManager等。

SpringBoot中手動開啟事務(wù)常用代碼

@Controller
public class TransactionDemo {
    @Autowired
    private DataSourceTransactionManager transactionManager;
    @RequestMapping("test")
    public void test(){
        //可做單例
        DefaultTransactionDefinition definition = new DefaultTransactionDefinition();
        definition.setPropagationBehaviorName("PROPAGATION_REQUIRED");
        TransactionStatus transaction = transactionManager.getTransaction(definition);
//        TransactionStatus transaction = transactionManager.getTransaction(TransactionDefinition.withDefaults());
        try {
            //do something
            transactionManager.commit(transaction);
        }catch (Exception e){
            //do error
            transactionManager.rollback(transaction);
        }
    }
}

DataSourceTransactionManager總結(jié)

1.Spring框架配置事務(wù)

1.1基于schema的自動代理

<beans xmlns="http://www.springframework.org/schema/beans"
? ? ? ?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
? ? ? ?xmlns:p="http://www.springframework.org/schema/p"
? ? ? ?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-4.0.xsd
? ? ? ? http://www.springframework.org/schema/aop
? ? ? ? http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
? ? ? ? http://www.springframework.org/schema/tx
? ? ? ? http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
? ? <!--對數(shù)據(jù)源進(jìn)行代理，使數(shù)據(jù)源具有感知事務(wù)上下文的能力，當(dāng)某些場景下顯示獲取數(shù)據(jù)庫連接時，保證獲取到的連接是綁定了當(dāng)前事務(wù)的連接（和通過DataSourceUtils.getConnection()獲取連接的效果一致）-->
? ? <bean id="dataSourceProxy" class="org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy"
? ? ? ? p:targetDataSource-ref="dataSource"/>
? ? <!--聲明式事務(wù)管理器-->
? ? <bean id="txManager"
? ? ? ? ? class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
? ? ? ? p:dataSource-ref="dataSourceProxy"/>
? ? <!--基于schema的自動代理-->
? ? <aop:config>
? ? ? ? <!--切點(diǎn) 匹配com.fxy子包下的所有方法-->
? ? ? ? <aop:pointcut id="serviceMethod"
? ? ? ? ? ? ? ? ? ? ? expression="execution(* com.fxy..*.*.service..*.*(..))"/>
? ? ? ? <!--切面-->
? ? ? ? <aop:advisor pointcut-ref="serviceMethod" advice-ref="txAdvice"/>
? ? </aop:config>
? ? <!--增強(qiáng) 新增變更刪除方法 遇到檢查型異常和非檢查型異常均回滾-->
? ? <tx:advice id="txAdvice" transaction-manager="txManager">
? ? ? ? <tx:attributes>
? ? ? ? ? ? <tx:method name="get*" read-only="true"/>
? ? ? ? ? ? <tx:method name="list*" read-only="true"/>
? ? ? ? ? ? <tx:method name="save*" rollback-for="Exception"/>
? ? ? ? ? ? <tx:method name="update*" rollback-for="Exception"/>
? ? ? ? ? ? <tx:method name="delete*" rollback-for="Exception"/>
? ? ? ? ? ? <tx:method name="*" rollback-for="Exception"/>
? ? ? ? </tx:attributes>
? ? </tx:advice>
</beans>

查看tx:advice標(biāo)簽，可以追蹤到TransactionInterceptor類，其實(shí)現(xiàn)了MethodInterceptor接口，會在目標(biāo)方法前后實(shí)施增強(qiáng)（即使用txManager，在方法執(zhí)行前關(guān)閉Connection對象自動提交，方法執(zhí)行完成后執(zhí)行Connection對象提交方法，異常時執(zhí)行Connection對象回滾方法）。

1.2使用@transactional注解

<beans xmlns="http://www.springframework.org/schema/beans"
? ? ? ?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
? ? ? ?xmlns:p="http://www.springframework.org/schema/p"
? ? ? ?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-4.0.xsd
? ? ? ? http://www.springframework.org/schema/aop
? ? ? ? http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
? ? ? ? http://www.springframework.org/schema/tx
? ? ? ? http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
? ? <!--對數(shù)據(jù)源進(jìn)行代理，使數(shù)據(jù)源具有感知事務(wù)上下文的能力，當(dāng)某些場景下顯示獲取數(shù)據(jù)庫連接時，保證獲取到的連接是綁定了當(dāng)前事務(wù)的連接（和通過DataSourceUtils.getConnection()獲取連接的效果一致）-->
? ? <bean id="dataSourceProxy" class="org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy"
? ? ? ? p:targetDataSource-ref="dataSource"/>
? ? <!--聲明式事務(wù)管理器-->
? ? <bean id="txManager"
? ? ? ? ? class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
? ? ? ? p:dataSource-ref="dataSourceProxy"/>
? ? <!--對使用transactional注解的bean進(jìn)行加工，織入事務(wù)管理切面 -->
? ? <tx:annotation-driven transaction-manager="txManager"/>
</beans>

2.SpringBoot框架配置事務(wù)

2.1@Transactional注解

2.1.1SpringBoot自動裝配事務(wù)管理器

package org.springframework.boot.autoconfigure.jdbc;
import javax.sql.DataSource;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.boot.autoconfigure.AutoConfigureOrder;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.autoconfigure.condition.ConditionalOnSingleCandidate;
import org.springframework.boot.autoconfigure.transaction.TransactionManagerCustomizers;
import org.springframework.boot.context.properties.EnableConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.support.JdbcTransactionManager;
import org.springframework.transaction.TransactionManager;
@Configuration(
? ? proxyBeanMethods = false
)
@ConditionalOnClass({JdbcTemplate.class, TransactionManager.class})
@AutoConfigureOrder(2147483647)
@EnableConfigurationProperties({DataSourceProperties.class})
public class DataSourceTransactionManagerAutoConfiguration {
?? ?public DataSourceTransactionManagerAutoConfiguration() {
? ? }
? ? @Configuration(
? ? ? ? proxyBeanMethods = false
? ? )
? ? @ConditionalOnSingleCandidate(DataSource.class)
? ? static class JdbcTransactionManagerConfiguration {
? ? ? ? JdbcTransactionManagerConfiguration() {
? ? ? ? }
? ? ? ? @Bean
? ? ? ? @ConditionalOnMissingBean({TransactionManager.class})
? ? ? ? DataSourceTransactionManager transactionManager(Environment environment, DataSource dataSource, ObjectProvider<TransactionManagerCustomizers> transactionManagerCustomizers) {
? ? ? ? ? ? DataSourceTransactionManager transactionManager = this.createTransactionManager(environment, dataSource);
? ? ? ? ? ? transactionManagerCustomizers.ifAvailable((customizers) -> {
? ? ? ? ? ? ? ? customizers.customize(transactionManager);
? ? ? ? ? ? });
? ? ? ? ? ? return transactionManager;
? ? ? ? }
? ? ? ? private DataSourceTransactionManager createTransactionManager(Environment environment, DataSource dataSource) {
? ? ? ? ? ? return (DataSourceTransactionManager)((Boolean)environment.getProperty("spring.dao.exceptiontranslation.enabled", Boolean.class, Boolean.TRUE) ? new JdbcTransactionManager(dataSource) : new DataSourceTransactionManager(dataSource));
? ? ? ? }
? ? }
}

2.2SpringBoot多數(shù)據(jù)源配置

2.2.1給數(shù)據(jù)源指定事務(wù)管理器

? ?@Bean("db1TxManager")
? ?public DataSourceTransactionManager db1TxManager(@Qualifier("db1DataSource") DataSource dataSource ){
? ? ? ?DataSourceTransactionManager txManager = new DataSourceTransactionManager();
? ? ? ?txManager.setDataSource(dataSource);
? ? ? ?return txManager;
? ?}
? ?@Bean("db2TxManager")
? ?public DataSourceTransactionManager db2TxManager(@Qualifier("db2DataSource") DataSource dataSource ){
? ? ? ?DataSourceTransactionManager txManager = new DataSourceTransactionManager();
? ? ? ?txManager.setDataSource(dataSource);
? ? ? ?return txManager;
? ?}

2.2.2注解上指定事務(wù)管理器

@Service("baseService1")
@Transactional("db1TxManager")
public class BaseService1 {
...
}

總結(jié)

以上為個人經(jīng)驗(yàn)，希望能給大家一個參考，也希望大家多多支持腳本之家。

相關(guān)文章

最新評論