SpringBoot添加多数据源mysql和oracle

阅读原文时间：2023年07月09日阅读：1

项目结构

多数据源配置文件

MultiDataSourceConfig.java

SqlSessionTemplate1.java

SqlSessionTemplate2.java

package com.holytax.accenture_fp_in.datasource;

import javax.sql.DataSource;

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;

/**
* 配置多数据源
*
*
*
*/
@Configuration
public class MultiDataSourceConfig {

@Bean(name = "primaryDataSource")  
@Qualifier("primaryDataSource")  
@Primary // 定义主数据源  
@ConfigurationProperties(prefix = "spring.datasource")  
public DataSource primaryDataSource() {  
    return DataSourceBuilder.create().build();  
}

@Bean(name = "secondaryDataSource")  
@Qualifier("secondaryDataSource")  
@ConfigurationProperties(prefix = "custom.datasource.ds1")  
public DataSource secondaryDataSource() {  
    return DataSourceBuilder.create().build();  
}

}

package com.holytax.accenture_fp_in.datasource;

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.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 org.springframework.transaction.PlatformTransactionManager;

/**
* spring 整合 mybatis 配置SqlSessionTemplate
*
*
*/
@Configuration
@MapperScan(basePackages = "com.holytax.accenture_fp_in.mapper", sqlSessionTemplateRef = "primarySqlSessionTemplate")
public class SqlSessionTemplate1 {

@Bean(name = "primarySqlSessionFactory")  
@Primary  
public SqlSessionFactory primarySqlSessionFactory(@Qualifier("primaryDataSource") DataSource dataSource)  
        throws Exception {  
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();  
    bean.setDataSource(dataSource);  
    bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/\*.xml"));  
    return bean.getObject();  
}

//配置声明式事务管理器  
@Bean(name = "primaryTransactionManager")  
@Primary  
public PlatformTransactionManager primaryTransactionManager(@Qualifier("primaryDataSource") DataSource dataSource) {  
    return new DataSourceTransactionManager(dataSource);  
}

@Bean(name = "primarySqlSessionTemplate")  
@Primary  
public SqlSessionTemplate primarySqlSessionTemplate(  
        @Qualifier("primarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {  
    return new SqlSessionTemplate(sqlSessionFactory);  
}

}

package com.holytax.accenture_fp_in.datasource;

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.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;

@Configuration
@MapperScan(basePackages = "com.holytax.accenture_fp_in.oracleMapper", sqlSessionTemplateRef = "secondarySqlSessionTemplate")
public class SqlSessionTemplate2 {

@Bean(name = "secondarySqlSessionFactory")  
public SqlSessionFactory secondarySqlSessionFactory(@Qualifier("secondaryDataSource") DataSource dataSource)  
        throws Exception {  
    SqlSessionFactoryBean bean = new SqlSessionFactoryBean();  
    bean.setDataSource(dataSource);  
    bean.setMapperLocations(  
            new PathMatchingResourcePatternResolver().getResources("classpath:oracleMapper/\*.xml"));  
    return bean.getObject();  
}

@Bean(name = "secondaryTransactionManager")  
public PlatformTransactionManager secondaryTransactionManager(  
        @Qualifier("secondaryDataSource") DataSource dataSource) {  
    return new DataSourceTransactionManager(dataSource);  
}

@Bean(name = "secondarySqlSessionTemplate")  
public SqlSessionTemplate secondarySqlSessionTemplate(  
        @Qualifier("secondarySqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {  
    return new SqlSessionTemplate(sqlSessionFactory);  
}

}

这里是对多数据源，扫描做了处理。mapper 对应Mysql的部分处理 SqlSessionTemplate1.java。oracleMapper 对应oracle的部分处理 SqlSessionTemplate2.java.

就是业务层的Mapper文件，不同数据源扫描不同的包。

2、数据库application.properties配置文件

#Server
server.port=8081
#MYBATIS
mybatis.configLocation:classpath:mybatis-config.xml
#mybatis.mapper-locations=classpath:mapper/*.xml //注意在单数据时，这配置文件，和springboot启动文件上配置了，扫描路劲，我们要把他干掉。因为我们上边的，
#测试 // SqlSessionTemplate1.java,SqlSessionTemplate2.java.文件已经对这些内容作了处理。
spring.datasource.url=jdbc:mysql://localhost:3306/accenture?useSSL=true
spring.datasource.username=user
spring.datasource.password=pass
spring.datasource.driver-class-name=com.mysql.jdbc.Driver

更多数据源

custom.datasource.ds1.driver-class-name=oracle.jdbc.driver.OracleDriver
custom.datasource.ds1.url=jdbc:oracle:thin:@localhost:1521:testdb
custom.datasource.ds1.username=user
custom.datasource.ds1.password=pass

spring.datasource.initialSize=5
spring.datasource.minIdle=5
spring.datasource.maxActive=20
spring.datasource.maxWait=60000
spring.datasource.timeBetweenEvictionRunsMillis=60000
spring.datasource.validationQuery=SELECT 1
spring.datasource.testWhileIdle=true
spring.datasource.testOnBorrow=false
spring.datasource.testOnReturn=false
spring.datasource.poolPreparedStatements=true
spring.datasource.maxPoolPreparedStatementPerConnectionSize=20
spring.datasource.filters=stat
spring.datasource.connectionProperties=druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000
#url params
spring.holytax.interface-url=http://localohst:8080/hltypt/api/callservice.do
spring.holytax.interface-company=accenture