springboot2.0配置多数据源

Bertha 。 2022-05-19 00:51 127阅读 0赞

package com.juebin.comm;

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

@Configuration // 该注解类似于spring配置文件  
@MapperScan(basePackages = "com.juebin.dao",sqlSessionFactoryRef="test1SqlSessionFactory")  
public class DataSourceConfig \{

/\*\*  
     \* 创建数据源(数据源的名称：方法名可以取为XXXDataSource(),XXX为数据库名称,该名称也就是数据源的名称)  
     \*/  
    @Bean(name="test1DataSource")  
    @ConfigurationProperties(prefix="spring.datasource.test1")  
    public DataSource testDataSource()\{  
        return DataSourceBuilder.create().build();  
    \}

/\*\*  
     \* @Primary 该注解表示在同一个接口有多个实现类可以注入的时候，默认选择哪一个，而不是让@autowire注解报错  
     \* @Qualifier 根据名称进行注入，通常是在具有相同的多个类型的实例的一个注入（例如有多个DataSource类型的实例）  
     \*/  
    @Bean(name="test1SqlSessionFactory")  
    public SqlSessionFactory test1SqlSessionFactory(@Qualifier("test1DataSource") DataSource myTestDbDataSource) throws Exception\{  
        SqlSessionFactoryBean fb = new SqlSessionFactoryBean();  
        fb.setDataSource(myTestDbDataSource);// 指定数据源(这个必须有，否则报错)  
        return fb.getObject();  
    \}

/\*\*  
     \* 配置事务管理器  
     \*/  
    @Bean(name="test1TransactionManager")  
    public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) throws Exception\{  
        return new DataSourceTransactionManager(dataSource);  
    \}

@Bean(name="test1SqlSessionTemplate")  
    public SqlSessionTemplate testqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception \{  
        return new SqlSessionTemplate(sqlSessionFactory);  
    \}