Package ca.uhn.fhir.jpa.dao

Class BaseHapiFhirResourceDao<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>

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

All Implemented Interfaces:

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

Direct Known Subclasses:

FhirResourceDaoSubscriptionDstu2, FhirResourceDaoSubscriptionDstu3, FhirResourceDaoSubscriptionR4, FhirResourceDaoSubscriptionR4B, FhirResourceDaoSubscriptionR5, JpaResourceDao, JpaResourceDaoBundle, JpaResourceDaoCodeSystem, JpaResourceDaoComposition, JpaResourceDaoEncounter, JpaResourceDaoObservation, JpaResourceDaoPatient, JpaResourceDaoSearchParameter, JpaResourceDaoStructureDefinition, JpaResourceDaoValueSet

public abstract class BaseHapiFhirResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>
extends BaseHapiFhirDao<T>
implements IFhirResourceDao<T>

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BASE_RESOURCE_NAME
protected ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster	myInterceptorBroadcaster
protected org.springframework.transaction.PlatformTransactionManager	myPlatformTransactionManager
protected IFulltextSearchSvc	mySearchDao
protected HapiTransactionService	myTransactionService

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

cacheTagDefinitionDao, myCodingSpy, myDeleteConflictService, myEntityManager, myIdHelperService, myInMemoryResourceMatcher, myJpaStorageResourceParser, myPartitionSettings, myResourceHistoryCalculator, myResourceHistoryTableDao, myResourceLinkDao, myResourceTableDao, myResourceTagDao, myResourceTypeCacheSvc, mySearchCoordinatorSvc, myTerminologySvc, 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, 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
BaseHapiFhirResourceDao()

Method Summary

Modifier and Type	Method	Description
DaoMethodOutcome	create(T theResource)	Deprecated. Use create(T, RequestDetails) instead
DaoMethodOutcome	create(T theResource, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
DaoMethodOutcome	create(T theResource, String theIfNoneExist)	Deprecated. Use create(T, String, RequestDetails) instead
DaoMethodOutcome	create(T theResource, String theIfNoneExist, boolean thePerformIndexing, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
DaoMethodOutcome	create(T theResource, String theIfNoneExist, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
DaoMethodOutcome	delete(org.hl7.fhir.instance.model.api.IIdType theId)	Deprecated. Use delete(IIdType, RequestDetails) instead
DaoMethodOutcome	delete(org.hl7.fhir.instance.model.api.IIdType theId, DeleteConflictList theDeleteConflicts, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
DaoMethodOutcome	delete(org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
DeleteMethodOutcome	deleteByUrl(String theUrl, DeleteConflictList deleteConflicts, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)	This method gets called by deleteByUrl(String, RequestDetails) as well as by transaction processors
DeleteMethodOutcome	deleteByUrl(String theUrl, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
<P extends ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> DeleteMethodOutcome	deletePidList(String theUrl, Collection<P> theResourceIds, DeleteConflictList theDeleteConflicts, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
protected DaoMethodOutcome	doCreateForPost(T theResource, String theIfNoneExist, boolean thePerformIndexing, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, RequestPartitionId theRequestPartitionId)	Called for FHIR create (POST) operations
protected <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> void	doMetaAddOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId, MT theMetaAdd, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, RequestPartitionId theRequestPartitionId)
<MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> void	doMetaDeleteOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId, MT theMetaDel, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, RequestPartitionId theRequestPartitionId)
protected DaoMethodOutcome	doUpdateForUpdateOrPatch(UpdateParameters<T> theUpdateParameters)
ExpungeOutcome	expunge(ExpungeOptions theExpungeOptions, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
<P extends ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> void	expunge(Collection<P> theResourceIds, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
ExpungeOutcome	expunge(org.hl7.fhir.instance.model.api.IIdType theId, ExpungeOptions theExpungeOptions, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
Stream<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId>	fetchAllVersionsOfResources(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, Collection<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> theIds)
ExpungeOutcome	forceExpungeInExistingTransaction(org.hl7.fhir.instance.model.api.IIdType theId, ExpungeOptions theExpungeOptions, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
protected ca.uhn.fhir.rest.api.server.storage.IDeleteExpungeJobSubmitter	getDeleteExpungeJobSubmitter()
protected MatchResourceUrlService	getMatchResourceUrlService()
protected MatchUrlService	getMatchUrlService()
protected String	getMessageSanitized(String theKey, String theIdPart)
protected IRequestPartitionHelperSvc	getRequestPartitionHelperService()
String	getResourceName()
Class<T>	getResourceType()
protected IStorageResourceParser	getStorageResourceParser()
protected HapiTransactionService	getTransactionService()
ca.uhn.fhir.rest.api.server.IBundleProvider	history(Date theSince, Date theUntil, Integer theOffset, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
ca.uhn.fhir.rest.api.server.IBundleProvider	history(org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.param.HistorySearchDateRangeParam theHistorySearchDateRangeParam, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
ca.uhn.fhir.rest.api.server.IBundleProvider	history(org.hl7.fhir.instance.model.api.IIdType theId, Date theSince, Date theUntil, Integer theOffset, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)	Deprecated. Use history(IIdType, HistorySearchDateRangeParam, RequestDetails) instead
static void	invokeStoragePreAccessResources(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, org.hl7.fhir.instance.model.api.IIdType theId, org.hl7.fhir.instance.model.api.IBaseResource theResource)
static <T extends org.hl7.fhir.instance.model.api.IBaseResource> T	invokeStoragePreShowResources(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, T retVal)
protected boolean	isPagingProviderDatabaseBacked(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
static <T extends org.hl7.fhir.instance.model.api.IBaseResource> boolean	isResourceIdServerAssigned(org.hl7.fhir.instance.model.api.IBaseResource theResource)
<MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> MT	metaAddOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId, MT theMetaAdd, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
<MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> MT	metaDeleteOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId, MT theMetaDel, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
<MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> MT	metaGetOperation(Class<MT> theType, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
<MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> MT	metaGetOperation(Class<MT> theType, org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
protected void	postUpdateTransaction(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
protected void	preDelete(T theResourceToDelete, ResourceTable theEntityToDelete, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)	Subclasses may override to provide behaviour.
T	read(org.hl7.fhir.instance.model.api.IIdType theId)	Deprecated. Use read(IIdType, RequestDetails) instead
T	read(org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
T	read(org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, boolean theDeletedOk)
T	readByPid(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePid)
T	readByPid(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePid, boolean theDeletedOk)
BaseHasResource	readEntity(org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
protected IBasePersistedResource	readEntityLatestVersion(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePersistentId, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
protected ResourceTable	readEntityLatestVersion(org.hl7.fhir.instance.model.api.IIdType theId, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
ReindexOutcome	reindex(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePid, ReindexParameters theReindexParameters, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
void	reindex(T theResource, IBasePersistedResource theEntity)	Deprecated. Use reindex(IResourcePersistentId, ReindexParameters, RequestDetails, TransactionDetails)
void	removeTag(org.hl7.fhir.instance.model.api.IIdType theId, TagTypeEnum theTagType, String theScheme, String theTerm)
void	removeTag(org.hl7.fhir.instance.model.api.IIdType theId, TagTypeEnum theTagType, String theScheme, String theTerm, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
protected void	requestReindexForRelatedResources(Boolean theCurrentlyReindexing, List<String> theBase, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
ca.uhn.fhir.rest.api.server.IBundleProvider	search(SearchParameterMap theParams)	Deprecated. Use search(SearchParameterMap, RequestDetails) instead
ca.uhn.fhir.rest.api.server.IBundleProvider	search(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
ca.uhn.fhir.rest.api.server.IBundleProvider	search(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, jakarta.servlet.http.HttpServletResponse theServletResponse)
List<JpaPid>	searchForIds(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, org.hl7.fhir.instance.model.api.IBaseResource theConditionalOperationTargetOrNull)
<PID extends ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId<?>> Stream<PID>	searchForIdStream(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, org.hl7.fhir.instance.model.api.IBaseResource theConditionalOperationTargetOrNull)
List<org.hl7.fhir.instance.model.api.IIdType>	searchForResourceIds(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
List<T>	searchForResources(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
void	setIdHelperSvcForUnitTest(IIdHelperService theIdHelperService)
protected void	setOffsetAndCount(SearchParameterMap theParams, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
void	setRequestPartitionHelperService(IRequestPartitionHelperSvc theRequestPartitionHelperService)
void	setResourceType(Class<? extends org.hl7.fhir.instance.model.api.IBaseResource> theTableType)
void	setTransactionService(HapiTransactionService theTransactionService)
protected final boolean	shouldSkipReindex(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
void	start()
protected <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType> MT	toMetaDt(Class<MT> theType, Collection<TagDefinition> tagDefinitions)
DaoMethodOutcome	update(T theResource)	Deprecated. Use update(T, RequestDetails) instead
DaoMethodOutcome	update(T theResource, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
DaoMethodOutcome	update(T theResource, String theMatchUrl)	Deprecated. Use update(T, String, RequestDetails) instead
DaoMethodOutcome	update(T theResource, String theMatchUrl, boolean thePerformIndexing, boolean theForceUpdateVersion, ca.uhn.fhir.rest.api.server.RequestDetails theRequest, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)
DaoMethodOutcome	update(T theResource, String theMatchUrl, boolean thePerformIndexing, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
DaoMethodOutcome	update(T theResource, String theMatchUrl, ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)
protected ResourceTable	updateEntityForDelete(ca.uhn.fhir.rest.api.server.RequestDetails theRequest, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, ResourceTable theEntity)
ca.uhn.fhir.rest.api.MethodOutcome	validate(T theResource, org.hl7.fhir.instance.model.api.IIdType theId, String theRawResource, ca.uhn.fhir.rest.api.EncodingEnum theEncoding, ca.uhn.fhir.rest.api.ValidationModeEnum theMode, String theProfile, ca.uhn.fhir.rest.api.server.RequestDetails theRequest)
ca.uhn.fhir.context.RuntimeResourceDefinition	validateCriteriaAndReturnResourceDefinition(String criteria)	Get the resource definition from the criteria which specifies the resource type
protected void	validatePartitionIdMatch(org.hl7.fhir.instance.model.api.IIdType theResourceIdType, RequestPartitionId theRequestPartitionId, ResourceTable theEntity)	Validates that the partition ID of the request resource matches the partition ID of the entity.

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

addPidToResource, decodeResource, getApplicationContext, getContext, getInterceptorBroadcaster, getStorageSettings, isLogicalReference, parseContentTextIntoWords, populateResourceIntoEntity, postDelete, postPersist, postUpdate, setApplicationContext, setContext, setDaoSearchParamSynchronizer, setDisableIncrementOnUpdateForUnitTest, setEntityManager, setExternallyStoredResourceServiceRegistryForUnitTest, setInterceptorBroadcasterForUnitTest, setJpaStorageResourceParserForUnitTest, setPartitionSettingsForUnitTest, setResourceHistoryCalculator, setResourceHistoryTableDao, setResourceTypeCacheSvc, setSearchParamPresenceSvc, setSearchParamWithInlineReferencesExtractor, setStorageSettingsForUnitTest, setValidationDisabledForUnitTest, shouldDroppedTagBeRemovedOnUpdate, updateEntity, updateHistoryEntity, updateInternal, updateTags, validateMetaCount, validateResourceForStorage

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

deleteExpunge, patch, patchInTransaction, 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.IDao

getContext

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

deletePidList, getCurrentVersionId, getReindexJobStatus, patch, patchInTransaction, searchForIds, translateRawParameters

Field Details

BASE_RESOURCE_NAME

public static final String BASE_RESOURCE_NAME

See Also:

• Constant Field Values

myInterceptorBroadcaster

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

myPlatformTransactionManager

@Autowired
protected org.springframework.transaction.PlatformTransactionManager myPlatformTransactionManager

mySearchDao

@Autowired(required=false)
protected IFulltextSearchSvc mySearchDao

myTransactionService

@Autowired
protected HapiTransactionService myTransactionService

Constructor Details

BaseHapiFhirResourceDao

public BaseHapiFhirResourceDao()

Method Details

invokeStoragePreShowResources

@Nullable
public static <T extends org.hl7.fhir.instance.model.api.IBaseResource>
T invokeStoragePreShowResources(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 T retVal)

invokeStoragePreAccessResources

public static void invokeStoragePreAccessResources(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 org.hl7.fhir.instance.model.api.IIdType theId,
 org.hl7.fhir.instance.model.api.IBaseResource theResource)

getTransactionService

protected HapiTransactionService getTransactionService()

Specified by:

getTransactionService in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

setTransactionService

public void setTransactionService(HapiTransactionService theTransactionService)

getMatchResourceUrlService

protected MatchResourceUrlService getMatchResourceUrlService()

Specified by:

getMatchResourceUrlService in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

getStorageResourceParser

protected IStorageResourceParser getStorageResourceParser()

Specified by:

getStorageResourceParser in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

getDeleteExpungeJobSubmitter

protected ca.uhn.fhir.rest.api.server.storage.IDeleteExpungeJobSubmitter getDeleteExpungeJobSubmitter()

Specified by:

getDeleteExpungeJobSubmitter in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

getRequestPartitionHelperService

protected IRequestPartitionHelperSvc getRequestPartitionHelperService()

Specified by:

getRequestPartitionHelperService in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

getMatchUrlService

protected MatchUrlService getMatchUrlService()

Specified by:

getMatchUrlService in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

create

public DaoMethodOutcome create(T theResource)

Deprecated.

Use create(T, RequestDetails) instead

Specified by:

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

create

public DaoMethodOutcome create(T theResource,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

create

public DaoMethodOutcome create(T theResource,
 String theIfNoneExist)

Deprecated.

Use create(T, String, RequestDetails) instead

Specified by:

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

create

public DaoMethodOutcome create(T theResource,
 String theIfNoneExist,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

create

public DaoMethodOutcome create(T theResource,
 String theIfNoneExist,
 boolean thePerformIndexing,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 @Nonnull
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

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

setRequestPartitionHelperService

public void setRequestPartitionHelperService(IRequestPartitionHelperSvc theRequestPartitionHelperService)

doCreateForPost

protected DaoMethodOutcome doCreateForPost(T theResource,
 String theIfNoneExist,
 boolean thePerformIndexing,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 RequestPartitionId theRequestPartitionId)

Called for FHIR create (POST) operations

getMessageSanitized

protected String getMessageSanitized(String theKey,
 String theIdPart)

delete

public DaoMethodOutcome delete(org.hl7.fhir.instance.model.api.IIdType theId)

Deprecated.

Use delete(IIdType, RequestDetails) instead

Specified by:

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

delete

public DaoMethodOutcome delete(org.hl7.fhir.instance.model.api.IIdType theId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

delete

public DaoMethodOutcome delete(org.hl7.fhir.instance.model.api.IIdType theId,
 DeleteConflictList theDeleteConflicts,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 @Nonnull
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

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

deleteByUrl

public DeleteMethodOutcome deleteByUrl(String theUrl,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

deleteByUrl

public DeleteMethodOutcome deleteByUrl(String theUrl,
 DeleteConflictList deleteConflicts,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 @Nonnull
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

This method gets called by deleteByUrl(String, RequestDetails) as well as by transaction processors

Specified by:

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

expunge

public <P extends ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId>
void expunge(Collection<P> theResourceIds,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

deletePidList

@Nonnull
public <P extends ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId>
DeleteMethodOutcome deletePidList(String theUrl,
 Collection<P> theResourceIds,
 DeleteConflictList theDeleteConflicts,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

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

updateEntityForDelete

protected ResourceTable updateEntityForDelete(ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 ResourceTable theEntity)

expunge

public ExpungeOutcome expunge(org.hl7.fhir.instance.model.api.IIdType theId,
 ExpungeOptions theExpungeOptions,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

expunge

public ExpungeOutcome expunge(ExpungeOptions theExpungeOptions,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

fetchAllVersionsOfResources

public Stream<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> fetchAllVersionsOfResources(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 Collection<ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId> theIds)

Specified by:

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

forceExpungeInExistingTransaction

public ExpungeOutcome forceExpungeInExistingTransaction(org.hl7.fhir.instance.model.api.IIdType theId,
 ExpungeOptions theExpungeOptions,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

getResourceName

@Nonnull
public String getResourceName()

Specified by:

getResourceName in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

getResourceType

public Class<T> getResourceType()

Specified by:

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

Specified by:

getResourceType in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

setResourceType

public void setResourceType(Class<? extends org.hl7.fhir.instance.model.api.IBaseResource> theTableType)

history

public ca.uhn.fhir.rest.api.server.IBundleProvider history(Date theSince,
 Date theUntil,
 Integer theOffset,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

history

public ca.uhn.fhir.rest.api.server.IBundleProvider history(org.hl7.fhir.instance.model.api.IIdType theId,
 Date theSince,
 Date theUntil,
 Integer theOffset,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Deprecated.

Use history(IIdType, HistorySearchDateRangeParam, RequestDetails) instead

Specified by:

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

history

public ca.uhn.fhir.rest.api.server.IBundleProvider history(org.hl7.fhir.instance.model.api.IIdType theId,
 ca.uhn.fhir.rest.param.HistorySearchDateRangeParam theHistorySearchDateRangeParam,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

isPagingProviderDatabaseBacked

protected boolean isPagingProviderDatabaseBacked(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

requestReindexForRelatedResources

protected void requestReindexForRelatedResources(Boolean theCurrentlyReindexing,
 List<String> theBase,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

shouldSkipReindex

protected final boolean shouldSkipReindex(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

metaAddOperation

@Transactional
public <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
MT metaAddOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId,
 MT theMetaAdd,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

doMetaAddOperation

protected <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
void doMetaAddOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId,
 MT theMetaAdd,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 RequestPartitionId theRequestPartitionId)

metaDeleteOperation

@Transactional
public <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
MT metaDeleteOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId,
 MT theMetaDel,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

doMetaDeleteOperation

@Transactional
public <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
void doMetaDeleteOperation(org.hl7.fhir.instance.model.api.IIdType theResourceId,
 MT theMetaDel,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 RequestPartitionId theRequestPartitionId)

metaGetOperation

public <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
MT metaGetOperation(Class<MT> theType,
 org.hl7.fhir.instance.model.api.IIdType theId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

metaGetOperation

@Transactional
public <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
MT metaGetOperation(Class<MT> theType,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

start

@PostConstruct
public void start()

Overrides:

start in class BaseHapiFhirDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

preDelete

protected void preDelete(T theResourceToDelete,
 ResourceTable theEntityToDelete,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Subclasses may override to provide behaviour. Invoked within a delete transaction with the resource that is about to be deleted.

readByPid

@Transactional
public T readByPid(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePid)

Specified by:

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

readByPid

@Transactional
public T readByPid(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePid,
 boolean theDeletedOk)

Specified by:

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

read

public T read(org.hl7.fhir.instance.model.api.IIdType theId)

Deprecated.

Use read(IIdType, RequestDetails) instead

Specified by:

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

read

public T read(org.hl7.fhir.instance.model.api.IIdType theId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

read

public T read(org.hl7.fhir.instance.model.api.IIdType theId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 boolean theDeletedOk)

Specified by:

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

readEntity

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

Specified by:

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

Overrides:

readEntity in class BaseHapiFhirDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

reindex

public ReindexOutcome reindex(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePid,
 ReindexParameters theReindexParameters,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

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

reindex

@Deprecated
public void reindex(T theResource,
 IBasePersistedResource theEntity)

Deprecated.

Use reindex(IResourcePersistentId, ReindexParameters, RequestDetails, TransactionDetails)

Specified by:

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

readEntityLatestVersion

protected IBasePersistedResource readEntityLatestVersion(ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId thePersistentId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

readEntityLatestVersion in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

readEntityLatestVersion

@Nonnull
protected ResourceTable readEntityLatestVersion(org.hl7.fhir.instance.model.api.IIdType theId,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

readEntityLatestVersion in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

removeTag

@Transactional
public void removeTag(org.hl7.fhir.instance.model.api.IIdType theId,
 TagTypeEnum theTagType,
 String theScheme,
 String theTerm)

Specified by:

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

removeTag

@Transactional
public void removeTag(org.hl7.fhir.instance.model.api.IIdType theId,
 TagTypeEnum theTagType,
 String theScheme,
 String theTerm,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

search

public ca.uhn.fhir.rest.api.server.IBundleProvider search(SearchParameterMap theParams)

Deprecated.

Use search(SearchParameterMap, RequestDetails) instead

Specified by:

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

search

public ca.uhn.fhir.rest.api.server.IBundleProvider search(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

search

public ca.uhn.fhir.rest.api.server.IBundleProvider search(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 jakarta.servlet.http.HttpServletResponse theServletResponse)

Specified by:

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

setOffsetAndCount

protected void setOffsetAndCount(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

searchForIds

public List<JpaPid> searchForIds(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 @Nullable
 org.hl7.fhir.instance.model.api.IBaseResource theConditionalOperationTargetOrNull)

Specified by:

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

searchForIdStream

public <PID extends ca.uhn.fhir.rest.api.server.storage.IResourcePersistentId<?>>
Stream<PID> searchForIdStream(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 @Nullable
 org.hl7.fhir.instance.model.api.IBaseResource theConditionalOperationTargetOrNull)

Specified by:

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

searchForResources

public List<T> searchForResources(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

searchForResourceIds

public List<org.hl7.fhir.instance.model.api.IIdType> searchForResourceIds(SearchParameterMap theParams,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

toMetaDt

protected <MT extends org.hl7.fhir.instance.model.api.IBaseMetaType>
MT toMetaDt(Class<MT> theType,
 Collection<TagDefinition> tagDefinitions)

update

public DaoMethodOutcome update(T theResource)

Deprecated.

Use update(T, RequestDetails) instead

Specified by:

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

update

public DaoMethodOutcome update(T theResource,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

update

public DaoMethodOutcome update(T theResource,
 String theMatchUrl)

Deprecated.

Use update(T, String, RequestDetails) instead

Specified by:

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

update

public DaoMethodOutcome update(T theResource,
 String theMatchUrl,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

update

public DaoMethodOutcome update(T theResource,
 String theMatchUrl,
 boolean thePerformIndexing,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails)

Specified by:

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

update

public DaoMethodOutcome update(T theResource,
 String theMatchUrl,
 boolean thePerformIndexing,
 boolean theForceUpdateVersion,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 @Nonnull
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

Specified by:

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

postUpdateTransaction

protected void postUpdateTransaction(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)

doUpdateForUpdateOrPatch

protected DaoMethodOutcome doUpdateForUpdateOrPatch(UpdateParameters<T> theUpdateParameters)

Overrides:

doUpdateForUpdateOrPatch in class BaseStorageResourceDao<T extends org.hl7.fhir.instance.model.api.IBaseResource>

validate

public ca.uhn.fhir.rest.api.MethodOutcome validate(T theResource,
 org.hl7.fhir.instance.model.api.IIdType theId,
 String theRawResource,
 ca.uhn.fhir.rest.api.EncodingEnum theEncoding,
 ca.uhn.fhir.rest.api.ValidationModeEnum theMode,
 String theProfile,
 ca.uhn.fhir.rest.api.server.RequestDetails theRequest)

Specified by:

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

validateCriteriaAndReturnResourceDefinition

public ca.uhn.fhir.context.RuntimeResourceDefinition validateCriteriaAndReturnResourceDefinition(String criteria)

Get the resource definition from the criteria which specifies the resource type

Specified by:

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

setIdHelperSvcForUnitTest

public void setIdHelperSvcForUnitTest(IIdHelperService theIdHelperService)

isResourceIdServerAssigned

public static <T extends org.hl7.fhir.instance.model.api.IBaseResource>
boolean isResourceIdServerAssigned(org.hl7.fhir.instance.model.api.IBaseResource theResource)

validatePartitionIdMatch

protected void validatePartitionIdMatch(@Nonnull
 org.hl7.fhir.instance.model.api.IIdType theResourceIdType,
 @Nonnull
 RequestPartitionId theRequestPartitionId,
 @Nonnull
 ResourceTable theEntity)

Validates that the partition ID of the request resource matches the partition ID of the entity.

If the request is for all partitions, this method does nothing. Otherwise, it checks that the resource type and FHIR ID of the entity match those of the provided resource ID type, and that the partition IDs are equal. If there is a mismatch, an InvalidRequestException is thrown.

Parameters:

theResourceIdType - The resource ID type being processed

theRequestPartitionId - The partition ID from the request

theEntity - The entity being updated

Throws:

ca.uhn.fhir.rest.server.exceptions.InvalidRequestException - if the partition IDs do not match for the same resource type and FHIR ID