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

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

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

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

配置文件

数据库配置相关类

importcom.alibaba.druid.pool.DruidDataSource;

importjava.io.Serializable;

importjava.sql.SQLException;

publicclassJdbcConfigimplementsSerializable{

publicJdbcConfig(){

super();

//TODOAuto-generatedconstructorstub

publicbooleanisDecrypt(){

returndecrypt;

publicvoidsetDecrypt(booleandecrypt){

this.decrypt=decrypt;

publicStringgetDriverClass(){

returndriverClass;

publicvoidsetDriverClass(StringdriverClass){

this.driverClass=driverClass;

publicStringgetTerminalUrl(){returnterminalUrl;}

publicvoidsetTerminalUrl(StringterminalUrl){this.terminalUrl=terminalUrl;}

publicStringgetSlaveurl(){

returnslaveurl;

publicvoidsetSlaveurl(Stringslaveurl){

this.slaveurl=slaveurl;

publicStringgetUsername(){

returnusername;

publicvoidsetUsername(Stringusername){

this.username=username;

publicStringgetPassword(){

returnpassword;

publicvoidsetPassword(Stringpassword){

this.password=password;

publicintgetInitialSize(){

returninitialSize;

publicvoidsetInitialSize(intinitialSize){

this.initialSize=initialSize;

publicintgetMinIdle(){

returnminIdle;

publicvoidsetMinIdle(intminIdle){

this.minIdle=minIdle;

publicintgetMaxActive(){

returnmaxActive;

publicvoidsetMaxActive(intmaxActive){

this.maxActive=maxActive;

privatebooleandecrypt;

privateStringdriverClass;

privateStringterminalUrl;

privateStringslaveurl;

privateStringusername;

privateStringpassword;

privateintinitialSize;

privateintminIdle;

privateintmaxActive;

publicDruidDataSourcemainds()throwsSQLException{

DruidDataSourceds=ds();

ds.setUrl(terminalUrl);

returnds;

publicDruidDataSourceslaveds()throwsSQLException{

DruidDataSourceds=ds();

ds.setUrl(slaveurl);

returnds;

privateDruidDataSourceds()throwsSQLException{

DruidDataSourceds=newDruidDataSource();

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

returnds;

}

相关配置

@Bean

@ConfigurationProperties(prefix="jdbc")

publicJdbcConfigjdbcConfig(){

returnnewJdbcConfig();

@Bean

@ConfigurationProperties(prefix="business.jdbc")

publicJdbcConfigbusinessJdbcConfig(){

returnnewJdbcConfig();

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

publicDruidDataSourcebusinessDataSource()throwsSQLException{

returnbusinessJdbcConfig().mainds();

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

publicDruidDataSourcemasterDataSource()throwsSQLException{

returnjdbcConfig().mainds();

@Bean("jdbctemplate")

publicJdbcTemplatejdbcTemplate()throwsSQLException{

JdbcTemplatet=newJdbcTemplate();

t.setDataSource(masterDataSource());

returnt;

@Bean("businessJdbctemplate")

publicJdbcTemplatebusinessjdbcTemplate()throwsSQLException{

JdbcTemplatet=newJdbcTemplate();

t.setDataSource(businessDataSource());

returnt;

}

使用

@Bean

publicRobotDataDaorobotDataDao()throwsSQLException{

Robot