AbstractRoutingDataSource 只支持单库事务,也就是说切换数据源要在开启事务之前执行。 spring DataSourceTransactionManager进行事务管理,开启事务,会将数据源缓存到DataSourceTransactionObject对象中进行后续的commit rollback等事务操作。
出现多数据源动态切换失败的原因是因为在事务开启后,数据源就不能再进行随意切换了,也就是说,一个事务对应一个数据源。
1.传统的Spring管理事务是放在Service业务层操作的,所以更换数据源的操作要放在这个操作之前进行。也就是切换数据源操作放在Controller层,可是这样操作会造成Controller层代码混乱的结果。
故而想到的解决方案是将事务管理在数据持久 (Dao层) 开启,切换数据源的操作放在业务层进行操作,就可在事务开启之前顺利进行数据源切换,不会再出现切换失败了。
2.如果管理事务是放在Service业务层操作的,Spring事务会在方法前获取数据连接connection,动态数据源的切面是在Dao层,但是这时还没有到DAO层进行路由选择,因此需要延迟加载数据源,需要用到LazyConnectionDataSourceProxy
<bean id="parentDataSource" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="${jdbc.driverClassName}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="initialSize" value="1"/>
<property name="minIdle" value="2"/>
<property name="validationQuery" value="SELECT 1 FROM DUAL"/>
<property name="testOnCreate" value="true"/>
<property name="testWhileIdle" value="true"/>
<property name="testOnBorrow" value="true"/>
</bean>
<bean id="dataSource" parent="parentDataSource">
<property name="driverClassName" value="${jdbc.driverClassName}"/>
<property name="url" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</bean>
<bean id="dataSourceM2" parent="parentDataSource">
<property name="driverClassName" value="${jdbcM2.driverClassName}"/>
<property name="url" value="${jdbcM2.url}"/>
<property name="username" value="${jdbcM2.username}"/>
<property name="password" value="${jdbcM2.password}"/>
</bean>
<bean id="dataSourceR" parent="parentDataSource">
<property name="driverClassName" value="${jdbcR.driverClassName}" />
<property name="url" value="${jdbcR.url}" />
<property name="username" value="${jdbcR.username}" />
<property name="password" value="${jdbcR.password}" />
</bean>
<bean id="dynamicDataSource" class="com.cmcc.open.ss.config.DynamicDataSource">
<property name="targetDataSources">
<map key-type="java.lang.String">
<entry key="dataSource" value-ref="dataSource"/>
<entry key="dataSourceM2" value-ref="dataSourceM2"/>
<entry key="dataSourceR" value-ref="dataSourceR"/>
</map>
</property>
<property name="defaultTargetDataSource" ref="dataSource"/>
</bean>
<!-- Spring事务会在方法前获取数据连接connection,但是这时还没有到DAO层进行路由选择,因此需要延迟加载数据源,需要用到LazyConnectionDataSourceProxy。 -->
<bean id="lazyDataSource" class="org.springframework.jdbc.datasource.LazyConnectionDataSourceProxy">
<property name="targetDataSource" ref="dynamicDataSource">
</property>
</bean>
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="dataSource" ref="lazyDataSource"/>
<property name="configLocation" value="classpath:acs_mysql.xml"></property>
</bean>
<bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg name="sqlSessionFactory" ref="sqlSessionFactory"/>
</bean>
<bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="lazyDataSource"/>
</bean>
<tx:annotation-driven transaction-manager="transactionManager"/>
3.如果不用LazyConnectionDataSourceProxy,可以给切面类上加上@Order(-1),让此切面优先于事务的切面执行
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.annotation.After;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Before;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.core.annotation.Order;
import org.springframework.stereotype.Component;
@Component
@Slf4j
@Aspect
@Order(-1)
public class DataSourceAspect {
/**
*
*/
@Pointcut("@within(com.hy.api.aop.DataSource) || @annotation(com.hy.api.aop.DataSource)")
public void pointCut() {
}
/**
*
* @param dataSource
*/
@Before("pointCut() && @annotation(dataSource)")
public void doBefore(DataSource dataSource) {
String ds = dataSource.value().getValue();
log.info("====================dataSource: " + ds);
MultipleDataSource.setDataSource(ds);
}
/**
*
*/
@After("pointCut()")
public void doAfter() {
MultipleDataSource.clear();
}
}
手机扫一扫
移动阅读更方便
你可能感兴趣的文章