Package ca.uhn.fhir.jpa.dao

Class BaseHapiFhirDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

java.lang.Object

ca.uhn.fhir.jpa.dao.BaseStorageDao

ca.uhn.fhir.jpa.dao.BaseStorageResourceDao<T>

ca.uhn.fhir.jpa.dao.BaseHapiFhirDao<T>

All Implemented Interfaces:

IDao, IFhirResourceDao<T>, IJpaDao<T>, org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware

Direct Known Subclasses:

BaseHapiFhirResourceDao

@Repository
public abstract class BaseHapiFhirDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>
extends BaseStorageResourceDao<T>
implements IDao, IJpaDao<T>, org.springframework.context.ApplicationContextAware

TODO: JA - This class has only one subclass now. Historically it was a common ancestor for BaseHapiFhirSystemDao and BaseHapiFhirResourceDao but I've untangled the former from this hierarchy in order to simplify moving common functionality for resource DAOs into the hapi-fhir-storage project. This class should be merged into BaseHapiFhirResourceDao, but that should be done in its own dedicated PR since it'll be a noisy change.

Field Summary

Fields

Modifier and Type	Field	Description
protected CacheTagDefinitionDao	cacheTagDefinitionDao
protected final CodingSpy	myCodingSpy
protected DeleteConflictService	myDeleteConflictService
protected jakarta.persistence.EntityManager	myEntityManager
protected IIdHelperService<JpaPid>	myIdHelperService
protected InMemoryResourceMatcher	myInMemoryResourceMatcher
protected ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster	myInterceptorBroadcaster
protected IJpaStorageResourceParser	myJpaStorageResourceParser
protected PartitionSettings	myPartitionSettings
protected ResourceHistoryCalculator	myResourceHistoryCalculator
protected IResourceHistoryTableDao	myResourceHistoryTableDao
protected IResourceLinkDao	myResourceLinkDao
protected IResourceTableDao	myResourceTableDao
protected IResourceTagDao	myResourceTagDao
protected IResourceTypeCacheSvc	myResourceTypeCacheSvc
protected ISearchCoordinatorSvc<JpaPid>	mySearchCoordinatorSvc
protected ITermReadSvc	myTerminologySvc
static final String	NS_JPA_PROFILE

Fields inherited from class ca.uhn.fhir.jpa.dao.BaseStorageResourceDao

STRICT_ERROR_HANDLER

Fields inherited from class ca.uhn.fhir.jpa.dao.BaseStorageDao

MESSAGE_KEY_DELETE_RESOURCE_ALREADY_DELETED, MESSAGE_KEY_DELETE_RESOURCE_NOT_EXISTING, myDaoRegistry, myFhirContext, myMetaTagSorter, myResourceVersionSvc, mySearchParamRegistry, myStorageSettings, OO_ISSUE_CODE_INFORMATIONAL, OO_SEVERITY_ERROR, OO_SEVERITY_INFO, OO_SEVERITY_WARN

Fields inherited from interface ca.uhn.fhir.jpa.api.dao.IDao

CURRENTLY_REINDEXING, RESOURCE_PID, RESOURCE_PID_KEY

Constructor Summary

Constructors

Constructor	Description
BaseHapiFhirDao()

Method Summary

Modifier and Type	Method	Description
protected void	addPidToResource(IResourceLookup<JpaPid> theEntity, org.hl7.fhir.instance.model.api.IBaseResource theResource)
static String	decodeResource(byte[] theResourceBytes, ResourceEncodingEnum theResourceEncoding)
protected org.springframework.context.ApplicationContext	getApplicationContext()
ca.uhn.fhir.context.FhirContext	getContext()
protected ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster	getInterceptorBroadcaster()
JpaStorageSettings	getStorageSettings()
boolean	isLogicalReference(org.hl7.fhir.instance.model.api.IIdType theId)
static String	parseContentTextIntoWords(ca.uhn.fhir.context.FhirContext theContext, org.hl7.fhir.instance.model.api.IBaseResource theResource)
protected ca.uhn.fhir.jpa.dao.EncodedResource	populateResourceIntoEntity(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, org.hl7.fhir.instance.model.api.IBaseResource theResource, ResourceTable theEntity, boolean thePerformIndexing)	Returns true if the resource has changed (either the contents or the tags)
protected void	postDelete(ResourceTable theEntity)	Subclasses may override to provide behaviour.
protected void	postPersist(ResourceTable theEntity, T theResource, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)	Subclasses may override to provide behaviour.
protected void	postUpdate(ResourceTable theEntity, T theResource, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)	Subclasses may override to provide behaviour.
BaseHasResource	readEntity(org.hl7.fhir.instance.model.api.IIdType theValueId, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
void	setApplicationContext(org.springframework.context.ApplicationContext theApplicationContext)
void	setContext(ca.uhn.fhir.context.FhirContext theContext)
void	setDaoSearchParamSynchronizer(DaoSearchParamSynchronizer theDaoSearchParamSynchronizer)
static void	setDisableIncrementOnUpdateForUnitTest(boolean theDisableIncrementOnUpdateForUnitTest)
void	setEntityManager(jakarta.persistence.EntityManager theEntityManager)
void	setExternallyStoredResourceServiceRegistryForUnitTest(ExternallyStoredResourceServiceRegistry theExternallyStoredResourceServiceRegistry)
void	setInterceptorBroadcasterForUnitTest(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster)
void	setJpaStorageResourceParserForUnitTest(IJpaStorageResourceParser theJpaStorageResourceParser)	Do not call this method outside of unit tests
void	setPartitionSettingsForUnitTest(PartitionSettings thePartitionSettings)
void	setResourceHistoryCalculator(ResourceHistoryCalculator theResourceHistoryCalculator)
void	setResourceHistoryTableDao(IResourceHistoryTableDao theResourceHistoryTableDao)
void	setResourceTypeCacheSvc(IResourceTypeCacheSvc theResourceTypeCacheSvc)
void	setSearchParamPresenceSvc(ISearchParamPresenceSvc theSearchParamPresenceSvc)
void	setSearchParamWithInlineReferencesExtractor(SearchParamWithInlineReferencesExtractor theSearchParamWithInlineReferencesExtractor)
void	setStorageSettingsForUnitTest(JpaStorageSettings theStorageSettings)
static void	setValidationDisabledForUnitTest(boolean theValidationDisabledForUnitTest)	Do not call this method outside of unit tests
protected boolean	shouldDroppedTagBeRemovedOnUpdate(ca.uhn.fhir.rest.api.server.RequestDetails theRequest, ResourceTag theTag)	This method is called when an update to an existing resource detects that the resource supplied for update is missing a tag/profile/security label that the currently persisted resource holds.
void	start()
ResourceTable	updateEntity(ca.uhn.fhir.rest.api.server.RequestDetails theRequest, org.hl7.fhir.instance.model.api.IBaseResource theResource, IBasePersistedResource theEntity, Date theDeletedTimestampOrNull, boolean thePerformIndexing, boolean theUpdateVersion, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, boolean theForceUpdate, boolean theCreateNewHistoryEntry)
IBasePersistedResource<?>	updateHistoryEntity(ca.uhn.fhir.rest.api.server.RequestDetails theRequest, T theResource, IBasePersistedResource<?> theEntity, IBasePersistedResource<?> theHistoryEntity, org.hl7.fhir.instance.model.api.IIdType theResourceId, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, boolean isUpdatingCurrent)
DaoMethodOutcome	updateInternal(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, T theResource, String theMatchUrl, boolean thePerformIndexing, boolean theForceUpdateVersion, IBasePersistedResource theEntity, org.hl7.fhir.instance.model.api.IIdType theResourceId, org.hl7.fhir.instance.model.api.IBaseResource theOldResource, ca.uhn.fhir.rest.api.RestOperationTypeEnum theOperationType, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
protected boolean	updateTags(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, org.hl7.fhir.instance.model.api.IBaseResource theResource, ResourceTable theEntity)
protected void	validateMetaCount(int theMetaCount)
protected void	validateResourceForStorage(T theResource, ResourceTable theEntityToSave)	This method is invoked immediately before storing a new resource, or an update to an existing resource to allow the DAO to ensure that it is valid for persistence.

Methods inherited from class ca.uhn.fhir.jpa.dao.BaseStorageResourceDao

deleteExpunge, doUpdateForUpdateOrPatch, getDeleteExpungeJobSubmitter, getMatchResourceUrlService, getMatchUrlService, getRequestPartitionHelperService, getResourceName, getResourceType, getStorageResourceParser, getTransactionService, patch, patchInTransaction, readEntityLatestVersion, readEntityLatestVersion, validateResourceType

Methods inherited from class ca.uhn.fhir.jpa.dao.BaseStorageDao

addIssueToOperationOutcomeForAutoCreatedPlaceholder, clearRequestAsProcessingSubRequest, createErrorOperationOutcome, createInfoOperationOutcome, createInfoOperationOutcome, createMethodOutcomeForResourceId, createResourceGoneException, createWarnOperationOutcome, doCallHooks, extractReferencesToAutoVersion, extractReferencesToAvoidReplacement, markRequestAsProcessingSubRequest, populateOperationOutcomeForUpdate, preProcessResourceForStorage, preProcessResourceForStorage, setMyMetaTagSorter, setSearchParamRegistry, toMethodOutcome, toMethodOutcomeLazy, translateRawParameters, verifyResourceIdIsValid

Methods inherited from class java.lang.Object

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

Methods inherited from interface ca.uhn.fhir.jpa.api.dao.IFhirResourceDao

create, create, create, create, create, delete, delete, delete, deleteByUrl, deleteByUrl, deletePidList, deletePidList, expunge, expunge, expunge, fetchAllVersionsOfResources, forceExpungeInExistingTransaction, getCurrentVersionId, getReindexJobStatus, history, history, history, metaAddOperation, metaDeleteOperation, metaGetOperation, metaGetOperation, read, read, read, readByPid, readByPid, reindex, reindex, removeTag, removeTag, search, search, search, searchForIds, searchForIds, searchForIdStream, searchForResourceIds, searchForResources, translateRawParameters, update, update, update, update, update, update, validate, validateCriteriaAndReturnResourceDefinition

Field Details

NS_JPA_PROFILE

public static final String NS_JPA_PROFILE

See Also:

• Constant Field Values

myEntityManager

protected jakarta.persistence.EntityManager myEntityManager

myIdHelperService

@Autowired
protected IIdHelperService<JpaPid> myIdHelperService

mySearchCoordinatorSvc

@Autowired
protected ISearchCoordinatorSvc<JpaPid> mySearchCoordinatorSvc

myTerminologySvc

@Autowired
protected ITermReadSvc myTerminologySvc

myResourceHistoryTableDao

@Autowired
protected IResourceHistoryTableDao myResourceHistoryTableDao

myResourceTableDao

@Autowired
protected IResourceTableDao myResourceTableDao

myResourceLinkDao

@Autowired
protected IResourceLinkDao myResourceLinkDao

myResourceTagDao

@Autowired
protected IResourceTagDao myResourceTagDao

myDeleteConflictService

@Autowired
protected DeleteConflictService myDeleteConflictService

myInterceptorBroadcaster

@Autowired
protected ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster myInterceptorBroadcaster

myInMemoryResourceMatcher

@Autowired
protected InMemoryResourceMatcher myInMemoryResourceMatcher

myJpaStorageResourceParser

@Autowired
protected IJpaStorageResourceParser myJpaStorageResourceParser

myPartitionSettings

@Autowired
protected PartitionSettings myPartitionSettings

myResourceHistoryCalculator

@Autowired
protected ResourceHistoryCalculator myResourceHistoryCalculator

cacheTagDefinitionDao

@Autowired
protected CacheTagDefinitionDao cacheTagDefinitionDao

myResourceTypeCacheSvc

@Autowired
protected IResourceTypeCacheSvc myResourceTypeCacheSvc

myCodingSpy

protected final CodingSpy myCodingSpy

Constructor Details

BaseHapiFhirDao

public BaseHapiFhirDao()

Method Details

setExternallyStoredResourceServiceRegistryForUnitTest

public void setExternallyStoredResourceServiceRegistryForUnitTest(ExternallyStoredResourceServiceRegistry theExternallyStoredResourceServiceRegistry)

setSearchParamPresenceSvc

public void setSearchParamPresenceSvc(ISearchParamPresenceSvc theSearchParamPresenceSvc)

setResourceHistoryCalculator

public void setResourceHistoryCalculator(ResourceHistoryCalculator theResourceHistoryCalculator)

setInterceptorBroadcasterForUnitTest

public void setInterceptorBroadcasterForUnitTest(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster)

getInterceptorBroadcaster

protected ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster getInterceptorBroadcaster()

Specified by:

getInterceptorBroadcaster in class BaseStorageDao

getApplicationContext

protected org.springframework.context.ApplicationContext getApplicationContext()

setApplicationContext

public void setApplicationContext(@Nonnull
 org.springframework.context.ApplicationContext theApplicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

getStorageSettings

public JpaStorageSettings getStorageSettings()

Specified by:

getStorageSettings in class BaseStorageDao

getContext

public ca.uhn.fhir.context.FhirContext getContext()

Specified by:

getContext in interface IDao

Specified by:

getContext in class BaseStorageDao

setContext

@Autowired
public void setContext(ca.uhn.fhir.context.FhirContext theContext)

isLogicalReference

public boolean isLogicalReference(org.hl7.fhir.instance.model.api.IIdType theId)

populateResourceIntoEntity

protected ca.uhn.fhir.jpa.dao.EncodedResource populateResourceIntoEntity(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 org.hl7.fhir.instance.model.api.IBaseResource theResource,
 ResourceTable theEntity,
 boolean thePerformIndexing)

Returns true if the resource has changed (either the contents or the tags)

updateTags

protected boolean updateTags(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 org.hl7.fhir.instance.model.api.IBaseResource theResource,
 ResourceTable theEntity)

postDelete

protected void postDelete(ResourceTable theEntity)

Subclasses may override to provide behaviour. Called when a pre-existing resource has been updated in the database

Parameters:

theEntity - The resource

postPersist

protected void postPersist(ResourceTable theEntity,
 T theResource,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Subclasses may override to provide behaviour. Called when a resource has been inserted into the database for the first time.

Parameters:

theEntity - The entity being updated (Do not modify the entity! Undefined behaviour will occur!)

theResource - The resource being persisted

theRequestDetails - The request details, needed for partition support

postUpdate

protected void postUpdate(ResourceTable theEntity,
 T theResource,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Subclasses may override to provide behaviour. Called when a pre-existing resource has been updated in the database

Parameters:

theEntity - The resource

theResource - The resource being persisted

theRequestDetails - The request details, needed for partition support

readEntity

public BaseHasResource readEntity(org.hl7.fhir.instance.model.api.IIdType theValueId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

readEntity in interface IFhirResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

shouldDroppedTagBeRemovedOnUpdate

protected boolean shouldDroppedTagBeRemovedOnUpdate(ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 ResourceTag theTag)

This method is called when an update to an existing resource detects that the resource supplied for update is missing a tag/profile/security label that the currently persisted resource holds.

The default implementation removes any profile declarations, but leaves tags and security labels in place. Subclasses may choose to override and change this behaviour.

See Updates to Tags, Profiles, and Security Labels for a description of the logic that the default behaviour follows.

Parameters:

theTag - The tag

Returns:

Returns true if the tag should be removed

setEntityManager

public void setEntityManager(jakarta.persistence.EntityManager theEntityManager)

setSearchParamWithInlineReferencesExtractor

public void setSearchParamWithInlineReferencesExtractor(SearchParamWithInlineReferencesExtractor theSearchParamWithInlineReferencesExtractor)

setResourceHistoryTableDao

public void setResourceHistoryTableDao(IResourceHistoryTableDao theResourceHistoryTableDao)

setDaoSearchParamSynchronizer

public void setDaoSearchParamSynchronizer(DaoSearchParamSynchronizer theDaoSearchParamSynchronizer)

updateEntity

public ResourceTable updateEntity(ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 org.hl7.fhir.instance.model.api.IBaseResource theResource,
 IBasePersistedResource theEntity,
 Date theDeletedTimestampOrNull,
 boolean thePerformIndexing,
 boolean theUpdateVersion,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 boolean theForceUpdate,
 boolean theCreateNewHistoryEntry)

Specified by:

updateEntity in interface IJpaDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

updateHistoryEntity

public IBasePersistedResource<?> updateHistoryEntity(ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 T theResource,
 IBasePersistedResource<?> theEntity,
 IBasePersistedResource<?> theHistoryEntity,
 org.hl7.fhir.instance.model.api.IIdType theResourceId,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 boolean isUpdatingCurrent)

updateInternal

public DaoMethodOutcome updateInternal(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 T theResource,
 String theMatchUrl,
 boolean thePerformIndexing,
 boolean theForceUpdateVersion,
 IBasePersistedResource theEntity,
 org.hl7.fhir.instance.model.api.IIdType theResourceId,
 @Nullable
 org.hl7.fhir.instance.model.api.IBaseResource theOldResource,
 ca.uhn.fhir.rest.api.RestOperationTypeEnum theOperationType,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

updateInternal in interface IJpaDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

addPidToResource

protected void addPidToResource(IResourceLookup<JpaPid> theEntity,
 org.hl7.fhir.instance.model.api.IBaseResource theResource)

validateMetaCount

protected void validateMetaCount(int theMetaCount)

validateResourceForStorage

protected void validateResourceForStorage(T theResource,
 ResourceTable theEntityToSave)

This method is invoked immediately before storing a new resource, or an update to an existing resource to allow the DAO to ensure that it is valid for persistence. By default, checks for the "subsetted" tag and rejects resources which have it. Subclasses should call the superclass implementation to preserve this check.

Parameters:

theResource - The resource that is about to be persisted

theEntityToSave - TODO

start

@PostConstruct
public void start()

setStorageSettingsForUnitTest

public void setStorageSettingsForUnitTest(JpaStorageSettings theStorageSettings)

setPartitionSettingsForUnitTest

public void setPartitionSettingsForUnitTest(PartitionSettings thePartitionSettings)

setJpaStorageResourceParserForUnitTest

public void setJpaStorageResourceParserForUnitTest(IJpaStorageResourceParser theJpaStorageResourceParser)

Do not call this method outside of unit tests

setResourceTypeCacheSvc

public void setResourceTypeCacheSvc(IResourceTypeCacheSvc theResourceTypeCacheSvc)

parseContentTextIntoWords

@Nullable
public static String parseContentTextIntoWords(@Nonnull
 ca.uhn.fhir.context.FhirContext theContext,
 @Nullable
 org.hl7.fhir.instance.model.api.IBaseResource theResource)

decodeResource

public static String decodeResource(byte[] theResourceBytes,
 ResourceEncodingEnum theResourceEncoding)

setDisableIncrementOnUpdateForUnitTest

public static void setDisableIncrementOnUpdateForUnitTest(boolean theDisableIncrementOnUpdateForUnitTest)

setValidationDisabledForUnitTest

public static void setValidationDisabledForUnitTest(boolean theValidationDisabledForUnitTest)

Do not call this method outside of unit tests