Package cz.metacentrum.perun.core.impl

Class TasksManagerImpl

java.lang.Object

cz.metacentrum.perun.core.impl.TasksManagerImpl

All Implemented Interfaces:

TasksManagerImplApi

public class TasksManagerImpl
extends Object
implements TasksManagerImplApi

TasksManagerImpl

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TASK_MAPPING_SELECT_QUERY
static final String	TASK_RESULT_MAPPING_SELECT_QUERY
static final RowMapper<Task>	TASK_ROWMAPPER
static final RowMapper<TaskResult>	TASKRESULT_ROWMAPPER

Constructor Summary

Constructors

Constructor	Description
TasksManagerImpl()	Create new instance of this class.
TasksManagerImpl(DataSource perunPool)	Create new instance of this class.

Method Summary

Modifier and Type	Method	Description
int	countTasks()
int	deleteAllTaskResults()	Delete all TaskResults
int	deleteOldTaskResults(int numDays)	Delete all TaskResults older than specified number of days
void	deleteTaskResultById(int taskResultId)	Delete TaskResult by its ID
int	deleteTaskResults(int taskId)	Delete all TaskResults for the particular Task
int	deleteTaskResults(int taskId, int destinationId)	Delete all TaskResults for the particular Task and Destination.
static SimpleDateFormat	getDateFormatter()	Method create formatter with default settings for perun timestamps and set lenient on false Timestamp format: "dd-MM-yyyy HH:mm:ss" - "ex. 01-01-2014 10:10:10"
static DateTimeFormatter	getDateTimeFormatter()	Method create formatter with default settings for perun timestamps and set ResolverStyle to STRICT Timestamp format: "dd-MM-yyyy HH:mm:ss" - "ex. 01-01-2014 10:10:10"
NamedParameterJdbcTemplate	getNamedParameterJdbcTemplate()
Task	getTask(int serviceId, int facilityId)	Retrieve task for given service and facility (by id).
Task	getTask(Service service, Facility facility)	Retrieve task for given service and facility.
Task	getTaskById(int id)	Retrieve task with given id.
TaskResult	getTaskResultById(int taskResultId)	Get TaskResult by its ID
List<TaskResult>	getTaskResults()	List TaskResults
List<TaskResult>	getTaskResultsByDestinations(List<String> destinationsNames)	Returns list of tasks results for defined destinations (string representation).
List<TaskResult>	getTaskResultsByTask(int taskId)	List TaskResults tied to a certain task
List<TaskResult>	getTaskResultsByTaskAndDestination(int taskId, int destinationId)	List newest TaskResults tied to a certain task and destination
List<TaskResult>	getTaskResultsByTaskOnlyNewest(int taskId)	List newest TaskResults tied to a certain task
int	insertNewTaskResult(TaskResult taskResult)	Store task result into DB.
int	insertTask(Task task)	Insert new task into DB.
boolean	isSuspendedTasksPropagation()	Check if propagating tasks to engine is suspended.
boolean	isThereSuchTask(Service service, Facility facility)	Check if there is a task for given service and facility.
List<Task>	listAllTasks()	Retrieve all tasks from DB.
List<Task>	listAllTasksForFacility(int facilityId)	Returns all tasks associated with selected facility.
List<Task>	listAllTasksForService(int serviceId)	Returns all tasks associated with given service
List<Task>	listAllTasksInState(Task.TaskStatus state)	Retrieve all tass in given state.
List<Task>	listAllTasksNotInState(Task.TaskStatus state)	Retrieve all tasks not in given state.
void	removeTask(int id)	Remove task with given id.
void	removeTask(Service service, Facility facility)	Remove task for given service and facility.
Task	retrieveRunIdForTask(Task task)	Retrieves a new run id for the task propagation.
void	suspendTasksPropagation(PerunSession sess, boolean suspend)	Suspend propagating tasks to engine.
void	updateTask(Task task)	Update DB record of given task.

Methods inherited from class java.lang.Object

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

Field Details

TASK_RESULT_MAPPING_SELECT_QUERY

public static final String TASK_RESULT_MAPPING_SELECT_QUERY

See Also:

• Constant Field Values

TASKRESULT_ROWMAPPER

public static final RowMapper<TaskResult> TASKRESULT_ROWMAPPER

TASK_MAPPING_SELECT_QUERY

public static final String TASK_MAPPING_SELECT_QUERY

See Also:

• Constant Field Values

TASK_ROWMAPPER

public static final RowMapper<Task> TASK_ROWMAPPER

Constructor Details

TasksManagerImpl

public TasksManagerImpl()

Create new instance of this class. Used for the tests only

TasksManagerImpl

public TasksManagerImpl(DataSource perunPool)

Create new instance of this class.

Method Details

getDateTimeFormatter

public static DateTimeFormatter getDateTimeFormatter()

Method create formatter with default settings for perun timestamps and set ResolverStyle to STRICT Timestamp format: "dd-MM-yyyy HH:mm:ss" - "ex. 01-01-2014 10:10:10"

ResolverStyle.STRICT means that formatter will be more strict to creating timestamp from string

Returns:

date formatter

getDateFormatter

public static SimpleDateFormat getDateFormatter()

Method create formatter with default settings for perun timestamps and set lenient on false Timestamp format: "dd-MM-yyyy HH:mm:ss" - "ex. 01-01-2014 10:10:10"

Lenient on false means that formatter will be more strict to creating timestamp from string

IMPORTANT: SimpleDateFormat is not thread safe !!!

Returns:

date formatter

countTasks

public int countTasks()

Specified by:

countTasks in interface TasksManagerImplApi

Returns:

deleteAllTaskResults

public int deleteAllTaskResults()

Description copied from interface: TasksManagerImplApi

Delete all TaskResults

Specified by:

deleteAllTaskResults in interface TasksManagerImplApi

Returns:

number of deleted TaskResults

deleteOldTaskResults

public int deleteOldTaskResults(int numDays)

Description copied from interface: TasksManagerImplApi

Delete all TaskResults older than specified number of days

Specified by:

deleteOldTaskResults in interface TasksManagerImplApi

Parameters:

numDays - Number of days to keep

Returns:

number of deleted TaskResults

deleteTaskResultById

public void deleteTaskResultById(int taskResultId)

Description copied from interface: TasksManagerImplApi

Delete TaskResult by its ID

Specified by:

deleteTaskResultById in interface TasksManagerImplApi

Parameters:

taskResultId - ID of TaskResult to delete

deleteTaskResults

public int deleteTaskResults(int taskId)

Description copied from interface: TasksManagerImplApi

Delete all TaskResults for the particular Task

Specified by:

deleteTaskResults in interface TasksManagerImplApi

Parameters:

taskId - ID of Task to delete TaskResults

Returns:

number of deleted TaskResults

deleteTaskResults

public int deleteTaskResults(int taskId,
 int destinationId)

Description copied from interface: TasksManagerImplApi

Delete all TaskResults for the particular Task and Destination.

Specified by:

deleteTaskResults in interface TasksManagerImplApi

Parameters:

taskId - ID of Task to delete TaskResults

destinationId - ID of Destination to delete TaskResults

Returns:

number of deleted TaskResults

getNamedParameterJdbcTemplate

public NamedParameterJdbcTemplate getNamedParameterJdbcTemplate()

getTask

public Task getTask(int serviceId,
 int facilityId)

Description copied from interface: TasksManagerImplApi

Retrieve task for given service and facility (by id).

Specified by:

getTask in interface TasksManagerImplApi

Parameters:

serviceId -

facilityId -

Returns:

Task

getTask

public Task getTask(Service service,
 Facility facility)

Description copied from interface: TasksManagerImplApi

Retrieve task for given service and facility.

Specified by:

getTask in interface TasksManagerImplApi

Parameters:

service -

facility -

Returns:

Task

getTaskById

public Task getTaskById(int id)

Description copied from interface: TasksManagerImplApi

Retrieve task with given id.

Specified by:

getTaskById in interface TasksManagerImplApi

Parameters:

id -

Returns:

Task

getTaskResultById

public TaskResult getTaskResultById(int taskResultId)

Description copied from interface: TasksManagerImplApi

Get TaskResult by its ID

Specified by:

getTaskResultById in interface TasksManagerImplApi

Parameters:

taskResultId -

Returns:

TaskResult

getTaskResults

public List<TaskResult> getTaskResults()

Description copied from interface: TasksManagerImplApi

List TaskResults

Specified by:

getTaskResults in interface TasksManagerImplApi

Returns:

all TaskResults

getTaskResultsByDestinations

public List<TaskResult> getTaskResultsByDestinations(List<String> destinationsNames)

Description copied from interface: TasksManagerImplApi

Returns list of tasks results for defined destinations (string representation).

Specified by:

getTaskResultsByDestinations in interface TasksManagerImplApi

Parameters:

destinationsNames -

Returns:

list of tasks results

getTaskResultsByTask

public List<TaskResult> getTaskResultsByTask(int taskId)

Description copied from interface: TasksManagerImplApi

List TaskResults tied to a certain task

Specified by:

getTaskResultsByTask in interface TasksManagerImplApi

Parameters:

taskId -

Returns:

getTaskResultsByTaskAndDestination

public List<TaskResult> getTaskResultsByTaskAndDestination(int taskId,
 int destinationId)

Description copied from interface: TasksManagerImplApi

List newest TaskResults tied to a certain task and destination

Specified by:

getTaskResultsByTaskAndDestination in interface TasksManagerImplApi

Parameters:

taskId -

Returns:

getTaskResultsByTaskOnlyNewest

public List<TaskResult> getTaskResultsByTaskOnlyNewest(int taskId)

Description copied from interface: TasksManagerImplApi

List newest TaskResults tied to a certain task

Specified by:

getTaskResultsByTaskOnlyNewest in interface TasksManagerImplApi

Parameters:

taskId -

Returns:

insertNewTaskResult

public int insertNewTaskResult(TaskResult taskResult)

Description copied from interface: TasksManagerImplApi

Store task result into DB.

Specified by:

insertNewTaskResult in interface TasksManagerImplApi

Parameters:

taskResult -

Returns:

id of new task result

insertTask

public int insertTask(Task task)

Description copied from interface: TasksManagerImplApi

Insert new task into DB.

Specified by:

insertTask in interface TasksManagerImplApi

Parameters:

task -

Returns:

id of new task

isSuspendedTasksPropagation

public boolean isSuspendedTasksPropagation()

Description copied from interface: TasksManagerImplApi

Check if propagating tasks to engine is suspended.

Specified by:

isSuspendedTasksPropagation in interface TasksManagerImplApi

Returns:

True if suspended, false if propagating

isThereSuchTask

public boolean isThereSuchTask(Service service,
 Facility facility)

Description copied from interface: TasksManagerImplApi

Check if there is a task for given service and facility.

Specified by:

isThereSuchTask in interface TasksManagerImplApi

Parameters:

service -

facility -

Returns:

boolean true if there is a task, false otherwise

listAllTasks

public List<Task> listAllTasks()

Description copied from interface: TasksManagerImplApi

Retrieve all tasks from DB.

Specified by:

listAllTasks in interface TasksManagerImplApi

Returns:

List of Task

listAllTasksForFacility

public List<Task> listAllTasksForFacility(int facilityId)

Description copied from interface: TasksManagerImplApi

Returns all tasks associated with selected facility.

Specified by:

listAllTasksForFacility in interface TasksManagerImplApi

Parameters:

facilityId -

Returns:

tasks for facility

listAllTasksForService

public List<Task> listAllTasksForService(int serviceId)

Description copied from interface: TasksManagerImplApi

Returns all tasks associated with given service

Specified by:

listAllTasksForService in interface TasksManagerImplApi

Parameters:

serviceId -

Returns:

tasks for service

listAllTasksInState

public List<Task> listAllTasksInState(Task.TaskStatus state)

Description copied from interface: TasksManagerImplApi

Retrieve all tass in given state.

Specified by:

listAllTasksInState in interface TasksManagerImplApi

Parameters:

state -

Returns:

List of Task

listAllTasksNotInState

public List<Task> listAllTasksNotInState(Task.TaskStatus state)

Description copied from interface: TasksManagerImplApi

Retrieve all tasks not in given state.

Specified by:

listAllTasksNotInState in interface TasksManagerImplApi

Parameters:

state -

Returns:

List of Task

removeTask

public void removeTask(int id)

Description copied from interface: TasksManagerImplApi

Remove task with given id.

Specified by:

removeTask in interface TasksManagerImplApi

Parameters:

id -

removeTask

public void removeTask(Service service,
 Facility facility)

Description copied from interface: TasksManagerImplApi

Remove task for given service and facility.

Specified by:

removeTask in interface TasksManagerImplApi

Parameters:

service -

facility -

suspendTasksPropagation

public void suspendTasksPropagation(PerunSession sess,
 boolean suspend)

Description copied from interface: TasksManagerImplApi

Suspend propagating tasks to engine.

Specified by:

suspendTasksPropagation in interface TasksManagerImplApi

Parameters:

sess -

suspend - True for suspending propagation, false for resuming propagation

updateTask

public void updateTask(Task task)

Description copied from interface: TasksManagerImplApi

Update DB record of given task.

Specified by:

updateTask in interface TasksManagerImplApi

Parameters:

task -

retrieveRunIdForTask

public Task retrieveRunIdForTask(Task task)

Description copied from interface: TasksManagerImplApi

Retrieves a new run id for the task propagation.

Specified by:

retrieveRunIdForTask in interface TasksManagerImplApi

Parameters:

task - task to schedule

Returns:

task with updated run id