springBoot多数据源配置以及事务控制

一&＃xff1a;多数据源配置

1、主数据源配置文件

package com.bert.datasource;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.jdbc.DataSourceBuilder;
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 com.github.pagehelper.PageInterceptor;import java.util.Properties;import javax.sql.DataSource;&＃64;Configuration
&＃64;MapperScan(basePackages &＃61; "com.bert.mapper.master1", sqlSessionTemplateRef &＃61; "master1SqlSessionTemplate")
public class DataSource1Config {&＃64;Bean(name &＃61; "master1DataSource")&＃64;ConfigurationProperties(prefix &＃61; "master1.datasource")&＃64;Primarypublic DataSource master1DataSource() {return DataSourceBuilder.create().build();}&＃64;Bean(name &＃61; "master1SqlSessionFactory")&＃64;Primarypublic SqlSessionFactory master1SqlSessionFactory(&＃64;Qualifier("master1DataSource") DataSource dataSource)throws Exception {SqlSessionFactoryBean bean &＃61; new SqlSessionFactoryBean();bean.setDataSource(dataSource);bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/master1/*.xml"));// 分页拦截器-beginPageInterceptor pageHelper &＃61; new PageInterceptor();Properties properties &＃61; new Properties();properties.setProperty("helperDialect", "com.github.pagehelper.dialect.helper.SqlServerDialect");properties.setProperty("offsetAsPageNum", "true");properties.setProperty("rowBoundsWithCount", "false");properties.setProperty("reasonable", "false");pageHelper.setProperties(properties);bean.getObject().getConfiguration().addInterceptor(pageHelper);return bean.getObject();}&＃64;Bean(name &＃61; "master1TransactionManager")&＃64;Primarypublic DataSourceTransactionManager master1TransactionManager(&＃64;Qualifier("master1DataSource") DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}&＃64;Bean(name &＃61; "master1SqlSessionTemplate")&＃64;Primarypublic SqlSessionTemplate master1SqlSessionTemplate(&＃64;Qualifier("master1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {return new SqlSessionTemplate(sqlSessionFactory);}}

2、其他数据源配置文件

package com.bert.datasource;import java.util.Properties;import javax.sql.DataSource;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.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import com.github.pagehelper.PageInterceptor;&＃64;Configuration
&＃64;MapperScan(basePackages &＃61; "com.bert.mapper.master2", sqlSessionTemplateRef &＃61; "master2SqlSessionTemplate")
public class DataSource2Config {&＃64;Bean(name &＃61; "master2DataSource")&＃64;ConfigurationProperties(prefix &＃61; "master2.datasource")public DataSource master2DataSource() {return DataSourceBuilder.create().build();}&＃64;Bean(name &＃61; "master2SqlSessionFactory")public SqlSessionFactory master2SqlSessionFactory(&＃64;Qualifier("master2DataSource") DataSource dataSource)throws Exception {SqlSessionFactoryBean bean &＃61; new SqlSessionFactoryBean();bean.setDataSource(dataSource);bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/master2/*.xml"));// 分页拦截器-beginPageInterceptor pageHelper &＃61; new PageInterceptor();Properties properties &＃61; new Properties();properties.setProperty("helperDialect", "com.github.pagehelper.dialect.helper.SqlServerDialect");properties.setProperty("offsetAsPageNum", "true");properties.setProperty("rowBoundsWithCount", "false");properties.setProperty("reasonable", "false");pageHelper.setProperties(properties);bean.getObject().getConfiguration().addInterceptor(pageHelper);return bean.getObject();}&＃64;Bean(name &＃61; "master2TransactionManager")public DataSourceTransactionManager master2TransactionManager(&＃64;Qualifier("master2DataSource") DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}&＃64;Bean(name &＃61; "master2SqlSessionTemplate")public SqlSessionTemplate master2SqlSessionTemplate(&＃64;Qualifier("master2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {return new SqlSessionTemplate(sqlSessionFactory);}}

注意&＃xff1a;
A&＃xff1a;只能有一个主数据源&＃xff0c;用注解&＃64;Primary表示
B&＃xff1a;&＃64;MapperScan属性basePackages&＃xff0c;表示数据源对应的mapper文件目录

3、springBoot配置文件

master1.datasource.url&＃61;jdbc:sqlserver://ip1:1433; DatabaseName&＃61;db1
master1.datasource.username&＃61;xx
master1.datasource.password&＃61;xxxxxx
master1.datasource.driverClassName&＃61;com.microsoft.sqlserver.jdbc.SQLServerDrivermaster2.datasource.url&＃61;jdbc:sqlserver://ip2:1433; DatabaseName&＃61;db2
master2.datasource.username&＃61;xx
master3.datasource.password&＃61;xxxxxx
master2.datasource.driverClassName&＃61;com.microsoft.sqlserver.jdbc.SQLServerDriver

二&＃xff1a;多数据源事务控制

1、启动文件&＃xff0c;配置事务注解&＃64;EnableTransactionManagement

&＃64;Controller
&＃64;SpringBootApplication
&＃64;EnableSwagger2
&＃64;EnableTransactionManagement
public class BootMain extends SpringBootServletInitializer{&＃64;Overrideprotected SpringApplicationBuilder configure(SpringApplicationBuilder application) {return application.sources(BootMain.class);}public static void main(String[] args) {SpringApplication.run(BootMain.class, args);}}


2、接口实现配置事务注解&＃64;Transactional

如果是单一数据源&＃xff0c;只需要在service实现的方法上加上&＃64;Transactional即可。
如果是多数据源&＃xff0c;需要指定事务管理器名称

&＃64;Transactional(value &＃61; "master2TransactionManager", rollbackFor &＃61; { Exception.class })


我在微信订阅号等你&＃xff01;