Spring Boot中如何配置和使用多数据源

大家好，我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编，也是冬天不穿秋裤，天冷也要风度的程序猿！今天，我们将深入探讨如何在Spring Boot应用中配置和使用多数据源，以满足复杂应用场景下的数据管理需求。

1. 引言

在许多现代应用中，数据存储和管理往往需要使用多个数据库，每个数据库可能有不同的访问权限、数据结构或者用途。Spring Boot提供了强大的支持来配置和管理多个数据源，使得开发者能够轻松地实现多数据源的配置和使用。

2. 准备工作

在开始之前，请确保你已经安装了以下软件和组件：

Java开发环境
Spring Boot框架

3. 创建Spring Boot项目

首先，让我们创建一个基本的Spring Boot项目。假设我们的包名是cn.juwatech.multidatasourcedemo。

package cn.juwatech.multidatasourcedemo;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class MultiDataSourceDemoApplication {public static void main(String[] args) {SpringApplication.run(MultiDataSourceDemoApplication.class, args);}
}

4. 配置多数据源

在application.properties中配置多个数据源的连接信息：

# 数据源1
spring.datasource.first.url=jdbc:mysql://localhost:3306/first_db
spring.datasource.first.username=root
spring.datasource.first.password=secret
spring.datasource.first.driver-class-name=com.mysql.jdbc.Driver# 数据源2
spring.datasource.second.url=jdbc:mysql://localhost:3306/second_db
spring.datasource.second.username=root
spring.datasource.second.password=secret
spring.datasource.second.driver-class-name=com.mysql.jdbc.Driver

5. 创建多数据源配置类

编写一个配置类，分别配置和注入多个数据源：

package cn.juwatech.multidatasourcedemo.config;import javax.sql.DataSource;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;@Configuration
public class DataSourceConfig {@Bean(name = "firstDataSource")@ConfigurationProperties(prefix = "spring.datasource.first")public DataSource firstDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "secondDataSource")@ConfigurationProperties(prefix = "spring.datasource.second")public DataSource secondDataSource() {return DataSourceBuilder.create().build();}
}

6. 创建JPA Repository

为每个数据源创建对应的JPA Repository接口：

package cn.juwatech.multidatasourcedemo.repository.first;import cn.juwatech.multidatasourcedemo.model.first.FirstEntity;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;@Repository
public interface FirstEntityRepository extends JpaRepository<FirstEntity, Long> {
}

package cn.juwatech.multidatasourcedemo.repository.second;import cn.juwatech.multidatasourcedemo.model.second.SecondEntity;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;@Repository
public interface SecondEntityRepository extends JpaRepository<SecondEntity, Long> {
}

7. 编写实体类

分别创建每个数据源的实体类，例如：

package cn.juwatech.multidatasourcedemo.model.first;import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;@Entity
public class FirstEntity {@Id@GeneratedValue(strategy = GenerationType.IDENTITY)private Long id;private String name;// 省略Getter和Setter方法
}

package cn.juwatech.multidatasourcedemo.model.second;import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;@Entity
public class SecondEntity {@Id@GeneratedValue(strategy = GenerationType.IDENTITY)private Long id;private String description;// 省略Getter和Setter方法
}

8. 使用多数据源

在Service层或Controller层使用@Qualifier注解指定具体的数据源：

package cn.juwatech.multidatasourcedemo.service;import cn.juwatech.multidatasourcedemo.model.first.FirstEntity;
import cn.juwatech.multidatasourcedemo.model.second.SecondEntity;
import cn.juwatech.multidatasourcedemo.repository.first.FirstEntityRepository;
import cn.juwatech.multidatasourcedemo.repository.second.SecondEntityRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;@Service
public class DataService {@Autowired@Qualifier("firstDataSource")private FirstEntityRepository firstRepository;@Autowired@Qualifier("secondDataSource")private SecondEntityRepository secondRepository;@Transactional(transactionManager = "firstTransactionManager")public void saveDataToFirstDB(FirstEntity entity) {firstRepository.save(entity);}@Transactional(transactionManager = "secondTransactionManager")public void saveDataToSecondDB(SecondEntity entity) {secondRepository.save(entity);}
}