spring boot 多数据源 + 事务控制

缺乏、安全感 2022-02-26 07:35 550阅读 0赞

一、spring boot 多数据源

1.配置文件application.yml：

# 数据源
    spring:
        datasource:
           # master数据源配置
           master:
               driverClassName: com.mysql.jdbc.Driver
               url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf-8
               username: root
               password: root
           # cluster数据源配置
           cluster:
               driverClassName: com.mysql.jdbc.Driver
               url: jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8
               username: root
               password: root

2.两个dataSourceConfig数据源配置类，类里创建不同数据库对应的事物管理器，并注册到spring容器中去。

@Bean(name = "masterTransactionManager")   @Bean(name = "clusterTransactionManager") @Primary 注解控制哪个事务管理器为默认事物管理器

package com.spring.boot.config;
    
    import javax.sql.DataSource; 
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.SqlSessionTemplate;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.boot.jdbc.DataSourceBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    /**
     * mysql从库配置类
     * @日期： 2019年3月29日
     * @作者： yuzt
     */
    @Configuration
    @MapperScan(basePackages = "com.spring.boot.mapper.cluster",sqlSessionTemplateRef = "clusterSqlSessionTemplate")
    public class ClusterDataSourceConfig {
    
    	/**
    	 * 创建数据源
    	 *@return DataSource
    	 */
    	@Bean(name = "clusterDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.cluster")
    	public DataSource masterDataSource() {
    		return DataSourceBuilder.create().build();
    	}
    	
    	/**
    	 * 创建工厂
    	 *@param dataSource
    	 *@throws Exception
    	 *@return SqlSessionFactory
    	 */
    	@Bean(name = "clusterSqlSessionFactory")
    	public SqlSessionFactory masterSqlSessionFactory(@Qualifier("clusterDataSource") DataSource dataSource) throws Exception {
    		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    		bean.setDataSource(dataSource);
    		bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/cluster/*.xml"));
    		return bean.getObject();
    	}
    	
    	/**
    	 * 创建事务
    	 *@param dataSource
    	 *@return DataSourceTransactionManager
    	 */
    	@Bean(name = "clusterTransactionManager")
    	public DataSourceTransactionManager masterDataSourceTransactionManager(@Qualifier("clusterDataSource") DataSource dataSource) {
    		return new DataSourceTransactionManager(dataSource);
    	}
    	
    	/**
    	 * 创建模板
    	 *@param sqlSessionFactory  
    	 *@return SqlSessionTemplate
    	 */
    	@Bean(name = "clusterSqlSessionTemplate")
    	public SqlSessionTemplate masterSqlSessionTemplate(@Qualifier("clusterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    		return new SqlSessionTemplate(sqlSessionFactory);
    	}
    	
    }

package com.spring.boot.config;
    
    import javax.sql.DataSource;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionFactoryBean;
    import org.mybatis.spring.SqlSessionTemplate;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.boot.jdbc.DataSourceBuilder;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    
    /**
     * mysql主库配置类
     * @日期： 2019年3月29日
     * @作者： yuzt
     */
    @Configuration
    @MapperScan(basePackages = "com.spring.boot.master.mapper",sqlSessionTemplateRef = "masterSqlSessionTemplate")
    public class MasterDataSourceConfig {
    
    	/**
    	 * 创建数据源
    	 *@return DataSource
    	 */
    	@Bean(name = "masterDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.master")
    	@Primary
    	public DataSource masterDataSource() {
    		return DataSourceBuilder.create().build();
    	}
    	
    	/**
    	 * 创建工厂
    	 *@param dataSource
    	 *@throws Exception
    	 *@return SqlSessionFactory
    	 */
    	@Bean(name = "masterSqlSessionFactory")
    	@Primary
    	public SqlSessionFactory masterSqlSessionFactory(@Qualifier("masterDataSource") DataSource dataSource) throws Exception {
    		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    		bean.setDataSource(dataSource);
    		bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/master/*.xml"));
    		return bean.getObject();
    	}
    	
    	/**
    	 * 创建事务
    	 *@param dataSource
    	 *@return DataSourceTransactionManager
    	 */
    	@Bean(name = "masterTransactionManager")
    	@Primary
    	public DataSourceTransactionManager masterDataSourceTransactionManager(@Qualifier("masterDataSource") DataSource dataSource) {
    		return new DataSourceTransactionManager(dataSource);
    	}
    	
    	/**
    	 * 创建模板
    	 *@param sqlSessionFactory  
    	 *@return SqlSessionTemplate
    	 */
    	@Bean(name = "masterSqlSessionTemplate")
    	@Primary
    	public SqlSessionTemplate masterSqlSessionTemplate(@Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    		return new SqlSessionTemplate(sqlSessionFactory);
    	}
    	
    }

3.目录结构

![20190329123415591.png][]![20190329123429537.png][]

二、spring boot 事物控制

1.在启动类BootdoApplication上添加@EnableTransactionManagement 注解

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1em9uZ3Rhbw_size_16_color_FFFFFF_t_70][]

2.在service层添加@Transactional注解

@Transactional(readOnly = true,rollbackFor = Exception.class,transactionManager = "clusterTransactionManager",
          isolation = Isolation.READ_UNCOMMITTED,propagation = Propagation.REQUIRED)

![20190329123750223.png][]

[20190329123415591.png]: https://img-blog.csdnimg.cn/20190329123415591.png
[20190329123429537.png]: /images/20220226/76812b381d3f45a2b9d36de0be491f7d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3l1em9uZ3Rhbw_size_16_color_FFFFFF_t_70]: /images/20220226/afe5d7b9e3024e75ad26fd8fd654d8fe.png
[20190329123750223.png]: /images/20220226/578caba3128a4f5eac197ec677720d40.png