Jdbctemplate多数据源配置方法详解

1.数据源配置

spring:
  #  jdbctemplate 连接多数据源配置
 db1:
  datasource:
   jdbcurl: jdbc:mysql://127.0.0.1:3306/cloud-main1?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true
   username: root
   password: 123456
   driver-class-name: com.mysql.jdbc.Driver
   type: com.alibaba.druid.pool.DruidDataSource
 db2:
  datasource:
   jdbcurl: jdbc:mysql://127.0.0.1:3306/cloud-main2?useUnicode=true&characterEncoding=utf8&useSSL=false&allowMultiQueries=true
   username: root
   password: 123456
   driver-class-name: com.mysql.jdbc.Driver
   type: com.alibaba.druid.pool.DruidDataSource

2.启动类

@SpringBootApplication(exclude = DataSourceAutoConfiguration.class)

3.config 配置datasource

package com.example.demo.jdbctemplate.config;

import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.boot.jdbc.DataSourceBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;

import javax.sql.DataSource;

@Configuration
public class DataSourceConfig {

  @Primary //（主数据源配置）
  @Bean(name = "db1")
  @Qualifier("db1")
  @ConfigurationProperties(prefix = "spring.db1.datasource")
  public DataSource mysqlDataSource(){

    return DataSourceBuilder.create().build();
  }

  //
  @Bean(name = "db2")
  @Qualifier("db2")
  @ConfigurationProperties(prefix = "spring.db2.datasource")
  public DataSource sqlServerDataSource(){

    return DataSourceBuilder.create().build();
  }
}

构造 db1JdbcTemplate、　　db2JdbcTemplate

package com.example.demo.jdbctemplate.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Component;
import org.springframework.stereotype.Repository;

import javax.sql.DataSource;

@Repository
public class DBLoader {
  @Bean(name = "db1JdbcTemplate")
  public JdbcTemplate primaryJdbcTemplate(@Qualifier("db1") DataSource dataSource) {
    return new JdbcTemplate(dataSource);
  }

  @Bean(name = "db2JdbcTemplate")
  public JdbcTemplate secondaryJdbcTemplate(@Qualifier("db2") DataSource dataSource) {
    return new JdbcTemplate(dataSource);
  }

}

4.调用

@Service
public class DBTools {
  @Autowired
  @Qualifier( "db1JdbcTemplate")
  private JdbcTemplate jdbcTemplate1;
  @Autowired
  @Qualifier("db2JdbcTemplate")
  private JdbcTemplate jdbcTemplate2 ;

  JdbcTemplate jdbcTemplate;

  public JdbcTemplate getDB(String db ) {
    if("db1".equals(db)){
      return jdbcTemplate1;
    }else if ("db2".equals(db)){
      return jdbcTemplate2;
    }else {
      return null ;
    }

  }

  /***
   * 查询
   * @param sql
   * @return 返回list
   */
  public  List<Map<String, Object>> queryForList(String db,String sql ) {
    List<Map<String, Object>> queryForList = getDB(db).queryForList(sql );
    return queryForList;
  }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。