本文由 简悦 SimpRead 转码， 原文地址 blog.csdn.net
本文将详细介绍如何在 Spring Boot 应用程序中实现数据源配置与多数据源切换。我们将探讨 Spring Boot 的数据源配置方式，以及如何使用 Spring Boot 实现多数据源切换。最后，我们将通过一个具体示例来演示整个实现过程。本文适合已经具备 Spring Boot 基础知识的开发者阅读，以加深对 Spring Boot 数据源配置与多数据源切换的理解。
一、引言
在 Java 应用程序中，数据库连接是至关重要的组成部分。Spring Boot 为开发者提供了一种简便的方式来配置数据源。此外，在实际应用中，我们可能需要与多个数据库进行交互，因此需要实现多数据源切换的功能。本文将介绍如何在 Spring Boot 中实现数据源配置与多数据源切换，并通过具体示例来演示这一过程。
二、Spring Boot 数据源配置
1. 基本数据源配置
在 Spring Boot 中，我们可以通过在 application.properties 或 application.yml 文件中配置数据库连接信息来实现数据源的配置。以下是一个基本的数据库连接配置示例：
spring.datasource.url=jdbc:mysql://localhost:3306/test_db?useSSL=false
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
2. 使用数据源配置类
除了基本的属性配置外，我们还可以通过创建数据源配置类来配置数据源。以下是一个使用 HikariCP 数据源配置类的示例：
@Configuration
public class DataSourceConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource dataSource() {
return new HikariDataSource();
}
}
三、Spring Boot 实现多数据源切换
在某些情况下，我们可能需要在一个应用程序中与多个数据库进行交互。Spring Boot 支持多数据源切换的功能，我们可以通过以下步骤来实现：
1. 配置多个数据源
首先，我们需要在 application.properties 或 application.yml 文件中配置多个数据源的信息。以下是一个配置两个数据源的示例：
spring.datasource.db1.url=jdbc:mysql://localhost:3306/test_db1?useSSL=false
spring.datasource.db1.username=root
spring.datasource.db1.password=root
spring.datasource.db1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.db2.url=jdbc:mysql://localhost:3306/test_db2?useSSL=false
spring.datasource.db2.username=root
spring.datasource.db2.password=root
spring.datasource.db2.driver-class-name=com.mysql.cj.jdbc.Driver
2. 创建数据源配置类
接下来，我们需要创建一个数据源配置类，用于生成多个数据源对象。以下是一个使用 HikariCP 数据源配置类的示例：
@Configuration
public class DataSourceConfig {
@Bean(name = "db1DataSource")
@ConfigurationProperties(prefix = "spring.datasource.db1")
public DataSource db1DataSource() {
return new HikariDataSource();
}
@Bean(name = "db2DataSource")
@ConfigurationProperties(prefix = "spring.datasource.db2")
public DataSource db2DataSource() {
return new HikariDataSource();
}
}
3. 使用 @Qualifier 注解指定数据源
在需要使用特定数据源的地方，我们可以使用 @Qualifier 注解来指定使用哪个数据源。以下是一个使用 @Qualifier 注解的示例：
@Service
public class UserService {
@Autowired
@Qualifier("db1DataSource")
private DataSource db1DataSource;
@Autowired
@Qualifier("db2DataSource")
private DataSource db2DataSource;
public void addUser(String username, int age) {
// 使用db1DataSource插入用户数据
// 使用db2DataSource插入用户数据
}
}
四、具体示例
现在，我们将通过一个具体示例来演示如何在 Spring Boot 应用程序中实现数据源配置与多数据源切换。
1. 创建 Spring Boot 项目
首先，我们需要创建一个 Spring Boot 项目。在创建项目时，选择相应的项目模板和依赖。本文以 Maven 项目为例，添加以下依赖：
<dependencies>
<!-- Spring Boot Web依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- Spring Boot JPA依赖 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<!-- MySQL驱动依赖 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
</dependencies>
2. 配置数据源
在 application.properties 文件中，添加以下数据源配置：
spring.datasource.db1.url=jdbc:mysql://localhost:3306/test_db1?useSSL=false
spring.datasource.db1.username=root
spring.datasource.db1.password=root
spring.datasource.db1.driver-class-name=com.mysql.cj.jdbc.Driver
spring.datasource.db2.url=jdbc:mysql://localhost:3306/test_db2?useSSL=false
spring.datasource.db2.username=root
spring.datasource.db2.password=root
spring.datasource.db2.driver-class-name=com.mysql.cj.jdbc.Driver
3. 创建数据源配置类
在 src/main/java/com/example/demo/config 目录下，创建一个名为 DataSourceConfig.java 的文件，用于配置两个数据源：
package com.example.demo.config;
import com.zaxxer.hikari.HikariDataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.context.annotation.Qualifier;
import javax.sql.DataSource;
@Configuration
public class DataSourceConfig {
@Primary
@Bean(name = "db1DataSource")
@ConfigurationProperties(prefix = "spring.datasource.db1")
public DataSource db1DataSource() {
return new HikariDataSource();
}
@Bean(name = "db2DataSource")
@ConfigurationProperties(prefix = "spring.datasource.db2")
public DataSource db2DataSource() {
return new HikariDataSource();
}
}
4. 创建 JPA 实体类
在 src/main/java/com/example/demo/entity 目录下，创建一个名为 User.java 的文件，用于表示用户表：
package com.example.demo.entity;
import javax.persistence.Entity;
import javax.persistence.Id;
@Entity
public class User {
@Id
private Long id;
private String name;
private Integer age;
// getter和setter方法
}
5. 创建 JPA 仓库接口
在 src/main/java/com/example/demo/repository 目录下，创建一个名为 UserRepository.java 的文件，用于定义用户仓库接口：
package com.example.demo.repository;
import com.example.demo.entity.User;
import org.springframework.data.jpa.repository.JpaRepository;
public interface UserRepository extends JpaRepository<User, Long> {
}
6. 创建 Service 类
在 src/main/java/com/example/demo/service 目录下，创建一个名为 UserService.java 的文件，用于实现用户服务：
package com.example.demo.service;
import com.example.demo.entity.User;
import com.example.demo.repository.UserRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class UserService {
@Autowired
private UserRepository userRepository;
public void addUser(User user) {
userRepository.save(user);
}
}
7. 创建 Controller 类
在 src/main/java/com/example/demo/controller 目录下，创建一个名为 UserController.java 的文件，用于实现用户控制器：
package com.example.demo.controller;
import com.example.demo.entity.User;
import com.example.demo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class UserController {
@Autowired
private UserService userService;
@PostMapping("/addUser")
public String addUser(@RequestBody User user) {
userService.addUser(user);
return "User added successfully";
}
}
8. 运行项目
将以上代码添加到您的 Spring Boot 项目中，并运行项目。我们可以使用 Postman 或 curl 工具向http://localhost:8080/addUser发送 POST 请求，以添加用户数据。
五、总结
本文详细介绍了如何在 Spring Boot 应用程序中实现数据源配置与多数据源切换。我们首先了解了 Spring Boot 的基本数据源配置方法，然后学习了如何使用数据源配置类来配置多个数据源。接着，我们探讨了如何使用 @Qualifier 注解在需要使用特定数据源的地方指定数据源。最后，我们通过一个具体示例演示了如何在 Spring Boot 应用程序中实现多数据源切换。
通过本文，您应该已经掌握了如何在 Spring Boot 中配置和管理多个数据源，以及在实际应用中实现多数据源切换的方法。希望本文能够帮助您在开发多数据源的 Spring Boot 应用程序时更加得心应手。如果您有任何疑问或建议，请随时留言交流。