SpringBoot配置多数据源

傷城~ 2024-04-18 08:51 18阅读 0赞

**1.application.properties添加两个数据源连接参数**

#数据源1
    spring.datasource.db1.driver-class-name=oracle.jdbc.driver.OracleDriver
    spring.datasource.db1.jdbc-url=jdbc:oracle:thin:@192.168.100.1:1521:orcl
    spring.datasource.db1.username=test1
    spring.datasource.db1.password=test1
    
    #数据源2
    spring.datasource.db2.driver-class-name=oracle.jdbc.driver.OracleDriver
    spring.datasource.db2.jdbc-url=jdbc:oracle:thin:@192.168.100.2:1521:orcl
    spring.datasource.db2.username=test2
    spring.datasource.db2.password=test2

**2.创建主库配置类**

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;
    
    //主库配置类
    @Configuration
    @MapperScan(basePackages = "cn.com.app.dao.master",sqlSessionTemplateRef = "masterSqlSessionTemplate")
    public class MasterDataSourceConfig {
    	
    	/**
    	 * 创建数据源
    	 */
    	@Bean(name = "masterDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.db1") 
    	@Primary //设置为默认数据源
    	public DataSource masterDataSource() {
    		return DataSourceBuilder.create().build();
    	}
    	
    	/**
    	 * 创建工厂
    	 * @Qualifier参数对应上面数据源Bean的name值
    	 */
    	@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();
    	}
    	
    	/**
    	 * 创建事务
    	 */
    	@Bean(name = "masterTransactionManager")
    	@Primary
    	public DataSourceTransactionManager masterDataSourceTransactionManager(@Qualifier("masterDataSource") DataSource dataSource) {
    		return new DataSourceTransactionManager(dataSource);
    	}
    	
    	/**
    	 * 创建模板
    	 */
    	@Bean(name = "masterSqlSessionTemplate")
    	@Primary
    	public SqlSessionTemplate masterSqlSessionTemplate(@Qualifier("masterSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    		return new SqlSessionTemplate(sqlSessionFactory);
    	}
    }

**3.创建从库配置类**

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;
    
    //从库配置类
    @Configuration
    @MapperScan(basePackages = "cn.com.app.dao.slave",sqlSessionTemplateRef = "slaveSqlSessionTemplate")
    public class SlaveDataSourceConfig {
    
    	/**
    	 * 创建数据源
    	 */
    	@Bean(name = "slaveDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.db2") 
    	public DataSource slaveDataSource() {
    		return DataSourceBuilder.create().build();
    	}
    	
    	/**
    	 * 创建工厂
    	 * @Qualifier参数对应上面数据源Bean的name值
    	 */
    	@Bean(name = "slaveSqlSessionFactory")
    	public SqlSessionFactory slaveSqlSessionFactory(@Qualifier("slaveDataSource") DataSource dataSource) throws Exception {
    		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
    		bean.setDataSource(dataSource);
    		bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:mapper/slave/*.xml"));
    		return bean.getObject();
    	}
    	
    	/**
    	 * 创建事务
    	 */
    	@Bean(name = "slaveTransactionManager")
    	public DataSourceTransactionManager slaveDataSourceTransactionManager(@Qualifier("slaveDataSource") DataSource dataSource) {
    		return new DataSourceTransactionManager(dataSource);
    	}
    	
    	/**
    	 * 创建模板
    	 */
    	@Bean(name = "slaveSqlSessionTemplate")
    	public SqlSessionTemplate slaveSqlSessionTemplate(@Qualifier("slaveSqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    		return new SqlSessionTemplate(sqlSessionFactory);
    	}
    }

**4.创建主库接口及Mapper**

import java.util.List;
    import java.util.Map;
    
    import org.apache.ibatis.annotations.Mapper;
    
    @Mapper
    public interface MasterDao { 
    	
    	List<Map<String, Object>> selectPage();
    	
    }

**    Mapper:**

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    
    <mapper namespace="cn.com.app.dao.master.MasterDao">		
    	
    	<select id="selectPage" parameterType="java.util.Map" resultType="java.util.Map">
                SELECT * FROM QQ_JZDX_GOIP
    	</select>
      	
    </mapper>

**5.创建从库接口及Mapper**

import java.util.List;
    import java.util.Map;
    
    import org.apache.ibatis.annotations.Mapper;
    
    @Mapper
    public interface SlaveDao { 
    	
    	List<Map<String, Object>> selectPage();
    	
    }

**Mapper:**

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE mapper  PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"  "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
    
    <mapper namespace="cn.com.app.dao.slave.SlaveDao">		
    	
    	<select id="selectPage" parameterType="java.util.Map" resultType="java.util.Map">
                SELECT * FROM T_SYS_ACCOUNT
    	</select>
      	
    </mapper>

**6.测试查询两个数据库数据**

import java.util.List;
    import java.util.Map;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    import org.springframework.ui.Model;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.ResponseBody;
    
    import cn.com.app.dao.master.MasterDao;
    import cn.com.app.dao.slave.SlaveDao;
    
    @Controller
    public class TestController {
    	
    	@Autowired
    	private MasterDao masterDao;
    	@Autowired
    	private SlaveDao slaveDao;
    	
    	@RequestMapping("/test")
    	@ResponseBody
    	public void test(Model model) throws Exception {
    		List<Map<String, Object>> masterList = masterDao.selectPage();
    		System.out.println("主库查询结果："+masterList);
    		List<Map<String, Object>> slaveList = slaveDao.selectPage();
    		System.out.println("从库查询结果："+slaveList);
    	}	
    }

文件目录结构

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3JleHVlcWluZ2NodW4_size_16_color_FFFFFF_t_70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3JleHVlcWluZ2NodW4_size_16_color_FFFFFF_t_70]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/17/adaf2762387d499cb0f1d347bc92dd75.png