Package ca.uhn.fhir.jpa.bulk.imprt.svc

Class BulkDataImportSvcImpl

java.lang.Object

ca.uhn.fhir.jpa.bulk.imprt.svc.BulkDataImportSvcImpl

All Implemented Interfaces:

IBulkDataImportSvc, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

public class BulkDataImportSvcImpl
extends Object
implements IBulkDataImportSvc, ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BulkDataImportSvcImpl.ActivationJob

Nested classes/interfaces inherited from interface ca.uhn.fhir.jpa.bulk.imprt.api.IBulkDataImportSvc

IBulkDataImportSvc.JobInfo

Constructor Summary

Constructors

Constructor	Description
BulkDataImportSvcImpl()

Method Summary

Modifier and Type	Method	Description
ActivateJobResult	activateNextReadyJob()	To be called by the job scheduler
void	addFilesToJob(String theBiJobId, List<BulkImportJobFileJson> theFiles)
String	createNewJob(BulkImportJobJson theJobDescription, List<BulkImportJobFileJson> theInitialFiles)
void	deleteJobFiles(String theBiJobId)
BulkImportJobFileJson	fetchFile(String theBiJobId, int theFileIndex)
BulkImportJobJson	fetchJob(String theBiJobId)
String	getFileDescription(String theBiJobId, int theFileIndex)
IBulkDataImportSvc.JobInfo	getJobStatus(String theBiJobId)
void	markJobAsReadyForActivation(String theBiJobId)
void	scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)
void	setJobToStatus(String theBiJobId, BulkImportJobStatusEnum theStatus)
void	setJobToStatus(String theBiJobId, BulkImportJobStatusEnum theStatus, String theStatusMessage)
void	start()

Methods inherited from class java.lang.Object

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

Constructor Details

BulkDataImportSvcImpl

public BulkDataImportSvcImpl()

Method Details

start

@PostConstruct
public void start()

scheduleJobs

public void scheduleJobs(ca.uhn.fhir.jpa.model.sched.ISchedulerService theSchedulerService)

Specified by:

scheduleJobs in interface ca.uhn.fhir.jpa.model.sched.IHasScheduledJobs

createNewJob

@Transactional
public String createNewJob(BulkImportJobJson theJobDescription,
 @Nonnull
 List<BulkImportJobFileJson> theInitialFiles)

Specified by:

createNewJob in interface IBulkDataImportSvc

addFilesToJob

@Transactional
public void addFilesToJob(String theBiJobId,
 List<BulkImportJobFileJson> theFiles)

Specified by:

addFilesToJob in interface IBulkDataImportSvc

markJobAsReadyForActivation

@Transactional
public void markJobAsReadyForActivation(String theBiJobId)

Specified by:

markJobAsReadyForActivation in interface IBulkDataImportSvc

activateNextReadyJob

@Transactional(propagation=NEVER)
public ActivateJobResult activateNextReadyJob()

To be called by the job scheduler

Specified by:

activateNextReadyJob in interface IBulkDataImportSvc

setJobToStatus

@Transactional
public void setJobToStatus(String theBiJobId,
 BulkImportJobStatusEnum theStatus)

Specified by:

setJobToStatus in interface IBulkDataImportSvc

setJobToStatus

public void setJobToStatus(String theBiJobId,
 BulkImportJobStatusEnum theStatus,
 String theStatusMessage)

Specified by:

setJobToStatus in interface IBulkDataImportSvc

fetchJob

@Transactional
public BulkImportJobJson fetchJob(String theBiJobId)

Specified by:

fetchJob in interface IBulkDataImportSvc

getJobStatus

@Transactional
public IBulkDataImportSvc.JobInfo getJobStatus(String theBiJobId)

Specified by:

getJobStatus in interface IBulkDataImportSvc

fetchFile

@Transactional
public BulkImportJobFileJson fetchFile(String theBiJobId,
 int theFileIndex)

Specified by:

fetchFile in interface IBulkDataImportSvc

getFileDescription

@Transactional
public String getFileDescription(String theBiJobId,
 int theFileIndex)

Specified by:

getFileDescription in interface IBulkDataImportSvc

deleteJobFiles

@Transactional
public void deleteJobFiles(String theBiJobId)

Specified by:

deleteJobFiles in interface IBulkDataImportSvc