diff --git a/README.md b/README.md
index 60bc4ae..949ff9d 100644
--- a/README.md
+++ b/README.md
@@ -115,3 +115,18 @@ The server may be configured with subscription support by enabling properties in
* `subscription.email.enabled` - Enables email subscriptions. Note that you must also provide the connection details for a usable SMTP server.
* `subscription.websocket.enabled` - Enables websocket subscriptions. With this enabled, your server will accept incoming websocket connections on the following URL (this example uses the default context path and port, you may need to tweak depending on your deployment environment): [ws://localhost:8080/hapi-fhir-jpaserver/websocket](ws://localhost:8080/hapi-fhir-jpaserver/websocket)
+
+# Using ElasticSearch
+
+By default, the server will use embedded lucene indexes for terminology and fulltext indexing purposes. You can switch this to using lucene by editing the properties in [hapi.properties](https://github.com/hapifhir/hapi-fhir-jpaserver-starter/blob/master/src/main/resources/hapi.properties)
+
+For example:
+
+```properties
+elasticsearch.enabled=true
+elasticsearch.rest_url=http://localhost:9200
+elasticsearch.username=SomeUsername
+elasticsearch.password=SomePassword
+elasticsearch.required_index_status=YELLOW
+elasticsearch.schema_management_strategy=CREATE
+```
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index 6816519..c0219df 100644
--- a/pom.xml
+++ b/pom.xml
@@ -11,10 +11,9 @@
ca.uhn.hapi.fhir
hapi-fhir
- 4.0.0
+ 4.1.0-SNAPSHOT
- ca.uhn.hapi.fhir
hapi-fhir-jpaserver-starter
diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu2.java b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu2.java
index 3255de7..dc91099 100644
--- a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu2.java
+++ b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu2.java
@@ -43,7 +43,7 @@ public class FhirServerConfigDstu2 extends BaseJavaConfigDstu2 {
throw new ConfigurationException("Could not set the data source due to a configuration issue", e);
}
- retVal.setJpaProperties(HapiProperties.getProperties());
+ retVal.setJpaProperties(HapiProperties.getJpaProperties());
return retVal;
}
diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu3.java b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu3.java
index 7cf6996..3344952 100644
--- a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu3.java
+++ b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigDstu3.java
@@ -43,7 +43,7 @@ public class FhirServerConfigDstu3 extends BaseJavaConfigDstu3 {
throw new ConfigurationException("Could not set the data source due to a configuration issue", e);
}
- retVal.setJpaProperties(HapiProperties.getProperties());
+ retVal.setJpaProperties(HapiProperties.getJpaProperties());
return retVal;
}
diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR4.java b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR4.java
index abf6938..77a798e 100644
--- a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR4.java
+++ b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR4.java
@@ -43,7 +43,7 @@ public class FhirServerConfigR4 extends BaseJavaConfigR4 {
throw new ConfigurationException("Could not set the data source due to a configuration issue", e);
}
- retVal.setJpaProperties(HapiProperties.getProperties());
+ retVal.setJpaProperties(HapiProperties.getJpaProperties());
return retVal;
}
diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR5.java b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR5.java
index e176080..6d9e45b 100644
--- a/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR5.java
+++ b/src/main/java/ca/uhn/fhir/jpa/starter/FhirServerConfigR5.java
@@ -1,7 +1,6 @@
package ca.uhn.fhir.jpa.starter;
import ca.uhn.fhir.context.ConfigurationException;
-import ca.uhn.fhir.jpa.config.BaseJavaConfigR4;
import ca.uhn.fhir.jpa.config.BaseJavaConfigR5;
import ca.uhn.fhir.jpa.search.DatabaseBackedPagingProvider;
import org.springframework.beans.factory.annotation.Autowired;
@@ -44,7 +43,7 @@ public class FhirServerConfigR5 extends BaseJavaConfigR5 {
throw new ConfigurationException("Could not set the data source due to a configuration issue", e);
}
- retVal.setJpaProperties(HapiProperties.getProperties());
+ retVal.setJpaProperties(HapiProperties.getJpaProperties());
return retVal;
}
diff --git a/src/main/java/ca/uhn/fhir/jpa/starter/HapiProperties.java b/src/main/java/ca/uhn/fhir/jpa/starter/HapiProperties.java
index 3dac8f4..4ddd31e 100644
--- a/src/main/java/ca/uhn/fhir/jpa/starter/HapiProperties.java
+++ b/src/main/java/ca/uhn/fhir/jpa/starter/HapiProperties.java
@@ -2,9 +2,13 @@ package ca.uhn.fhir.jpa.starter;
import ca.uhn.fhir.context.ConfigurationException;
import ca.uhn.fhir.context.FhirVersionEnum;
+import ca.uhn.fhir.jpa.search.elastic.ElasticsearchHibernatePropertiesBuilder;
import ca.uhn.fhir.rest.api.EncodingEnum;
import ca.uhn.fhir.rest.server.ETagSupportEnum;
import com.google.common.annotations.VisibleForTesting;
+import org.hibernate.search.elasticsearch.cfg.ElasticsearchIndexStatus;
+import org.hibernate.search.elasticsearch.cfg.IndexSchemaManagementStrategy;
+import org.jetbrains.annotations.NotNull;
import java.io.FileInputStream;
import java.io.InputStream;
@@ -57,13 +61,17 @@ public class HapiProperties {
private static final String VALIDATE_RESPONSES_ENABLED = "validation.responses.enabled";
private static final String FILTER_SEARCH_ENABLED = "filter_search.enabled";
private static final String GRAPHQL_ENABLED = "graphql.enabled";
- private static Properties properties;
+ private static Properties ourProperties;
+
+ public static boolean isElasticSearchEnabled() {
+ return HapiProperties.getPropertyBoolean("elasticsearch.enabled", false);
+ }
/*
* Force the configuration to be reloaded
*/
public static void forceReload() {
- properties = null;
+ ourProperties = null;
getProperties();
}
@@ -76,22 +84,48 @@ public class HapiProperties {
getProperties().setProperty(theKey, theValue);
}
- public static Properties getProperties() {
- if (properties == null) {
- // Load the configurable properties file
- try (InputStream in = HapiProperties.class.getClassLoader().getResourceAsStream(HAPI_PROPERTIES)) {
- HapiProperties.properties = new Properties();
- HapiProperties.properties.load(in);
- } catch (Exception e) {
- throw new ConfigurationException("Could not load HAPI properties", e);
- }
+ public static Properties getJpaProperties() {
+ Properties retVal = loadProperties();
- Properties overrideProps = loadOverrideProperties();
- if (overrideProps != null) {
- properties.putAll(overrideProps);
- }
+ if (isElasticSearchEnabled()) {
+ ElasticsearchHibernatePropertiesBuilder builder = new ElasticsearchHibernatePropertiesBuilder();
+ builder.setRequiredIndexStatus(getPropertyEnum("elasticsearch.required_index_status", ElasticsearchIndexStatus.class, ElasticsearchIndexStatus.YELLOW));
+ builder.setRestUrl(getProperty("elasticsearch.rest_url"));
+ builder.setUsername(getProperty("elasticsearch.username"));
+ builder.setPassword(getProperty("elasticsearch.password"));
+ builder.setIndexSchemaManagementStrategy(getPropertyEnum("elasticsearch.schema_management_strateg", IndexSchemaManagementStrategy.class, IndexSchemaManagementStrategy.CREATE));
+ builder.setDebugRefreshAfterWrite(getPropertyBoolean("elasticsearch.debug.refresh_after_write", false));
+ builder.setDebugPrettyPrintJsonLog(getPropertyBoolean("elasticsearch.debug.pretty_print_json_log", false));
+ builder.apply(retVal);
}
+ return retVal;
+ }
+
+ private static Properties getProperties() {
+ if (ourProperties == null) {
+ Properties properties = loadProperties();
+ HapiProperties.ourProperties = properties;
+ }
+
+ return ourProperties;
+ }
+
+ @NotNull
+ private static Properties loadProperties() {
+ // Load the configurable properties file
+ Properties properties;
+ try (InputStream in = HapiProperties.class.getClassLoader().getResourceAsStream(HAPI_PROPERTIES)) {
+ properties = new Properties();
+ properties.load(in);
+ } catch (Exception e) {
+ throw new ConfigurationException("Could not load HAPI properties", e);
+ }
+
+ Properties overrideProps = loadOverrideProperties();
+ if (overrideProps != null) {
+ properties.putAll(overrideProps);
+ }
return properties;
}
@@ -375,5 +409,15 @@ public class HapiProperties {
return HapiProperties.getBooleanProperty(GRAPHQL_ENABLED, true);
}
+ private static boolean getPropertyBoolean(String thePropertyName, boolean theDefaultValue) {
+ String value = getProperty(thePropertyName, Boolean.toString(theDefaultValue));
+ return Boolean.parseBoolean(value);
+ }
+
+ private static T getPropertyEnum(String thePropertyName, Class theEnumType, T theDefaultValue) {
+ String value = getProperty(thePropertyName, theDefaultValue.name());
+ return (T) Enum.valueOf(theEnumType, value);
+ }
+
}
diff --git a/src/main/resources/hapi.properties b/src/main/resources/hapi.properties
index 0f9bd81..5cbb918 100644
--- a/src/main/resources/hapi.properties
+++ b/src/main/resources/hapi.properties
@@ -78,6 +78,24 @@ hibernate.search.default.indexBase=target/lucenefiles
hibernate.search.lucene_version=LUCENE_CURRENT
tester.config.refuse_to_fetch_third_party_urls=false
+##################################################
+# ElasticSearch
+# Note that using ElasticSearch is disabled by
+# default and the server will use Lucene instead.
+##################################################
+elasticsearch.enabled=false
+elasticsearch.rest_url=http://localhost:9200
+elasticsearch.username=SomeUsername
+elasticsearch.password=SomePassword
+elasticsearch.rest_url=http://localhost:9200
+elasticsearch.required_index_status=YELLOW
+elasticsearch.schema_management_strategy=CREATE
+# Immediately refresh indexes after every write. This is very bad for
+# performance, but can be helpful for testing.
+elasticsearch.debug.refresh_after_write=false
+elasticsearch.debug.pretty_print_json_log=false
+
+
##################################################
# Binary Storage Operations
##################################################