springboot+springJdbc+postgresql 实现多数据源的配置

springboot+springJdbc+postgresql 实现多数据源的配置

背景

最近公司在服务拆迁,接口转移,相同的功能接口到要迁移到对应的服务中,因为时间比较赶,别问为什么没给时间,没人,没资源,但是活还是得干的,为了减少工作量和稳妥的需要分两步走

先迁移相关代码,保证包的路径不变,请求接口的路径不变

将迁移的相关代码进行迁表迁库(这目前还没做,计划9月实施)

实施

配置文件

数据库配置相关类

import com.alibaba.druid.pool.DruidDataSource;

import java.io.Serializable;

import java.sql.SQLException;

public class JdbcConfig implements Serializable {

public JdbcConfig() {

super();

// TODO Auto-generated constructor stub

}

public boolean isDecrypt() {

return decrypt;

}

public void setDecrypt(boolean decrypt) {

this.decrypt = decrypt;

}

public String getDriverClass() {

return driverClass;

}

public void setDriverClass(String driverClass) {

this.driverClass = driverClass;

}

public String getTerminalUrl() { return terminalUrl; }

public void setTerminalUrl(String terminalUrl) { this.terminalUrl = terminalUrl; }

public String getSlaveurl() {

return slaveurl;

}

public void setSlaveurl(String slaveurl) {

this.slaveurl = slaveurl;

}

public String getUsername() {

return username;

}

public void setUsername(String username) {

this.username = username;

}

public String getPassword() {

return password;

}

public void setPassword(String password) {

this.password = password;

}

public int getInitialSize() {

return initialSize;

}

public void setInitialSize(int initialSize) {

this.initialSize = initialSize;

}

public int getMinIdle() {

return minIdle;

}

public void setMinIdle(int minIdle) {

this.minIdle = minIdle;

}

public int getMaxActive() {

return maxActive;

}

public void setMaxActive(int maxActive) {

this.maxActive = maxActive;

}

private boolean decrypt;

private String driverClass;

private String terminalUrl;

private String slaveurl;

private String username;

private String password;

private int initialSize;

private int minIdle;

private int maxActive;

public DruidDataSource mainds() throws SQLException {

DruidDataSource ds = ds();

ds.setUrl(terminalUrl);

return ds;

}

public DruidDataSource slaveds() throws SQLException {

DruidDataSource ds = ds();

ds.setUrl(slaveurl);

return ds;

}

private DruidDataSource ds() throws SQLException {

DruidDataSource ds = new DruidDataSource();

ds.setUrl(terminalUrl);

ds.setUsername(username);

ds.setPassword(password);

ds.setFilters("config");

ds.setConnectionProperties("config.decrypt=" + decrypt);

ds.setInitialSize(initialSize);

ds.setMaxActive(maxActive);

ds.setTimeBetweenEvictionRunsMillis(60000);

ds.setMinEvictableIdleTimeMillis(300000);

ds.setValidationQuery("select 'X'");

ds.setTestWhileIdle(true);

ds.setTestOnBorrow(false);

ds.setTestOnReturn(false);

System.out.println("terminalUrl: " + terminalUrl);

return ds;

}

}

相关配置

@Bean

@ConfigurationProperties(prefix = "jdbc")

public JdbcConfig jdbcConfig() {

return new JdbcConfig();

}

@Bean

@ConfigurationProperties(prefix = "business.jdbc")

public JdbcConfig businessJdbcConfig() {

return new JdbcConfig();

}

@Bean(initMethod = "init", destroyMethod = "close")

public DruidDataSource businessDataSource() throws SQLException {

return businessJdbcConfig().mainds();

}

@Bean(initMethod = "init", destroyMethod = "close")

public DruidDataSource masterDataSource() throws SQLException {

return jdbcConfig().mainds();

}

@Bean("jdbctemplate")

public JdbcTemplate jdbcTemplate() throws SQLException {

JdbcTemplate t = new JdbcTemplate();

t.setDathttp://aSource(masterDataSource());

return t;

}

@Bean("businessJdbctemplate")

public JdbcTemplate businessjdbcTemplate() throws SQLException {

JdbcTemplate t = new JdbcTemplate();

t.setDataSource(businessDataSource());

return t;

}

使用

@Bean

public Rhttp://obotDataDao robotDataDao() throws SQLException {

RobotDataDao dao = new RobotDataDao();

dao.setJdbcTemplate(jdbcTemplate());

dao.setTableName("t_business_robot_data");

dao.setPrimaryKey("id");

dao.setSeqName("seq_t_business");

return dao;

}

@Bean

public VDeviceDao vdeviceDao() throws SQLException {

VDeviceDao dao = new VDeviceDao();

dao.setJdbcTemplate(businessjdbcTemplate());

dao.setTableName("t_device");

dao.setPrimaryKey("id");

dao.setSeqName("seq_t_default");

return dao;

}

特别注意的,一定要配置的,因为现在有多数据源了就要配置对应的事务配置,单个默认的,多个就要指定

@Configuration

public class TransactionConfig {

@Bean

puCXsletblic PlatformTransactionManager bfscrmTransactionManager(@Qualifier("masterDataSource") DataSource masterDataSource) {

return new DataSourceTransactionManager(masterDataSource);

}

}

这就配置好了多个数据源了

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。