Я работаю над переводом приложения на последнюю версию quarkus. Приложение реализует мультитенантность с использованием стратегии базы данных из интерфейсов гибернации. Quarkus рекомендует (если возможно) избегать использования persistence.xml, каков правильный подход для этого случая мультитенантности с учетом контекста quarkus ? сохранить persistence.xml или использовать только application.properties, рекомендованные quarkus?
@Singleton
public class HibernateConnectionProviderFactory implements ConnectionProviderFactory {
private Logger logger = Logger.getLogger(getClass().getName());
private static final String TENANT_ID_PLACEHOLDER = "{tenant.id}";
@Inject
@SystemProperty("multitenant.hibernate.connection.url")
private Optional<String> dbUrl;
@Inject
@SystemProperty("multitenant.hibernate.connection.driver_class")
private Optional<String> dbDriverClass;
@Inject
@SystemProperty("multitenant.hibernate.dialect")
private Optional<String> dbDialect;
@Inject
@SystemProperty("multitenant.hibernate.connection.username")
private Optional<String> dbUsername;
@Inject
@SystemProperty("multitenant.hibernate.connection.password")
private Optional<String> dbPassword;
@Inject
@SystemProperty(value = "multitenant.hibernate.schema.generation", defaultValue = "false")
private boolean generateSchema;
@Inject
@SystemProperty("multitenant.default.tenant.id")
private Optional<String> defaultTenantId;
@Inject
private PersistenceUnitDescriptorFactory persistenceUnitDescriptorFactory;
@Inject
private SchemaGenerator schemaGenerator;
private final ConcurrentHashMap<String, ConnectionProvider> providers = new ConcurrentHashMap<>();
@Override
public Optional<ConnectionProvider> getDefaultConnectionProvider() {
return defaultTenantId.map(this::getConnectionProvider);
}
@Override
public ConnectionProvider getConnectionProvider(String tenantId) {
return providers.computeIfAbsent(tenantId, this::createDriverManagerConnectionProvider);
}
private ConnectionProvider createDriverManagerConnectionProvider(String tenantId) {
final PersistenceUnitDescriptor persistenceUnit = persistenceUnitDescriptorFactory.getPersistenceUnitDescriptor(tenantId);
final Map<Object, Object> persistenceProperties = getPersistenceProperties(tenantId, persistenceUnit.getProperties());
final StandardServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(persistenceProperties).build();
if (generateSchema) {
schemaGenerator.updateSchema(serviceRegistry, persistenceUnit);
}
final ConnectionProvider connectionProvider = serviceRegistry.getService(ConnectionProvider.class);
return connectionProvider;
}
//...
}
