Class PostgresResourceReferenceDAO
- java.lang.Object
-
- com.ibm.fhir.persistence.jdbc.dao.impl.ResourceReferenceDAO
-
- com.ibm.fhir.persistence.jdbc.postgres.PostgresResourceReferenceDAO
-
- All Implemented Interfaces:
IResourceReferenceDAO
,java.lang.AutoCloseable
public class PostgresResourceReferenceDAO extends ResourceReferenceDAO
Postgres-specific extension of theResourceReferenceDAO
to work around some SQL syntax and Postgres concurrency issues
-
-
Field Summary
-
Fields inherited from class com.ibm.fhir.persistence.jdbc.dao.impl.ResourceReferenceDAO
BATCH_SIZE
-
-
Constructor Summary
Constructors Constructor Description PostgresResourceReferenceDAO(IDatabaseTranslator t, java.sql.Connection c, java.lang.String schemaName, ICommonTokenValuesCache cache, INameIdCache<java.lang.Integer> parameterNameCache)
Public constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
doCanonicalValuesUpsert(java.lang.String paramList, java.util.Collection<java.lang.String> sortedURLS)
Insert any missing values into the common_canonical_values tablevoid
doCodeSystemsUpsert(java.lang.String paramList, java.util.Collection<java.lang.String> sortedSystemNames)
Insert any missing values into the code_systems tableprotected void
doCommonTokenValuesUpsert(java.lang.String paramList, java.util.Collection<CommonTokenValue> sortedTokenValues)
Execute the insert (upsert) into the common_token_values table for the given collection of values.protected int
readOrAddParameterNameId(java.lang.String parameterName)
Fetch the id for the given parameter name from the database, creating a new entry if required.-
Methods inherited from class com.ibm.fhir.persistence.jdbc.dao.impl.ResourceReferenceDAO
addNormalizedValues, close, doCodeSystemsFetch, flush, getCache, getConnection, getParameterNameId, getResourceReferenceCache, getSchemaName, getTranslator, insertResourceProfiles, insertResourceSecurity, insertResourceTags, insertResourceTokenRefs, insertSystemResourceProfiles, insertSystemResourceSecurity, insertSystemResourceTags, insertSystemResourceTokenRefs, persist, readCanonicalId, readCommonTokenValueId, readCommonTokenValueIdList, readCommonTokenValueIds, upsertCanonicalValues, upsertCodeSystems, upsertCommonTokenValues
-
-
-
-
Constructor Detail
-
PostgresResourceReferenceDAO
public PostgresResourceReferenceDAO(IDatabaseTranslator t, java.sql.Connection c, java.lang.String schemaName, ICommonTokenValuesCache cache, INameIdCache<java.lang.Integer> parameterNameCache)
Public constructor- Parameters:
t
-c
-schemaName
-cache
-
-
-
Method Detail
-
doCodeSystemsUpsert
public void doCodeSystemsUpsert(java.lang.String paramList, java.util.Collection<java.lang.String> sortedSystemNames)
Description copied from class:ResourceReferenceDAO
Insert any missing values into the code_systems table- Specified by:
doCodeSystemsUpsert
in classResourceReferenceDAO
-
doCanonicalValuesUpsert
public void doCanonicalValuesUpsert(java.lang.String paramList, java.util.Collection<java.lang.String> sortedURLS)
Description copied from class:ResourceReferenceDAO
Insert any missing values into the common_canonical_values table- Specified by:
doCanonicalValuesUpsert
in classResourceReferenceDAO
-
doCommonTokenValuesUpsert
protected void doCommonTokenValuesUpsert(java.lang.String paramList, java.util.Collection<CommonTokenValue> sortedTokenValues)
Description copied from class:ResourceReferenceDAO
Execute the insert (upsert) into the common_token_values table for the given collection of values. Note, this insert from negative outer join requires the database concurrency implementation to be correct. This does not work for Postgres, hence Postgres gets its own implementation of this method- Specified by:
doCommonTokenValuesUpsert
in classResourceReferenceDAO
-
readOrAddParameterNameId
protected int readOrAddParameterNameId(java.lang.String parameterName) throws FHIRPersistenceDBConnectException, FHIRPersistenceDataAccessException
Description copied from class:ResourceReferenceDAO
Fetch the id for the given parameter name from the database, creating a new entry if required.- Specified by:
readOrAddParameterNameId
in classResourceReferenceDAO
- Returns:
- Throws:
FHIRPersistenceDBConnectException
FHIRPersistenceDataAccessException
-
-