SpringBoot學習——SpringBoot整合多資料源

一、為什麼需要多資料源

在項目中，可能會出現需要查詢不同資料庫的表的情況，是以這就需要配置多資料源。原則上可以配置無數個資料源，但是需要硬體的支援（記憶體等）。

二、整合多資料源的兩種方式

1. 分包，根據不同的業務劃分不同包名作為區分
2. 根據注解的方式，自定義注解

三、具體實作

本人才疏學淺，這裡就先實作第一種方式——分包，開發以及技術版本環境：eclipse、springboot2.0、jdk1.8

1.項目結構

根據不同的業務，我這裡劃分test01、test02兩個包

2.資料庫設計

3.pom檔案依賴

<dependencies>
		<!-- jdbcTemplate 依賴 -->
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-jdbc</artifactId>
		</dependency>
		<!-- mysql 依賴 -->
		<dependency>
			<groupId>mysql</groupId>
			<artifactId>mysql-connector-java</artifactId>
		</dependency>
		<dependency>
			<groupId>org.mybatis.spring.boot</groupId>
			<artifactId>mybatis-spring-boot-starter</artifactId>
			<version>1.1.1</version>
		</dependency>
		<!-- 測試 -->
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
			<scope>test</scope>
		</dependency>
		<!-- springboot-web元件 -->
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		<!-- Lombok插件 -->
		<dependency>
			<groupId>org.projectlombok</groupId>
			<artifactId>lombok</artifactId>
		</dependency>
	</dependencies>
           

4.配置檔案中新增兩個資料源

在配置檔案中自定義資料源，spring.datasource.test1.****、spring.datasource.test2.****、前半段是自定義的

###datasource1
spring.datasource.test1.driver-class-name = com.mysql.jdbc.Driver
spring.datasource.test1.jdbc-url = jdbc:mysql://localhost:3306/test01?useUnicode=true&characterEncoding=utf-8
spring.datasource.test1.username = root
spring.datasource.test1.password = root
###datasource2
spring.datasource.test2.driver-class-name = com.mysql.jdbc.Driver
spring.datasource.test2.jdbc-url = jdbc:mysql://localhost:3306/test02?useUnicode=true&characterEncoding=utf-8
spring.datasource.test2.username = root
spring.datasource.test2.password = root
           

5.配置資料源

因為在配置檔案中定義了兩個資料源，但是spring boot是無法識别的，是以就需要寫兩個配置檔案去配置資料源的相關内容

DataSource1Config.java

package com.zhu.dataSource;

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.jdbc.datasource.DataSourceTransactionManager;

//DataSource01
@Configuration // 注冊到springboot容器中
@MapperScan(basePackages = "com.zhu.test01.mapper", sqlSessionFactoryRef = "test1SqlSessionFactory")//basePackages的位址要寫全
public class DataSource1Config {

	/**
	 * 功能描述:(配置test1資料庫)
	 * @return
	 */
	@Bean(name = "test1DataSource")
	@ConfigurationProperties(prefix = "spring.datasource.test1")
	@Primary
	public DataSource testDataSource() {
		return DataSourceBuilder.create().build();
	}

	/**
	 * 功能描述:(test1 sql會話工廠)
	 * @param dataSource
	 * @return
	 * @throws Exception
	 */
	@Bean(name = "test1SqlSessionFactory")
	@Primary
	public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource)
			throws Exception {
		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
		bean.setDataSource(dataSource);
		// bean.setMapperLocations(
		// new
		// PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));
		return bean.getObject();
	}

	/**
	 * 功能描述:(test1 事物管理)
	 * @param dataSource
	 * @return
	 */
	@Bean(name = "test1TransactionManager")
	@Primary
	public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) {
		return new DataSourceTransactionManager(dataSource);
	}

	@Bean(name = "test1SqlSessionTemplate")
	@Primary
	public SqlSessionTemplate testSqlSessionTemplate(
			@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
		return new SqlSessionTemplate(sqlSessionFactory);
	}

}

           

DataSource2Config.jave

package com.zhu.dataSource;

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.jdbc.datasource.DataSourceTransactionManager;

//DataSource2
@Configuration // 注冊到springboot容器中
@MapperScan(basePackages = "com.zhu.test02.mapper", sqlSessionFactoryRef = "test2SqlSessionFactory")
public class DataSource2Config {

	/**
	 * 功能描述:(配置test2資料庫)
	 * @return
	 */
	@Bean(name = "test2DataSource")
	@ConfigurationProperties(prefix = "spring.datasource.test2")
	public DataSource testDataSource() {
		return DataSourceBuilder.create().build();
	}

	/**
	 * 功能描述:(test2 sql會話工廠)
	 * @param dataSource
	 * @return
	 * @throws Exception
	 */
	@Bean(name = "test2SqlSessionFactory")
	public SqlSessionFactory testSqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource)
			throws Exception {
		SqlSessionFactoryBean bean = new SqlSessionFactoryBean();
		bean.setDataSource(dataSource);
		// bean.setMapperLocations(
		// new
		// PathMatchingResourcePatternResolver().getResources("classpath:mybatis/mapper/test1/*.xml"));
		return bean.getObject();
	}

	/**
	 * 功能描述:(test2 事物管理)
	 * @param dataSource
	 * @return
	 */
	@Bean(name = "test2TransactionManager")
	public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) {
		return new DataSourceTransactionManager(dataSource);
	}

	@Bean(name = "test2SqlSessionTemplate")
	public SqlSessionTemplate testSqlSessionTemplate(
			@Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception {
		return new SqlSessionTemplate(sqlSessionFactory);
	}

}

           

@Primary：指定主資料源，spring boot2.0以下版本必須加上這個注解，否則會報錯，2.0可以不需要指定

@MapperScan(basePackages = "com.zhu.test01.mapper", sqlSessionFactoryRef = "test1SqlSessionFactory")

@MapperScan(basePackages = "com.zhu.test02.mapper", sqlSessionFactoryRef = "test2SqlSessionFactory")

包掃描，告訴spring boot我們的mapper層的位置。

6.spring boot整合多資料源demo下載下傳

https://download.csdn.net/download/qq_22774179/11504826