Package ca.uhn.fhir.jpa.dao

Class BaseTransactionProcessor

java.lang.Object

ca.uhn.fhir.jpa.dao.BaseTransactionProcessor

public abstract class BaseTransactionProcessor
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	BaseTransactionProcessor.RetriableBundleTask
class	BaseTransactionProcessor.TransactionSorter	Transaction Order, per the spec:

Field Summary

Fields

Modifier and Type	Field	Description
static final Pattern	INVALID_PLACEHOLDER_PATTERN
protected IHapiTransactionService	myHapiTransactionService
static final Pattern	UNQUALIFIED_MATCH_URL_START
static final String	URN_PREFIX
static final String	URN_PREFIX_ESCAPED

Constructor Summary

Constructors

Constructor	Description
BaseTransactionProcessor()

Method Summary

Modifier and Type	Method	Description
org.hl7.fhir.instance.model.api.IBaseBundle	collection(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, org.hl7.fhir.instance.model.api.IBaseBundle theRequest)
protected RequestPartitionId	determineRequestPartitionIdForWriteEntries(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, List<org.hl7.fhir.instance.model.api.IBase> theEntries)	This method looks at the FHIR actions being performed in a List of bundle entries, and determines the associated request partitions.
protected EntriesToProcessMap	doTransactionWriteOperations(ca.uhn.fhir.rest.api.server.RequestDetails theRequest, RequestPartitionId theRequestPartitionId, String theActionName, ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails, Set<org.hl7.fhir.instance.model.api.IIdType> theAllIds, IdSubstitutionMap theIdSubstitutions, Map<org.hl7.fhir.instance.model.api.IIdType,DaoMethodOutcome> theIdToPersistedOutcome, org.hl7.fhir.instance.model.api.IBaseBundle theResponse, IdentityHashMap<org.hl7.fhir.instance.model.api.IBase,Integer> theOriginalRequestOrder, List<org.hl7.fhir.instance.model.api.IBase> theEntries, ca.uhn.fhir.util.StopWatch theTransactionStopWatch)	After pre-hooks have been called
protected abstract void	flushSession(Map<org.hl7.fhir.instance.model.api.IIdType,DaoMethodOutcome> theIdToPersistedOutcome)
ITransactionProcessorVersionAdapter	getVersionAdapter()
protected void	handleVerbChangeInTransactionWriteOperations()	Subclasses may override this in order to invoke specific operations when we're finished handling all the write entries in the transaction bundle with a given verb.
static boolean	isPlaceholder(org.hl7.fhir.instance.model.api.IIdType theId)
static String	performIdSubstitutionsInMatchUrl(IdSubstitutionMap theIdSubstitutions, String theMatchUrl)	Given a match URL containing
protected void	postTransactionProcess(ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails)	Implement to handle post transaction processing
void	setContext(ca.uhn.fhir.context.FhirContext theContext)
void	setDaoRegistry(DaoRegistry theDaoRegistry)
void	setHapiTransactionService(HapiTransactionService theHapiTransactionService)
void	setInterceptorBroadcasterForUnitTest(ca.uhn.fhir.interceptor.api.IInterceptorBroadcaster theInterceptorBroadcaster)
void	setPartitionSettingsForUnitTest(PartitionSettings thePartitionSettings)
void	setStorageSettings(StorageSettings theStorageSettings)
void	setTxManager(org.springframework.transaction.PlatformTransactionManager theTxManager)
void	setVersionAdapter(ITransactionProcessorVersionAdapter theVersionAdapter)
static String	toStatusString(int theStatusCode)
<BUNDLE extends org.hl7.fhir.instance.model.api.IBaseBundle> BUNDLE	transaction(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails, BUNDLE theRequest, boolean theNestedMode)
protected void	validateDependencies()

Methods inherited from class java.lang.Object

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

Field Details

URN_PREFIX

public static final String URN_PREFIX

See Also:

• Constant Field Values

URN_PREFIX_ESCAPED

public static final String URN_PREFIX_ESCAPED

UNQUALIFIED_MATCH_URL_START

public static final Pattern UNQUALIFIED_MATCH_URL_START

INVALID_PLACEHOLDER_PATTERN

public static final Pattern INVALID_PLACEHOLDER_PATTERN

myHapiTransactionService

@Autowired
protected IHapiTransactionService myHapiTransactionService

Constructor Details

BaseTransactionProcessor

public BaseTransactionProcessor()

Method Details

setStorageSettings

public void setStorageSettings(StorageSettings theStorageSettings)

getVersionAdapter

public ITransactionProcessorVersionAdapter getVersionAdapter()

setVersionAdapter

public void setVersionAdapter(ITransactionProcessorVersionAdapter theVersionAdapter)

transaction

public <BUNDLE extends org.hl7.fhir.instance.model.api.IBaseBundle>
BUNDLE transaction(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 BUNDLE theRequest,
 boolean theNestedMode)

collection

public org.hl7.fhir.instance.model.api.IBaseBundle collection(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 org.hl7.fhir.instance.model.api.IBaseBundle theRequest)

setTxManager

public void setTxManager(org.springframework.transaction.PlatformTransactionManager theTxManager)

setHapiTransactionService

public void setHapiTransactionService(HapiTransactionService theHapiTransactionService)

determineRequestPartitionIdForWriteEntries

@Nullable
protected RequestPartitionId determineRequestPartitionIdForWriteEntries(ca.uhn.fhir.rest.api.server.RequestDetails theRequestDetails,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 List<org.hl7.fhir.instance.model.api.IBase> theEntries)

This method looks at the FHIR actions being performed in a List of bundle entries, and determines the associated request partitions.

validateDependencies

protected void validateDependencies()

doTransactionWriteOperations

protected EntriesToProcessMap doTransactionWriteOperations(ca.uhn.fhir.rest.api.server.RequestDetails theRequest,
 RequestPartitionId theRequestPartitionId,
 String theActionName,
 ca.uhn.fhir.rest.api.server.storage.TransactionDetails theTransactionDetails,
 Set<org.hl7.fhir.instance.model.api.IIdType> theAllIds,
 IdSubstitutionMap theIdSubstitutions,
 Map<org.hl7.fhir.instance.model.api.IIdType,DaoMethodOutcome> theIdToPersistedOutcome,
 org.hl7.fhir.instance.model.api.IBaseBundle theResponse,
 IdentityHashMap<org.hl7.fhir.instance.model.api.IBase,Integer> theOriginalRequestOrder,
 List<org.hl7.fhir.instance.model.api.IBase> theEntries,
 ca.uhn.fhir.util.StopWatch theTransactionStopWatch)

After pre-hooks have been called

handleVerbChangeInTransactionWriteOperations

protected void handleVerbChangeInTransactionWriteOperations()

Subclasses may override this in order to invoke specific operations when we're finished handling all the write entries in the transaction bundle with a given verb.

postTransactionProcess

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

Implement to handle post transaction processing

flushSession

protected abstract void flushSession(Map<org.hl7.fhir.instance.model.api.IIdType,DaoMethodOutcome> theIdToPersistedOutcome)

setDaoRegistry

public void setDaoRegistry(DaoRegistry theDaoRegistry)

setContext

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

setInterceptorBroadcasterForUnitTest

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

setPartitionSettingsForUnitTest

public void setPartitionSettingsForUnitTest(PartitionSettings thePartitionSettings)

isPlaceholder

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

toStatusString

public static String toStatusString(int theStatusCode)

performIdSubstitutionsInMatchUrl

public static String performIdSubstitutionsInMatchUrl(IdSubstitutionMap theIdSubstitutions,
 String theMatchUrl)

Given a match URL containing

Parameters:

theIdSubstitutions -

theMatchUrl -

Returns: