springboot配置多数据源

·1.配置文件中多数据源配置

#多数据源配置，配置两个数据源
# 注意事项，较早的springboot版本用url，新的话用jdbc-url，否则会报错
#spring.datasource.db1.url=jdbc:mysql://localhost:3306/guoguo?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
spring.datasource.db1.jdbc-url=jdbc:mysql://localhost:3306/guoguo?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
spring.datasource.db1.username=root
spring.datasource.db1.password=root
spring.datasource.db1.driver-class-name=com.mysql.cj.jdbc.Driver

spring.datasource.db2.jdbc-url=jdbc:mysql://localhost:3306/mysql_study?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
#spring.datasource.db2.url=jdbc:mysql://localhost:3306/mysql_study?autoReconnect=true&useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
spring.datasource.db2.username=root
spring.datasource.db2.password=root
spring.datasource.db2.driver-class-name=com.mysql.cj.jdbc.Driver

2.配置数据源

数据源1配置

package com.guoguo.config;

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionTemplate;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import javax.sql.DataSource;


@Configuration
@MapperScan(basePackages = "com.guoguo.mapper.db1", sqlSessionFactoryRef = "db1SqlSessionFactory")
public class MyDataSourceConfig1 {

	@Bean("db1DataSource")
	@ConfigurationProperties(prefix = "spring.datasource.db1") //读取application.yml中的配置参数映射成为一个对象
	public DataSource getDb1DataSource() {
		return DataSourceBuilder.create().build();
	}

	@Bean("db1SqlSessionFactory")
	public SqlSessionFactory db1SqlSessionFactory(@Qualifier("db1DataSource") DataSource dataSource) throws Exception {
	//如果你没有使用mybatisplus，用的原生的sql查询，那么这里就用注释掉的代码就可以
//		注释掉的是原生的数据源，但是如果代码中用的是mybatisplus，就会报错
//		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
//		bean.setDataSource(dataSource);
//		// mapper的xml形式文件位置必须要配置，不然将报错：no statement （这种错误也可能是mapper的xml中，namespace与项目的路径不一致导致）
//		bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/db1
@Configuration
@MapperScan(basePackages = "com.guoguo.mapper.db2", sqlSessionFactoryRef = "db2SqlSessionFactory")
public class MyDataSourceConfig2 {

	@Bean("db2DataSource")
	@ConfigurationProperties(prefix = "spring.datasource.db2") //读取application.yml中的配置参数映射成为一个对象
	public DataSource getDb2DataSource() {
		return DataSourceBuilder.create().build();
	}

	@Bean("db2SqlSessionFactory")
	public SqlSessionFactory db2SqlSessionFactory(@Qualifier("db2DataSource") DataSource dataSource) throws Exception {
		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
		bean.setDataSource(dataSource);
		// mapper的xml形式文件位置必须要配置，不然将报错：no statement （这种错误也可能是mapper的xml中，namespace与项目的路径不一致导致）
		bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/db2/*.xml"));
		return bean.getObject();
	}

	@Bean("db2SqlSessionTemplate")
	public SqlSessionTemplate db2SqlSessionTemplate(@Qualifier("db2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
		return new SqlSessionTemplate(sqlSessionFactory);
	}
}