连接数据库的多数据源配置有多种方式,简单介绍两种比较常见的:
一、第一种方式
MybatisPlus自带多数据源功能:
使用 @DS 切换数据源
@DS 可以注解在方法上或类上,同时存在就近原则 方法上注解 优先于 类上注解。
注解 | 结果 |
---|---|
没有@DS | 默认数据源 |
@DS("dsName") | dsName可以为组名也可以为具体某个库的名称 |
@Service
@DS("slave")
public class UserServiceImpl implements UserService {
@Autowired
private JdbcTemplate jdbcTemplate;
public List selectAll() {
return jdbcTemplate.queryForList("select * from user");
}
@Override
@DS("slave_1")
public List selectByCondition() {
return jdbcTemplate.queryForList("select * from user where age >10");
}
}
这种方式配起来感觉比较繁琐,需要分库的每个类都需要配置。
二、第二种方式
配置数据源(mybatis的配置方式)
@Configuration
@MapperScan(basePackages = "com.*.dao", sqlSessionTemplateRef = "serviceSqlSessionTemplate")
public class ServiceDataSourceConfig {
@Bean("serviceDataSource")
@ConfigurationProperties("spring.datasource.service")
public HikariDataSource dataSource() {
return new HikariDataSource();
}
/**
* 创建SessionFactory
*/
@Bean(name = "serviceSqlSessionFactory")
public SqlSessionFactory serviceSqlSessionFactory(@Qualifier("serviceDataSource") DataSource dataSource) throws Exception {
SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
bean.setDataSource(dataSource);
//设置mapper配置文件
bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:sqlmap/*.xml"));
return bean.getObject();
}
/**
* 创建事务管理器
*/
@Bean("serviceTransactionManger")
public DataSourceTransactionManager serviceTransactionManger(@Qualifier("serviceDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
/**
* 创建SqlSessionTemplate
*/
@Bean(name = "serviceSqlSessionTemplate")
public SqlSessionTemplate serviceSqlSessionTemplate(@Qualifier("serviceSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
配置数据源(MybatisPlus的配置方式)
@Configuration
@MapperScan(basePackages = "com.*.dao", sqlSessionTemplateRef = "serviceSqlSessionTemplate")
public class ServiceDataSourceConfig {
@Bean
@ConfigurationProperties("spring.datasource.service")
public HikariDataSource serviceDataSource() {
return new HikariDataSource();
}
/**
* 创建SessionFactory
*/
@Bean
@Primary
public SqlSessionFactory serviceSqlSessionFactory(@Qualifier("serviceDataSource") DataSource dataSource) throws Exception {
MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();
bean.setDataSource(dataSource);
//设置mapper配置文件
bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:sqlmap/*.xml"));
return bean.getObject();
}
/**
* 创建事务管理器
*/
@Bean
@Primary
public DataSourceTransactionManager serviceTransactionManger(@Qualifier("serviceDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}
/**
* 创建SqlSessionTemplate
*/
@Bean
@Primary
public SqlSessionTemplate serviceSqlSessionTemplate(@Qualifier("serviceSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
区别在于创建SessionFactory时,
mybatis:
SqlSessionFactoryBean
MybatisPlus:
MybatisSqlSessionFactoryBean
如果用的是MybatisPlus,数据源里配的是SqlSessionFactoryBean,
那就会报Invalid bound statement (not found)