Springboot實(shí)現(xiàn)多數(shù)據(jù)源切換詳情

第Springboot實(shí)現(xiàn)多數(shù)據(jù)源切換詳情@Bean

@ConditionalOnProperty(prefix="datasource.stragegy",name="routingStategy",havingValue="ROUTING_DS_TABLE_STATEGY")

publicIRoutingInterfaceroutingDsAndTbStrategy(){

returnnewRoutingDsAndTbStrategy();

*Routingdsstrategy

*@returntheroutinginterface

*@since1.0.0

@Bean

@ConditionalOnProperty(prefix="datasource.stragegy",name="routingStategy",havingValue="ROUTGING_DS_STATEGY")

publicIRoutingInterfaceroutingDsStrategy(){

returnnewRoutingDsStrategy();

*Routingtbstrategy

*@returntheroutinginterface

*@since1.0.0

@Bean

@ConditionalOnProperty(prefix="datasource.stragegy",name="routingStategy",havingValue="ROUTGIN_TABLE_STATEGY")

publicIRoutingInterfaceroutingTbStrategy(){

returnnewRoutingTbStrategy();

}

4.3MultipleDataSourceStrategyConfig

根據(jù)對(duì)應(yīng)的配置創(chuàng)建不同的分庫策略

@Configuration

publicclassMultipleDataSourceStrategyConfig{

*當(dāng)配置文件里面包含某個(gè)配置，并且值是多少時(shí)生效

*@returnroutinginterface

*@since1.0.0

@Bean

@ConditionalOnProperty(prefix="datasource.stragegy",name="routingStategy",havingValue="ROUTING_DS_TABLE_STATEGY")

publicIRoutingInterfaceroutingDsAndTbStrategy(){

returnnewRoutingDsAndTbStrategy();

*Routingdsstrategy

*@returntheroutinginterface

*@since1.0.0

@Bean

@ConditionalOnProperty(prefix="datasource.stragegy",name="routingStategy",havingValue="ROUTGING_DS_STATEGY")

publicIRoutingInterfaceroutingDsStrategy(){

returnnewRoutingDsStrategy();

*Routingtbstrategy

*@returntheroutinginterface

*@since1.0.0

@Bean

@ConditionalOnProperty(prefix="datasource.stragegy",name="routingStategy",havingValue="ROUTGIN_TABLE_STATEGY")

publicIRoutingInterfaceroutingTbStrategy(){

returnnewRoutingTbStrategy();

}

4.4MultipleDataSourceConfig

多數(shù)據(jù)源自動(dòng)裝配類，其中創(chuàng)建了多個(gè)數(shù)據(jù)源，通過spring提供的AbstractRoutingDataSource類進(jìn)行數(shù)據(jù)源的切換

@Configuration

//開啟數(shù)據(jù)源以及數(shù)據(jù)分庫策略配置

@EnableConfigurationProperties({MultipleDataSourceProperties.class,MultipleStategyProperties.class})

publicclassMultipleDataSourceConfig{

@Resource

privateMultipleDataSourcePropertiesmultipleDataSourceProperties;

@Resource

privateMultipleStategyPropertiesmultipleStategyProperties;

*配置數(shù)據(jù)源

*@return

@Bean("data0")

publicDataSourcedataSource0(){

DruidDataSourcedruidDataSource=newDruidDataSource();

druidDataSource.setUsername(multipleDataSourceProperties.getData0().getUser());

druidDataSource.setPassword(multipleDataSourceProperties.getData0().getPassword());

druidDataSource.setUrl(multipleDataSourceProperties.getData0().getUrl());

druidDataSource.setDriverClassName(multipleDataSourceProperties.getData0().getDriver());

returndruidDataSource;

@Bean("data1")

publicDataSourcedataSource1(){

DruidDataSourcedruidDataSource=newDruidDataSource();

druidDataSource.setUsername(multipleDataSourceProperties.getData1().getUser());

druidDataSource.setPassword(multipleDataSourceProperties.getData1().getPassword());

druidDataSource.setUrl(multipleDataSourceProperties.getData1().getUrl());

druidDataSource.setDriverClassName(multipleDataSourceProperties.getData1().getDriver());

returndruidDataSource;

*設(shè)置多數(shù)據(jù)源

*@paramdata0

*@paramdata1

*@return

@Bean

publicMultiDataSourcemultiDataSource(DataSourcedata0,DataSourcedata1){

//將多個(gè)數(shù)據(jù)與數(shù)據(jù)源關(guān)聯(lián)起來

MultiDataSourcemultiDataSource=newMultiDataSource();

HashMapObject,ObjectmultiMap=newHashMap();

multiMap.put("data0",data0);

multiMap.put("data1",data1);

//設(shè)置目標(biāo)數(shù)據(jù)源

multiDataSource.setTargetDataSources(multiMap);

//設(shè)置默認(rèn)的數(shù)據(jù)源

multiDataSource.setDefaultTargetDataSource(data0);

//設(shè)置數(shù)據(jù)源名稱的映射

MapInteger,StringmultiMappings=newHashMap();

multiMappings.put(0,"data0");

multiMappings.put(1,"data1");

multipleStategyProperties.setDataSourceKeysMapping(multiMappings);

returnmultiDataSource;

*將多數(shù)據(jù)源設(shè)置進(jìn)mybatis的工廠類中

*@parammultiDataSource

*@return

@Bean

publicSqlSessionFactorysqlSessionFactory(@Qualifier("multiDataSource")MultiDataSourcemultiDataSource)throwsException{

SqlSessionFactoryBeansqlSessionFactoryBean=newSqlSessionFactoryBean();

sqlSessionFactoryBean.setDataSource(multiDataSource);

sqlSessionFactoryBean.setMapperLocations(newPathMatchingResourcePatternResolver().getResources("classpath:/mybatis/mappers/*.xml"));

sqlSessionFactoryBean.setType