Spring Boot集成MyBatis配置多数据源详细教程
一、工程创建
申明一点本案例使用的springboot版本是1.5.6.RELEASE。首先需要创建springBoot项目,添加springBoot框架对MyBatis支持的相关依赖Jar:分别添加MyBatis、MySQL以及Web依赖以及Druid依赖,这里添加Druid依赖必须是Spring boot支持的Druid,不能使用传统的Druid。完整的依赖jar如下:
<dependencies> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.10</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>fastjson</artifactId> <version>1.2.28</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.mybatis.spring.boot</groupId> <artifactId>mybatis-spring-boot-starter</artifactId> <version>1.3.3</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.15</version> <scope>runtime</scope> </dependency> </dependencies>
二、多数据源配置
接下来配置多数据源,首先在配置文件application.properties中配置2个数据库基本信息,然后配置两个DataSource即可,这里笔者把代码贴出来,并且附上解释说明信息。application.properties文件的配置:
server.port=7001 spring.application.name=springCloud-multiple-dataSources spring.instance.instance-id=${spring.application.name}:${server.port} ## 数据源1的配置(此处***替换成自己数据库的连接串以及用户名和密码) spring.datasource.wxdev.url= **** spring.datasource.wxdev.username=**** spring.datasource.wxdev.password=**** spring.datasource.wxdev.driverClassName=com.mysql.jdbc.Driver spring.datasource.wxdev.type=com.alibaba.druid.pool.DruidDataSource ## 数据源2的配置(此处***替换成自己数据库的连接串以及用户名和密码) spring.datasource.platform.url=*** spring.datasource.platform.username=**** spring.datasource.platform.password=**** spring.datasource.platform.driverClassName=com.mysql.jdbc.Driver spring.datasource.platform.type=com.alibaba.druid.pool.DruidDataSource logging.config=classpath:logback_spring.xml ## mybatis mapper文件配置 mybatis.mapper-locations=classpath:mybatis/mapper/*.xml mybatis.config-location=classpath:mybatis/mybatis-config.xml
然后再定义两个DataSource的配置类(分别对应上面的2个数据源),如下:
数据源1配置
@Configuration @MapperScan(basePackages = "com.chenyun.cloud.mapper.wxdev",sqlSessionTemplateRef = "SqlSessionTemplate1") public class DataSourceOneConfig { private static final String MAPPER_LOCATION = "classpath:mybatis/mapper/wxdev/*.xml"; @Value("${spring.datasource.wxdev.url}") private String url; @Value("${spring.datasource.wxdev.username}") private String user; @Value("${spring.datasource.wxdev.password}") private String password; @Value("${spring.datasource.wxdev.driverClassName}") private String driverClass; @Bean @Primary public DataSource dataSourceOne() { DruidDataSource dataSource = new DruidDataSource(); dataSource.setDriverClassName(driverClass); dataSource.setUrl(url); dataSource.setUsername(user); dataSource.setPassword(password); return dataSource; } @Bean(name = "dataSourceOneTransactionManager") public DataSourceTransactionManager transactionManager() { return new DataSourceTransactionManager(dataSourceOne()); } @Bean(name = "SqlSessionFactory1") public SqlSessionFactory getSqlSessionFactory1(@Qualifier("dataSourceOne") DataSource dataSource) throws Exception { final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean(); sessionFactory.setDataSource(dataSource); sessionFactory.setMapperLocations( new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION)); return sessionFactory.getObject(); } @Bean(name = "SqlSessionTemplate1") public SqlSessionTemplate getSqlSessionTemplate1( @Qualifier("SqlSessionFactory1") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } }
数据源2配置
@Configuration @MapperScan(basePackages = "com.chenyun.cloud.mapper.platform", sqlSessionTemplateRef = "SqlSessionTemplate2") public class DataSourceTwoConfig { private static final String MAPPER_LOCATION = "classpath:mybatis/mapper/platform/*.xml"; @Value("${spring.datasource.platform.url}") private String url; @Value("${spring.datasource.platform.username}") private String user; @Value("${spring.datasource.platform.password}") private String password; @Value("${spring.datasource.platform.driverClassName}") private String driverClass; @Bean(name = "dataSourceTwo") public DataSource dataSourceTwo() { DruidDataSource dataSource = new DruidDataSource(); dataSource.setDriverClassName(driverClass); dataSource.setUrl(url); dataSource.setUsername(user); dataSource.setPassword(password); return dataSource; } @Bean(name = "dataSourceOneTransactionManager") public DataSourceTransactionManager transactionManager() { return new DataSourceTransactionManager(dataSourceTwo()); } @Bean(name = "SqlSessionFactory2") public SqlSessionFactory getSqlSessionFactory2(@Qualifier("dataSourceTwo") DataSource dataSourceTwo) throws Exception { final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean(); sessionFactory.setDataSource(dataSourceTwo); sessionFactory.setMapperLocations( new PathMatchingResourcePatternResolver().getResources(MAPPER_LOCATION)); return sessionFactory.getObject(); } @Bean(name = "SqlSessionTemplate2") public SqlSessionTemplate getSqlSessionTemplate2( @Qualifier("SqlSessionFactory2") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } }
上面这个数据源配置类说明:在配置类上面加注解@Configuration表示这是一个可以被spring容器扫描到的配置类,配置类中注解@MapperScan表示要扫描的包路径com.chenyun.cloud.mapper.platform,即该包下的Mapper接口将操作dataSourceTwo中的数据,对应的SqlSessionFactory和SqlSessionTemplate分别是sqlSessionFactory2和sqlSessionTemplate2,在配置类内部,分别提供SqlSessionFactory和SqlSessionTemplate即可。需要注意的是,多数据源配置必须指定哪个数据源是主数据源,需用注解@Primary标明,例如本案例数据源dataSourceOne上的注解。
现在MyBatis多数据源就配置好了,接下来只需要在com.chenyun.cloud.mapper.wxdev和com.chenyun.cloud.mapper.platform包中提供不同的Mapper接口以及在resources目录下面创建不同xml映射文件。
接下来,在Service中注入两个不同的Mapper接口,就可以操作不同的数据源,关于springBoot集成MyBatis多数据源案例就分享到这里,如有问题,扫码关注公众号,联系笔者微信。