Package com.ibm.fhir.persistence.jdbc.postgres

Class PostgresResourceReferenceDAO

java.lang.Object

com.ibm.fhir.persistence.jdbc.dao.impl.ResourceReferenceDAO

com.ibm.fhir.persistence.jdbc.postgres.PostgresResourceReferenceDAO

All Implemented Interfaces:

IResourceReferenceDAO, AutoCloseable

public class PostgresResourceReferenceDAO
extends ResourceReferenceDAO

Postgres-specific extension of the ResourceReferenceDAO 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, Connection c, String schemaName, ICommonTokenValuesCache cache, INameIdCache<Integer> parameterNameCache)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	doCanonicalValuesUpsert(String paramList, Collection<String> sortedURLS)	Insert any missing values into the common_canonical_values table
void	doCodeSystemsUpsert(String paramList, Collection<String> sortedSystemNames)	Insert any missing values into the code_systems table
protected void	doCommonTokenValuesUpsert(String paramList, Collection<CommonTokenValue> sortedTokenValues)	Execute the insert (upsert) into the common_token_values table for the given collection of values.
protected int	readOrAddParameterNameId(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

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PostgresResourceReferenceDAO

public PostgresResourceReferenceDAO(IDatabaseTranslator t,
                                    Connection c,
                                    String schemaName,
                                    ICommonTokenValuesCache cache,
                                    INameIdCache<Integer> parameterNameCache)

Public constructor

Parameters:

t -

c -

schemaName -

cache -

Method Detail

doCodeSystemsUpsert

public void doCodeSystemsUpsert(String paramList,
                                Collection<String> sortedSystemNames)

Description copied from class: ResourceReferenceDAO

Insert any missing values into the code_systems table

Specified by:

doCodeSystemsUpsert in class ResourceReferenceDAO

doCanonicalValuesUpsert

public void doCanonicalValuesUpsert(String paramList,
                                    Collection<String> sortedURLS)

Description copied from class: ResourceReferenceDAO

Insert any missing values into the common_canonical_values table

Specified by:

doCanonicalValuesUpsert in class ResourceReferenceDAO

doCommonTokenValuesUpsert

protected void doCommonTokenValuesUpsert(String paramList,
                                         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 class ResourceReferenceDAO

readOrAddParameterNameId

protected int readOrAddParameterNameId(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 class ResourceReferenceDAO

Returns:

Throws:

FHIRPersistenceDBConnectException

FHIRPersistenceDataAccessException