详解SpringBoot和Mybatis配置多数据源
目前业界操作数据库的框架一般是Mybatis，但在很多业务场景下，我们需要在一个工程里配置多个数据源来实现业务逻辑。在SpringBoot中也可以实现多数据源并配合Mybatis框架编写xml文件来执行SQL。在SpringBoot中，配置多数据源的方式十分便捷，
下面开始上代码：
在pom.xml文件中需要添加一些依赖
org.mybatis.spring.boot mybatis-spring-boot-starter 1.2.0 mysql mysql-connector-java 5.1.39 com.alibaba druid 1.0.18
application.properties配置两个数据源配置
#master数据源配置 master.datasource.url=jdbc:mysql://localhost:3306/springbootdb?useUnicode=true&characterEncoding=utf8 master.datasource.username=root master.datasource.password=xieshuai6666 master.datasource.driverClassName=com.mysql.jdbc.Driver #second数据源配置 second.datasource.url=jdbc:mysql://localhost:3306/springbootdb_second?useUnicode=true&characterEncoding=utf8 second.datasource.username=root second.datasource.password=xieshuai6666 second.datasource.driverClassName=com.mysql.jdbc.Driver
数据源配置
多数据源配置的时候注意，必须要有一个主数据源，即MasterDataSourceConfig配置
- @Primary标志这个Bean如果在多个同类Bean候选时，该Bean优先被考虑。「多数据源配置的时候注意，必须要有一个主数据源，用@Primary标志该Bean
- @MapperScan扫描Mapper接口并容器管理，包路径精确到master，为了和下面cluster数据源做到精确区分
- @Value获取全局配置文件application.properties的kv配置,并自动装配sqlSessionFactoryRef表示定义了key，表示一个唯一SqlSessionFactory实例
MasterDataSourceConfig的代码：
@Configuration
//扫描Mapper接口并容器管理
@MapperScan(basePackages=MasterDataSourceConfig.PACKAGE,sqlSessionFactoryRef="masterSqlSessionFactory")
publicclassMasterDataSourceConfig{
//精确到master目录，以便跟其他数据源隔离
staticfinalStringPACKAGE="org.spring.springboot.dao.master";
staticfinalStringMAPPER_LOCATION="classpath:mapper/master/*.xml";
@Value("${master.datasource.url}")
privateStringurl;
@Value("${master.datasource.username}")
privateStringuser;
@Value("${master.datasource.password}")
privateStringpassword;
@Value("${master.datasource.driverClassName}")
privateStringdriverClass;
@Bean(name="masterDataSource")
@Primary
publicDataSourcemasterDataSource(){
DruidDataSourcedataSource=newDruidDataSource();
dataSource.setDriverClassName(driverClass);
dataSource.setUrl(url);
dataSource.setUsername(user);
dataSource.setPassword(password);
returndataSource;
}
@Bean(name="masterTransactionManager")
@Primary
publicDataSourceTransactionManagermasterTransactionManager(){
returnnewDataSourceTransactionManager(masterDataSource());
}
@Bean(name="masterSqlSessionFactory")
@Primary
publicSqlSessionFactorymasterSqlSessionFactory(@Qualifier("masterDataSource")DataSourcemasterDataSource)
throwsException{
finalSqlSessionFactoryBeansessionFactory=newSqlSessionFactoryBean();
sessionFactory.setDataSource(masterDataSource);
sessionFactory.setMapperLocations(newPathMatchingResourcePatternResolver()
.getResources(MasterDataSourceConfig.MAPPER_LOCATION));
returnsessionFactory.getObject();
}
}
第二个数据源SecondDataSourceConfig的配置如下:
@Configuration
//扫描Mapper接口并容器管理
@MapperScan(basePackages=ClusterDataSourceConfig.PACKAGE,sqlSessionFactoryRef="clusterSqlSessionFactory")
publicclassClusterDataSourceConfig{
//精确到cluster目录，以便跟其他数据源隔离
staticfinalStringPACKAGE="org.spring.springboot.dao.cluster";
staticfinalStringMAPPER_LOCATION="classpath:mapper/cluster/*.xml";
@Value("${cluster.datasource.url}")
privateStringurl;
@Value("${cluster.datasource.username}")
privateStringuser;
@Value("${cluster.datasource.password}")
privateStringpassword;
@Value("${cluster.datasource.driverClassName}")
privateStringdriverClass;
@Bean(name="clusterDataSource")
publicDataSourceclusterDataSource(){
DruidDataSourcedataSource=newDruidDataSource();
dataSource.setDriverClassName(driverClass);
dataSource.setUrl(url);
dataSource.setUsername(user);
dataSource.setPassword(password);
returndataSource;
}
@Bean(name="clusterTransactionManager")
publicDataSourceTransactionManagerclusterTransactionManager(){
returnnewDataSourceTransactionManager(clusterDataSource());
}
@Bean(name="clusterSqlSessionFactory")
publicSqlSessionFactoryclusterSqlSessionFactory(@Qualifier("clusterDataSource")DataSourceclusterDataSource)
throwsException{
finalSqlSessionFactoryBeansessionFactory=newSqlSessionFactoryBean();
sessionFactory.setDataSource(clusterDataSource);
sessionFactory.setMapperLocations(newPathMatchingResourcePatternResolver()
.getResources(ClusterDataSourceConfig.MAPPER_LOCATION));
returnsessionFactory.getObject();
}
}
到此，不同的数据源配置就已经完成，剩下的只需要将将Mybatis的xml文件和DAO层的接口写好，并在Service层注入，直接使用就行。
Service层的代码：
@Service
publicclassUserAndCityServiceImplimplementsUserAndCityService{
@Autowired
privateUserDaouserDao;
@Autowired
privateCityDaocityDao;
@Override
publicUserVogetUser(StringuserName){
UserVouserVo=userDao.selectByUserName(userName);
CityVocityVo=cityDao.selectByCityName("北京市");
userVo.setDescription(cityVo.getCityName());
returnuserVo;
}
}
Mybatis的xml文件UserDao.xml和CityDao.xml的内容，就不一一展示了。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持毛票票。