springboot配置多数据源,不同的数据库

mybatis根据不同的数据源调用不同的dao和mapper文件,在这里需要把你想要被扫描的dao建在一个新的文件夹。

@MapperScan(basePackages = "com.sthg.dao.pg", sqlSessionTemplateRef = "pgSqlSessionTemplate")

sqlSessionTemplateRef 指定使用哪个SqlSessionTemplate,SqlSessionTemplate是创建SqlSession的会话,SqlSessionTemplate是SqlSession的一个实现类，SqlSessionFactory是一个SqlSession的创建工厂,
SqlSessionFactory里又是注入DataSource(数据库连接配置),这里就实现了,当调用哪个dao使用哪个接口的逻辑。

package com.sthg.common.config;

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.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.jdbc.datasource.DataSourceTransactionManager;

import javax.sql.DataSource;

@Configuration
@MapperScan(basePackages = "com.sthg.dao.trino",sqlSessionTemplateRef = "appstoreSqlSessionTemplate")
public class AppstoreDataSourceConfig {

	@Bean(name="appstoreDataSource")
	@ConfigurationProperties(prefix = "spring.datasource.trino")
	public DataSource appstoreDataSource() {
		return DataSourceBuilder.create().build();
	}

	@Bean(name="appstoreSqlSessionFactory")
	public SqlSessionFactory appstoreSqlSessionFactory(@Qualifier("appstoreDataSource") DataSource dataSource) throws Exception {
		SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
		sqlSessionFactoryBean.setDataSource(dataSource);
		sqlSessionFactoryBean.setTypeAliasesPackage("com.sthg.entity");
//		sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/appstore
@Configuration
@MapperScan(basePackages = "com.sthg.dao.clickhouse",sqlSessionTemplateRef = "iamSqlSessionTemplate")
public class IamDataSourceConfig {

	
	@Bean(name="iamDataSource")    //作用在方法上，注入；一般和@Qualifier配合使用
	@ConfigurationProperties(prefix = "spring.datasource.ck")   //指定加载哪个数据库配置
	@Primary   //是指默认值，多个数据源只能存在一个默认值，及仅能一个数据源使用该注解
	public DataSource iamDataSource() {
		return DataSourceBuilder.create().build();
	}

	
	@Bean(name="iamSqlSessionFactory")
	@Primary
	public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource) throws Exception {
		SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
		sqlSessionFactoryBean.setDataSource(dataSource);
		sqlSessionFactoryBean.setTypeAliasesPackage("com.sthg.entity");   //设置mybatis别名
//		sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam
	@Bean(name="iamTransactionManager")
	@Primary
	public DataSourceTransactionManager testTransactionManager(@Qualifier("iamDataSource") DataSource dataSource) {
		return new DataSourceTransactionManager(dataSource);
	}

	
	@Bean(name="iamSqlSessionTemplate")
	@Primary
	public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("iamSqlSessionFactory") SqlSessionFactory sqlSessionFactory){
		return new SqlSessionTemplate(sqlSessionFactory);
	}
}

到此多数据源配置完成.