springcloud中配置多資料源

1、mybatis多資料源的使用場景：
操作同一台伺服器上不同的資料庫，或者多地機器上的相同或不相同資料庫。
進行跨庫操作、多資料源進行分離資料；
使得程式得以擴充，當一台或者部分伺服器當機，不影響整個應用的服務；
2、多資料源配置的思路：
資料隔離，把資料分别存放在test、test02這兩個資料庫中；
建立資料源Datasource指定使用的哪個資料源配置，并将其注入到SqlSessionFactory 會話工廠；
建立事務TransactionManager，需把資料源注入；
把SqlSessionFactory 注入，建立sqlSessionTemplate模闆，使用模闆操作mapper接口；
把模闆放到mapper 路徑下，并 @MapperScan注解 聲明mapper接口位置；

1，在application.yml中配置兩個資料源的資訊

#配置多資料源
spring.datasource.iam.jdbc-url: jdbc:mysql://localhost:3306/iam
spring.datasource.iam.username: root
spring.datasource.iam.password: root
spring.datasource.iam.driver-class-name: com.mysql.cj.jdbc.Driver

spring.datasource.appstore.jdbc-url: jdbc:mysql://localhost:3306/appstore
spring.datasource.appstore.username: root
spring.datasource.appstore.password: root
spring.datasource.appstore.driver-class-name: com.mysql.cj.jdbc.Driver

2，建立并配置兩個資料源的datasourceConfig

2.1 iamDataSourceConfig配置

/**
 * 建立iam庫的資料源
 */
@Configuration
@MapperScan(basePackages = "com.primeton.tags.mapper.iam",sqlSessionTemplateRef = "iamSqlSessionTemplate")
public class IamDataSourceConfig {

    /**
     * 加載配置資料源
     * @return
     * @Primary 是指具有預設值
     */
    @Bean(name="iamDataSource")    //作用在方法上，注入；一般和@Qualifier配合使用
    @ConfigurationProperties(prefix = "spring.datasource.iam")   //指定加載哪個資料庫配置
    @Primary   //是指預設值，多個資料源隻能存在一個預設值，及僅能一個資料源使用該注解
    public DataSource iamDataSource() {
        return DataSourceBuilder.create().build();
    }

    /**
     * 建立會話工廠SqlSessionFactory
     * @param dataSource
     * @return
     * @throws Exception
     */
    @Bean(name="iamSqlSessionFactory")
    @Primary
    public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity");   //設定mybatis别名
        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam/*.xml"));
        return sqlSessionFactoryBean.getObject();
    }

    /**
     * 建立事務 TransactionManager
     * @param dataSource
     * @return
     */
    @Bean(name="iamTransactionManager")
    @Primary
    public DataSourceTransactionManager testTransactionManager(@Qualifier("iamDataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    /**
     * 建立SqlSessionTemplate模版
     * @param sqlSessionFactory
     * @return
     */
    @Bean(name="iamSqlSessionTemplate")
    @Primary
    public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("iamSqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

2.2 AppstoreDataSourceConfig配置

@Configuration
@MapperScan(basePackages = "com.primeton.tags.mapper.appstore",sqlSessionTemplateRef = "appstoreSqlSessionTemplate")
public class AppstoreDataSourceConfig {

    @Bean(name="appstoreDataSource")
    @ConfigurationProperties(prefix = "spring.datasource.appstore")
    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.primeton.tags.entity");
        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/appstore/*.xml"));
        return sqlSessionFactoryBean.getObject();
    }

    @Bean(name="appstoreTransactionManager")
    public DataSourceTransactionManager testTransactionManager(@Qualifier("appstoreDataSource") DataSource dataSource) {
        return new DataSourceTransactionManager(dataSource);
    }

    @Bean(name="appstoreSqlSessionTemplate")
    public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("appstoreSqlSessionFactory") SqlSessionFactory sqlSessionFactory){
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

3，編寫mapper接口和對應的xml(跟單庫時一樣)；

@Mapper
public interface TagMapper {
    List<Tag> selectAllTag();
}

<mapper namespace="com.primeton.tags.mapper.iam.TagMapper">
    <select id="selectAllTag" resultType="tag">
        select
            *
        from tag_tb t
    </select>
</mapper>

4，單元測試

@SpringBootTest
public class MultiDataSourceTest {
    @Autowired
    private TagMapper tagMapper;
    @Autowired
    private Tag2Mapper tag2Mapper;

    @Test
    public void testSelectAll() {
        List<Tag> tagList = tagMapper.selectAllTag();
        List<Tag> tag2List = tag2Mapper.selectAllTag();
        System.out.println("tagList:"+tagList);
        System.out.println("tag2List:"+tag2List);
    }
}

開發中遇到的問題：

1，使用多資料源後别名失效；

解決辦法：在多資料源的配置中設定别名：

sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity");   //設定mybatis别名

2，使用多資料源後mybatis日志失效：

解決辦法：

1，在yml中添加mybatis日志配置

mybatis:
  configuration:
    log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

2，在某一個自定義的多資料源配置中進行配置；

注意：不能在每個多資料源配置中都添加，否則會報錯。

@Bean(name="iamSqlSessionFactory")
    @Primary
    public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource, MybatisProperties mybatisProperties) throws Exception {
        SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity");   //設定mybatis别名
        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam/*.xml"));
      sqlSessionFactoryBean.setConfiguration(mybatisProperties.getConfiguration());
        return sqlSessionFactoryBean.getObject();
    }

3，在配置了多資料源後，mybatis-plus分頁功能失效

解決辦法：內建多資料源的時候需要手動配置分頁插件

3.1 mybatis-plus分頁配置

@Configuration
public class MybatisPlusConfig {
    @Bean
    public PaginationInterceptor paginationInterceptor() {
        return new PaginationInterceptor();
    }
}

3.2 在多資料源配置中進行配置

@Bean(name="iamSqlSessionFactory")
    @Primary
    public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource, MybatisProperties mybatisProperties) throws Exception {

            SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
        sqlSessionFactoryBean.setDataSource(dataSource);
        sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity");   //設定mybatis别名
        sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam/*.xml"));
        sqlSessionFactoryBean.setConfiguration(mybatisProperties.getConfiguration());  //配置多資料源後列印日志
        MybatisConfiguration config = new MybatisConfiguration();
        config.addInterceptor(new PaginationInterceptor());
        sqlSessionFactoryBean.setConfiguration(config);   //解決配置多資料源後mybatis-plus分頁失效問題
        return sqlSessionFactoryBean.getObject();
    }

#配置多資料源spring.datasource.iam.jdbc-url: jdbc:mysql://localhost:3306/iamspring.datasource.iam.username: rootspring.datasource.iam.password: rootspring.datasource.iam.driver-class-name: com.mysql.cj.jdbc.Driver

spring.datasource.appstore.jdbc-url: jdbc:mysql://localhost:3306/appstorespring.datasource.appstore.username: rootspring.datasource.appstore.password: rootspring.datasource.appstore.driver-class-name: com.mysql.cj.jdbc.Driver123456789102，建立并配置兩個資料源的datasourceConfig2.1 iamDataSourceConfig配置

/** * 建立iam庫的資料源 */@Configuration@MapperScan(basePackages = "com.primeton.tags.mapper.iam",sqlSessionTemplateRef = "iamSqlSessionTemplate")public class IamDataSourceConfig {

/** * 加載配置資料源 * @return * @Primary 是指具有預設值 */ @Bean(name="iamDataSource") //作用在方法上，注入；一般和@Qualifier配合使用 @ConfigurationProperties(prefix = "spring.datasource.iam") //指定加載哪個資料庫配置 @Primary //是指預設值，多個資料源隻能存在一個預設值，及僅能一個資料源使用該注解 public DataSource iamDataSource() { return DataSourceBuilder.create().build(); }

/** * 建立會話工廠SqlSessionFactory * @param dataSource * @return * @throws Exception */ @Bean(name="iamSqlSessionFactory") @Primary public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource) throws Exception { SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); sqlSessionFactoryBean.setDataSource(dataSource); sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity"); //設定mybatis别名 sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam/*.xml")); return sqlSessionFactoryBean.getObject(); }

/** * 建立事務 TransactionManager * @param dataSource * @return */ @Bean(name="iamTransactionManager") @Primary public DataSourceTransactionManager testTransactionManager(@Qualifier("iamDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); }

/** * 建立SqlSessionTemplate模版 * @param sqlSessionFactory * @return */ @Bean(name="iamSqlSessionTemplate") @Primary public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("iamSqlSessionFactory") SqlSessionFactory sqlSessionFactory){ return new SqlSessionTemplate(sqlSessionFactory); }}

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657582.2 AppstoreDataSourceConfig配置

@Configuration@MapperScan(basePackages = "com.primeton.tags.mapper.appstore",sqlSessionTemplateRef = "appstoreSqlSessionTemplate")public class AppstoreDataSourceConfig {

@Bean(name="appstoreDataSource") @ConfigurationProperties(prefix = "spring.datasource.appstore") 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.primeton.tags.entity"); sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/appstore/*.xml")); return sqlSessionFactoryBean.getObject(); }

@Bean(name="appstoreTransactionManager") public DataSourceTransactionManager testTransactionManager(@Qualifier("appstoreDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); }

@Bean(name="appstoreSqlSessionTemplate") public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("appstoreSqlSessionFactory") SqlSessionFactory sqlSessionFactory){ return new SqlSessionTemplate(sqlSessionFactory); }}12345678910111213141516171819202122232425262728293，編寫mapper接口和對應的xml(跟單庫時一樣)；

@Mapperpublic interface TagMapper { List<Tag> selectAllTag();}1234<mapper namespace="com.primeton.tags.mapper.iam.TagMapper"> <select id="selectAllTag" resultType="tag"> select * from tag_tb t </select></mapper>12345674，單元測試

@SpringBootTestpublic class MultiDataSourceTest { @Autowired private TagMapper tagMapper; @Autowired private Tag2Mapper tag2Mapper;

@Test public void testSelectAll() { List<Tag> tagList = tagMapper.selectAllTag(); List<Tag> tag2List = tag2Mapper.selectAllTag(); System.out.println("tagList:"+tagList); System.out.println("tag2List:"+tag2List); }}123456789101112131415開發中遇到的問題：

1，使用多資料源後别名失效；部落格：

sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity"); //設定mybatis别名12，使用多資料源後mybatis日志失效：解決辦法：1，在yml中添加mybatis日志配置

mybatis: configuration: log-impl: org.apache.ibatis.logging.stdout.StdOutImpl1232，在某一個自定義的多資料源配置中進行配置；注意：不能在每個多資料源配置中都添加，否則會報錯。

@Bean(name="iamSqlSessionFactory") @Primary public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource, MybatisProperties mybatisProperties) throws Exception { SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); sqlSessionFactoryBean.setDataSource(dataSource); sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity"); //設定mybatis别名 sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam/*.xml")); sqlSessionFactoryBean.setConfiguration(mybatisProperties.getConfiguration()); return sqlSessionFactoryBean.getObject(); }123456789103，在配置了多資料源後，mybatis-plus分頁功能失效

解決辦法：內建多資料源的時候需要手動配置分頁插件3.1 mybatis-plus分頁配置

@Configurationpublic class MybatisPlusConfig { @Bean public PaginationInterceptor paginationInterceptor() { return new PaginationInterceptor(); }}12345673.2 在多資料源配置中進行配置

@Bean(name="iamSqlSessionFactory") @Primary public SqlSessionFactory iamSqlSessionFactory(@Qualifier("iamDataSource") DataSource dataSource, MybatisProperties mybatisProperties) throws Exception {

SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean(); sqlSessionFactoryBean.setDataSource(dataSource); sqlSessionFactoryBean.setTypeAliasesPackage("com.primeton.tags.entity"); //設定mybatis别名 sqlSessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/iam/*.xml")); sqlSessionFactoryBean.setConfiguration(mybatisProperties.getConfiguration()); //配置多資料源後列印日志 MybatisConfiguration config = new MybatisConfiguration(); config.addInterceptor(new PaginationInterceptor()); sqlSessionFactoryBean.setConfiguration(config); //解決配置多資料源後mybatis-plus分頁失效問題 return sqlSessionFactoryBean.getObject(); }

springcloud中配置多資料源

1，使用多資料源後别名失效；

2，使用多資料源後mybatis日志失效：

繼續閱讀

SSM架構（二）------------表現層的SpringMVC

Intellij idea基于Maven 的SSM 架構整合

Oracle的基本操作

為什麼要選擇UniDAC

SIP Presence SUBSCRIBE-NOTIFY

SQL優化SQL語句優化的目的

Spring資料和Redis

JAVA高效程式設計指南

SpringMVC的啟動過程源碼分析1 SpringMVC 配置XML的方式啟動2 SpringMVC純注解模式啟動

Java Spring 架構

QName是什麼

關于SQL語言

SQL語言基礎：常用的資料查詢語句

SpringCloud微服務（四）之ribbon筆記ribbon是什麼？入門案例自定義均衡負載算法

neo4j之cypher使用文檔

sqlServer根據經緯查距離