springboot(八):整合多資料來源
資料來源是如何劃分:
按包名(業務)和註解劃分 ;例如:com.test.learn01----使用datasource1; com.test.learn02----使用datasource2。
專案目錄結構:
配置檔案中新增兩個資料來源
建立資料來源DataSource1Config
@Configuration // 註冊到springboot容器中
@MapperScan(basePackages = "com.learn.datasource1", sqlSessionFactoryRef = "test1SqlSessionFactory")
public class DataSource1Config {
@Bean(name = "test1DataSource")
// 以spring.datasource.test1開頭去讀peroperties檔案的資料來源資訊
@ConfigurationProperties(prefix = "spring.datasource.test1")
@Primary
public DataSource testDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "test1SqlSessionFactory")
@Primary
public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)
throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
/*
* bean.setMapperLocations( new
* PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"))
* ;
*/
return bean.getObject();
}
@Bean(name = "test1TransactionManager")
@Primary
public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean(name = "test1SqlSessionTemplate")
@Primary
public SqlSessionTemplate testSqlSessionTemplate(
@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
建立資料來源DataSource2Config
@Configuration // 註冊到springboot容器中
@MapperScan(basePackages = "com.learn.datasource2", sqlSessionFactoryRef = "test2SqlSessionFactory")
public class DataSource2Config {
@Bean(name = "test2DataSource")
// 以spring.datasource.test1開頭去讀peroperties檔案的資料來源資訊
@ConfigurationProperties(prefix = "spring.datasource.test2")
public DataSource testDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "test2SqlSessionFactory")
public SqlSessionFactory testSqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource)
throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
/*
* bean.setMapperLocations( new
* PathMatchingResourcePatternResolver().getResources("classpath:mapper/*.xml"))
* ;
*/
return bean.getObject();
}
@Bean(name = "test2TransactionManager")
public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
@Bean(name = "test2SqlSessionTemplate")
public SqlSessionTemplate testSqlSessionTemplate(
@Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
寫Mappper介面
service層