jdbctemplate多数据源 Jdbctemplate多数据源配置方法详解
higsan 人气:01.数据源配置
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; } }
加载全部内容