在运行时在多个事务管理器之间进行选择

我有 2 个客户端使用在 tomcat 中部署的基于 Spring 的相同 REST 应用程序。根据客户端的不同，我需要在数据源和事务管理器之间进行选择。如何在运行时选择使用哪个事务管理器？

    <bean id="First_dataSource" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="url" value="${First_jdbc.url}" />
            <property name="driverClassName" value="${First_jdbc.driverClassName}" />
            <property name="username" value="${First_jdbc.username}" />
            <property name="password" value="${First_jdbc.password}" />
            <property name="removeAbandoned" value="true" />
            <property name="initialSize" value="20" />
            <property name="maxActive" value="30" />
            <!-- <property name="defaultAutoCommit" value="false" /> -->
   </bean>
    <bean id="Second_dataSource" class="org.apache.commons.dbcp.BasicDataSource"
            destroy-method="close">
            <property name="url" value="${Second_jdbc.url}" />
            <property name="driverClassName" value="${Second_jdbc.driverClassName}" />
            <property name="username" value="${Second_jdbc.username}" />
            <property name="password" value="${Second_jdbc.password}" />
            <property name="removeAbandoned" value="true" />
            <property name="initialSize" value="20" />
            <property name="maxActive" value="30" />
            <!-- <property name="defaultAutoCommit" value="false" /> -->
   </bean>
<bean id="First_TransactionManager"
    class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
        scope="singleton">
        <property name="dataSource" ref="First_dataSource" />
        <qualifier value="SC_TM"></qualifier>
</bean>
<bean id="Second_TransactionManager"
          class="org.springframework.jdbc.datasource.DataSourceTransactionManager"
          scope="singleton">
          <property name="dataSource" ref="Second_dataSource" />
          <qualifier value="Second_TM"></qualifier>
</bean>

在代码中，如何在运行时选择 @Transactional（"????"）。如果使用org.springframework.jdbc.datasource.DataSourceTransactionManager无法做到这一点，还有其他方法可以做到这一点吗？

考虑使用 Spring 提供的AbstractRoutingDataSource，而不是沿着在多个事务管理器之间进行选择的道路前进。这将是一个更干净的解决方案。

请参阅我对类似问题的回答这里：
https://stackoverflow.com/a/44167079/2200690

使用 @Transactional ，您可以像这样指定事务管理器：

@Transactional("First_TransactionManager")

或

@Transactional("Second_TransactionManager")

取决于您要使用的一个。确保在事务方法中使用正确的实体管理器/会话工厂。那些您还必须指定要注入的那些 @PersistenceContext("nameOfPersistenceUnit") .

我不知道

为什么要在 2 个事务管理器之间切换，您可能需要检查事务管理器链解决方案，但如果您需要这个，您可以在 Repo 方法上添加您的@transactional并执行 2 个存储库并从服务层作为开关进行管理，否则我相信可以使用 AOP 完成解决方案，但它需要更多时间来考虑它。

问题通过AOP解决。

定义多个数据源和相应的交易管理器（如我在我的基本问题）
First_dataSource映射First_TransactionManager，Second_dataSource映射Second_TransactionManager

根据业务规则选择要以编程方式使用的数据源。就我而言，它是orgId

公共类数据源提供程序 { @Autowired 数据源First_dataSource; @Autowired 数据源Second_dataSource;

    public DataSource getDataSource(int orgId) {
        if (orgId == Constants.BUSINESS_PARTY_1)
            return Second_dataSource;
        else
            return First_dataSource;
    }
    public DataSource getFirst_dataSource() {
        return First_dataSource;
    }
    public void setFirst_dataSource(DataSource First_dataSource) {
        First_dataSource = First_dataSource;
    }
    public DataSource getSecond_dataSource() {
        return Second_dataSource;
    }
    public void setSecond_dataSource(DataSource Second_dataSource) {
        Second_dataSource = Second_dataSource;
    }
}

AOP 配置：

<tx:advice id="First_txAdvice" transaction-manager="First_TransactionManager">
    <tx:attributes>
        <tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
    </tx:attributes>
</tx:advice>
<aop:config>
    <aop:pointcut id="First_daoimplOperation"
        expression="execution(* in.company.common.service.CommonServiceImpl.*(..))" />
    <aop:advisor advice-ref="First_txAdvice" pointcut-ref="First_daoimplOperation" />
</aop:config>
<tx:advice id="Second_txAdvice" transaction-manager="Second_TransactionManager">
    <tx:attributes>
        <tx:method name="*" propagation="REQUIRED" rollback-for="Exception" />
    </tx:attributes>
</tx:advice>
<aop:config>
    <aop:pointcut id="Second_daoimplOperation"
        expression="execution(* in.company.common.service.CommonServiceImpl.*(..))" />
    <aop:advisor advice-ref="Second_txAdvice" pointcut-ref="Second_daoimplOperation" />
</aop:config>

所有与数据库相关的服务都应该在匹配的切入点中，在本例中它是：in.company.common.service.CommonServiceImpl.*（..））

相关内容

最新更新

热门标签：