diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/AppProperties.java b/src/main/java/ca/uhn/fhir/jpa/starter/AppProperties.java index 34b0c75f7d..c053d62c38 100644 --- a/src/main/java/ca/uhn/fhir/jpa/starter/AppProperties.java +++ b/src/main/java/ca/uhn/fhir/jpa/starter/AppProperties.java @@ -19,6 +19,8 @@ import java.util.Objects; import java.util.Set; +import static org.apache.commons.lang3.ObjectUtils.defaultIfNull; + @ConfigurationProperties(prefix = "hapi.fhir") @Configuration @EnableConfigurationProperties @@ -46,6 +48,7 @@ public class AppProperties { private Boolean mass_ingestion_mode_enabled = false; private Boolean language_search_parameter_enabled = false; private Boolean dao_scheduling_enabled = true; + private Boolean delete_enabled = true; private Boolean delete_expunge_enabled = false; private Boolean enable_index_missing_fields = false; private Boolean enable_index_contained_resource = false; @@ -111,6 +114,8 @@ public class AppProperties { JpaStorageSettings.StoreMetaSourceInformationEnum.NONE; private Map remote_terminology_service = null; + private Boolean match_url_cache_enabled = false; + private Boolean index_storage_optimized = false; public List getCustomInterceptorClasses() { return custom_interceptor_classes; @@ -376,6 +381,14 @@ public Boolean getDelete_expunge_enabled() { return delete_expunge_enabled; } + public boolean getDelete_enabled() { + return defaultIfNull(delete_enabled, true); + } + + public void setDelete_enabled(boolean theDelete_enabled) { + delete_enabled = theDelete_enabled; + } + public void setDelete_expunge_enabled(Boolean delete_expunge_enabled) { this.delete_expunge_enabled = delete_expunge_enabled; } @@ -745,6 +758,22 @@ public void setRemote_terminology_service(Map remote_termi this.remote_terminology_service = remote_terminology_service; } + public boolean getMatch_url_cache_enabled() { + return defaultIfNull(match_url_cache_enabled, false); + } + + public void setMatch_url_cache_enabled(boolean theMatchUrlCacheEnabled) { + match_url_cache_enabled = theMatchUrlCacheEnabled; + } + + public boolean getIndex_storage_optimized() { + return defaultIfNull(index_storage_optimized, false); + } + + public void setIndex_storage_optimized(boolean theIndex_storage_optimized) { + index_storage_optimized = theIndex_storage_optimized; + } + public JpaStorageSettings.StoreMetaSourceInformationEnum getStore_meta_source_information() { return store_meta_source_information; } diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/common/FhirServerConfigCommon.java b/src/main/java/ca/uhn/fhir/jpa/starter/common/FhirServerConfigCommon.java index 60f994820f..468f1f56ae 100644 --- a/src/main/java/ca/uhn/fhir/jpa/starter/common/FhirServerConfigCommon.java +++ b/src/main/java/ca/uhn/fhir/jpa/starter/common/FhirServerConfigCommon.java @@ -16,6 +16,8 @@ import ca.uhn.fhir.rest.server.mail.MailSvc; import com.google.common.base.Strings; import org.hl7.fhir.r4.model.Bundle.BundleType; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.boot.env.YamlPropertySourceLoader; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @@ -36,7 +38,7 @@ @EnableTransactionManagement public class FhirServerConfigCommon { - private static final org.slf4j.Logger ourLog = org.slf4j.LoggerFactory.getLogger(FhirServerConfigCommon.class); + private static final Logger ourLog = LoggerFactory.getLogger(FhirServerConfigCommon.class); public FhirServerConfigCommon(AppProperties appProperties) { ourLog.info("Server configured to " + (appProperties.getAllow_contains_searches() ? "allow" : "deny") @@ -176,6 +178,9 @@ public JpaStorageSettings jpaStorageSettings(AppProperties appProperties) { jpaStorageSettings.setAllowMultipleDelete(appProperties.getAllow_multiple_delete()); jpaStorageSettings.setAllowExternalReferences(appProperties.getAllow_external_references()); jpaStorageSettings.setSchedulingDisabled(!appProperties.getDao_scheduling_enabled()); + jpaStorageSettings.setIndexStorageOptimized(appProperties.getIndex_storage_optimized()); + jpaStorageSettings.setMatchUrlCacheEnabled(appProperties.getMatch_url_cache_enabled()); + jpaStorageSettings.setDeleteEnabled(appProperties.getDelete_enabled()); jpaStorageSettings.setDeleteExpungeEnabled(appProperties.getDelete_expunge_enabled()); jpaStorageSettings.setExpungeEnabled(appProperties.getExpunge_enabled()); jpaStorageSettings.setLanguageSearchParameterEnabled(appProperties.getLanguage_search_parameter_enabled()); @@ -291,6 +296,19 @@ public PartitionSettings partitionSettings(AppProperties appProperties) { } retVal.setConditionalCreateDuplicateIdentifiersEnabled( appProperties.getPartitioning().getConditional_create_duplicate_identifiers_enabled()); + + ourLog.info( + """ + Partitioning is enabled on this server. Settings: + * Database Partition Mode Enabled: {} + * Default Partition ID : {} + * Cross-Partition References : {}""", + databasePartitionModeEnabled, + defaultPartitionId, + retVal.getAllowReferencesAcrossPartitions()); + + } else { + ourLog.info("Partitioning is not enabled on this server"); } return retVal; diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/util/JpaHibernatePropertiesProvider.java b/src/main/java/ca/uhn/fhir/jpa/starter/util/JpaHibernatePropertiesProvider.java index 9a4bc0bea7..da0d496dbc 100644 --- a/src/main/java/ca/uhn/fhir/jpa/starter/util/JpaHibernatePropertiesProvider.java +++ b/src/main/java/ca/uhn/fhir/jpa/starter/util/JpaHibernatePropertiesProvider.java @@ -2,31 +2,45 @@ import ca.uhn.fhir.context.ConfigurationException; import ca.uhn.fhir.jpa.config.HibernatePropertiesProvider; +import ca.uhn.fhir.util.ReflectionUtil; import org.hibernate.dialect.Dialect; import org.hibernate.engine.jdbc.dialect.internal.StandardDialectResolver; import org.hibernate.engine.jdbc.dialect.spi.DatabaseMetaDataDialectResolutionInfoAdapter; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean; import java.sql.Connection; import java.sql.SQLException; import javax.sql.DataSource; +import static org.apache.commons.lang3.StringUtils.isNotBlank; + public class JpaHibernatePropertiesProvider extends HibernatePropertiesProvider { + private static final Logger ourLog = LoggerFactory.getLogger(JpaHibernatePropertiesProvider.class); - private final Dialect dialect; + private final Dialect myDialect; - public JpaHibernatePropertiesProvider(LocalContainerEntityManagerFactoryBean myEntityManagerFactory) { - DataSource connection = myEntityManagerFactory.getDataSource(); - try (Connection dbConnection = connection.getConnection()) { - dialect = new StandardDialectResolver() - .resolveDialect(new DatabaseMetaDataDialectResolutionInfoAdapter(dbConnection.getMetaData())); - } catch (SQLException sqlException) { - throw new ConfigurationException(sqlException.getMessage(), sqlException); + public JpaHibernatePropertiesProvider(LocalContainerEntityManagerFactoryBean theEntityManagerFactory) { + String dialectClass = + (String) theEntityManagerFactory.getJpaPropertyMap().get("hibernate.dialect"); + if (isNotBlank(dialectClass)) { + myDialect = ReflectionUtil.newInstanceOrReturnNull(dialectClass, Dialect.class); + } else { + ourLog.warn( + "'hibernate.dialect' not set in application configuration! Please explicitly specify a valid HAPI FHIR hibernate dialect."); + DataSource connection = theEntityManagerFactory.getDataSource(); + try (Connection dbConnection = connection.getConnection()) { + myDialect = new StandardDialectResolver() + .resolveDialect(new DatabaseMetaDataDialectResolutionInfoAdapter(dbConnection.getMetaData())); + } catch (SQLException sqlException) { + throw new ConfigurationException(sqlException.getMessage(), sqlException); + } } } @Override public Dialect getDialect() { - return dialect; + return myDialect; } } diff --git a/src/main/resources/application.yaml b/src/main/resources/application.yaml index cb0c0ce246..cff71e2dcd 100644 --- a/src/main/resources/application.yaml +++ b/src/main/resources/application.yaml @@ -190,8 +190,12 @@ hapi: # default_encoding: JSON # default_pretty_print: true # default_page_size: 20 + # delete_enabled: true # delete_expunge_enabled: true + # match_url_cache_enabled: false # enable_repository_validating_interceptor: true + ### Reduce the size used by search indexes by not tagging every row with the resource type and parameter name (this setting makes manual inspection of the database more difficult, but does not impact HAPI FHIR functionality in any way) + # index_storage_optimized: false # enable_index_missing_fields: false # enable_index_of_type: true # enable_index_contained_resource: false @@ -237,11 +241,26 @@ hapi: - https://unitsofmeasure.org/* - http://loinc.org/* - https://loinc.org/* - # partitioning: - # allow_references_across_partitions: false - # partitioning_include_in_search_hashes: false - # conditional_create_duplicate_identifiers_enabled: false - # request_tenant_partitioning_mode: true + + ### Uncomment the following section, and any sub-properties you need in order to enable + ### partitioning support on this server. + partitioning: + allow_references_across_partitions: false + partitioning_include_in_search_hashes: false + default_partition_id: 0 + ### Enable the following setting to enable Database Partitioning Mode + ### See: https://hapifhir.io/hapi-fhir/docs/server_jpa_partitioning/db_partition_mode.html + database_partition_mode_enabled: true + ### Partition Style: Partitioning requires a partition interceptor which helps the server + ### select which partition(s) should be accessed for a given request. You can supply your + ### own interceptor (see https://hapifhir.io/hapi-fhir/docs/server_jpa_partitioning/partitioning.html#partition-interceptors ) + ### but the following setting can also be used to use a built-in form. + ### Patient ID Partitioning Mode uses the patient/subject ID to determine the partition + patient_id_partitioning_mode: true + ### Request tenant mode can be used for a multi-tenancy setup where the request path is + ### expected to have an additional path element, e.g. GET http://example.com/fhir/TENANT-ID/Patient/A + request_tenant_partitioning_mode: false + cors: allow_Credentials: true # These are allowed_origin patterns, see: https://docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/web/cors/CorsConfiguration.html#setAllowedOriginPatterns-java.util.List- diff --git a/src/test/java/ca/uhn/fhir/jpa/starter/ExampleServerR4IT.java b/src/test/java/ca/uhn/fhir/jpa/starter/ExampleServerR4IT.java index 1aef83a21f..a63a672cfa 100644 --- a/src/test/java/ca/uhn/fhir/jpa/starter/ExampleServerR4IT.java +++ b/src/test/java/ca/uhn/fhir/jpa/starter/ExampleServerR4IT.java @@ -1,6 +1,8 @@ package ca.uhn.fhir.jpa.starter; import ca.uhn.fhir.context.FhirContext; +import ca.uhn.fhir.jpa.config.HibernatePropertiesProvider; +import ca.uhn.fhir.jpa.model.dialect.HapiFhirH2Dialect; import ca.uhn.fhir.jpa.searchparam.config.NicknameServiceConfig; import ca.uhn.fhir.jpa.starter.cr.CrProperties; import ca.uhn.fhir.model.primitive.IdDt; @@ -80,6 +82,9 @@ class ExampleServerR4IT implements IServerSupport { @Autowired private CrProperties crProperties; + @Autowired + private HibernatePropertiesProvider myHibernatePropertiesProvider; + @LocalServerPort private int port; @@ -367,6 +372,11 @@ void testValidateRemoteTerminology() { Parameters localResult = ourClient.operation().onType(CodeSystem.class).named("$validate-code").withParameter(Parameters.class, "url", new UrlType(testCodeSystem)).andParameter("coding", new Coding(testCodeSystem, "yes", null)).execute(); } + @Test + public void testHibernatePropertiesProvider_GetDialect() { + assertEquals(HapiFhirH2Dialect.class, myHibernatePropertiesProvider.getDialect().getClass()); + } + @BeforeEach void beforeEach() {