com.prosyst.mprm.backend.database.onetimetask

Interface OneTimeTaskServiceDatabase

public interface OneTimeTaskServiceDatabase

Method Summary

Modifier and Type	Method and Description
TaskInfo	getTask(java.lang.String id) Returns the task with the bigest version that has been executed.
java.lang.String	obtainTaskControl(java.lang.String id, java.lang.String version, java.lang.String localhost) Try to create record (id, version, localhost, RUNNING) (if not exists) Returns the FINISHED task with such id (if has) or null (if has not).
void	taskError(java.lang.String id, java.lang.String version, java.lang.String host) Removes row (id, version, localhost, RUNNING) (if exists)
void	taskFinished(java.lang.String id, java.lang.String version, java.lang.String localHost) if (has FINISHED with >= version) -> do nothing else -> removes FINISHED record with (id and < version).

Method Detail

getTask

TaskInfo getTask(java.lang.String id)
          throws DatabaseException

Returns the task with the bigest version that has been executed.

Parameters:

id - the task id.

Returns:

the task with the bigest version that has been executed.

Throws:

DatabaseException - if an exception occurs.

obtainTaskControl

java.lang.String obtainTaskControl(java.lang.String id,
                                   java.lang.String version,
                                   java.lang.String localhost)
                            throws DatabaseException

Try to create record (id, version, localhost, RUNNING) (if not exists) Returns the FINISHED task with such id (if has) or null (if has not).

Parameters:

id - the task id.

version - the version.

localhost - the host.

Returns:

the last version of the executed task.

Throws:

DatabaseException - if an exception occurs.

taskFinished

void taskFinished(java.lang.String id,
                  java.lang.String version,
                  java.lang.String localHost)
           throws DatabaseException

if (has FINISHED with >= version) -> do nothing else -> removes FINISHED record with (id and < version). // should not remove appeared after checking bigger verson (evenutaly) updates row with (id, version) and sets state FINISHED and localHost Note: this is made in transaction. if fail to update row and there has no FINISHED with biger version -> try INSERT

Parameters:

id - the id.

version - the version.

localHost - the host.

Throws:

DatabaseException - if an exception occurs.

taskError

void taskError(java.lang.String id,
               java.lang.String version,
               java.lang.String host)
        throws DatabaseException

Removes row (id, version, localhost, RUNNING) (if exists)

Parameters:

id - task id.

version - task version.

host - host.

Throws:

DatabaseException - if an exception occurs.