详解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的内容,就不一一展示了。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。