quarkus框架原生支持在单个应用中连接并管理多种不同类型的数据库，例如postgresql和mysql。通过配置命名数据源和hibernate orm的多持久化单元，开发者可以灵活地将实体对象持久化到特定的数据库中，从而实现复杂的数据存储需求。本教程将详细介绍如何在quarkus应用中配置和使用多数据源及多持久化单元。
配置多数据源
在Quarkus应用中，配置多个数据源非常直观。每个数据源都通过一个唯一的名称进行标识，并在application.properties文件中进行详细配置。
首先，确保你的pom.xml文件中包含了所有需要连接的数据库的JDBC驱动依赖。例如，要连接PostgreSQL和MySQL，你需要添加以下依赖：
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-jdbc-postgresql</artifactId>
</dependency>
<dependency>
<groupId>io.quarkus</groupId>
<artifactId>quarkus-jdbc-mysql</artifactId>
</dependency>接下来，在application.properties文件中为每个数据源定义其连接参数。Quarkus使用quarkus.datasource.<name>.*的格式来区分不同的数据源。例如，配置一个名为postgresql的数据源和一个名为mysql的数据源：
# PostgreSQL 数据源配置 quarkus.datasource.postgresql.db-kind=postgresql quarkus.datasource.postgresql.username=xyz quarkus.datasource.postgresql.password=xyz quarkus.datasource.postgresql.jdbc.url=jdbc:postgresql://localhost:5432/xyz quarkus.datasource.postgresql.max-pool-size=10 # 可选：配置连接池大小 # MySQL 数据源配置 quarkus.datasource.mysql.db-kind=mysql quarkus.datasource.mysql.username=xyz quarkus.datasource.mysql.password=xyz quarkus.datasource.mysql.jdbc.url=jdbc:mysql://localhost:3305/xyz quarkus.datasource.mysql.max-pool-size=10 # 可选：配置连接池大小
通过上述配置，Quarkus将为每个命名数据源创建并管理独立的连接池。
使用Hibernate ORM多持久化单元
当需要将实体对象持久化到特定的数据源时，Quarkus结合Hibernate ORM提供了多持久化单元（Multiple Persistence Units）的功能。每个持久化单元可以与一个特定的数据源关联。
-
定义命名持久化单元
在application.properties中，为每个需要与特定数据源关联的持久化单元进行配置。Quarkus使用quarkus.hibernate-orm.<name>.*的格式。
# 默认持久化单元（可选，通常用于与默认数据源关联） # quarkus.hibernate-orm.database.generation=drop-and-create # 示例：数据库模式生成策略 # PostgreSQL 持久化单元 quarkus.hibernate-orm.postgresql.datasource=postgresql # 关联到上面定义的 'postgresql' 数据源 quarkus.hibernate-orm.postgresql.packages=com.example.app.postgresql.entities # 指定该持久化单元管理的实体包 quarkus.hibernate-orm.postgresql.database.generation=drop-and-create # 示例：数据库模式生成策略 # MySQL 持久化单元 quarkus.hibernate-orm.mysql.datasource=mysql # 关联到上面定义的 'mysql' 数据源 quarkus.hibernate-orm.mysql.packages=com.example.app.mysql.entities # 指定该持久化单元管理的实体包 quarkus.hibernate-orm.mysql.database.generation=drop-and-create # 示例：数据库模式生成策略
- quarkus.hibernate-orm.<name>.datasource：指定此持久化单元将使用哪个命名数据源。
- quarkus.hibernate-orm.<name>.packages：指定此持久化单元负责扫描和管理的实体类所在的包。这是关键，它告诉Quarkus哪些实体属于哪个持久化单元。
-
创建实体类
根据你的持久化单元配置，将实体类放置在相应的包中。
例如，PostgreSQL的实体： src/main/java/com/example/app/postgresql/entities/PostgreEntity.java
package com.example.app.postgresql.entities; import io.quarkus.hibernate.orm.panache.PanacheEntity; import jakarta.persistence.Entity; import jakarta.persistence.Table; @Entity @Table(name = "postgre_data") public class PostgreEntity extends PanacheEntity { public String name; public String description; }MySQL的实体： src/main/java/com/example/app/mysql/entities/MySQLEntity.java
package com.example.app.mysql.entities; import io.quarkus.hibernate.orm.panache.PanacheEntity; import jakarta.persistence.Entity; import jakarta.persistence.Table; @Entity @Table(name = "mysql_data") public class MySQLEntity extends PanacheEntity { public String code; public int value; } -
使用特定的EntityManager
在业务逻辑中，你需要注入与特定持久化单元关联的EntityManager或PanacheRepository。Quarkus通过@PersistenceUnit注解结合命名持久化单元来区分它们。
使用EntityManager：
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.postgresql.entities.PostgreEntity; import com.example.app.mysql.entities.MySQLEntity; @ApplicationScoped public class DataService { @Inject @PersistenceUnit("postgresql") // 注入与 'postgresql' 持久化单元关联的 EntityManager EntityManager postgreEntityManager; @Inject @PersistenceUnit("mysql") // 注入与 'mysql' 持久化单元关联的 EntityManager EntityManager mysqlEntityManager; @Transactional public void persistToPostgre(String name, String description) { PostgreEntity entity = new PostgreEntity(); entity.name = name; entity.description = description; postgreEntityManager.persist(entity); } @Transactional public void persistToMySQL(String code, int value) { MySQLEntity entity = new MySQLEntity(); entity.code = code; entity.value = value; mysqlEntityManager.persist(entity); } public PostgreEntity findFromPostgre(long id) { return postgreEntityManager.find(PostgreEntity.class, id); } public MySQLEntity findFromMySQL(long id) { return mysqlEntityManager.find(MySQLEntity.class, id); } }使用PanacheRepository（推荐）：
对于Panache实体，你可以为每个持久化单元创建独立的PanacheRepository或PanacheRepositoryBase。
首先，为PostgreSQL实体创建一个Repository： src/main/java/com/example/app/postgresql/repositories/PostgreEntityRepository.java
package com.example.app.postgresql.repositories; import io.quarkus.hibernate.orm.panache.PanacheRepository; import io.quarkus.hibernate.orm.PersistenceUnit; import jakarta.enterprise.context.ApplicationScoped; import com.example.app.postgresql.entities.PostgreEntity; @ApplicationScoped @PersistenceUnit("postgresql") // 指定此Repository关联的持久化单元 public class PostgreEntityRepository implements PanacheRepository<PostgreEntity> { // Panache提供了默认的CRUD方法，无需额外实现 }然后，为MySQL实体创建一个Repository： src/main/java/com/example/app/mysql/repositories/MySQLEntityRepository.java
package com.example.app.mysql.repositories; import io.quarkus.hibernate.orm.panache.PanacheRepository; import io.quarkus.hibernate.orm.PersistenceUnit; import jakarta.enterprise.context.ApplicationScoped; import com.example.app.mysql.entities.MySQLEntity; @ApplicationScoped @PersistenceUnit("mysql") // 指定此Repository关联的持久化单元 public class MySQLEntityRepository implements PanacheRepository<MySQLEntity> { // Panache提供了默认的CRUD方法，无需额外实现 }现在，你可以在服务类中注入这些Repository来操作特定数据库的实体：
import jakarta.enterprise.context.ApplicationScoped; import jakarta.inject.Inject; import jakarta.transaction.Transactional; import com.example.app.postgresql.entities.PostgreEntity; import com.example.app.mysql.entities.MySQLEntity; import com.example.app.postgresql.repositories.PostgreEntityRepository; import com.example.app.mysql.repositories.MySQLEntityRepository; @ApplicationScoped public class DataService { @Inject PostgreEntityRepository postgreRepository; @Inject MySQLEntityRepository mysqlRepository; @Transactional public void createPostgreData(String name, String description) { PostgreEntity entity = new PostgreEntity(); entity.name = name; entity.description = description; postgreRepository.persist(entity); // 持久化到PostgreSQL } @Transactional public void createMySQLData(String code, int value) { MySQLEntity entity = new MySQLEntity(); entity.code = code; entity.value = value; mysqlRepository.persist(entity); // 持久化到MySQL } public PostgreEntity getPostgreData(long id) { return postgreRepository.findById(id); } public MySQLEntity getMySQLData(long id) { return mysqlRepository.findById(id); } }
注意事项
- 事务管理： 默认情况下，@Transactional注解会作用于当前的EntityManager。当使用多个EntityManager时，每个@Transactional方法通常只管理一个持久化单元的事务。如果需要跨多个数据库的分布式事务，则需要更复杂的XA事务配置，这通常涉及JTA和特定的数据库驱动支持，并且配置更为复杂。在大多数场景下，不同数据库的操作通常在独立的事务中完成。
- 命名冲突： 确保你的数据源名称和持久化单元名称是唯一的，并且在application.properties、@PersistenceUnit注解中保持一致。
- 实体包分离： 强烈建议将不同持久化单元管理的实体类放在不同的Java包中，这样可以清晰地界定每个持久化单元的职责范围，避免混淆。
- 连接池优化： 根据应用的负载和数据库性能，合理配置每个数据源的连接池大小（max-pool-size等参数）以优化资源利用和响应时间。
总结
Quarkus通过其灵活的数据源配置和Hibernate ORM的多持久化单元功能，为在单个应用中集成和管理多种数据库提供了强大而简洁的解决方案。开发者可以轻松地将不同类型的实体映射到不同的数据库，从而满足复杂的业务需求和数据存储策略。遵循上述指南，你可以有效地在Quarkus应用中实现多数据库连接和持久化。
