• SpringBoot Mybatis 多数据源 MySQL+Oracle+Redis

     一、背景

    在SpringBoot Mybatis 项目中，需要连接 多个数据源，连接多个数据库，需要连接一个MySQL数据库和一个Oracle数据库和一个Redis

    二、依赖 pom.xml

    1.  <dependencies>
    2.         <dependency>
    3.             <groupId>org.springframework.bootgroupId>
    4.             <artifactId>spring-boot-starter-webartifactId>
    5.         dependency>
    6.  
    7.         <dependency>
    8.             <groupId>org.springframework.bootgroupId>
    9.             <artifactId>spring-boot-starter-testartifactId>
    10.             <scope>testscope>
    11.         dependency>
    12.         
    13.         <dependency>
    14.             <groupId>mysqlgroupId>
    15.             <artifactId>mysql-connector-javaartifactId>
    16.             <version>8.0.26version>
    17.         dependency>
    18.         <dependency>
    19.             <groupId>org.springframework.bootgroupId>
    20.             <artifactId>spring-boot-starter-jdbcartifactId>
    21.         dependency>
    22.  
    23.         <dependency>
    24.             <groupId>org.mybatis.spring.bootgroupId>
    25.             <artifactId>mybatis-spring-boot-starterartifactId>
    26.             <version>1.3.2version>
    27.         dependency>
    28.         
    29.         <dependency>
    30.             <groupId>com.oracle.database.jdbcgroupId>
    31.             <artifactId>ojdbc8artifactId>
    32.             <version>19.8.0.0version>
    33.         dependency>
    34.  
    35.         
    36.         <dependency>
    37.             <groupId>org.springframework.bootgroupId>
    38.             <artifactId>spring-boot-starter-data-redisartifactId>
    39.             <version>2.4.4version>
    40.         dependency>
    41.         
    42.         <dependency>
    43.             <groupId>org.projectlombokgroupId>
    44.             <artifactId>lombokartifactId>
    45.             <version>1.18.16version>
    46.             <scope>providedscope>
    47.         dependency>
    48.         <dependency>
    49.             <groupId>javax.persistencegroupId>
    50.             <artifactId>javax.persistence-apiartifactId>
    51.             <version>2.2version>
    52.         dependency>
    53.         
    54.         <dependency>
    55.             <groupId>io.springfoxgroupId>
    56.             <artifactId>springfox-swagger2artifactId>
    57.             <version>2.9.2version>
    58.         dependency>
    59.         
    60.         <dependency>
    61.             <groupId>io.springfoxgroupId>
    62.             <artifactId>springfox-swagger-uiartifactId>
    63.             <version>2.9.2version>
    64.         dependency>
    65.  
    66.  
    67.         
    68.         <dependency>
    69.             <groupId>cn.easyprojectgroupId>
    70.             <artifactId>orai18nartifactId>
    71.             <version>12.1.0.2.0version>
    72.         dependency>
    73.  
    74.     dependencies>

    三、项目结构

    四、application.yml

    spring.datasource.url数据库的JDBC URL

    spring.datasource.jdbc-url用来重写自定义连接池

    Hikari没有url属性，但是有jdbcUrl属性，在这中情况下必须使用jdbc_url

    1. server:
    2.   port: 8080
    3.  
    4. spring:
    5.   datasource:
    6.     primary:
    7.       jdbc-url: jdbc:mysql://localhost:3306/database_name
    8.       username: root
    9.       password: 123456
    10.       driver-class-name: com.mysql.cj.jdbc.Driver
    11.  
    12.     secondary:
    13.       jdbc-url: jdbc:oracle:thin:@localhost:1521/ORCL
    14.       username: root
    15.       password: 123456
    16.       driver-class-name: oracle.jdbc.driver.OracleDriver

    五、MySQL配置类

    MysqlDataSourceConfig

    使用注解@Primary配置默认数据源

    1. package com.example.multipledata.config.mysqlconfig;
    2.  
    3. import org.apache.ibatis.session.SqlSessionFactory;
    4. import org.mybatis.spring.SqlSessionFactoryBean;
    5. import org.mybatis.spring.annotation.MapperScan;
    6. import org.springframework.beans.factory.annotation.Qualifier;
    7. import org.springframework.boot.context.properties.ConfigurationProperties;
    8. import org.springframework.boot.jdbc.DataSourceBuilder;
    9. import org.springframework.context.annotation.Bean;
    10. import org.springframework.context.annotation.Configuration;
    11. import org.springframework.context.annotation.Primary;
    12. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    13. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    14.  
    15. import javax.sql.DataSource;
    16.  
    17.  
    18. @Configuration
    19. @MapperScan(basePackages = MysqlDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "mysqlSqlSessionFactory")
    20. public class MysqlDataSourceConfig {
    21.    
    22.     static final String PACKAGE = "com.example.multipledata.mapper.mysqlmapper";
    23.  
    24.     static final String MAPPER_LOCATION = "classpath*:mapper/mysqlmapper/*.xml";
    25.  
    26.     @Primary
    27.     @Bean(name = "mysqlDataSource")
    28.     @ConfigurationProperties(prefix = "spring.datasource.primary")
    29.     public DataSource mysqlDataSource() {
    30.         return DataSourceBuilder.create().build();
    31.     }
    32.  
    33.     @Primary
    34.     @Bean(name = "mysqlTransactionManager")
    35.     public DataSourceTransactionManager mysqlTransactionManager() {
    36.         return new DataSourceTransactionManager((mysqlDataSource()));
    37.     }
    38.  
    39.     @Primary
    40.     @Bean(name = "mysqlSqlSessionFactory")
    41.     public SqlSessionFactory mysqlSqlSessionFactory(@Qualifier("mysqlDataSource") DataSource mysqlDatasource) throws Exception {
    42.         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    43.         sessionFactory.setDataSource(mysqlDatasource);
    44.         sessionFactory.setMapperLocations(
    45.                 new PathMatchingResourcePatternResolver().getResources(MysqlDataSourceConfig.MAPPER_LOCATION)
    46.         );
    47.         return sessionFactory.getObject();
    48.     }
    49. }

    六、Oracle配置类

    OracleDataSourceConfig

    1. package com.example.multipledata.config.oracleconfig;
    2.  
    3. import org.apache.ibatis.session.SqlSessionFactory;
    4. import org.mybatis.spring.SqlSessionFactoryBean;
    5. import org.mybatis.spring.annotation.MapperScan;
    6. import org.springframework.beans.factory.annotation.Qualifier;
    7. import org.springframework.boot.context.properties.ConfigurationProperties;
    8. import org.springframework.boot.jdbc.DataSourceBuilder;
    9. import org.springframework.context.annotation.Bean;
    10. import org.springframework.context.annotation.Configuration;
    11. import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    12. import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    13.  
    14. import javax.sql.DataSource;
    15.  
    16. @Configuration
    17. @MapperScan(basePackages = OracleDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "oracleSqlSessionFactory")
    18. public class OracleDataSourceConfig {
    19.  
    20.     static final String PACKAGE = "com.example.multipledata.mapper.oraclemapper";
    21.  
    22.     static final String MAPPER_LOCATION = "classpath*:mapper/oraclemapper/*.xml";
    23.  
    24.     @Bean(name = "oracleDataSource")
    25.     @ConfigurationProperties(prefix = "spring.datasource.secondary")
    26.     public DataSource oracleDataSource() {
    27.         return DataSourceBuilder.create().build();
    28.     }
    29.  
    30.     @Bean(name = "oracleTransactionManager")
    31.     public DataSourceTransactionManager oracleTransactionManager() {
    32.         return new DataSourceTransactionManager(oracleDataSource());
    33.     }
    34.  
    35.     @Bean(name = "oracleSqlSessionFactory")
    36.     public SqlSessionFactory oracleSqlSessionFactory(@Qualifier("oracleDataSource") DataSource oracleDataSource) throws Exception {
    37.         final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
    38.         sessionFactory.setDataSource(oracleDataSource);
    39.         sessionFactory.setMapperLocations(
    40.                 new PathMatchingResourcePatternResolver().getResources(OracleDataSourceConfig.MAPPER_LOCATION)
    41.         );
    42.         return sessionFactory.getObject();
    43.     }
    44. }

    原文地址：

    https://www.cnblogs.com/windy-xmwh/p/14748567.html

    七、增加Redis连接

    注意，我的Redis连接，使用了密码

    7.1 新增依赖 pom.xml

    pom.xml

    1.         
    2.         <dependency>
    3.             <groupId>org.springframework.bootgroupId>
    4.             <artifactId>spring-boot-starter-data-redisartifactId>
    5.             <version>2.4.4version>
    6.         dependency>
    7.         <dependency>
    8.             <groupId>io.lettucegroupId>
    9.             <artifactId>lettuce-coreartifactId>
    10.         dependency>

    7.2 配置Redis连接  application.yml

    1.   spring:
    2.     redis:
    3.         host: host
    4.         port: 6379
    5.         password: 1

    7.3 Redis 配置文件 RedisConfig

    在config目录下，新增RedisConfig文件

    1. package com.example.kyjjserver.config;
    2.  
    3. import org.springframework.beans.factory.annotation.Value;
    4. import org.springframework.context.annotation.Bean;
    5. import org.springframework.context.annotation.Configuration;
    6. import org.springframework.data.redis.connection.RedisConnectionFactory;
    7. import org.springframework.data.redis.core.RedisTemplate;
    8. import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
    9. import org.springframework.data.redis.serializer.StringRedisSerializer;
    10. import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
    11.  
    12. @Configuration
    13. public class RedisConfig {
    14.  
    15.     @Value("${spring.redis.host}")
    16.     private String redisHost;
    17.  
    18.     @Value("${spring.redis.port}")
    19.     private int redisPort;
    20.  
    21.     @Value("${spring.redis.password}")
    22.     private String redisPassword;
    23.  
    24.     @Bean
    25.     public RedisConnectionFactory redisConnectionFactory() {
    26.         LettuceConnectionFactory lettuceConnectionFactory = new LettuceConnectionFactory(redisHost, redisPort);
    27.         lettuceConnectionFactory.setPassword(redisPassword);
    28.         return lettuceConnectionFactory;
    29.     }
    30.  
    31.     @Bean
    32.     public RedisTemplate redisTemplate(RedisConnectionFactory redisConnectionFactory) {
    33.         RedisTemplate redisTemplate = new RedisTemplate<>();
    34.         redisTemplate.setConnectionFactory(redisConnectionFactory);
    35.         redisTemplate.setKeySerializer(new StringRedisSerializer());
    36.         redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
    37.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
    38.         redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
    39.         redisTemplate.afterPropertiesSet();
    40.         return redisTemplate;
    41.     }
    42. }

    7.4 操作Redis

    7.4.1 封装操作方法

    在service目录下，新增RedisService文件

    1. package com.example.kyjjserver.service;
    2.  
    3. import org.springframework.beans.factory.annotation.Autowired;
    4. import org.springframework.data.redis.core.RedisTemplate;
    5. import org.springframework.stereotype.Service;
    6.  
    7. import java.util.Set;
    8.  
    9. @Service
    10. public class RedisService {
    11.  
    12.     private final RedisTemplate redisTemplate;
    13.  
    14.     @Autowired
    15.     public RedisService(RedisTemplate redisTemplate) {
    16.         this.redisTemplate = redisTemplate;
    17.     }
    18.  
    19.     public void deleteData(String key) {
    20.         redisTemplate.delete(key);
    21.     }
    22.  
    23.     public void deleteDataAll(String pattern) {
    24.         Set keys = redisTemplate.keys("*" + pattern + "*");
    25.         if (keys != null) {
    26.             redisTemplate.delete(keys);
    27.         }
    28.     }
    29. }

    7.4.2 调用方法，操作Redis库

    1、注入

    2、调用

    1. @Component
    2. public class DeleteRedisInfo {
    3.     @Autowired
    4.     private RedisService redisService;
    5.  
    6.     @Transactional
    7.     public AAA deleteUser(xxx xxx){
    8.         // 删除手机号
    9.         redisService.deleteDataAll(xxx);
    10.       
    11.  
    12.  
    13.         return xxx;
    14.     }
    15. }

  • 相关阅读:
    数据中心深度制冷联合解决方案登陆VMware云市场及VMware Explore 2022大会
    android获取RAM、CPU频率、系统版本、CPU核数
    1704. 判断字符串的两半是否相似 : 简单模拟题
    vue项目关闭eslint
    Cy5反式环辛烯，TCO-Cy5，Cy5 trans-cyclooctene标记生物分子
    Drools（8）：WorkBench使用
    尚硅谷大数据项目《在线教育之实时数仓》笔记006
    Redis数据结构
    断点续传-http中Header参数Range(分段请求基础)
    vscode launch.json
  • 原文地址：https://blog.csdn.net/qq_39208536/article/details/132575001