在开发微服务的过程中，有时我们的服务需要连接两个以上的数据库进行业务数据的CRUD操作，这时候就需要我们进行多数据源的配置。

pom.xml

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

4.0.0

com.tl

hello-spring-boot-dependencies

1.0.0

../hello-spring-boot-dependencies/pom.xml

hello-spring-boot-mybatis-hikari

jar

org.springframework.boot

spring-boot-starter-web

org.springframework.boot

spring-boot-starter-test

org.springframework.boot

spring-boot-devtools

org.springframework.boot

spring-boot-starter-data-jpa

mysql

mysql-connector-java

org.mybatis.spring.boot

mybatis-spring-boot-starter

org.projectlombok

lombok

io.springfox

springfox-swagger2

io.springfox

springfox-swagger-ui

org.apache.commons

commons-lang3

主要配置文件

datasource.properties

hikari.primary.jdbc-url=jdbc:mysql://localhost:3306/source_data

hikari.primary.username=root

hikari.primary.password=root

hikari.primary.driver-class-name=com.mysql.cj.jdbc.Driver

hikari.second.jdbc-url=jdbc:mysql://localhost:3306/target_data

hikari.second.username=root

hikari.second.password= root

hikari.second.driver-class-name=com.mysql.cj.jdbc.Driver

数据库连接池配置

PrimaryDataSource.java

package com.tl.hello.spring.boot.mybatis.hikari.config;

import com.zaxxer.hikari.HikariDataSource;

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.context.annotation.PropertySource;

import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

/**

* @author tianl

* @date 2020/3/27 22:11

*/

@Configuration

@MapperScan(basePackages = {"com.tl.hello.spring.boot.mybatis.druid.dao.primary"}, sqlSessionFactoryRef = "primarySqlSessionFactory")

@PropertySource("classpath:config/datasource.properties")

public class PrimaryDataSourceConfig {

@Value("${hikari.primary.jdbc-url}")

private String jdbcUrl;

@Value("${hikari.primary.username}")

private String username;

@Value("${hikari.primary.password}")

private String password;

@Value("${hikari.primary.driver-class-name}")

private String driverClassName;

@Bean(name = {"primaryDataSource"})

@Primary

public HikariDataSource dataSource() {

HikariDataSource hikariDataSource = new HikariDataSource();

hikariDataSource.setJdbcUrl(jdbcUrl);

hikariDataSource.setUsername(username);

hikariDataSource.setPassword(password);

hikariDataSource.setDriverClassName(driverClassName);

return hikariDataSource;

}

@Bean(name = "primaryTransactionManager")

@Primary

public DataSourceTransactionManager transactionManager() {

return new DataSourceTransactionManager(this.dataSource());

}

@Bean(name = "primarySqlSessionFactory")

@Primary

public SqlSessionFactory sqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource) throws Exception {

final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();

sessionFactory.setDataSource(dataSource);

sessionFactory.setMapperLocations(

new PathMatchingResourcePatternResolver().getResources("classpath:mapper/sourcedata/*Mapper.xml"));

return sessionFactory.getObject();

}

}

SecondDataSource.java

package com.tl.hello.spring.boot.mybatis.hikari.config;

import com.zaxxer.hikari.HikariDataSource;

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.PropertySource;

import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

/**

* @author tianl

* @date 2020/3/27 22:53

*/

@Configuration

@MapperScan(basePackages = {"com.tl.hello.spring.boot.mybatis.druid.dao.second"},sqlSessionFactoryRef = "secondSqlSessionFactory")

@PropertySource("classpath:config/datasource.properties")

public class SecondDataSourceConfig {

@Value("${hikari.second.jdbc-url}")

private String jdbcUrl;

@Value("${hikari.second.username}")

private String username;

@Value("${hikari.second.password}")

private String password;

@Value("${hikari.second.driver-class-name}")

private String driverClassName;

@Bean(name = "secondDataSource")

public HikariDataSource dataSource(){

HikariDataSource hikariDataSource = new HikariDataSource();

hikariDataSource.setJdbcUrl(jdbcUrl);

hikariDataSource.setUsername(username);

hikariDataSource.setPassword(password);

hikariDataSource.setDriverClassName(driverClassName);

return hikariDataSource;

}

@Bean(name = "secondTransactionManager")

public DataSourceTransactionManager transactionManager() {

return new DataSourceTransactionManager(this.dataSource());

}

@Bean(name = "secondSqlSessionFactory")

public SqlSessionFactory sqlSessionFactory(@Qualifier("secondDataSource") DataSource dataSource) throws Exception {

final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();

sessionFactory.setDataSource(dataSource);

sessionFactory.setMapperLocations(

new PathMatchingResourcePatternResolver().getResources("classpath:mapper/targetdata/*Mapper.xml"));

return sessionFactory.getObject();

}

}

测试：启动一个定时任务同步连个数据中数据

package com.tl.hello.spring.boot.mybatis.hikari.service;

import com.tl.hello.spring.boot.mybatis.hikari.model.primary.PrimaryUser;

import com.tl.hello.spring.boot.mybatis.hikari.model.second.SecondUser;

import com.tl.hello.spring.boot.mybatis.hikari.service.primary.PrimaryUserService;

import com.tl.hello.spring.boot.mybatis.hikari.service.second.SecondUserService;

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Service;

import javax.annotation.Resource;

/**

* @author tianl

* @date 2020/3/28 0:51

*/

@Service

public class SyncDataService {

@Resource

private PrimaryUserService primaryUserService;

@Resource

private SecondUserService secondUserService;

@Scheduled(cron = "0/5 * * * * ?")

public void sync(){

PrimaryUser primaryUser = primaryUserService.selectByPrimaryKey(19L);

SecondUser secondUser=new SecondUser();

secondUser.setAge(primaryUser.getAge());

secondUser.setName(primaryUser.getName());

secondUser.setUsername(primaryUser.getUsername());

secondUser.setPassword(primaryUser.getPassword());

secondUserService.insertOrUpdate(secondUser);

}

}

代码完成地址：[码云]