public class TaskoFactory extends HibernateFactory
Modifier and Type | Method and Description |
---|---|
static void |
delete(TaskoBunch taskoBunch)
hibernate delete bunch
|
static void |
delete(TaskoRun taskoRun)
hibernate delete run
|
static void |
delete(TaskoSchedule taskoSchedule)
hibernate delete schedule
|
static void |
delete(TaskoTask taskoTask)
hibernate delete task
|
static void |
delete(TaskoTemplate taskoTemplate)
hibernate delete template
|
static void |
deleteLogFiles(TaskoRun run)
delete log files associated with given run
|
static void |
deleteRun(TaskoRun run)
deletes specified tasko run
|
protected org.apache.log4j.Logger |
getLogger()
Get the Logger for the derived class so log messages show up on the
correct class
|
static java.util.List<TaskoSchedule> |
listActiveSchedulesByOrg(java.lang.Integer orgId)
lists active schedules for a given org
|
static java.util.List<TaskoSchedule> |
listActiveSchedulesByOrgAndBunch(java.lang.Integer orgId,
java.lang.String bunchName)
lists active schedule of the given bunch
|
static java.util.List<TaskoSchedule> |
listActiveSchedulesByOrgAndLabel(java.lang.Integer orgId,
java.lang.String jobLabel)
lists active schedules of given name for a given org
|
static java.util.List<TaskoSchedule> |
listFuture()
list schedules, that shall be run sometime in the future
|
static java.util.List<TaskoRun> |
listNewerRunsBySchedule(java.lang.Long scheduleId,
java.util.Date limitTime)
list all schedule runs with (future) timestamps newer than limitTime
|
static java.util.List<TaskoBunch> |
listOrgBunches()
list all available organizational bunches
|
static java.util.List<TaskoRun> |
listRunsByBunch(java.lang.String bunchName)
lists runs by bunch
|
static java.util.List<TaskoRun> |
listRunsByOrgAndSchedule(java.lang.Integer orgId,
java.lang.Integer scheduleId)
lists organizational runs by schedule
|
static java.util.List<TaskoRun> |
listRunsBySchedule(java.lang.Long scheduleId)
list all runs associated with a schedule
|
static java.util.List<TaskoRun> |
listRunsOlderThan(java.util.Date limitTime)
lists runs older than given date
|
static java.util.List<TaskoBunch> |
listSatBunches()
list all available satellite bunches
|
static java.util.List<TaskoSchedule> |
listSchedulesByOrg(java.lang.Integer orgId)
lists all schedules for an org
|
static java.util.List<TaskoSchedule> |
listSchedulesByOrgAndLabel(java.lang.Integer orgId,
java.lang.String jobLabel)
lists organizational schedules by name
|
static java.util.List<TaskoSchedule> |
listSchedulesOlderThan(java.util.Date limitTime)
list schedules older than given date
|
static java.util.List<TaskoTask> |
listTasks()
lists all available tasks
|
static java.util.List<TaskoRun> |
listUnfinishedRuns()
Lists taskomatic runs those endTime IS NULL (most probably were interrupted by
taskomatic shutdown)
|
static TaskoBunch |
lookupBunchByName(java.lang.String bunchName)
lookup bunch by label
|
static TaskoBunch |
lookupOrgBunchByName(java.lang.String bunchName)
lookup a organization bunch by name
|
static TaskoRun |
lookupRunById(java.lang.Long runId)
lookup run by id
|
static TaskoRun |
lookupRunByOrgAndId(java.lang.Integer orgId,
java.lang.Integer runId)
lookup organizational run by id
|
static TaskoBunch |
lookupSatBunchByName(java.lang.String bunchName)
lookup a satellite bunch by name
|
static TaskoSchedule |
lookupScheduleById(java.lang.Long scheduleId)
lookup schedule by id
|
static TaskoSchedule |
lookupScheduleByLabel(java.lang.String jobLabel)
lookup schedule by label
|
static TaskoSchedule |
reinitializeScheduleFromNow(TaskoSchedule schedule,
java.util.Date now)
Reinitializes schedule
used, when quartz needs to be updated according to our tasko table entries
|
static void |
save(TaskoBunch taskoBunch)
hibernate save bunch
|
static void |
save(TaskoRun taskoRun)
hibernate save run
|
static void |
save(TaskoSchedule taskoSchedule)
hibernate save schedule
|
static void |
save(TaskoTask taskoTask)
hibernate save task
|
static void |
save(TaskoTemplate taskoTemplate)
hibernate save template
|
addConfigurator, blobToByteArray, byteArrayToBlob, closeSession, closeSessionFactory, commitTransaction, createSessionFactory, createSessionFactory, executeCallableMode, executeSelectMode, getBlobContents, getByteArrayContents, getObject, getSession, initialize, inTransaction, isClosed, isInitialized, listObjectsByNamedQuery, listObjectsByNamedQuery, listObjectsByNamedQuery, lockObject, lookupObjectByNamedQuery, lookupObjectByNamedQuery, reload, removeObject, rollbackTransaction, saveObject, saveObject, stringToByteArray
protected org.apache.log4j.Logger getLogger()
HibernateFactory
getLogger
in class HibernateFactory
public static TaskoBunch lookupOrgBunchByName(java.lang.String bunchName)
bunchName
- bunch namepublic static TaskoBunch lookupSatBunchByName(java.lang.String bunchName)
bunchName
- bunch namepublic static java.util.List<TaskoBunch> listOrgBunches()
public static java.util.List<TaskoBunch> listSatBunches()
public static void save(TaskoRun taskoRun)
taskoRun
- run to savepublic static void delete(TaskoRun taskoRun)
taskoRun
- run to deletepublic static void delete(TaskoSchedule taskoSchedule)
taskoSchedule
- schedule to deletepublic static void save(TaskoSchedule taskoSchedule)
taskoSchedule
- schedule to savepublic static void save(TaskoTemplate taskoTemplate)
taskoTemplate
- run to savepublic static void delete(TaskoTemplate taskoTemplate)
taskoTemplate
- run to deletepublic static void save(TaskoBunch taskoBunch)
taskoBunch
- run to savepublic static void delete(TaskoBunch taskoBunch)
taskoBunch
- run to deletepublic static void save(TaskoTask taskoTask)
taskoTask
- run to savepublic static void delete(TaskoTask taskoTask)
taskoTask
- run to deletepublic static java.util.List<TaskoTask> listTasks()
public static java.util.List<TaskoRun> listRunsOlderThan(java.util.Date limitTime)
limitTime
- date of interestpublic static void deleteRun(TaskoRun run)
run
- run to deletepublic static void deleteLogFiles(TaskoRun run)
run
- run to delete logspublic static java.util.List<TaskoSchedule> listActiveSchedulesByOrg(java.lang.Integer orgId)
orgId
- organization idpublic static java.util.List<TaskoSchedule> listActiveSchedulesByOrgAndLabel(java.lang.Integer orgId, java.lang.String jobLabel)
orgId
- organization idjobLabel
- unique job namepublic static java.util.List<TaskoSchedule> listActiveSchedulesByOrgAndBunch(java.lang.Integer orgId, java.lang.String bunchName) throws NoSuchBunchTaskException
orgId
- organization idbunchName
- bunch nameNoSuchBunchTaskException
- in case of unknown bunch namepublic static java.util.List<TaskoSchedule> listFuture()
public static java.util.List<TaskoRun> listNewerRunsBySchedule(java.lang.Long scheduleId, java.util.Date limitTime)
scheduleId
- schedule idlimitTime
- limit timepublic static TaskoSchedule lookupScheduleById(java.lang.Long scheduleId)
scheduleId
- schedule idpublic static TaskoSchedule lookupScheduleByLabel(java.lang.String jobLabel)
jobLabel
- schedule labelpublic static TaskoBunch lookupBunchByName(java.lang.String bunchName)
bunchName
- bunch labelpublic static java.util.List<TaskoSchedule> listSchedulesByOrg(java.lang.Integer orgId)
orgId
- organizational idpublic static java.util.List<TaskoRun> listRunsBySchedule(java.lang.Long scheduleId)
scheduleId
- schedule idpublic static java.util.List<TaskoSchedule> listSchedulesOlderThan(java.util.Date limitTime)
limitTime
- time of interestpublic static java.util.List<TaskoSchedule> listSchedulesByOrgAndLabel(java.lang.Integer orgId, java.lang.String jobLabel)
orgId
- organization idjobLabel
- unique job namepublic static TaskoRun lookupRunById(java.lang.Long runId)
runId
- run idpublic static TaskoRun lookupRunByOrgAndId(java.lang.Integer orgId, java.lang.Integer runId) throws InvalidParamException
orgId
- organizational idrunId
- run idInvalidParamException
- thrown in case of wrong runIdpublic static java.util.List<TaskoRun> listRunsByOrgAndSchedule(java.lang.Integer orgId, java.lang.Integer scheduleId)
orgId
- organization idscheduleId
- schedule idpublic static java.util.List<TaskoRun> listRunsByBunch(java.lang.String bunchName)
bunchName
- bunch namepublic static TaskoSchedule reinitializeScheduleFromNow(TaskoSchedule schedule, java.util.Date now)
schedule
- schedule to reinitnow
- time to setpublic static java.util.List<TaskoRun> listUnfinishedRuns()