Springboot + Mybatis配置多数据源

今天药忘吃喽~ 2023-03-13 15:27 144阅读 0赞

## 0、pom依赖 ##

<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jdbc</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.mybatis.spring.boot</groupId>
    			<artifactId>mybatis-spring-boot-starter</artifactId>
    			<version>2.1.2</version>
    		</dependency>
    		<dependency>
    			<groupId>mysql</groupId>
    			<artifactId>mysql-connector-java</artifactId>
    			<scope>runtime</scope>
    		</dependency>

## 1、application.properties多数据源连接配置 ##

**testa、testb数据源配置：**

## 数据源A
    spring.datasource.testa.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.datasource.testa.url=jdbc:mysql://localhost:3306/db_testa?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
    spring.datasource.testa.username=root
    spring.datasource.testa.password=123456
    
    ## 数据源B
    spring.datasource.testb.driver-class-name=com.mysql.cj.jdbc.Driver
    spring.datasource.testb.url=jdbc:mysql://localhost:3306/db_testb?useUnicode=true&characterEncoding=UTF-8&allowMultiQueries=true&serverTimezone=Asia/Shanghai
    spring.datasource.testb.username=root
    spring.datasource.testb.password=123456

## 2、Mybatis多数据源配置 ##

**testa的mybatis事务配置：TestaDatasourceConfig.java：**

package com.jack.config;
    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.beans.factory.annotation.Value;
    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.DriverManagerDataSource;
    
    @Configuration
    @MapperScan(basePackages = "com.jack.mapper.testa.**", sqlSessionFactoryRef = "testaSqlSessionFactory", sqlSessionTemplateRef = "testaSqlSessionTemplate")
    public class TestaDatasourceConfig { 
    	
    	@Value("${spring.datasource.testa.driver-class-name}")
    	private String driverClassName;
    	@Value("${spring.datasource.testa.url}")
    	private String url;
    	@Value("${spring.datasource.testa.username}")
    	private String username;
    	@Value("${spring.datasource.testa.password}")
    	private String password;
    	
    	@Bean(name = "testaDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.testa")
    	public DataSource dataSource() { 
    		DriverManagerDataSource dataSource = new DriverManagerDataSource();
    		dataSource.setDriverClassName(driverClassName);
    		dataSource.setUrl(url);
    		dataSource.setUsername(username);
    		dataSource.setPassword(password);
    		return dataSource;
    	}
    
    	@Bean(name = "testaSqlSessionFactory")
    	public SqlSessionFactory sessionFactory(@Qualifier("testaDataSource") DataSource dataSource) throws Exception { 
    		SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
    		factoryBean.setDataSource(dataSource);
    		factoryBean.setMapperLocations(
    				new PathMatchingResourcePatternResolver().getResources("classpath:mappers/testa/*.xml"));
    		return factoryBean.getObject();
    	}
    
    	@Bean(name = "testaSqlSessionTemplate")
    	public SqlSessionTemplate sessionTemplate(
    			@Qualifier("testaSqlSessionFactory") SqlSessionFactory sessionFactory) { 
    		SqlSessionTemplate sessionTemplate = new SqlSessionTemplate(sessionFactory);
    		return sessionTemplate;
    	}
    }

**testb的mybatis事务配置：TestbDatasourceConfig.java：**

package com.jack.config;
    
    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.beans.factory.annotation.Value;
    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.DriverManagerDataSource;
    
    @Configuration
    @MapperScan(basePackages = "com.jack.mapper.testb.**", sqlSessionFactoryRef = "testbSqlSessionFactory", sqlSessionTemplateRef = "testbSqlSessionTemplate")
    public class TestbDatasourceConfig { 
    	
    	@Value("${spring.datasource.testb.driver-class-name}")
    	private String driverClassName;
    	@Value("${spring.datasource.testb.url}")
    	private String url;
    	@Value("${spring.datasource.testb.username}")
    	private String username;
    	@Value("${spring.datasource.testb.password}")
    	private String password;
    	
    	@Bean(name = "testbDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.testb")
    	public DataSource dataSource() { 
    		DriverManagerDataSource dataSource = new DriverManagerDataSource();
    		dataSource.setDriverClassName(driverClassName);
    		dataSource.setUrl(url);
    		dataSource.setUsername(username);
    		dataSource.setPassword(password);
    		return dataSource;
    	}
    
    	@Bean(name = "testbSqlSessionFactory")
    	public SqlSessionFactory sessionFactory(@Qualifier("testbDataSource") DataSource dataSource) throws Exception { 
    		SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
    		factoryBean.setDataSource(dataSource);
    		factoryBean.setMapperLocations(
    				new PathMatchingResourcePatternResolver().getResources("classpath:mappers/testb/*.xml"));
    		return factoryBean.getObject();
    	}
    
    	@Bean(name = "testbSqlSessionTemplate")
    	public SqlSessionTemplate sessionTemplate(
    			@Qualifier("testbSqlSessionFactory") SqlSessionFactory sessionFactory) { 
    		SqlSessionTemplate sessionTemplate = new SqlSessionTemplate(sessionFactory);
    		return sessionTemplate;
    	}
    }

## 3、启动类加入配置： ##

package com.jack;
    
    import org.mybatis.spring.boot.autoconfigure.MybatisAutoConfiguration;
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration;
    import org.springframework.boot.context.properties.EnableConfigurationProperties;
    import org.springframework.context.annotation.ComponentScan;
    
    @SpringBootApplication
    @EnableConfigurationProperties
    @ComponentScan(basePackages = {  "com.jack"})
    @EnableAutoConfiguration(exclude = {  MybatisAutoConfiguration.class, DataSourceAutoConfiguration.class,
            DataSourceTransactionManagerAutoConfiguration.class })
    public class JackApplication{ 
    
        public static void main(String[] args) throws Exception { 
            SpringApplication.run(JackApplication.class, args);
        }
    
    }

## 4、测试 ##

为了mybatis便于管理事务，需要将testa、testb的Mapper接口类与Mapper.xml目录分开存放，分开扫包即可。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZhbmdjaGFvMjAxMQ_size_16_color_FFFFFF_t_70]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZhbmdjaGFvMjAxMQ_size_16_color_FFFFFF_t_70]: /images/20230312/88e277f1a543408ebd531115df72c999.png