码迷,mamicode.com
首页 > 数据库 > 详细

jdbctemplate 多数据源

时间:2020-06-24 18:04:45      阅读:57      评论:0      收藏:0      [点我收藏+]

标签:ruid   @param   roo   exclude   autowire   import   clu   cond   mysql   

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

  

 

 

jdbctemplate 多数据源

标签:ruid   @param   roo   exclude   autowire   import   clu   cond   mysql   

原文地址:https://www.cnblogs.com/heshana/p/13188755.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!