SpringBoot @DS注解实现多数据源配置及问题解决

绝地灬酷狼 2023-09-24 22:54 19阅读 0赞

### 一、导入依赖： ###

<dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
                <version>3.5.0</version>
            </dependency>

### 二、配置文件： ###

datasource:
        dynamic:
          druid:
            initial-size: 5
            min-idle: 5
            maxActive: 20
            # 配置获取连接等待超时的时间
            maxWait: 60000
            # 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
            timeBetweenEvictionRunsMillis: 6000
            # 配置一个连接在池中最小生存的时间，单位是毫秒
            minEvictableIdleTimeMillis: 60000
            # 配置一个连接在池中最大生存的时间，单位是毫秒
            maxEvictableIdleTimeMillis: 900000
            validationQuery: SELECT 1 FROM DUAL
            testWhileIdle: true
            testOnBorrow: false
            testOnReturn: false
            # 打开PSCache，并且指定每个连接上PSCache的大小
            poolPreparedStatements: true
            maxPoolPreparedStatementPerConnectionSize: 20
          primary: master #设置默认的数据源或者数据源组,默认值即为master
          strict: false #严格匹配数据源,默认false. true未匹配到指定数据源时抛异常,false使用默认数据源
          datasource:
            master:
              driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
              url: jdbc:mysql://localhost:3306/table1?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true&allowPublicKeyRetrieval=true
              username: xxxx
              password: xxxxx
            slave_1:
              driver-class-name: com.mysql.cj.jdbc.Driver # 3.2.0开始支持SPI可省略此配置
              url: jdbc:mysql://localhost:3306/table2?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf-8&useSSL=false&allowMultiQueries=true&allowPublicKeyRetrieval=true
              username: xxxx
              password: xxxxx

### 三、在启动类上配置一行 ###

@SpringBootApplication(exclude={DataSourceAutoConfiguration.class})

### 四、在需要切换数据源的类上、方法上使用@DS注解（一般是用在mapper、service） ###

![75d6d6830a50d0537fce7344b884c39e.png][]

### 五、@DS注解不生效的几种情况 ###

1.  进过验证，@DS注解加到mapper接口、service接口、service方法里都不生效，获取的还是默认的主数据源。猜测是由于spring的aop切面机制导致拦截不到@DS注解，进而不能切换数据源，正确的做法是添加到service实现类或者实现类里具体的方法上。

1.  在事务方法内调用@DS注解的方法，@DS注解同样不生效，原因是spring只能拦截到最外层方法的@Transactional注解，此时加载该事务的数据源，在事务方法内即使调用了@DS注解的方法，获取的是外层事务的数据源，导致@DS失效。

1.  在同一个实现类中，一个非DS注解的常规方法里调用@DS注解的方法，同样存在@DS失效的情况，原因同2，是由spring的aop机制导致的，如果确有这种业务需要，可以将该DS注解方法定义在不同的类中，通过bean注入的方式调用，就不会出现这个问题。

### **六、本人使用时遇到的问题：** ###

1.  配置文件配置的jackson时间返回格式失效了，返回的还是时间戳格式数据

原：（无效）

jackson:
       date-format: yyyy-MM-dd HH:mm:ss
       time-zone: GMT+8

可能原因：

添加拦截器并继承 [WebMvcConfigurationSupport][] 后会覆盖@EnableAutoConfiguration关于WebMvcAutoConfiguration的配置！从而导致所有的Date返回都变成时间戳。

解决办法：

在继承了 [WebMvcConfigurationSupport][]的拦截器中，重写extendMessageConverters方法

public class xxxConfig extends WebMvcConfigurationSupport {
        @Override
        public void extendMessageConverters(List<HttpMessageConverter<?>> converters) {
            MappingJackson2HttpMessageConverter converter = new MappingJackson2HttpMessageConverter();
            ObjectMapper objectMapper = converter.getObjectMapper();
            // 生成JSON时,将所有Long转换成String
            SimpleModule simpleModule = new SimpleModule();
            simpleModule.addSerializer(Long.class, ToStringSerializer.instance);
            simpleModule.addSerializer(Long.TYPE, ToStringSerializer.instance);
            objectMapper.registerModule(simpleModule);
            // 时间格式化
            objectMapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
            objectMapper.setDateFormat(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));
            // 设置格式化内容
            converter.setObjectMapper(objectMapper);
            converters.add(0, converter);
        }
    }

注：需要导入的依赖

<dependency>
        <groupId>org.mybatis</groupId>
        <artifactId>mybatis-typehandlers-jsr310</artifactId>
        <version>1.0.1</version>
    </dependency>
    <dependency>
        <groupId>com.fasterxml.jackson.datatype</groupId>
        <artifactId>jackson-datatype-jsr310</artifactId>
        <version>2.9.2</version>
    </dependency>

1.  启动的时候找不到数据源，报"java.lang.ClassNotFoundException: com.mysql.cj.jdbc.Driver"异常

首先检查是否引入了mysql-connector-java依赖：

<dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.15</version>
    </dependency>

其次检查jar包版本是否是6.x及以上（因为 com.mysql.cj.jdbc.Driver这个类就位于mysql-connector-java的6.x版本中）

[75d6d6830a50d0537fce7344b884c39e.png]: https://img-blog.csdnimg.cn/img_convert/75d6d6830a50d0537fce7344b884c39e.png
[WebMvcConfigurationSupport]: https://so.csdn.net/so/search?q=WebMvcConfigurationSupport&spm=1001.2101.3001.7020