Package ca.uhn.fhir.jpa.batch2

Class JpaJobPersistenceImpl

java.lang.Object

ca.uhn.fhir.jpa.batch2.JpaJobPersistenceImpl

All Implemented Interfaces:

IJobPersistence, IWorkChunkPersistence

public class JpaJobPersistenceImpl
extends Object
implements IJobPersistence

Nested Class Summary

Nested classes/interfaces inherited from interface ca.uhn.fhir.batch2.api.IJobPersistence

IJobPersistence.CreateResult, IJobPersistence.JobInstanceUpdateCallback

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CREATE_TIME

Constructor Summary

Constructors

Constructor	Description
JpaJobPersistenceImpl(IBatch2JobInstanceRepository theJobInstanceRepository, IBatch2WorkChunkRepository theWorkChunkRepository, IHapiTransactionService theTransactionService, javax.persistence.EntityManager theEntityManager)	Constructor

Method Summary

Modifier and Type	Method	Description
boolean	canAdvanceInstanceToNextStep(String theInstanceId, String theCurrentStepId)
JobOperationResultJson	cancelInstance(String theInstanceId)
void	deleteChunksAndMarkInstanceAsChunksPurged(String theInstanceId)
void	deleteInstanceAndChunks(String theInstanceId)
List<String>	fetchAllChunkIdsForStepWithStatus(String theInstanceId, String theStepId, WorkChunkStatusEnum theStatusEnum)
Stream<WorkChunk>	fetchAllWorkChunksForStepStream(String theInstanceId, String theStepId)
Iterator<WorkChunk>	fetchAllWorkChunksIterator(String theInstanceId, boolean theWithData)	Note: Not @Transactional because the transaction happens in a lambda that's called outside of this method's scope
Optional<JobInstance>	fetchInstance(String theInstanceId)
List<JobInstance>	fetchInstances(int thePageSize, int thePageIndex)
List<JobInstance>	fetchInstances(FetchJobInstancesRequest theRequest, int thePage, int theBatchSize)
List<JobInstance>	fetchInstances(String theJobDefinitionId, Set<StatusEnum> theStatuses, Date theCutoff, org.springframework.data.domain.Pageable thePageable)
List<JobInstance>	fetchInstancesByJobDefinitionId(String theJobDefinitionId, int thePageSize, int thePageIndex)
List<JobInstance>	fetchInstancesByJobDefinitionIdAndStatus(String theJobDefinitionId, Set<StatusEnum> theRequestedStatuses, int thePageSize, int thePageIndex)
org.springframework.data.domain.Page<JobInstance>	fetchJobInstances(JobInstanceFetchRequest theRequest)
List<JobInstance>	fetchRecentInstances(int thePageSize, int thePageIndex)
boolean	markInstanceAsStatusWhenStatusIn(String theInstanceId, StatusEnum theStatusEnum, Set<StatusEnum> thePriorStates)
void	markWorkChunksWithStatusAndWipeData(String theInstanceId, List<String> theChunkIds, WorkChunkStatusEnum theStatus, String theErrorMessage)
void	onWorkChunkCompletion(WorkChunkCompletionEvent theEvent)
String	onWorkChunkCreate(WorkChunkCreateEvent theBatchWorkChunk)
Optional<WorkChunk>	onWorkChunkDequeue(String theChunkId)
WorkChunkStatusEnum	onWorkChunkError(WorkChunkErrorEvent theParameters)
void	onWorkChunkFailed(String theChunkId, String theErrorMessage)
String	storeNewInstance(JobInstance theInstance)
boolean	updateInstance(String theInstanceId, IJobPersistence.JobInstanceUpdateCallback theModifier)
void	updateInstanceUpdateTime(String theInstanceId)

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.batch2.api.IJobPersistence

onChunkDequeued, onCreateWithFirstChunk

Field Details

CREATE_TIME

public static final String CREATE_TIME

See Also:

• Constant Field Values

Constructor Details

JpaJobPersistenceImpl

public JpaJobPersistenceImpl(IBatch2JobInstanceRepository theJobInstanceRepository,
 IBatch2WorkChunkRepository theWorkChunkRepository,
 IHapiTransactionService theTransactionService,
 javax.persistence.EntityManager theEntityManager)

Constructor

Method Details

onWorkChunkCreate

public String onWorkChunkCreate(WorkChunkCreateEvent theBatchWorkChunk)

Specified by:

onWorkChunkCreate in interface IWorkChunkPersistence

onWorkChunkDequeue

@Transactional(propagation=REQUIRED)
public Optional<WorkChunk> onWorkChunkDequeue(String theChunkId)

Specified by:

onWorkChunkDequeue in interface IWorkChunkPersistence

storeNewInstance

@Transactional(propagation=REQUIRED)
public String storeNewInstance(JobInstance theInstance)

Specified by:

storeNewInstance in interface IJobPersistence

fetchInstances

@Transactional(propagation=REQUIRES_NEW)
public List<JobInstance> fetchInstances(String theJobDefinitionId,
 Set<StatusEnum> theStatuses,
 Date theCutoff,
 org.springframework.data.domain.Pageable thePageable)

Specified by:

fetchInstances in interface IJobPersistence

fetchInstancesByJobDefinitionIdAndStatus

@Transactional(propagation=REQUIRES_NEW)
public List<JobInstance> fetchInstancesByJobDefinitionIdAndStatus(String theJobDefinitionId,
 Set<StatusEnum> theRequestedStatuses,
 int thePageSize,
 int thePageIndex)

Specified by:

fetchInstancesByJobDefinitionIdAndStatus in interface IJobPersistence

fetchInstancesByJobDefinitionId

@Transactional(propagation=REQUIRES_NEW)
public List<JobInstance> fetchInstancesByJobDefinitionId(String theJobDefinitionId,
 int thePageSize,
 int thePageIndex)

Specified by:

fetchInstancesByJobDefinitionId in interface IJobPersistence

fetchJobInstances

@Transactional(propagation=REQUIRES_NEW)
public org.springframework.data.domain.Page<JobInstance> fetchJobInstances(JobInstanceFetchRequest theRequest)

Specified by:

fetchJobInstances in interface IJobPersistence

fetchInstance

@Nonnull
public Optional<JobInstance> fetchInstance(String theInstanceId)

Specified by:

fetchInstance in interface IJobPersistence

fetchInstances

@Transactional(propagation=REQUIRES_NEW)
public List<JobInstance> fetchInstances(FetchJobInstancesRequest theRequest,
 int thePage,
 int theBatchSize)

Specified by:

fetchInstances in interface IJobPersistence

fetchInstances

@Transactional(propagation=REQUIRES_NEW)
public List<JobInstance> fetchInstances(int thePageSize,
 int thePageIndex)

Specified by:

fetchInstances in interface IJobPersistence

fetchRecentInstances

@Transactional(propagation=REQUIRES_NEW)
public List<JobInstance> fetchRecentInstances(int thePageSize,
 int thePageIndex)

Specified by:

fetchRecentInstances in interface IJobPersistence

onWorkChunkError

@Transactional(propagation=REQUIRES_NEW)
public WorkChunkStatusEnum onWorkChunkError(WorkChunkErrorEvent theParameters)

Specified by:

onWorkChunkError in interface IWorkChunkPersistence

onWorkChunkFailed

@Transactional
public void onWorkChunkFailed(String theChunkId,
 String theErrorMessage)

Specified by:

onWorkChunkFailed in interface IWorkChunkPersistence

onWorkChunkCompletion

@Transactional
public void onWorkChunkCompletion(WorkChunkCompletionEvent theEvent)

Specified by:

onWorkChunkCompletion in interface IWorkChunkPersistence

markWorkChunksWithStatusAndWipeData

public void markWorkChunksWithStatusAndWipeData(String theInstanceId,
 List<String> theChunkIds,
 WorkChunkStatusEnum theStatus,
 String theErrorMessage)

Specified by:

markWorkChunksWithStatusAndWipeData in interface IWorkChunkPersistence

canAdvanceInstanceToNextStep

@Transactional(propagation=REQUIRES_NEW)
public boolean canAdvanceInstanceToNextStep(String theInstanceId,
 String theCurrentStepId)

Specified by:

canAdvanceInstanceToNextStep in interface IJobPersistence

fetchAllChunkIdsForStepWithStatus

public List<String> fetchAllChunkIdsForStepWithStatus(String theInstanceId,
 String theStepId,
 WorkChunkStatusEnum theStatusEnum)

Specified by:

fetchAllChunkIdsForStepWithStatus in interface IWorkChunkPersistence

updateInstanceUpdateTime

public void updateInstanceUpdateTime(String theInstanceId)

Specified by:

updateInstanceUpdateTime in interface IJobPersistence

fetchAllWorkChunksIterator

public Iterator<WorkChunk> fetchAllWorkChunksIterator(String theInstanceId,
 boolean theWithData)

Note: Not @Transactional because the transaction happens in a lambda that's called outside of this method's scope

Specified by:

fetchAllWorkChunksIterator in interface IJobPersistence

Specified by:

fetchAllWorkChunksIterator in interface IWorkChunkPersistence

fetchAllWorkChunksForStepStream

public Stream<WorkChunk> fetchAllWorkChunksForStepStream(String theInstanceId,
 String theStepId)

Specified by:

fetchAllWorkChunksForStepStream in interface IJobPersistence

Specified by:

fetchAllWorkChunksForStepStream in interface IWorkChunkPersistence

updateInstance

public boolean updateInstance(String theInstanceId,
 IJobPersistence.JobInstanceUpdateCallback theModifier)

Specified by:

updateInstance in interface IJobPersistence

deleteInstanceAndChunks

@Transactional(propagation=REQUIRES_NEW)
public void deleteInstanceAndChunks(String theInstanceId)

Specified by:

deleteInstanceAndChunks in interface IJobPersistence

deleteChunksAndMarkInstanceAsChunksPurged

@Transactional(propagation=REQUIRES_NEW)
public void deleteChunksAndMarkInstanceAsChunksPurged(String theInstanceId)

Specified by:

deleteChunksAndMarkInstanceAsChunksPurged in interface IJobPersistence

markInstanceAsStatusWhenStatusIn

public boolean markInstanceAsStatusWhenStatusIn(String theInstanceId,
 StatusEnum theStatusEnum,
 Set<StatusEnum> thePriorStates)

Specified by:

markInstanceAsStatusWhenStatusIn in interface IJobPersistence

cancelInstance

@Transactional(propagation=REQUIRES_NEW)
public JobOperationResultJson cancelInstance(String theInstanceId)

Specified by:

cancelInstance in interface IJobPersistence