quarkus框架原生支持在单个应用中连接并管理多个不同类型的数据库，如postgresql和mysql。本文将详细阐述如何在quarkus中配置多数据源，并通过定义不同的持久化单元（persistence units）实现实体与特定数据库的精确映射和持久化操作，确保数据流向正确的目标数据库。
引言：Quarkus的多数据源能力
在现代企业级应用开发中，一个应用可能需要与多个数据库进行交互，这些数据库甚至可能是不同类型（如关系型数据库与NoSQL数据库，或不同厂商的关系型数据库）的。Quarkus作为一个云原生Java框架，提供了强大且灵活的多数据源支持，允许开发者在同一个应用中轻松配置和管理多个异构数据库连接，并精确控制实体对象的持久化目标。这极大地简化了复杂数据架构下的应用开发。
多数据源配置
在Quarkus中配置多个数据源主要通过 application.properties 文件完成。每个数据源都通过一个唯一的名称进行标识。配置的基本格式是 quarkus.datasource.
以下是一个配置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驱动依赖。
io.quarkus quarkus-jdbc-postgresql io.quarkus quarkus-jdbc-mysql io.quarkus quarkus-hibernate-orm
持久化单元的定义与关联
仅仅配置了多个数据源并不能直接指导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.
.datasource 属性将持久化单元与之前定义的数据源（postgresql 或 mysql）关联起来。 - quarkus.hibernate-orm.
.packages 属性则指定了该持久化单元将要管理的实体类所在的Java包。这是将实体与特定数据库绑定的关键机制。
实体与持久化单元的绑定
有了持久化单元的定义，接下来就是如何将实体类与这些单元关联起来。最推荐和清晰的方式是通过 quarkus.hibernate-orm.
例如：
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.
.packages 配置更加直观，也避免了潜在的实体冲突。 - 事务管理： 尽管Quarkus为每个持久化单元提供了独立的事务上下文，但在需要协调跨多个数据库操作的场景下，你可能需要考虑分布式事务（XA事务），但这会增加复杂性。对于大多数情况，独立事务足以满足需求。
- 配置验证： 仔细检查 application.properties 中的数据库连接URL、用户名、密码和 db-kind。任何配置错误都可能导致应用程序启动失败或运行时连接问题。
- 资源消耗： 每个数据源都会消耗一定的系统资源（如连接池、内存）。在设计多数据源架构时，应评估其对资源的影响。
- 代码组织： 可以为每个数据源创建独立的Repository或DAO接口和实现，以进一步封装和隔离数据访问逻辑。
总结
Quarkus通过其灵活的数据源配置和强大的Hibernate ORM集成，使得在单个应用中管理多个异构数据库成为可能。通过定义明确的持久化单元，并将实体与特定数据源关联，开发者可以精确地控制数据流向，实现复杂应用场景下的数据持久化需求。遵循上述配置和最佳实践，可以构建出高效、可维护且功能强大的Quarkus应用。
