码迷,mamicode.com
首页 > 编程语言 > 详细

springboot(八):整合多数据源

时间:2018-12-05 01:55:17      阅读:147      评论:0      收藏:0      [点我收藏+]

标签:注册   业务   service   .com   创建   cto   exce   base   temp   

数据源是如何划分:

  按包名(业务)和注解划分 ;例如: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层

技术分享图片

技术分享图片

技术分享图片

 

springboot(八):整合多数据源

标签:注册   业务   service   .com   创建   cto   exce   base   temp   

原文地址:https://www.cnblogs.com/xianshiwang/p/10068326.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!