springboot后端配置多个数据源、Mysql数据库的便捷方法

# test1 数据库的配置

test1.spring.datasource.driver- class -name=com.mysql.cj.jdbc.Driver

test1.spring.datasource.jdbc-url=jdbc:mysql: //localhost:3306/database1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT

test1.spring.datasource.username=username

test1.spring.datasource.password=password

# test2 数据库的配置

test2.spring.datasource.driver- class -name=com.mysql.cj.jdbc.Driver

test2.spring.datasource.jdbc-url=jdbc:mysql: //localhost:3306/database2?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT

test2.spring.datasource.username=username

test2.spring.datasource.password=password

# 配置 mybatis 配置 mapper.xml 文件路径mybatis.mapper-locations=classpath:/mapper/*.xml,classpath:/mapper/test1/*.xml,classpath:/mapper/test2/*.xml

# 配置 mybatis 配置 实体类 文件路径

mybatis.type-aliases- package =com.xxx.entity.test1, com.xxx.entity.test2

package com.xxx.config.dataSource;

import com.alibaba.druid.pool.DruidDataSource;

import org.apache.ibatis.session.SqlSessionFactory;

import org.mybatis.spring.SqlSessionFactoryBean;

import org.mybatis.spring.annotation.MapperScan;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

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 javax.sql.DataSource;

/** * @program: test1 主数据源配置

* @author: JackLee

* @create: 2020-08-09 09:30

* @version: 1.0

**/ //

扫描 Mapper 接口并容器管理

@MapperScan (basePackages = Test1DataSourceConfig.PACKAGE, sqlSessionFactoryRef = "test1SqlSessionFactory" )

@Configuration

public class Test1DataSourceConfig {

// 精确到 test1 目录，以便跟其他数据源隔离

static final String PACKAGE = "com.xxx.dao.test1" ;

static final String MAPPER_LOCATION = "classpath:mapper/test1/*.xml" ;

@Value ( "${test1.spring.datasource.jdbc-url}" )

private String url;

@Value ( "${test1.spring.datasource.username}" )

private String user;

@Value ( "${test1.spring.datasource.password}" )

private String password;

@Value ( "${test1.spring.datasource.driver-class-name}" )

private String driverClass;

@Bean (name = "test1DataSource" )

@Primary

public DataSource test1DataSource() {

DruidDataSource dataSource = new DruidDataSource();

dataSource.setDriverClassName(driverClass);

dataSource.setUrl(url);

dataSource.setUsername(user);

dataSource.setPassword(password);

return dataSource;

}

@Bean (name = "test1TransactionManager" )

@Primary

public DataSourceTransactionManager test1TransactionManager() {

return new DataSourceTransactionManager(test1DataSource());

}

@Bean (name = "test1SqlSessionFactory" )

@Primary

public SqlSessionFactory test1SqlSessionFactory( @Qualifier ( "test1DataSource" ) DataSource test1DataSource)

throws Exception {

final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();

sessionFactory.setDataSource(test1DataSource);

sessionFactory.setMapperLocations( new PathMatchingResourcePatternResolver()

.getResources(Test1DataSourceConfig.MAPPER_LOCATION));

return sessionFactory.getObject();

}

}

package com.xxx.config.dataSource;

import com.alibaba.druid.pool.DruidDataSource;

import org.apache.ibatis.session.SqlSessionFactory;

import org.mybatis.spring.SqlSessionFactoryBean;

import org.mybatis.spring.annotation.MapperScan;

import org.springframework.beans.factory.annotation.Qualifier;

import org.springframework.beans.factory.annotation.Value;

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 javax.sql.DataSource;

/**

* @program: test2 其他数据源配置

* @author: JackLee

* @create: 2020-08-09 09:30

* @version: 1.0

**/

// 扫描 Mapper 接口并容器管理

@MapperScan (basePackages = Test2DataSourceConfig.PACKAGE, sqlSessionFactoryRef = "test2SqlSessionFactory" )

@Configuration

public class Test2DataSourceConfig {  

  // 精确到 test2 目录，以便跟其他数据源隔离   

  static final String PACKAGE = "com.xxx.dao.test2" ;   

  static final String MAPPER_LOCATION = "classpath:mapper/test2/*.xml" ;  

  @Value ( "${test2.spring.datasource.jdbc-url}" )   

  private String url;  

  @Value ( "${test2.spring.datasource.username}" )   

  private String user;  

  @Value ( "${test2.spring.datasource.password}" )   

  private String password;  

  @Value ( "${test2.spring.datasource.driver-class-name}" )  

  private String driverClass; 

  @Bean (name = "test2DataSource" )   

  public DataSource test2DataSource() {      

  DruidDataSource dataSource = new DruidDataSource();       

  dataSource.setDriverClassName(driverClass);       

  dataSource.setUrl(url);       

  dataSource.setUsername(user);       

  dataSource.setPassword(password);       

  return dataSource;   

  }  

  @Bean (name = "test2TransactionManager" )  

  public DataSourceTransactionManager test2TransactionManager() {      

  return new DataSourceTransactionManager(test2DataSource());   

  }   

  @Bean (name = "test2SqlSessionFactory" )  

  public SqlSessionFactory test2SqlSessionFactory( @Qualifier ( "test2DataSource" ) DataSource test2DataSource)          

  throws Exception {      

  final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();       

  sessionFactory.setDataSource(test2DataSource);       

  sessionFactory.setMapperLocations( new PathMatchingResourcePatternResolver()               

  .getResources(Test2DataSourceConfig.MAPPER_LOCATION));

  return sessionFactory.getObject();    }

}