Quarkus应用中多数据源配置与异构数据库实体持久化实践

聖光之護

发布时间：2025-10-29 14:42:14

838人浏览过

来源于php中文网

原创

Quarkus应用中多数据源配置与异构数据库实体持久化实践

quarkus框架原生支持在单个应用中连接并管理多个不同类型的数据库，如postgresql和mysql。本文将详细阐述如何在quarkus中配置多数据源，并通过定义不同的持久化单元（persistence units）实现实体与特定数据库的精确映射和持久化操作，确保数据流向正确的目标数据库。

引言：Quarkus的多数据源能力

在现代企业级应用开发中，一个应用可能需要与多个数据库进行交互，这些数据库甚至可能是不同类型（如关系型数据库与NoSQL数据库，或不同厂商的关系型数据库）的。Quarkus作为一个云原生Java框架，提供了强大且灵活的多数据源支持，允许开发者在同一个应用中轻松配置和管理多个异构数据库连接，并精确控制实体对象的持久化目标。这极大地简化了复杂数据架构下的应用开发。

多数据源配置

在Quarkus中配置多个数据源主要通过 application.properties 文件完成。每个数据源都通过一个唯一的名称进行标识。配置的基本格式是 quarkus.datasource.<name>.<property>。

以下是一个配置PostgreSQL和MySQL数据源的示例：

# PostgreSQL 数据源配置
quarkus.datasource.postgresql.db-kind=postgresql
quarkus.datasource.postgresql.username=your_pg_user
quarkus.datasource.postgresql.password=your_pg_password
quarkus.datasource.postgresql.jdbc.url=jdbc:postgresql://localhost:5432/your_pg_db

# MySQL 数据源配置
quarkus.datasource.mysql.db-kind=mysql
quarkus.datasource.mysql.username=your_mysql_user
quarkus.datasource.mysql.password=your_mysql_password
quarkus.datasource.mysql.jdbc.url=jdbc:mysql://localhost:3305/your_mysql_db

在上述配置中：

quarkus.datasource.postgresql 和 quarkus.datasource.mysql 分别定义了名为 postgresql 和 mysql 的两个数据源。
db-kind 属性指定了数据库的类型，Quarkus会根据此属性自动加载相应的驱动和配置。
username, password, jdbc.url 则是标准的JDBC连接参数。

Maven依赖管理

为了让Quarkus应用能够连接到不同的数据库，你需要在 pom.xml 中添加相应的JDBC驱动依赖。

<dependencies>
    <!-- Quarkus PostgreSQL JDBC 驱动 -->
    <dependency>
        <groupId>io.quarkus</groupId>
        <artifactId>quarkus-jdbc-postgresql</artifactId>
    </dependency>
    <!-- Quarkus MySQL JDBC 驱动 -->
    <dependency>
        <groupId>io.quarkus</groupId>
        <artifactId>quarkus-jdbc-mysql</artifactId>
    </dependency>
    <!-- 如果使用 Hibernate ORM，还需要添加其依赖 -->
    <dependency>
        <groupId>io.quarkus</groupId>
        <artifactId>quarkus-hibernate-orm</artifactId>
    </dependency>
</dependencies>

持久化单元的定义与关联

仅仅配置了多个数据源并不能直接指导Hibernate ORM将实体持久化到哪个数据库。为了实现这一点，Quarkus引入了“持久化单元”（Persistence Unit）的概念。每个持久化单元都与一个特定的数据源关联，并管理一组实体。

在 application.properties 中，你可以为每个数据源定义一个或多个持久化单元：

# 关联 PostgreSQL 数据源的持久化单元
quarkus.hibernate-orm.pg-unit.datasource=postgresql
quarkus.hibernate-orm.pg-unit.packages=com.example.app.pgentities # 指定此单元管理的实体包

# 关联 MySQL 数据源的持久化单元
quarkus.hibernate-orm.mysql-unit.datasource=mysql
quarkus.hibernate-orm.mysql-unit.packages=com.example.app.mysqltentities # 指定此单元管理的实体包

在上述配置中：

pg-unit 和 mysql-unit 是我们自定义的持久化单元名称。
quarkus.hibernate-orm.<persistence-unit-name>.datasource 属性将持久化单元与之前定义的数据源（postgresql 或 mysql）关联起来。
quarkus.hibernate-orm.<persistence-unit-name>.packages 属性则指定了该持久化单元将要管理的实体类所在的Java包。这是将实体与特定数据库绑定的关键机制。

实体与持久化单元的绑定

有了持久化单元的定义，接下来就是如何将实体类与这些单元关联起来。最推荐和清晰的方式是通过 quarkus.hibernate-orm.<persistence-unit-name>.packages 配置属性，将不同数据源的实体放在不同的包中。

触站AI

专业的中文版AI绘画生成平台

下载

例如：

PostgreSQL 实体 (com.example.app.pgentities.PgProduct.java)

package com.example.app.pgentities;

import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.GenerationType;
import jakarta.persistence.Id;
import jakarta.persistence.Table;

@Entity
@Table(name = "pg_products")
public class PgProduct {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String name;
    private String description;

    // Getters and Setters
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
    public String getDescription() { return description; }
    public void setDescription(String description) { this.description = description; }
}

MySQL 实体 (com.example.app.mysqltentities.MysqlOrder.java)

package com.example.app.mysqltentities;

import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.GenerationType;
import jakarta.persistence.Id;
import jakarta.persistence.Table;

@Entity
@Table(name = "mysql_orders")
public class MysqlOrder {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private String orderNumber;
    private double amount;

    // Getters and Setters
    public Long getId() { return id; }
    public void setId(Long id) { this.id = id; }
    public String getOrderNumber() { return orderNumber; }
    public void setOrderNumber(String orderNumber) { this.orderNumber = orderNumber; }
    public double getAmount() { return amount; }
    public void setAmount(double amount) { this.amount = amount; }
}

通过 application.properties 中的 packages 配置，PgProduct 将由 pg-unit 持久化单元管理并持久化到 PostgreSQL 数据库，而 MysqlOrder 将由 mysql-unit 持久化单元管理并持久化到 MySQL 数据库。

注入特定EntityManager进行持久化

在服务层或数据访问对象（DAO）中，你需要注入与特定持久化单元关联的 EntityManager 来执行持久化操作。Quarkus允许你通过 @PersistenceUnit 注解指定要注入的持久化单元。

import jakarta.enterprise.context.ApplicationScoped;
import jakarta.inject.Inject;
import jakarta.persistence.EntityManager;
import io.quarkus.hibernate.orm.PersistenceUnit;
import jakarta.transaction.Transactional;

import com.example.app.pgentities.PgProduct;
import com.example.app.mysqltentities.MysqlOrder;

@ApplicationScoped
public class DataService {

    // 注入与 "pg-unit" 关联的 EntityManager
    @Inject
    @PersistenceUnit("pg-unit")
    EntityManager pgEntityManager;

    // 注入与 "mysql-unit" 关联的 EntityManager
    @Inject
    @PersistenceUnit("mysql-unit")
    EntityManager mysqlEntityManager;

    @Transactional
    public void createPgProduct(String name, String description) {
        PgProduct product = new PgProduct();
        product.setName(name);
        product.setDescription(description);
        pgEntityManager.persist(product);
    }

    @Transactional
    public void createMysqlOrder(String orderNumber, double amount) {
        MysqlOrder order = new MysqlOrder();
        order.setOrderNumber(orderNumber);
        order.setAmount(amount);
        mysqlEntityManager.persist(order);
    }

    // 可以添加其他查询方法，如：
    public PgProduct findPgProductById(Long id) {
        return pgEntityManager.find(PgProduct.class, id);
    }

    public MysqlOrder findMysqlOrderById(Long id) {
        return mysqlEntityManager.find(MysqlOrder.class, id);
    }
}

在上述示例中：

@PersistenceUnit("pg-unit") 确保 pgEntityManager 实例与 PostgreSQL 数据库连接。
@PersistenceUnit("mysql-unit") 确保 mysqlEntityManager 实例与 MySQL 数据库连接。
@Transactional 注解用于管理事务，每个 EntityManager 实例都将在其自己的事务上下文中运行。

注意事项与最佳实践

命名规范： 为数据源和持久化单元选择清晰、有意义的名称，这有助于提高代码的可读性和可维护性。
实体隔离： 强烈建议将属于不同数据源的实体类放置在不同的Java包中。这不仅使 quarkus.hibernate-orm.<persistence-unit-name>.packages 配置更加直观，也避免了潜在的实体冲突。
事务管理： 尽管Quarkus为每个持久化单元提供了独立的事务上下文，但在需要协调跨多个数据库操作的场景下，你可能需要考虑分布式事务（XA事务），但这会增加复杂性。对于大多数情况，独立事务足以满足需求。
配置验证： 仔细检查 application.properties 中的数据库连接URL、用户名、密码和 db-kind。任何配置错误都可能导致应用程序启动失败或运行时连接问题。
资源消耗： 每个数据源都会消耗一定的系统资源（如连接池、内存）。在设计多数据源架构时，应评估其对资源的影响。
代码组织： 可以为每个数据源创建独立的Repository或DAO接口和实现，以进一步封装和隔离数据访问逻辑。

总结

Quarkus通过其灵活的数据源配置和强大的Hibernate ORM集成，使得在单个应用中管理多个异构数据库成为可能。通过定义明确的持久化单元，并将实体与特定数据源关联，开发者可以精确地控制数据流向，实现复杂应用场景下的数据持久化需求。遵循上述配置和最佳实践，可以构建出高效、可维护且功能强大的Quarkus应用。

如何让 Java 项目在其他电脑上远程连接原开发机的 MySQL 数据库

如何让 Java 项目 JAR 包在其他电脑上远程连接 MySQL 数据库

在Java中如何配置本地开发环境和生产环境_Java环境配置对比解析

动态切换 Spring Boot 请求级数据库：安全、可扩展的多租户实现方案

如何在 jOOQ 中正确编写带 SUM 聚合的嵌套子查询（含条件计数）

夸克浏览器

夸克Quark是一款采用 chromium 单核设计，网页渲染加载速度快，还有 0.3s 闪电启动的极速体验。内置隐私防护功能，能多方面保护用户隐私，可识别各种恶意软件和钓鱼网站，确保上网安全。与夸克网盘一体设计，拥有夸克高考、夸克搜题等多种智能工具，还有超过上万条过滤规则的超强去广告功能，以及智能拼页的阅读模式等。

下载