开发者社区> 田大汪> 正文

Spring-Boot + Mybatis 多数据源配置

简介: Spring-Boot + Mybatis 多数据源
+关注继续查看


折腾了一天,终于完成了多数据源的配置,记录在这里!

1,先上SpringBoot 基础配置


5445199fee730a4259fea748791eb03d7d1b6ff8

        ①,系统引入了Security的包,但是没有配置Security相关信息,在启动时会打印警告log,故这里排除SecurityAutoConfiguration这个类


2,配置两个数据源



@Configuration
public class DataBaseConfig implements EnvironmentAware {

	private RelaxedPropertyResolver dbPropertyResolver;

	private static final Logger logger = LoggerFactory.getLogger(EnvironmentAware.class);

	@Override
	public void setEnvironment(Environment environment) {
		dbPropertyResolver = new RelaxedPropertyResolver(environment,"jdbc.");
	}


	/**
	 * 写库
	 * @return
	 */
	@Bean(name="writeDataSource", destroyMethod = "close", initMethod="init")
	@Primary
	public DataSource writeDataSource() {
		DruidDataSource datasource = new DruidDataSource();
		datasource.setUrl(dbPropertyResolver.getProperty("url"));
		datasource.setDriverClassName(dbPropertyResolver.getProperty("driverClass"));
		datasource.setUsername(dbPropertyResolver.getProperty("username"));
		datasource.setPassword(dbPropertyResolver.getProperty("password"));
		return datasource;
	}

	/**
	 * 读库
	 * @return
	 */
	@Bean(name="readDataSource", destroyMethod = "close", initMethod="init")
	public DataSource readOneDataSource() {
		DruidDataSource datasource = new DruidDataSource();
		datasource.setUrl(dbPropertyResolver.getProperty("url"));
		datasource.setDriverClassName(dbPropertyResolver.getProperty("driverClassName"));
		datasource.setUsername(dbPropertyResolver.getProperty("username"));
		datasource.setPassword(dbPropertyResolver.getProperty("password"));
		return datasource;
	}
}

②,将写库作为默认主数据源,在注入时,若没有指定该注入哪一个数据源,默认注入使用写库数据源



3,配置只读数据源与Mybatis的配置信息



@Configuration
@EnableTransactionManagement
@AutoConfigureAfter(WriteMybatisConfig.class)
public class ReadMybatisConfig implements EnvironmentAware {

	/**
	 * 日志记录器
	 */
	private static final Logger LOGGER = LoggerFactory.getLogger(ReadMybatisConfig.class);

	private RelaxedPropertyResolver mybatisPropertyResolver;

	/**
	 * 获取配置信息
	 * @param environment
	 */
	@Override
	public void setEnvironment(Environment environment) {
		mybatisPropertyResolver = new RelaxedPropertyResolver(environment,"mybatis.");
	}

	//从库数据源
	@Resource(name = "readDataSource")
	private DataSource readDataSource;

	/**
	 * 只读sqlSessionFactory
	 * @return
	 */
	@Bean(name = "readSqlSessionFactory")
	public SqlSessionFactory readSqlSessionFactory() {
		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
		bean.setDataSource(readDataSource);
		bean.setTypeAliasesPackage(mybatisPropertyResolver.getProperty("typeAliasesPackage"));

		//分页插件
		PageHelper pageHelper = new PageHelper();
		Properties properties = new Properties();
		properties.setProperty("reasonable", "true");
		properties.setProperty("supportMethodsArguments", "true");
		properties.setProperty("returnPageInfo", "check");
		properties.setProperty("params", "count=countSql");
		pageHelper.setProperties(properties);
		bean.setPlugins(new Interceptor[]{pageHelper});

		//添加mybatis配置文件
		PathMatchingResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
		bean.setConfigLocation(resourceResolver.getResource(mybatisPropertyResolver.getProperty("configLocation")));
		try {
			bean.setMapperLocations(resourceResolver.getResources(mybatisPropertyResolver.getProperty("mapperLocations")));
			return bean.getObject();
		} catch (IOException e) {
			LOGGER.error("获取mapper资源出现异常",e);
			throw new RuntimeException("获取mapper资源出现异常",e);
		} catch (Exception e){
			LOGGER.error("初始化sqlSessionFactory时出现异常",e);
			throw new RuntimeException("初始化sqlSessionFactory时出现异常",e);
		}
	}

}

4,配置写数据源与Mybatis的配置



@Configuration
@EnableTransactionManagement
@AutoConfigureAfter
public class WriteMybatisConfig implements EnvironmentAware {
    public static final Logger LOGGER = LoggerFactory.getLogger(WriteMybatisConfig.class);

	private RelaxedPropertyResolver mybatisPropertyResolver;

	@Override
	public void setEnvironment(Environment environment) {
		mybatisPropertyResolver = new RelaxedPropertyResolver(environment,"mybatis.");
	}

	//写库
	@Resource(name = "writeDataSource")
    private DataSource writeDataSource;

	/**
	 * 可读可写sqlSessionFactory
	 * @return
	 */
    @Bean(name = "writeSqlSessionFactory")
    public SqlSessionFactory writeSqlSessionFactory() {
        SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
        bean.setDataSource(writeDataSource);
        bean.setTypeAliasesPackage(mybatisPropertyResolver.getProperty("typeAliasesPackage"));

        //分页插件
        PageHelper pageHelper = new PageHelper();
        Properties properties = new Properties();
        properties.setProperty("reasonable", "true");
        properties.setProperty("supportMethodsArguments", "true");
        properties.setProperty("returnPageInfo", "check");
        properties.setProperty("params", "count=countSql");
        pageHelper.setProperties(properties);
        bean.setPlugins(new Interceptor[]{pageHelper});

        //添加mybatis配置文件
		PathMatchingResourcePatternResolver resourceResolver = new PathMatchingResourcePatternResolver();
		bean.setConfigLocation(resourceResolver.getResource(mybatisPropertyResolver.getProperty("configLocation")));
        try {
			bean.setMapperLocations(resourceResolver.getResources(mybatisPropertyResolver.getProperty("mapperLocations")));
			return bean.getObject();
        } catch (IOException e) {
			LOGGER.error("获取mapper资源出现异常",e);
            throw new RuntimeException("获取mapper资源出现异常",e);
        } catch (Exception e){
			LOGGER.error("初始化sqlSessionFactory时出现异常",e);
			throw new RuntimeException("初始化sqlSessionFactory时出现异常",e);
		}
    }

	/**
	 * 因为当前项目中有
	 * @return
	 */
	@Bean(name = "writeTransactionManager")
	public DataSourceTransactionManager writeTransactionManager() {
		DataSourceTransactionManager manager = new DataSourceTransactionManager(writeDataSource);
		return manager;
	}


}


注意,写数据源对应的持久化操作需要用到事务,所以配置了DataSourceTransactionManager


5,配置Mybatis的Mapper扫描器



@Configuration
public class MybatisMapperScannerConfig {

	/**
	 * 扫描读写模式-mapper,只有在basePackage包下且继承自BaseWriterMapper的mapper才会被扫描到
	 * @return
	 */
	@Bean(name = "writeMapperScanner")
	public MapperScannerConfigurer writeMapperScanner(){
		MapperScannerConfigurer configurer = new MapperScannerConfigurer();
		configurer.setBasePackage("com.llktop.dao");
		configurer.setMarkerInterface(BaseWriteMapper.class);
		configurer.setSqlSessionFactoryBeanName("writeSqlSessionFactory");
		return configurer;
	}

	/**
	 * 扫描只读模式-mapper,只有在basePackage包下且继承自BaseReadMapper的mapper才会被扫描到
	 * @return
	 */
	@Bean(name = "readMapperScanner")
	public MapperScannerConfigurer readMapperScanner(){
		MapperScannerConfigurer configurer = new MapperScannerConfigurer();
		configurer.setBasePackage("com.llktop.dao");
		configurer.setMarkerInterface(BaseReadMapper.class);
		configurer.setSqlSessionFactoryBeanName("readSqlSessionFactory");
		return configurer;
	}
}

注意,这里多配置了一个叫MarkerInterface的属性,目的是,所有的mapper中只有继承自BaseWriteMapper这个类的Mapper会走写数据源,而所有继承自ReadMapper的Mapper会走读数据源


这样,就做到了多套数据源,可以配合Mysql读写分离进行使用!



版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
多数据源配置Jpa(十六)上
多数据源配置Jpa(十六)上
32 0
springboot自定义start解析(start中配置从数据源)
在springboot相比于springmvc提供了一个极为重要的功能,就是自定义start(自定义jar包),同时spring也提供了一大波start。如spring-boot-starter-data-redis,spring-boot-starter-amqp。本文将教你如何自定义start。例子为从start中获取数据源。
74 0
Spring Boot 多数据源,整合 Atomikos 实现分布式事务
最近的项目需要整合两个数据库,有些业务逻辑也涉及到两个数据库同时插入、更新的操作;所以就涉及到跨数据库的数据一致性问题。于是基于 `Spring Boot` 整合了 `Atomikos` 的一个项目 demo。
2112 0
SpringBoot2 配置多数据源,整合MybatisPlus增强插件
本文源码:GitHub·点这里 || GitEE·点这里 一、项目案例简介 1、多数据简介 实际的项目中,经常会用到不同的数据库以满足项目的实际需求。随着业务的并发量的不断增加,一个项目使用多个数据库:主从复制、读写分离、分布式数据库等方式,越来越常见。
2625 0
SpringBoot:配置数据源详解
SpringBoot:配置数据源详解
65 0
SpringBoot2.0.3整合Mybatis添加动态数据源实现多库查询(DynamicDataSource)
最近由于项目使用了spring boot 2.0.3版本,业务从多个数据查询,必须支持动态数据源,由于2.0.3的版本与之前的版本有了较大的改动其实现上有些不同,再采坑以后在此记录
9791 0
springboot 详解 (三) 多数据源
 ---------------------------------------------------------------------------------------------------------------- springboot 详解 (一) helloworld...
1073 0
谈谈Spring Boot 数据源加载及其多数据源简单实现
业务需求 提供所有微服务数据源的图形化维护功能 代码生成可以根据选择的数据源加载表等源信息 数据源管理要支持动态配置,实时生效附录效果图 实现思路 本文提供方法仅供类似简单业务场景,在生产环境和复杂的业务场景 请使用分库分表的中间件(例如mycat)或者框架 sharding-sphere (一直在用)等 先来看Spring 默认的数据源注入策略,如下代码默认的事务管理器在初始化时回去加载数据源实现。
1154 0
spring-boot | 使员Druid 整合Mybatis 最简配置多数据源
在实际开发过程中,同一个项目很可能需要多个数据源进行支持,所以今天我把自己整合Mybatis多数据源的过程和大家分享下。 添加所需依赖 mysql mysql-connector-java ...
2656 0
+关注
1
文章
2
问答
文章排行榜
最热
最新
相关电子书
更多
OceanBase 入门到实战教程
立即下载
阿里云图数据库GDB,加速开启“图智”未来.ppt
立即下载
实时数仓Hologres技术实战一本通2.0版(下)
立即下载