springboot+springJdbc+postgresql 實(shí)現(xiàn)多數(shù)據(jù)源的配置

第springboot+springJdbc+postgresql實(shí)現(xiàn)多數(shù)據(jù)源的配置最近公司在服務(wù)拆遷,接口轉(zhuǎn)移,相同的功能接口到要遷移到對(duì)應(yīng)的服務(wù)中,因?yàn)闀r(shí)間比較趕,別問(wèn)為什么沒(méi)給時(shí)間,沒(méi)人,沒(méi)資源,但是活還是得干的,為了減少工作量和穩(wěn)妥的需要分兩步走

先遷移相關(guān)代碼,保證包的路徑不變,請(qǐng)求接口的路徑不變

將遷移的相關(guān)代碼進(jìn)行遷表遷庫(kù)(這目前還沒(méi)做,計(jì)劃9月實(shí)施)

配置文件

數(shù)據(jù)庫(kù)配置相關(guān)類

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;

}

相關(guān)配置

@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