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;
}
}