Package ca.uhn.fhir.jpa.migrate

Class HapiMigrationStorageSvc

java.lang.Object

ca.uhn.fhir.jpa.migrate.HapiMigrationStorageSvc

public class HapiMigrationStorageSvc
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	LOCK_TYPE
static final String	UNKNOWN_VERSION

Constructor Summary

Constructors

Constructor	Description
HapiMigrationStorageSvc(HapiMigrationDao theHapiMigrationDao)

Method Summary

Modifier and Type	Method	Description
boolean	createMigrationTableIfRequired()	Create the migration table if it does not already exist
boolean	deleteLockRecord(String theLockDescription)
MigrationTaskList	diff(MigrationTaskList theTaskList)	Returns a list of migration tasks that have not yet been successfully run against the database
Optional<HapiMigrationEntity>	findFirstByPidAndNotDescription(Integer theLockPid, String theLockDescription)
String	getLatestAppliedVersion()
String	getMigrationTablename()
boolean	insertLockRecord(String theLockDescription)
void	saveTask(BaseTask theBaseTask, Integer theMillis, boolean theSuccess)	Save a migration task to the database

Methods inherited from class java.lang.Object

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

Field Details

UNKNOWN_VERSION

public static final String UNKNOWN_VERSION

See Also:

• Constant Field Values

LOCK_TYPE

public static final String LOCK_TYPE

See Also:

• Constant Field Values

Constructor Details

HapiMigrationStorageSvc

public HapiMigrationStorageSvc(HapiMigrationDao theHapiMigrationDao)

Method Details

getMigrationTablename

public String getMigrationTablename()

diff

public MigrationTaskList diff(MigrationTaskList theTaskList)

Returns a list of migration tasks that have not yet been successfully run against the database

Parameters:

theTaskList - the full list of tasks for this release

Returns:

a list of tasks that have not yet been successfully run against the database

getLatestAppliedVersion

public String getLatestAppliedVersion()

Returns:

the most recent version that was run against the database (used for logging purposes)

saveTask

public void saveTask(BaseTask theBaseTask,
 Integer theMillis,
 boolean theSuccess)

Save a migration task to the database

createMigrationTableIfRequired

public boolean createMigrationTableIfRequired()

Create the migration table if it does not already exist

deleteLockRecord

public boolean deleteLockRecord(String theLockDescription)

Parameters:

theLockDescription - value of the Description for the lock record

Returns:

true if the record was successfully deleted

insertLockRecord

public boolean insertLockRecord(String theLockDescription)

findFirstByPidAndNotDescription

public Optional<HapiMigrationEntity> findFirstByPidAndNotDescription(Integer theLockPid,
 String theLockDescription)