当前位置: 首页 > news >正文

Spring Boot 项目中的多数据源配置

关键词:Spring Boot、多数据源配置、MySQL、SQL Server、Oracle、动态切换


✅ 摘要

在实际企业级开发中,一个 Spring Boot 项目可能需要连接多个数据库,比如 MySQL、SQL Server 和 Oracle。不同的业务模块可能依赖不同的数据源,这就要求我们掌握 如何在 Spring Boot 中灵活配置和管理多个数据源

本文将围绕以下内容进行详细讲解:

  • Spring Boot 默认数据源配置方式
  • 配置单个数据库(MySQL、SQL Server、Oracle)
  • 多数据源配置与使用(MySQL + SQL Server + Oracle)
  • 使用 AbstractRoutingDataSource 实现动态数据源切换
  • 常见问题与解决方案(驱动类、URL格式、连接失败)

每部分都配有 完整的 application.yml 配置文件和 Java 配置类代码示例


📌 一、Spring Boot 数据源配置基础

🔹 1. 默认数据源配置(以 MySQL 为例)

spring:datasource:url: jdbc:mysql://localhost:3306/test_db?useSSL=false&serverTimezone=UTCusername: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Driver

⚠️ 注意:

  • url 要注意时区配置(serverTimezone)
  • 确保引入了正确的 JDBC 驱动包

📌 二、单个数据库的配置方式

🔹 1. MySQL 数据源配置

Maven 依赖:
<dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.33</version>
</dependency>
application.yml:
spring:datasource:mysql:url: jdbc:mysql://localhost:3306/mysql_db?useSSL=false&serverTimezone=UTCusername: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Driver

🔹 2. SQL Server 数据源配置

Maven 依赖:
<dependency><groupId>com.microsoft.sqlserver</groupId><artifactId>mssql-jdbc</artifactId><version>12.4.0.jre8</version>
</dependency>
application.yml:
spring:datasource:sqlserver:url: jdbc:sqlserver://localhost:1433;databaseName=SqlServerDB;encrypt=true;trustServerCertificate=false;loginTimeout=30;username: sapassword: yourStrongPassworddriver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver

🔹 3. Oracle 数据源配置

Maven 依赖(需手动下载 ojdbc jar 并安装到本地仓库):
mvn install:install-file -Dfile=ojdbc8.jar -DgroupId=com.oracle.database.jdbc -DartifactId=ojdbc8 -Dversion=21.10.0.0 -Dpackaging=jar
pom.xml 添加依赖:
<dependency><groupId>com.oracle.database.jdbc</groupId><artifactId>ojdbc8</artifactId><version>21.10.0.0</version>
</dependency>
application.yml:
spring:datasource:oracle:url: jdbc:oracle:thin:@//localhost:1521/ORCLCDBusername: systempassword: oracledriver-class-name: oracle.jdbc.OracleDriver

📌 三、多数据源配置(MySQL + SQL Server + Oracle)

🔹 1. application.yml 多数据源配置

spring:datasource:mysql:url: jdbc:mysql://localhost:3306/mysql_db?useSSL=false&serverTimezone=UTCusername: rootpassword: rootdriver-class-name: com.mysql.cj.jdbc.Driversqlserver:url: jdbc:sqlserver://localhost:1433;databaseName=SqlServerDB;encrypt=true;trustServerCertificate=false;loginTimeout=30;username: sapassword: yourStrongPassworddriver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriveroracle:url: jdbc:oracle:thin:@//localhost:1521/ORCLCDBusername: systempassword: oracledriver-class-name: oracle.jdbc.OracleDriver

🔹 2. Java 配置类实现多数据源注入

第一步:定义配置属性类
@Configuration
@ConfigurationProperties(prefix = "spring.datasource")
@Data
public class DataSourceProperties {private Map<String, DataSourceConfig> datasource;@Datapublic static class DataSourceConfig {private String url;private String username;private String password;private String driverClassName;}
}

第二步:创建多个数据源 Bean
@Configuration
@RequiredArgsConstructor
public class DataSourceConfig {private final DataSourceProperties dataSourceProperties;@Bean("mysqlDataSource")@ConfigurationProperties(prefix = "spring.datasource.mysql")public DataSource mysqlDataSource() {return DataSourceBuilder.create().url(dataSourceProperties.getDatasource().get("mysql").getUrl()).username(dataSourceProperties.getDatasource().get("mysql").getUsername()).password(dataSourceProperties.getDatasource().get("mysql").getPassword()).driverClassName(dataSourceProperties.getDatasource().get("mysql").getDriverClassName()).build();}@Bean("sqlServerDataSource")public DataSource sqlServerDataSource() {return DataSourceBuilder.create().url(dataSourceProperties.getDatasource().get("sqlserver").getUrl()).username(dataSourceProperties.getDatasource().get("sqlserver").getUsername()).password(dataSourceProperties.getDatasource().get("sqlserver").getPassword()).driverClassName(dataSourceProperties.getDatasource().get("sqlserver").getDriverClassName()).build();}@Bean("oracleDataSource")public DataSource oracleDataSource() {return DataSourceBuilder.create().url(dataSourceProperties.getDatasource().get("oracle").getUrl()).username(dataSourceProperties.getDatasource().get("oracle").getUsername()).password(dataSourceProperties.getDatasource().get("oracle").getPassword()).driverClassName(dataSourceProperties.getDatasource().get("oracle").getDriverClassName()).build();}
}

📌 四、动态切换数据源(基于 AbstractRoutingDataSource)

🔹 1. 定义当前线程使用的数据源标识

public class DynamicDataSourceContextHolder {private static final ThreadLocal<String> CONTEXT_HOLDER = new ThreadLocal<>();public static void setDataSourceKey(String key) {CONTEXT_HOLDER.set(key);}public static String getDataSourceKey() {return CONTEXT_HOLDER.get();}public static void clearDataSourceKey() {CONTEXT_HOLDER.remove();}
}

🔹 2. 自定义 AbstractRoutingDataSource

@Component
@RequiredArgsConstructor
public class DynamicDataSource extends AbstractRoutingDataSource {private final DataSource mysqlDataSource;private final DataSource sqlServerDataSource;private final DataSource oracleDataSource;@PostConstructpublic void init() {Map<Object, Object> targetDataSources = new HashMap<>();targetDataSources.put("mysql", mysqlDataSource);targetDataSources.put("sqlserver", sqlServerDataSource);targetDataSources.put("oracle", oracleDataSource);this.setTargetDataSources(targetDataSources);this.setDefaultTargetDataSource(mysqlDataSource); // 设置默认数据源this.afterPropertiesSet();}@Overrideprotected Object determineCurrentLookupKey() {return DynamicDataSourceContextHolder.getDataSourceKey();}
}

🔹 3. 配置为事务管理器的数据源

@Bean
public PlatformTransactionManager transactionManager(DynamicDataSource dynamicDataSource) {return new DataSourceTransactionManager(dynamicDataSource);
}

🔹 4. 在 Service 层使用动态数据源

@Service
@RequiredArgsConstructor
public class UserService {private final JdbcTemplate jdbcTemplate;public void queryFromMysql() {DynamicDataSourceContextHolder.setDataSourceKey("mysql");List<Map<String, Object>> result = jdbcTemplate.queryForList("SELECT * FROM user");System.out.println("MySQL 查询结果:" + result);}public void queryFromSqlServer() {DynamicDataSourceContextHolder.setDataSourceKey("sqlserver");List<Map<String, Object>> result = jdbcTemplate.queryForList("SELECT * FROM Users");System.out.println("SQL Server 查询结果:" + result);}public void queryFromOracle() {DynamicDataSourceContextHolder.setDataSourceKey("oracle");List<Map<String, Object>> result = jdbcTemplate.queryForList("SELECT * FROM employees");System.out.println("Oracle 查询结果:" + result);}
}

✅ 总结

以下几点为本文重点:

模块技能点
单数据源配置MySQL、SQL Server、Oracle 的基本配置方法
多数据源配置如何在一个 Spring Boot 项目中配置多个数据源
动态数据源切换使用 AbstractRoutingDataSource 实现运行时切换
实战能力结合 JdbcTemplate、事务管理器使用多数据源

这些技能是你构建复杂微服务系统、支持多数据库架构的重要基础。


📚 参考资料

  • Spring Boot 官方文档
  • Spring Data Access 文档
http://www.lryc.cn/news/582782.html

相关文章:

  • ElasticSearch集群状态查询及_cat 命令详解
  • GitHub Copilot 三种模式详解:Ask、Agent、Edit
  • 【web安全】SQLMap 参数深度解析:--risk 与 --level 详解
  • leetcode-二叉树的层序遍历-113
  • 基于Java+Maven+Testng+RestAssured+Allure+Jenkins搭建一个接口自动化框架
  • 谁主沉浮:人工智能对未来信息技术发展路径的影响研究
  • 基于 Rust 的Actix Web 框架的应用与优化实例
  • 从零构建MCP服务器:FastMCP实战指南
  • 基于物联网架构的温室环境温湿度传感器节点设计
  • 微信小程序控制空调之接收MQTT消息
  • Maven 打包排除特定依赖的完整指南(详细方法 + 示例)
  • 作业03-SparkSQL开发
  • 无缝矩阵的音频合成与音频分离功能详解
  • Rust BSS段原理与实践解析
  • RustFS一款Rust 驱动的 高性能 分布式存储系统
  • Modbus TCP转Profinet网关实现视觉相机与西门子PLC配置实例研究
  • Tomcat:启用https(Windows)
  • 传输层协议TCP、UDP
  • CI/CD — DevOps概念之实现k8s持续交付持续集成(一)
  • 数据结构:位图
  • IDEA Maven报错 无法解析 com.taobao:parent:pom:1.0.1【100%解决 此类型问题】
  • 分布式光纤传感:为储能安全保驾护航
  • 广度优先与深度优先遍历核心逻辑理解及实践
  • 关于 scrapy框架 详解
  • OpenCV在Visual Studio 2022下的配置
  • Android 中的多线程编程全面解析
  • 【机器学习笔记 Ⅲ】5 强化学习
  • 【docker】linux CentOS docker 安装流程
  • Centos和麒麟系统如何每天晚上2点10分定时备份达梦数据库
  • Redis:高性能内存数据库与缓存利器