springboot多資料來源配置
阿新 • • 發佈：2020-10-27
資料庫配置檔案：
#********* primary jdbc ************************** spring.datasource.druid.primary.url=jdbc:mysql://127.0.0.1:3306/one?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&useSSL=false spring.datasource.druid.primary.username=test1 spring.datasource.druid.primary.password=test1 spring.datasource.druid.primary.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.druid.primary.test-on-borrow=true spring.datasource.druid.primary.test-while-idle=true #********* primary jdbc ************************** #********* two jdbc ************************** spring.datasource.druid.two.url=jdbc:mysql://127.0.0.2:3306/two?useUnicode=true&characterEncoding=UTF-8&rewriteBatchedStatements=true&useSSL=false spring.datasource.druid.two.username=test2 spring.datasource.druid.two.password=test2 spring.datasource.druid.two.driver-class-name=com.mysql.cj.jdbc.Driver spring.datasource.druid.two.test-on-borrow=true spring.datasource.druid.two.test-while-idle=true #********* two jdbc **************************
資料來源one(即主資料來源)配置：
package com.test.common.config; import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan;import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import javax.sql.DataSource; /** * <p>Description: primary資料庫配置類 </p>*/ @Configuration @MapperScan(basePackages = {"com.test.one.dao"}, sqlSessionTemplateRef = "oneSqlSessionTemplate") public class DataSourceConfig { @Bean(name = "dataSource")public DataSource Datasource() { return DruidDataSourceBuilder.create().build(); } /** * 返回primary資料庫的會話工廠 * @param ds * @return * @throws Exception */ @Bean(name = "sqlSessionFactory") public SqlSessionFactory SqlSessionFactory(@Qualifier("dataSource") DataSource ds) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(ds); return bean.getObject(); } @Bean(name = "TransactionManager") public DataSourceTransactionManager basementTransactionManager(@Qualifier("dataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } /** * 返回primary資料庫的會話模板 * @param sessionFactory * @return * @throws Exception */ @Bean(name = "sqlSessionTemplate") public SqlSessionTemplate SqlSessionTemplate(@Qualifier("sqlSessionFactory") SqlSessionFactory sessionFactory) throws Exception { return new SqlSessionTemplate(sessionFactory); } }
package com.test.common.config; 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.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.interceptor.*; import java.util.Collections; import java.util.HashMap; import java.util.Map; /** * <p>Description: primary事務配置 </p>*/ @Configurationpublic class TransactionConfig { /* * 通過AOP切面設定全域性事務，攔截service包下面所有方法 * AOP術語：通知（Advice）、連線點（Joinpoint）、切入點（Pointcut)、切面（Aspect）、目標(Target)、代理(Proxy)、織入（Weaving） */ /** * 事務超時時間 */ private static final int TX_METHOD_TIMEOUT = 5; /** * 定義切點變數：攔截指定包下所有類的所有方法,返回值型別任意的方法 */ private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.test.*.*.impl.*.*(..))"; /** * <p>Description: springBoot事務配置</p>*/ @Bean(name="txAdvice") public TransactionInterceptor txAdvice( @Qualifier("transactionManager") PlatformTransactionManager transactionManager){ /*事務管理規則，宣告具備事務管理的方法名*/ NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource(); /*只讀事物、不做更新刪除等 當前存在事務就用當前的事務，當前不存在事務就建立一個新的事務*/ RuleBasedTransactionAttribute readOnlyRule = new RuleBasedTransactionAttribute(); //設定當前事務是否為只讀事務，true為只讀*/ readOnlyRule.setReadOnly(true); //transactiondefinition 定義事務的隔離級別； // PROPAGATION_NOT_SUPPORTED事務傳播級別5，以非事務執行，如果當前存在事務，則把當前事務掛起 readOnlyRule.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED); RuleBasedTransactionAttribute requireRule = new RuleBasedTransactionAttribute(); //丟擲異常後執行切點回滾*/ requireRule.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class))); //PROPAGATION_REQUIRED:事務隔離性為1，若當前存在事務，則加入該事務；如果當前沒有事務，則建立一個新的事務。這是預設值。 */ requireRule.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); //設定事務失效時間，如果超過5秒，則回滾事務 requireRule.setTimeout(TX_METHOD_TIMEOUT); Map<String, TransactionAttribute> txMap = new HashMap<>(20); txMap.put("add*",requireRule); txMap.put("save*", requireRule); txMap.put("insert*",requireRule); txMap.put("delete*",requireRule); txMap.put("remove*",requireRule); txMap.put("update*",requireRule); txMap.put("modify*",requireRule); txMap.put("get*",readOnlyRule); txMap.put("query*", readOnlyRule); txMap.put("find*", readOnlyRule); txMap.put("select*",readOnlyRule); source.setNameMap(txMap); TransactionInterceptor txAdvice = new TransactionInterceptor(transactionManager, source); return txAdvice; } /** * 利用AspectJExpressionPointcut設定切面=切點+通知（寫成內部bean的方式） */ @Bean(name="txAdviceAdvisor") public Advisor txAdviceAdvisor(@Qualifier("txAdvice") TransactionInterceptor txAdvice){ //切面（Aspect）：切面就是通知和切入點的結合。通知和切入點共同定義了關於切面的全部內容——它的功能、在何時和何地完成其功能。 AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut(); //宣告和設定需要攔截的方法,用切點語言描寫 pointcut.setExpression(AOP_POINTCUT_EXPRESSION); return new DefaultPointcutAdvisor(pointcut, txAdvice); } }
資料來源two配置：
package com.test.common.config; import com.alibaba.druid.spring.boot.autoconfigure.DruidDataSourceBuilder; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import javax.sql.DataSource; /** * <p>Description: two資料庫配置類 </p>*/ @Configuration @ConditionalOnProperty(prefix = "spring.datasource.druid.two" ,name = "url", matchIfMissing = false) @MapperScan(basePackages = {"com.test.two.dao"}, sqlSessionTemplateRef = "twoSqlSessionTemplate") public class twoDataSourceConfig { @Bean(name = "twoDataSource") @ConfigurationProperties(prefix = "spring.datasource.druid.two") public DataSource twoDatasource() { return DruidDataSourceBuilder.create().build(); } /** * 返回two資料庫的會話工廠 * @param ds * @return * @throws Exception */ @Bean(name = "twoSqlSessionFactory") public SqlSessionFactory twoSqlSessionFactory(@Qualifier("twoDataSource") DataSource ds) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(ds); return bean.getObject(); } @Bean(name = "twoTransactionManager") public DataSourceTransactionManager basementTransactionManager(@Qualifier("twoDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } /** * 返回two資料庫的會話模板 * @param sessionFactory * @return * @throws Exception */ @Bean(name = "twoSqlSessionTemplate") public SqlSessionTemplate twoSqlSessionTemplate(@Qualifier("twoSqlSessionFactory") SqlSessionFactory sessionFactory) throws Exception { return new SqlSessionTemplate(sessionFactory); } }
package com.test.common.config; 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.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.interceptor.*; import java.util.Collections; import java.util.HashMap; import java.util.Map; /** * <p>Description: two事務配置 </p>*/ @Configuration @ConditionalOnProperty(name ="spring.datasource.druid.two.driver-class-name",havingValue="com.mysql.cj.jdbc.Driver") public class TransactionTwoConfig { /* * 通過AOP切面設定全域性事務，攔截service包下面所有方法 * AOP術語：通知（Advice）、連線點（Joinpoint）、切入點（Pointcut)、切面（Aspect）、目標(Target)、代理(Proxy)、織入（Weaving） */ /** * 事務超時時間 */ private static final int TX_METHOD_TIMEOUT = 5; /** * 定義切點變數：攔截指定包下所有類的所有方法,返回值型別任意的方法 */ private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.test.*.*.impl.*.*(..))"; /** * <p>Description: springBoot事務配置</p>*/ @Bean(name="txAdvice-two") public TransactionInterceptor txAdvice( @Qualifier("twoTransactionManager") PlatformTransactionManager transactionManager){ /*事務管理規則，宣告具備事務管理的方法名*/ NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource(); /*只讀事物、不做更新刪除等 當前存在事務就用當前的事務，當前不存在事務就建立一個新的事務*/ RuleBasedTransactionAttribute readOnlyRule = new RuleBasedTransactionAttribute(); //設定當前事務是否為只讀事務，true為只讀*/ readOnlyRule.setReadOnly(true); //transactiondefinition 定義事務的隔離級別； // PROPAGATION_NOT_SUPPORTED事務傳播級別5，以非事務執行，如果當前存在事務，則把當前事務掛起 readOnlyRule.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED); RuleBasedTransactionAttribute requireRule = new RuleBasedTransactionAttribute(); //丟擲異常後執行切點回滾*/ requireRule.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class))); //PROPAGATION_REQUIRED:事務隔離性為1，若當前存在事務，則加入該事務；如果當前沒有事務，則建立一個新的事務。這是預設值。 */ requireRule.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); //設定事務失效時間，如果超過5秒，則回滾事務 requireRule.setTimeout(TX_METHOD_TIMEOUT); Map<String, TransactionAttribute> txMap = new HashMap<>(20); txMap.put("add*",requireRule); txMap.put("save*", requireRule); txMap.put("insert*",requireRule); txMap.put("delete*",requireRule); txMap.put("remove*",requireRule); txMap.put("update*",requireRule); txMap.put("modify*",requireRule); txMap.put("get*",readOnlyRule); txMap.put("query*", readOnlyRule); txMap.put("find*", readOnlyRule); txMap.put("select*",readOnlyRule); source.setNameMap(txMap); TransactionInterceptor txAdvice = new TransactionInterceptor(transactionManager, source); return txAdvice; } /** * 利用AspectJExpressionPointcut設定切面=切點+通知（寫成內部bean的方式） */ @Bean(name="txAdviceAdvisor-two") public Advisor txAdviceAdvisor(@Qualifier("txAdvice-two") TransactionInterceptor txAdvice){ //切面（Aspect）：切面就是通知和切入點的結合。通知和切入點共同定義了關於切面的全部內容——它的功能、在何時和何地完成其功能。 AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut(); //宣告和設定需要攔截的方法,用切點語言描寫 pointcut.setExpression(AOP_POINTCUT_EXPRESSION); return new DefaultPointcutAdvisor(pointcut, txAdvice); } }