SpringBoot多数据源配置DataSources

川长思鸟来 2024-03-26 16:24 59阅读 0赞

> **1.xml**

<dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>

> **2.yml文件**

spring:
      datasource:
        primary:
          url: jdbc:mysql://xxx.myqcloud.com:3333/pro?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
          username: root
          password: 123***
          driver-class-name: com.mysql.cj.jdbc.Driver
        secondary:
          url: jdbc:mysql://xxx.xx.xx.xx:3333/spider?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
          username: readonly
          password: 321112
          driver-class-name: com.mysql.cj.jdbc.Driver
        tertiary:
          url: jdbc:mysql://xxx.com:222/zzv2?characterEncoding=utf8&useSSL=false&serverTimezone=UTC&zeroDateTimeBehavior=convertToNull
          username: root
          password: 123321
          driver-class-name: com.mysql.cj.jdbc.Driver

> **3.config**

import com.zaxxer.hikari.HikariDataSource;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.jdbc.core.JdbcTemplate;
    import javax.sql.DataSource;
    
    @Configuration
    public class DataSourcesConfig {
        
    
        @Bean
        @Primary
        @Qualifier("primaryDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.primary")
        public DataSource primaryDataSource(@Value("${spring.datasource.primary.url}") String url,
                                            @Value("${spring.datasource.primary.username}") String userName,
                                            @Value("${spring.datasource.primary.password}") String pass,
                                            @Value("${spring.datasource.primary.driver-class-name}") String className) {
        
            HikariDataSource hikariDataSource = new HikariDataSource();
            hikariDataSource.setJdbcUrl(url);
            hikariDataSource.setDriverClassName(className);
            hikariDataSource.setUsername(userName);
            hikariDataSource.setPassword(pass);
            return hikariDataSource;
        }
    
        @Bean
        @Qualifier("secondaryDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.secondary")
        public DataSource secondaryDataSource(@Value("${spring.datasource.secondary.url}") String url,
                                              @Value("${spring.datasource.secondary.username}") String userName,
                                              @Value("${spring.datasource.secondary.password}") String pass,
                                              @Value("${spring.datasource.secondary.driver-class-name}") String className){
        
            HikariDataSource hikariDataSource = new HikariDataSource();
            hikariDataSource.setJdbcUrl(url);
            hikariDataSource.setDriverClassName(className);
            hikariDataSource.setUsername(userName);
            hikariDataSource.setPassword(pass);
            return hikariDataSource;
        }
    
        @Bean
        @Qualifier("tertiaryDataSource")
        @ConfigurationProperties(prefix = "spring.datasource.tertiary")
        public DataSource tertiaryDataSource(@Value("${spring.datasource.tertiary.url}") String url,
                                             @Value("${spring.datasource.tertiary.username}") String userName,
                                             @Value("${spring.datasource.tertiary.password}") String pass,
                                             @Value("${spring.datasource.tertiary.driver-class-name}") String className){
        
            HikariDataSource hikariDataSource = new HikariDataSource();
            hikariDataSource.setJdbcUrl(url);
            hikariDataSource.setDriverClassName(className);
            hikariDataSource.setUsername(userName);
            hikariDataSource.setPassword(pass);
            return hikariDataSource;
        }
    
        @Bean(name = "primaryJdbcTemplate")
        public JdbcTemplate primaryJdbcTemplate(@Qualifier("primaryDataSource") DataSource dataSource) {
        
            return new JdbcTemplate(dataSource);
        }
    
        @Bean(name = "secondaryJdbcTemplate")
        public JdbcTemplate secondaryJdbcTemplate(@Qualifier("secondaryDataSource") DataSource dataSource) {
        
            return new JdbcTemplate(dataSource);
        }
    
        @Bean(name = "tertiaryJdbcTemplate")
        public JdbcTemplate tertiaryJdbcTemplate(@Qualifier("tertiaryDataSource") DataSource dataSource) {
        
            return new JdbcTemplate(dataSource);
        }
    
    
    
    }

> **4.Controller调用**

@Api("AssociationController")
    @RestController
    @RequestMapping("/api/association")
    public class AssociationController {
        
    	Logger logger = LoggerFactory.getLogger(AssociationController.class);
    	@Resource(name = "secondaryJdbcTemplate")
    	private JdbcTemplate jdbcTemplate2;
    /**
    	private static String YQ_Search;
    	@Value("${yq_search}")
    	public void setYQ_Search(String YQ_Search){
    		this.YQ_Search=YQ_Search;
    	}**/
    }