• mybatis-plus多数据源配置

    这里结合了springboot的多数据源配置，主要是手动创建数据源，再手动设置配置一些配置参数。

    其中DateSource和transactionManager是关于数据源和事务的配置。SqlSessionTemplate和sqlSessionFactory是mybatis-plus框架的配置，通过@MapperScan注解的属性关联。

    多数据源事务参考多数据源事务（非分布式）_SomeOtherTime的博客-CSDN博客_多数据源事务

    参考源码分析 - MyBatis Plus 多数据源踩坑 - 知乎

    mybatis多数据源的驼峰命名法_mybatis 多个数据源名称驼峰-CSDN博客

    yml： 

    1. ## 部署环境
    2. server:
    3.   port: 8210
    4.  
    5. spring:
    6.   datasource:
    7.     #不同数据配置名会变，以下是HikariDataSource
    8.     one:
    9.       driver-class-name: org.postgresql.Driver
    10.       jdbc-url: jdbc:postgresql://192.168.2.89:5435/la_water_river
    11.       username: postgres
    12.       password: 
    13.       minimum-idle: 10
    14.       maximum-pool-size: 5
    15.     two:
    16.       driver-class-name: com.kingbase8.Driver
    17.       jdbc-url: jdbc:kingbase8://172.16.1.28:54321/la_water_monitor?currentSchema=PUBLIC
    18.       username: kingbases
    19.       password: 
    20.       minimum-idle: 5
    21.       maximum-pool-size: 20
    22.   # redis 配置
    23.   redis:
    24.     host: 192.168.2.76
    25.     port: 6379
    26.     password: 
    27.     database: 10
    28.     timeout: 10s
    29.   cache:
    30.     type: redis
    31.     redis:
    32.       time-to-live: 20000 #缓存超时时间ms
    33.       cache-null-values: false #是否缓存空值
    34.  
    35. management:
    36.   endpoints:
    37.     web:
    38.       base-path: /actuator
    39.       exposure:
    40.         include: "*"
    41.   endpoint:
    42.     health:
    43.       show-details: always
    44.   security:
    45.     enabled: false
    46.  
    47. swagger:
    48.   enable: true
    49.  
    50. logging:
    51.   config: classpath:logback-spring-dev.xml
    52.  
    53. mybatis-plus:
    54.   type-handlers-package: com.zjzy.mapper.typehandler
    55.   configuration:
    56.     map-underscore-to-camel-case: true
    57.     auto-mapping-behavior: full
    58.     log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
    59.   mapper-locations: classpath*:mapper/**/*Mapper.xml #多数据源下该配置失效，配置在代码中

    数据源1:

    1. package com.wisdomcity.laian.river.config.datasource;
    2.  
    3. import com.baomidou.mybatisplus.core.config.GlobalConfig;
    4. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
    5. import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
    6. import com.wisdomcity.laian.river.config.MybatisPlusConfig;
    7. import com.wisdomcity.laian.river.config.UpdateMetaObjectHandler;
    8. import org.apache.ibatis.session.SqlSessionFactory;
    9. import org.apache.ibatis.type.TypeHandler;
    10. import org.mybatis.spring.SqlSessionTemplate;
    11. import org.mybatis.spring.annotation.MapperScan;
    12. import org.springframework.beans.factory.annotation.Autowired;
    13. import org.springframework.beans.factory.annotation.Qualifier;
    14. import org.springframework.boot.context.properties.ConfigurationProperties;
    15. import org.springframework.boot.jdbc.DataSourceBuilder;
    16. import org.springframework.context.annotation.Bean;
    17. import org.springframework.context.annotation.Configuration;
    18. import org.springframework.context.annotation.Primary;
    19. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    20. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    21.  
    22. import javax.sql.DataSource;
    23.  
    24. @Configuration
    25. @MapperScan(basePackages = "com.wisdomcity.laian.river.mapper.water",sqlSessionFactoryRef = "sqlSessionFactoryOne",sqlSessionTemplateRef = "sqlSessionTemplateOne")
    26. public class DatasourceConfigOne {
    27. //
    28. //    @Autowired
    29. //    @Qualifier("globalConfig")
    30. //    private GlobalConfig globalConfig;
    31.  
    32.     @Autowired
    33.     MybatisPlusInterceptor mybatisPlusInterceptor;
    34.  
    35.     @Bean(name = "dataSourceOne")
    36.     @ConfigurationProperties(prefix = "spring.datasource.one")
    37.     @Primary
    38.     public DataSource dataSource() {
    39.         return DataSourceBuilder.create().build();
    40.     }
    41.  
    42.     @Primary
    43.     @Bean(name = "sqlSessionFactoryOne")
    44.     public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSourceOne") DataSource dataSource) throws Exception {
    45.         //SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    46.         MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
    47.         bean.setDataSource(dataSource);
    48.         bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/water/*.xml"));
    49. //        bean.setGlobalConfig(globalConfig);
    50.         bean.setGlobalConfig(globalConfig());
    51.         bean.setPlugins(mybatisPlusInterceptor);
    52.  
    53.         //https://blog.csdn.net/weixin_41785851/article/details/119739897
    54.         MybatisConfiguration configuration = new MybatisConfiguration();
    55.         configuration.setMapUnderscoreToCamelCase(true);
    56.         // 配置打印sql语句
    57.         configuration.setLogImpl(StdOutImpl.class);
    58.         bean.setConfiguration(configuration);
    59.         return bean.getObject();
    60.     }
    61.  
    62.     @Primary
    63.     @Bean(name = "transactionManagerOne")
    64.     public DataSourceTransactionManager transactionManager(@Qualifier("dataSourceOne") DataSource dataSource) {
    65.         return new DataSourceTransactionManager(dataSource);
    66.     }
    67.  
    68.     @Primary
    69.     @Bean(name = "sqlSessionTemplateOne")
    70.     public SqlSessionTemplate sqlSessionTemplate(@Qualifier("sqlSessionFactoryOne") SqlSessionFactory sqlSessionFactory) {
    71.         return new SqlSessionTemplate(sqlSessionFactory);
    72.     }
    73.  
    74. //    /** 全局自定义配置 */
    75. //    @Bean(name = "globalConfigMP")
    76. //    @ConfigurationProperties(prefix = "mybatis-plus")
    77. //    public GlobalConfig globalConfig(){
    78. //        return new GlobalConfig();
    79. //    }
    80.  
    81.     /**
    82.      * 自动插入创建和更新时间
    83.      * 多数据源下要创建多个，或者不创建，不然saveBatch等批量操作方法会报错，因为save方法是获取baseMapper，而批量操作的saveBatch方法是从全局配置 GlobalConfig 里获取的。
    84.      */
    85.     @Bean("waterGlobalConfig")
    86.     public GlobalConfig globalConfig() {
    87.         GlobalConfig globalConfig = new GlobalConfig();
    88.         globalConfig.setMetaObjectHandler(new UpdateMetaObjectHandler());
    89.         return globalConfig;
    90.     }
    91. }

    数据源2：

    1. package com.wisdomcity.laian.river.config.datasource;
    2.  
    3. import com.baomidou.mybatisplus.core.config.GlobalConfig;
    4. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
    5. import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
    6. import com.wisdomcity.laian.river.config.UpdateMetaObjectHandler;
    7. import org.apache.ibatis.session.SqlSessionFactory;
    8. import org.mybatis.spring.SqlSessionTemplate;
    9. import org.mybatis.spring.annotation.MapperScan;
    10. import org.springframework.beans.factory.annotation.Autowired;
    11. import org.springframework.beans.factory.annotation.Qualifier;
    12. import org.springframework.boot.context.properties.ConfigurationProperties;
    13. import org.springframework.boot.jdbc.DataSourceBuilder;
    14. import org.springframework.context.annotation.Bean;
    15. import org.springframework.context.annotation.Configuration;
    16. import org.springframework.context.annotation.Primary;
    17. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    18. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    19.  
    20. import javax.sql.DataSource;
    21.  
    22. @Configuration
    23. @MapperScan(basePackages = "com.wisdomcity.laian.river.mapper.monitor",sqlSessionFactoryRef = "sqlSessionFactoryTwo",sqlSessionTemplateRef = "sqlSessionTemplateTwo")
    24. public class DatasourceConfigTwo {
    25.  
    26. //    @Autowired
    27. //    @Qualifier("globalConfig")
    28. //    private GlobalConfig globalConfig;
    29.  
    30.     @Autowired
    31.     MybatisPlusInterceptor mybatisPlusInterceptor;
    32.  
    33.     @Bean(name = "dataSourceTwo")
    34.     @ConfigurationProperties(prefix = "spring.datasource.two")
    35.     public DataSource dataSource() {
    36.         return DataSourceBuilder.create().build();
    37.     }
    38.  
    39.     @Bean(name = "sqlSessionFactoryTwo")
    40.     public SqlSessionFactory sqlSessionFactory(@Qualifier("dataSourceTwo") DataSource dataSource) throws Exception {
    41.         //SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    42.         MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
    43.         bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/monitor/*.xml"));
    44. //        bean.setGlobalConfig(globalConfig);
    45.         bean.setGlobalConfig(globalConfig());
    46.         bean.setPlugins(mybatisPlusInterceptor);
    47.         bean.setDataSource(dataSource);
    48.  
    49.         //https://blog.csdn.net/weixin_41785851/article/details/119739897
    50.         MybatisConfiguration configuration = new MybatisConfiguration();
    51.         configuration.setMapUnderscoreToCamelCase(true);
    52.         // 配置打印sql语句
    53.         configuration.setLogImpl(StdOutImpl.class);
    54.         bean.setConfiguration(configuration);
    55.         return bean.getObject();
    56.     }
    57.  
    58.     @Bean(name = "transactionManagerTwo")
    59.     public DataSourceTransactionManager transactionManager(@Qualifier("dataSourceTwo") DataSource dataSource) {
    60.         return new DataSourceTransactionManager(dataSource);
    61.     }
    62.  
    63.     @Bean(name = "sqlSessionTemplateTwo")
    64.     public SqlSessionTemplate sqlSessionTemplate(@Qualifier("sqlSessionFactoryTwo") SqlSessionFactory sqlSessionFactory) {
    65.         return new SqlSessionTemplate(sqlSessionFactory);
    66.     }
    67.  
    68.     /**
    69.      * 自动插入创建和更新时间
    70.      * 多数据源下要创建多个，或者不创建，不然saveBatch等批量操作方法会报错，因为save方法是获取baseMapper，而批量操作的saveBatch方法是从全局配置 GlobalConfig 里获取的。
    71.      */
    72.     @Bean("monitorGlobalConfig")
    73.     public GlobalConfig globalConfig() {
    74.         GlobalConfig globalConfig = new GlobalConfig();
    75.         globalConfig.setMetaObjectHandler(new UpdateMetaObjectHandler());
    76.         return globalConfig;
    77.     }
    78. }

    分页配置

    1. package com.wisdomcity.laian.river.config;
    2.  
    3. import com.baomidou.mybatisplus.annotation.DbType;
    4. import com.baomidou.mybatisplus.core.config.GlobalConfig;
    5. import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
    6. import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
    7. import org.springframework.context.annotation.Bean;
    8. import org.springframework.context.annotation.Configuration;
    9.  
    10. /**
    11.  * MybatisPlus分页配置
    12.  */
    13. @Configuration
    14. public class MybatisPlusConfig {
    15.     /**
    16.      * 分页插件
    17.      */
    18.     @Bean
    19.     public MybatisPlusInterceptor mybatisPlusInterceptor() {
    20.         MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
    21.         interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.POSTGRE_SQL));
    22.         return interceptor;
    23.     }
    24.  
    25. }

    jpa配置思路类似

    1. @Configuration
    2. @EntityScan(basePackages = "com.zjzy.po.sqlserver")
    3. //1、实体扫描
    4. //2、实体管理ref
    5. //3、事务管理
    6. @EnableJpaRepositories(
    7.         basePackages = "com.zjzy.repository.sqlserver",
    8.         entityManagerFactoryRef = "secondaryEntityManagerFactoryBean",
    9.         transactionManagerRef = "secondaryTransactionManager")
    10. @EnableTransactionManagement
    11. public class SqlDataSourceConfig {
    12.     /**
    13.      * sqlserver第二个数据源，可以不加Qualifier
    14.      */
    15.     @Autowired
    16.     @Qualifier("sqlDataSource")
    17.     private DataSource dataSource;
    18.  
    19.     /**
    20.      * jpa其他参数配置
    21.      */
    22.     @Autowired
    23.     private JpaProperties jpaProperties;
    24.  
    25.     /**
    26.      *  实体管理工厂builder
    27.      */
    28.     @Autowired
    29.     private EntityManagerFactoryBuilder factoryBuilder;
    30.  
    31.     /**
    32.      * 配置第二个实体管理工厂的bean
    33.      * @return
    34.      */
    35.     @Bean(name = "secondaryEntityManagerFactoryBean")
    36.     public LocalContainerEntityManagerFactoryBean entityManagerFactoryBean() {
    37.         return factoryBuilder.dataSource(dataSource)
    38.                 //这一行的目的是加入jpa的其他配置参数比如（ddl-auto: update等）
    39.                 //当然这个参数配置可以在事务配置的时候也可以
    40. //                .properties(jpaProperties.getHibernateProperties(new HibernateSettings()))
    41.                 .packages("com.zjzy.po.sqlserver")
    42.                 .persistenceUnit("secondaryPersistenceUnit")
    43.                 .build();
    44.     }
    45.  
    46.     /**
    47.      * EntityManager不过解释，用过jpa的应该都了解
    48.      * @return
    49.      */
    50.     @Bean(name = "secondaryEntityManager")
    51.     public EntityManager entityManager() {
    52.         return entityManagerFactoryBean().getObject().createEntityManager();
    53.     }
    54.  
    55.     /**
    56.      * jpa事务管理
    57.      * @return
    58.      */
    59.     @Bean(name = "secondaryTransactionManager")
    60.     public JpaTransactionManager transactionManager() {
    61.         JpaTransactionManager jpaTransactionManager = new JpaTransactionManager();
    62.         jpaTransactionManager.setEntityManagerFactory(entityManagerFactoryBean().getObject());
    63.         return jpaTransactionManager;
    64.     }
    65. }
    dynamicDataSource的配置方法
    1. @Configuration
    2. //@MapperScan(basePackages = "com.zjzy.emergencyservice.dao")
    3. @MapperScan(basePackages = "com.zjzy.emergencyservice.dao",sqlSessionFactoryRef = "sqlSessionFactoryZero",sqlSessionTemplateRef = "sqlSessionTemplateZero")
    4. public class DataSourceConfig {
    5. //
    6.     @Bean(name = "sqlSessionFactoryZero")
    7.     public SqlSessionFactory sqlSessionFactory(@Qualifier("dynamicDataSource") DataSource dataSource) throws Exception {
    8.         //SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    9. //        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    10.         SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();
    11.         sessionFactoryBean.setDataSource(dataSource);
    12.         //mybatis多数据源添加驼峰命名https://blog.csdn.net/qq_37752382/article/details/120769453
    13.         org.apache.ibatis.session.Configuration configuration = new org.apache.ibatis.session.Configuration();
    14.         configuration.setMapUnderscoreToCamelCase(true);
    15.  
    16.         sessionFactoryBean.setConfiguration(configuration);
    17.         String locationPattern = "classpath*:/mapper/*.xml";
    18.         PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
    19.         sessionFactoryBean.setMapperLocations(resolver.getResources(locationPattern));
    20.         return sessionFactoryBean.getObject();
    21.     }
    22.  
    23.     @Bean(name = "transactionManagerZero")
    24.     public DataSourceTransactionManager transactionManager(@Qualifier("dynamicDataSource") DataSource dataSource) {
    25.         return new DataSourceTransactionManager(dataSource);
    26.     }
    27.  
    28.     @Bean(name = "sqlSessionTemplateZero")
    29.     public SqlSessionTemplate sqlSessionTemplate(@Qualifier("sqlSessionFactoryZero") SqlSessionFactory sqlSessionFactory) {
    30.         return new SqlSessionTemplate(sqlSessionFactory);
    31.     }
    32.  
    33.     @Bean("dataSource1")
    34.     @ConfigurationProperties(prefix = "spring.datasource.db1")
    35.     public DataSource dataSource1(){
    36.         return DataSourceBuilder.create().build();
    37.     }
    38.  
    39.     @Bean("dataSource2")
    40.     @ConfigurationProperties(prefix = "spring.datasource.db2")
    41.     public DataSource dataSource2(){
    42.         return DataSourceBuilder.create().build();
    43.     }
    44.  
    45.     @Bean("dataSource3")
    46.     @ConfigurationProperties(prefix = "spring.datasource.db3")
    47.     public DataSource dataSource3(){
    48.         return DataSourceBuilder.create().build();
    49.     }
    50.  
    51.     @Bean("dataSource4")
    52.     @ConfigurationProperties(prefix = "spring.datasource.db4")
    53.     public DataSource dataSource4(){
    54.         return DataSourceBuilder.create().build();
    55.     }
    56.  
    57.     /**
    58.      * 动态数据源: 通过AOP在不同数据源之间动态切换
    59.      * @return
    60.      */
    61. //    @Primary
    62.     @Bean(name = "dynamicDataSource")
    63.     @Primary
    64.     public DataSource dynamicDataSource() {
    65.         DynamicDataSource dynamicDataSource = new DynamicDataSource();
    66.         // 默认数据源
    67.         dynamicDataSource.setDefaultTargetDataSource(dataSource1());
    68.         // 配置多数据源
    69.         Map<Object, Object> dsMap = new HashMap();
    70.         dsMap.put(DataSourceEnum.MASTER_DATA_SOURCE_NAME.getDataSource(), dataSource1());
    71.         dsMap.put(DataSourceEnum.CLUSTER_DATA_SOURCE_NAME.getDataSource(), dataSource2());
    72.         dsMap.put(DataSourceEnum.POSTGRES_DATA_SOURCE_NAME.getDataSource(), dataSource3());
    73.         dsMap.put(DataSourceEnum.MYSQL_DATA_SOURCE_NAME.getDataSource(), dataSource4());
    74.         dynamicDataSource.setTargetDataSources(dsMap);
    75.         return dynamicDataSource;
    76.     }
    77.  
    78.     /**
    79.      * 配置@Transactional注解事物
    80.      * @return
    81.      */
    82.     @Bean
    83.     public PlatformTransactionManager transactionManager() {
    84.         return new DataSourceTransactionManager(dynamicDataSource());
    85.     }
    86. }

  • 相关阅读:
    【计算机网络笔记】网络层服务模型——数据报网络
    驱动开发：内核枚举ShadowSSDT基址
    【电源专题】LDO的电源抑制比（PSRR）
    【漏洞复现】OneThink前台注入漏洞
    windows部署java环境
    查询三级数据结构sql语句
    华为机试真题 C++ 实现【火星文计算】
    打开 Chrome 的 「内存节省程序」开关和关闭硬件加速
    2022-08-20-网易笔试题
    springboot集成kafka详解
  • 原文地址：https://blog.csdn.net/yaoct/article/details/128145307