org.quartz.impl.jdbcjobstore
Interface DriverDelegate

All Known Implementing Classes:

CloudscapeDelegate, DB2v6Delegate, DB2v7Delegate, DB2v8Delegate, HSQLDBDelegate, MSSQLDelegate, PointbaseDelegate, PostgreSQLDelegate, StdJDBCDelegate

public interface DriverDelegate

This is the base interface for all driver delegate classes.

This interface is very similar to the JobStore interface except each method has an additional Connection parameter.

Unless a database driver has some extremely-DB-specific requirements, any DriverDelegate implementation classes should extend the StdJDBCDelegate class.

Author:

Jeffrey Wescott, James House

Method Summary

boolean	calendarExists(java.sql.Connection conn, java.lang.String calendarName) Check whether or not a calendar exists.
boolean	calendarIsReferenced(java.sql.Connection conn, java.lang.String calendarName) Check whether or not a calendar is referenced by any triggers.
int	countMisfiredTriggersInStates(java.sql.Connection conn, java.lang.String state1, java.lang.String state2, long ts) Get the number of triggers in the given states that have misfired - according to the given timestamp.
int	deleteAllPausedTriggerGroups(java.sql.Connection conn)
int	deleteBlobTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Delete the BLOB trigger data for a trigger.
int	deleteCalendar(java.sql.Connection conn, java.lang.String calendarName) Delete a calendar.
int	deleteCronTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Delete the cron trigger data for a trigger.
int	deleteFiredTrigger(java.sql.Connection conn, java.lang.String entryId) Delete a fired trigger.
int	deleteFiredTriggers(java.sql.Connection conn) Delete all fired triggers.
int	deleteFiredTriggers(java.sql.Connection conn, java.lang.String instanceId) Delete all fired triggers of the given instance.
int	deleteJobDetail(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Delete the job detail record for the given job.
int	deleteJobListeners(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Delete all job listeners for the given job.
int	deletePausedTriggerGroup(java.sql.Connection conn, java.lang.String groupName)
int	deleteSchedulerState(java.sql.Connection conn, java.lang.String instanceId) Delete a scheduler-instance state record.
int	deleteSimpleTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Delete the simple trigger data for a trigger.
int	deleteTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Delete the base trigger data for a trigger.
int	deleteTriggerListeners(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Delete all of the listeners associated with a given trigger.
int	deleteVolatileFiredTriggers(java.sql.Connection conn) Delete all volatile fired triggers.
int	insertBlobTrigger(java.sql.Connection conn, Trigger trigger) Insert the blob trigger data.
int	insertCalendar(java.sql.Connection conn, java.lang.String calendarName, Calendar calendar) Insert a new calendar.
int	insertCronTrigger(java.sql.Connection conn, CronTrigger trigger) Insert the cron trigger data.
int	insertFiredTrigger(java.sql.Connection conn, Trigger trigger, java.lang.String state, JobDetail jobDetail) Insert a fired trigger.
int	insertJobDetail(java.sql.Connection conn, JobDetail job) Insert the job detail record.
int	insertJobListener(java.sql.Connection conn, JobDetail job, java.lang.String listener) Associate a listener with a job.
int	insertPausedTriggerGroup(java.sql.Connection conn, java.lang.String groupName)
int	insertSchedulerState(java.sql.Connection conn, java.lang.String instanceId, long checkInTime, long interval) Insert a scheduler-instance state record.
int	insertSimpleTrigger(java.sql.Connection conn, SimpleTrigger trigger) Insert the simple trigger data.
int	insertTrigger(java.sql.Connection conn, Trigger trigger, java.lang.String state, JobDetail jobDetail) Insert the base trigger data.
int	insertTriggerListener(java.sql.Connection conn, Trigger trigger, java.lang.String listener) Associate a listener with the given trigger.
boolean	isExistingTriggerGroup(java.sql.Connection conn, java.lang.String groupName)
boolean	isJobStateful(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Check whether or not the given job is stateful.
boolean	isTriggerGroupPaused(java.sql.Connection conn, java.lang.String groupName)
boolean	jobExists(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Check whether or not the given job exists.
Calendar	selectCalendar(java.sql.Connection conn, java.lang.String calendarName) Select a calendar.
java.lang.String[]	selectCalendars(java.sql.Connection conn) Select all of the stored calendars.
java.util.Set	selectFiredTriggerInstanceNames(java.sql.Connection conn) Select the distinct instance names of all fired-trigger records.
java.util.List	selectFiredTriggerRecords(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Select the states of all fired-trigger records for a given trigger, or trigger group if trigger name is null.
java.util.List	selectFiredTriggerRecordsByJob(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Select the states of all fired-trigger records for a given job, or job group if job name is null.
java.util.List	selectInstancesFiredTriggerRecords(java.sql.Connection conn, java.lang.String instanceName) Select the states of all fired-trigger records for a given scheduler instance.
JobDetail	selectJobDetail(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName, ClassLoadHelper loadHelper) Select the JobDetail object for a given job name / group name.
int	selectJobExecutionCount(java.sql.Connection conn, java.lang.String jobName, java.lang.String jobGroup) Get the number instances of the identified job currently executing.
JobDetail	selectJobForTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName, ClassLoadHelper loadHelper) Select the job to which the trigger is associated.
java.lang.String[]	selectJobGroups(java.sql.Connection conn) Select all of the job group names that are stored.
java.lang.String[]	selectJobListeners(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Get all of the listeners for a given job.
java.lang.String[]	selectJobsInGroup(java.sql.Connection conn, java.lang.String groupName) Select all of the jobs contained in a given group.
Key[]	selectMisfiredTriggers(java.sql.Connection conn, long ts) Get the names of all of the triggers that have misfired - according to the given timestamp.
Key[]	selectMisfiredTriggersInGroupInState(java.sql.Connection conn, java.lang.String groupName, java.lang.String state, long ts) Get the names of all of the triggers in the given group and state that have misfired - according to the given timestamp.
Key[]	selectMisfiredTriggersInState(java.sql.Connection conn, java.lang.String state, long ts) Get the names of all of the triggers in the given state that have misfired - according to the given timestamp.
boolean	selectMisfiredTriggersInStates(java.sql.Connection conn, java.lang.String state1, java.lang.String state2, long ts, int count, java.util.List resultList) Get the names of all of the triggers in the given states that have misfired - according to the given timestamp.
long	selectNextFireTime(java.sql.Connection conn) Deprecated. Does not account for misfires.
int	selectNumCalendars(java.sql.Connection conn) Select the total number of calendars stored.
int	selectNumJobs(java.sql.Connection conn) Select the total number of jobs stored.
int	selectNumTriggers(java.sql.Connection conn) Select the total number of triggers stored.
int	selectNumTriggersForJob(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Select the number of triggers associated with a given job.
java.util.Set	selectPausedTriggerGroups(java.sql.Connection conn)
java.util.List	selectSchedulerStateRecords(java.sql.Connection conn, java.lang.String instanceId) A List of all current SchedulerStateRecords.
java.util.List	selectStatefulJobsOfTriggerGroup(java.sql.Connection conn, java.lang.String groupName) Select the stateful jobs which are referenced by triggers in the given trigger group.
Trigger	selectTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Select a trigger.
Key	selectTriggerForFireTime(java.sql.Connection conn, long fireTime) Select the trigger that will be fired at the given fire time.
java.lang.String[]	selectTriggerGroups(java.sql.Connection conn) Select all of the trigger group names that are stored.
JobDataMap	selectTriggerJobDataMap(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Select a trigger's JobDataMap.
java.lang.String[]	selectTriggerListeners(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Select the listeners associated with a given trigger.
Key[]	selectTriggerNamesForJob(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Get the names of all of the triggers associated with the given job.
Trigger[]	selectTriggersForCalendar(java.sql.Connection conn, java.lang.String calName) Select the triggers for a calendar
Trigger[]	selectTriggersForJob(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName) Select the triggers for a job
Trigger[]	selectTriggersForRecoveringJobs(java.sql.Connection conn) Select all of the triggers for jobs that are requesting recovery.
java.lang.String[]	selectTriggersInGroup(java.sql.Connection conn, java.lang.String groupName) Select all of the triggers contained in a given group.
Key[]	selectTriggersInState(java.sql.Connection conn, java.lang.String state) Select all of the triggers in a given state.
java.lang.String	selectTriggerState(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Select a trigger' state value.
TriggerStatus	selectTriggerStatus(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Select a trigger' status (state & next fire time).
java.util.List	selectTriggerToAcquire(java.sql.Connection conn, long noLaterThan, long noEarlierThan) Select the next trigger which will fire to fire between the two given timestamps in ascending order of fire time, and then descending by priority.
Key[]	selectVolatileJobs(java.sql.Connection conn) Get the names of all of the jobs that are volatile.
Key[]	selectVolatileTriggers(java.sql.Connection conn) Get the names of all of the triggers that are volatile.
boolean	triggerExists(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Check whether or not a trigger exists.
int	updateBlobTrigger(java.sql.Connection conn, Trigger trigger) Update the blob trigger data.
int	updateCalendar(java.sql.Connection conn, java.lang.String calendarName, Calendar calendar) Update a calendar.
int	updateCronTrigger(java.sql.Connection conn, CronTrigger trigger) Update the cron trigger data.
int	updateJobData(java.sql.Connection conn, JobDetail job) Update the job data map for the given job.
int	updateJobDetail(java.sql.Connection conn, JobDetail job) Update the job detail record.
int	updateSchedulerState(java.sql.Connection conn, java.lang.String instanceId, long checkInTime) Update a scheduler-instance state record.
int	updateSimpleTrigger(java.sql.Connection conn, SimpleTrigger trigger) Update the simple trigger data.
int	updateTrigger(java.sql.Connection conn, Trigger trigger, java.lang.String state, JobDetail jobDetail) Update the base trigger data.
int	updateTriggerGroupStateFromOtherState(java.sql.Connection conn, java.lang.String groupName, java.lang.String newState, java.lang.String oldState) Update all of the triggers of the given group to the given new state, if they are in the given old state.
int	updateTriggerGroupStateFromOtherStates(java.sql.Connection conn, java.lang.String groupName, java.lang.String newState, java.lang.String oldState1, java.lang.String oldState2, java.lang.String oldState3) Update all triggers in the given group to the given new state, if they are in one of the given old states.
int	updateTriggerState(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName, java.lang.String state) Update the state for a given trigger.
int	updateTriggerStateFromOtherState(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName, java.lang.String newState, java.lang.String oldState) Update the given trigger to the given new state, if it is in the given old state.
int	updateTriggerStateFromOtherStates(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName, java.lang.String newState, java.lang.String oldState1, java.lang.String oldState2, java.lang.String oldState3) Update the given trigger to the given new state, if it is one of the given old states.
int	updateTriggerStateFromOtherStatesBeforeTime(java.sql.Connection conn, java.lang.String newState, java.lang.String oldState1, java.lang.String oldState2, long time) Update the all triggers to the given new state, if they are in one of the given old states AND its next fire time is before the given time.
int	updateTriggerStatesForJob(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName, java.lang.String state) Update the states of all triggers associated with the given job.
int	updateTriggerStatesForJobFromOtherState(java.sql.Connection conn, java.lang.String jobName, java.lang.String groupName, java.lang.String state, java.lang.String oldState) Update the states of any triggers associated with the given job, that are the given current state.
int	updateTriggerStatesFromOtherStates(java.sql.Connection conn, java.lang.String newState, java.lang.String oldState1, java.lang.String oldState2) Update all triggers having one of the two given states, to the given new state.

Method Detail

updateTriggerStatesFromOtherStates

int updateTriggerStatesFromOtherStates(java.sql.Connection conn,
                                       java.lang.String newState,
                                       java.lang.String oldState1,
                                       java.lang.String oldState2)
                                       throws java.sql.SQLException

Update all triggers having one of the two given states, to the given new state.

Parameters:

conn - the DB Connection

newState - the new state for the triggers

oldState1 - the first old state to update

oldState2 - the second old state to update

Returns:

number of rows updated

Throws:

java.sql.SQLException

selectMisfiredTriggers

Key[] selectMisfiredTriggers(java.sql.Connection conn,
                             long ts)
                             throws java.sql.SQLException

Get the names of all of the triggers that have misfired - according to the given timestamp.

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

Throws:

java.sql.SQLException

selectMisfiredTriggersInState

Key[] selectMisfiredTriggersInState(java.sql.Connection conn,
                                    java.lang.String state,
                                    long ts)
                                    throws java.sql.SQLException

Get the names of all of the triggers in the given state that have misfired - according to the given timestamp.

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

Throws:

java.sql.SQLException

selectMisfiredTriggersInStates

boolean selectMisfiredTriggersInStates(java.sql.Connection conn,
                                       java.lang.String state1,
                                       java.lang.String state2,
                                       long ts,
                                       int count,
                                       java.util.List resultList)
                                       throws java.sql.SQLException

Get the names of all of the triggers in the given states that have misfired - according to the given timestamp. No more than count will be returned.

Parameters:

conn - the DB Connection

count - the most misfired triggers to return, negative for all

resultList - Output parameter. A List of Key objects. Must not be null.

Returns:

Whether there are more misfired triggers left to find beyond the given count.

Throws:

java.sql.SQLException

countMisfiredTriggersInStates

int countMisfiredTriggersInStates(java.sql.Connection conn,
                                  java.lang.String state1,
                                  java.lang.String state2,
                                  long ts)
                                  throws java.sql.SQLException

Get the number of triggers in the given states that have misfired - according to the given timestamp.

Parameters:

conn - the DB Connection

Throws:

java.sql.SQLException

selectMisfiredTriggersInGroupInState

Key[] selectMisfiredTriggersInGroupInState(java.sql.Connection conn,
                                           java.lang.String groupName,
                                           java.lang.String state,
                                           long ts)
                                           throws java.sql.SQLException

Get the names of all of the triggers in the given group and state that have misfired - according to the given timestamp.

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

Throws:

java.sql.SQLException

selectTriggersForRecoveringJobs

Trigger[] selectTriggersForRecoveringJobs(java.sql.Connection conn)
                                          throws java.sql.SQLException,
                                                 java.io.IOException,
                                                 java.lang.ClassNotFoundException

Select all of the triggers for jobs that are requesting recovery. The returned trigger objects will have unique "recoverXXX" trigger names and will be in the Scheduler.DEFAULT_RECOVERY_GROUP trigger group.

In order to preserve the ordering of the triggers, the fire time will be set from the COL_FIRED_TIME column in the TABLE_FIRED_TRIGGERS table. The caller is responsible for calling computeFirstFireTime on each returned trigger. It is also up to the caller to insert the returned triggers to ensure that they are fired.

Parameters:

conn - the DB Connection

Returns:

an array of Trigger objects

Throws:

java.sql.SQLException

java.io.IOException

java.lang.ClassNotFoundException

deleteFiredTriggers

int deleteFiredTriggers(java.sql.Connection conn)
                        throws java.sql.SQLException

Delete all fired triggers.

Parameters:

conn - the DB Connection

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

deleteFiredTriggers

int deleteFiredTriggers(java.sql.Connection conn,
                        java.lang.String instanceId)
                        throws java.sql.SQLException

Delete all fired triggers of the given instance.

Parameters:

conn - the DB Connection

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

deleteVolatileFiredTriggers

int deleteVolatileFiredTriggers(java.sql.Connection conn)
                                throws java.sql.SQLException

Delete all volatile fired triggers.

Parameters:

conn - the DB Connection

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

selectVolatileTriggers

Key[] selectVolatileTriggers(java.sql.Connection conn)
                             throws java.sql.SQLException

Get the names of all of the triggers that are volatile.

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

Throws:

java.sql.SQLException

selectVolatileJobs

Key[] selectVolatileJobs(java.sql.Connection conn)
                         throws java.sql.SQLException

Get the names of all of the jobs that are volatile.

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

Throws:

java.sql.SQLException

insertJobDetail

int insertJobDetail(java.sql.Connection conn,
                    JobDetail job)
                    throws java.io.IOException,
                           java.sql.SQLException

Insert the job detail record.

Parameters:

conn - the DB Connection

job - the job to insert

Returns:

number of rows inserted

Throws:

java.io.IOException - if there were problems serializing the JobDataMap

java.sql.SQLException

updateJobDetail

int updateJobDetail(java.sql.Connection conn,
                    JobDetail job)
                    throws java.io.IOException,
                           java.sql.SQLException

Update the job detail record.

Parameters:

conn - the DB Connection

job - the job to update

Returns:

number of rows updated

Throws:

java.io.IOException - if there were problems serializing the JobDataMap

java.sql.SQLException

selectTriggerNamesForJob

Key[] selectTriggerNamesForJob(java.sql.Connection conn,
                               java.lang.String jobName,
                               java.lang.String groupName)
                               throws java.sql.SQLException

Get the names of all of the triggers associated with the given job.

Parameters:

conn - the DB Connection

jobName - the job name

groupName - the job group

Returns:

an array of Key objects

Throws:

java.sql.SQLException

deleteJobListeners

int deleteJobListeners(java.sql.Connection conn,
                       java.lang.String jobName,
                       java.lang.String groupName)
                       throws java.sql.SQLException

Delete all job listeners for the given job.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

deleteJobDetail

int deleteJobDetail(java.sql.Connection conn,
                    java.lang.String jobName,
                    java.lang.String groupName)
                    throws java.sql.SQLException

Delete the job detail record for the given job.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

isJobStateful

boolean isJobStateful(java.sql.Connection conn,
                      java.lang.String jobName,
                      java.lang.String groupName)
                      throws java.sql.SQLException

Check whether or not the given job is stateful.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

true if the job exists and is stateful, false otherwise

Throws:

java.sql.SQLException

jobExists

boolean jobExists(java.sql.Connection conn,
                  java.lang.String jobName,
                  java.lang.String groupName)
                  throws java.sql.SQLException

Check whether or not the given job exists.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

true if the job exists, false otherwise

Throws:

java.sql.SQLException

updateJobData

int updateJobData(java.sql.Connection conn,
                  JobDetail job)
                  throws java.io.IOException,
                         java.sql.SQLException

Update the job data map for the given job.

Parameters:

conn - the DB Connection

job - the job to update

Returns:

the number of rows updated

Throws:

java.io.IOException - if there were problems serializing the JobDataMap

java.sql.SQLException

insertJobListener

int insertJobListener(java.sql.Connection conn,
                      JobDetail job,
                      java.lang.String listener)
                      throws java.sql.SQLException

Associate a listener with a job.

Parameters:

conn - the DB Connection

job - the job to associate with the listener

listener - the listener to insert

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

selectJobListeners

java.lang.String[] selectJobListeners(java.sql.Connection conn,
                                      java.lang.String jobName,
                                      java.lang.String groupName)
                                      throws java.sql.SQLException

Get all of the listeners for a given job.

Parameters:

conn - the DB Connection

jobName - the job name whose listeners are wanted

groupName - the group containing the job

Returns:

array of String listener names

Throws:

java.sql.SQLException

selectJobDetail

JobDetail selectJobDetail(java.sql.Connection conn,
                          java.lang.String jobName,
                          java.lang.String groupName,
                          ClassLoadHelper loadHelper)
                          throws java.lang.ClassNotFoundException,
                                 java.io.IOException,
                                 java.sql.SQLException

Select the JobDetail object for a given job name / group name.

Parameters:

conn - the DB Connection

jobName - the job name whose listeners are wanted

groupName - the group containing the job

Returns:

the populated JobDetail object

Throws:

java.lang.ClassNotFoundException - if a class found during deserialization cannot be found or if the job class could not be found

java.io.IOException - if deserialization causes an error

java.sql.SQLException

selectNumJobs

int selectNumJobs(java.sql.Connection conn)
                  throws java.sql.SQLException

Select the total number of jobs stored.

Parameters:

conn - the DB Connection

Returns:

the total number of jobs stored

Throws:

java.sql.SQLException

selectJobGroups

java.lang.String[] selectJobGroups(java.sql.Connection conn)
                                   throws java.sql.SQLException

Select all of the job group names that are stored.

Parameters:

conn - the DB Connection

Returns:

an array of String group names

Throws:

java.sql.SQLException

selectJobsInGroup

java.lang.String[] selectJobsInGroup(java.sql.Connection conn,
                                     java.lang.String groupName)
                                     throws java.sql.SQLException

Select all of the jobs contained in a given group.

Parameters:

conn - the DB Connection

groupName - the group containing the jobs

Returns:

an array of String job names

Throws:

java.sql.SQLException

insertTrigger

int insertTrigger(java.sql.Connection conn,
                  Trigger trigger,
                  java.lang.String state,
                  JobDetail jobDetail)
                  throws java.sql.SQLException,
                         java.io.IOException

Insert the base trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

state - the state that the trigger should be stored in

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

java.io.IOException

insertSimpleTrigger

int insertSimpleTrigger(java.sql.Connection conn,
                        SimpleTrigger trigger)
                        throws java.sql.SQLException

Insert the simple trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

insertBlobTrigger

int insertBlobTrigger(java.sql.Connection conn,
                      Trigger trigger)
                      throws java.sql.SQLException,
                             java.io.IOException

Insert the blob trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

java.io.IOException

insertCronTrigger

int insertCronTrigger(java.sql.Connection conn,
                      CronTrigger trigger)
                      throws java.sql.SQLException

Insert the cron trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

updateTrigger

int updateTrigger(java.sql.Connection conn,
                  Trigger trigger,
                  java.lang.String state,
                  JobDetail jobDetail)
                  throws java.sql.SQLException,
                         java.io.IOException

Update the base trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

state - the state that the trigger should be stored in

Returns:

the number of rows updated

Throws:

java.sql.SQLException

java.io.IOException

updateSimpleTrigger

int updateSimpleTrigger(java.sql.Connection conn,
                        SimpleTrigger trigger)
                        throws java.sql.SQLException

Update the simple trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows updated

Throws:

java.sql.SQLException

updateCronTrigger

int updateCronTrigger(java.sql.Connection conn,
                      CronTrigger trigger)
                      throws java.sql.SQLException

Update the cron trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows updated

Throws:

java.sql.SQLException

updateBlobTrigger

int updateBlobTrigger(java.sql.Connection conn,
                      Trigger trigger)
                      throws java.sql.SQLException,
                             java.io.IOException

Update the blob trigger data.

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows updated

Throws:

java.sql.SQLException

java.io.IOException

triggerExists

boolean triggerExists(java.sql.Connection conn,
                      java.lang.String triggerName,
                      java.lang.String groupName)
                      throws java.sql.SQLException

Check whether or not a trigger exists.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows updated

Throws:

java.sql.SQLException

updateTriggerState

int updateTriggerState(java.sql.Connection conn,
                       java.lang.String triggerName,
                       java.lang.String groupName,
                       java.lang.String state)
                       throws java.sql.SQLException

Update the state for a given trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

state - the new state for the trigger

Returns:

the number of rows updated

Throws:

java.sql.SQLException

updateTriggerStateFromOtherState

int updateTriggerStateFromOtherState(java.sql.Connection conn,
                                     java.lang.String triggerName,
                                     java.lang.String groupName,
                                     java.lang.String newState,
                                     java.lang.String oldState)
                                     throws java.sql.SQLException

Update the given trigger to the given new state, if it is in the given old state.

Parameters:

conn - the DB connection

triggerName - the name of the trigger

groupName - the group containing the trigger

newState - the new state for the trigger

oldState - the old state the trigger must be in

Returns:

int the number of rows updated

Throws:

java.sql.SQLException

updateTriggerStateFromOtherStates

int updateTriggerStateFromOtherStates(java.sql.Connection conn,
                                      java.lang.String triggerName,
                                      java.lang.String groupName,
                                      java.lang.String newState,
                                      java.lang.String oldState1,
                                      java.lang.String oldState2,
                                      java.lang.String oldState3)
                                      throws java.sql.SQLException

Update the given trigger to the given new state, if it is one of the given old states.

Parameters:

conn - the DB connection

triggerName - the name of the trigger

groupName - the group containing the trigger

newState - the new state for the trigger

oldState1 - one of the old state the trigger must be in

oldState2 - one of the old state the trigger must be in

oldState3 - one of the old state the trigger must be in

Returns:

int the number of rows updated

Throws:

java.sql.SQLException

updateTriggerStateFromOtherStatesBeforeTime

int updateTriggerStateFromOtherStatesBeforeTime(java.sql.Connection conn,
                                                java.lang.String newState,
                                                java.lang.String oldState1,
                                                java.lang.String oldState2,
                                                long time)
                                                throws java.sql.SQLException

Update the all triggers to the given new state, if they are in one of the given old states AND its next fire time is before the given time.

Parameters:

conn - the DB connection

newState - the new state for the trigger

oldState1 - one of the old state the trigger must be in

oldState2 - one of the old state the trigger must be in

time - the time before which the trigger's next fire time must be

Returns:

int the number of rows updated

Throws:

java.sql.SQLException

updateTriggerGroupStateFromOtherStates

int updateTriggerGroupStateFromOtherStates(java.sql.Connection conn,
                                           java.lang.String groupName,
                                           java.lang.String newState,
                                           java.lang.String oldState1,
                                           java.lang.String oldState2,
                                           java.lang.String oldState3)
                                           throws java.sql.SQLException

Update all triggers in the given group to the given new state, if they are in one of the given old states.

Parameters:

conn - the DB connection

groupName - the group containing the trigger

newState - the new state for the trigger

oldState1 - one of the old state the trigger must be in

oldState2 - one of the old state the trigger must be in

oldState3 - one of the old state the trigger must be in

Returns:

int the number of rows updated

Throws:

java.sql.SQLException

updateTriggerGroupStateFromOtherState

int updateTriggerGroupStateFromOtherState(java.sql.Connection conn,
                                          java.lang.String groupName,
                                          java.lang.String newState,
                                          java.lang.String oldState)
                                          throws java.sql.SQLException

Update all of the triggers of the given group to the given new state, if they are in the given old state.

Parameters:

conn - the DB connection

groupName - the group containing the triggers

newState - the new state for the trigger group

oldState - the old state the triggers must be in

Returns:

int the number of rows updated

Throws:

java.sql.SQLException

updateTriggerStatesForJob

int updateTriggerStatesForJob(java.sql.Connection conn,
                              java.lang.String jobName,
                              java.lang.String groupName,
                              java.lang.String state)
                              throws java.sql.SQLException

Update the states of all triggers associated with the given job.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

state - the new state for the triggers

Returns:

the number of rows updated

Throws:

java.sql.SQLException

updateTriggerStatesForJobFromOtherState

int updateTriggerStatesForJobFromOtherState(java.sql.Connection conn,
                                            java.lang.String jobName,
                                            java.lang.String groupName,
                                            java.lang.String state,
                                            java.lang.String oldState)
                                            throws java.sql.SQLException

Update the states of any triggers associated with the given job, that are the given current state.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

state - the new state for the triggers

oldState - the old state of the triggers

Returns:

the number of rows updated

Throws:

java.sql.SQLException

deleteTriggerListeners

int deleteTriggerListeners(java.sql.Connection conn,
                           java.lang.String triggerName,
                           java.lang.String groupName)
                           throws java.sql.SQLException

Delete all of the listeners associated with a given trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger whose listeners will be deleted

groupName - the name of the group containing the trigger

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

insertTriggerListener

int insertTriggerListener(java.sql.Connection conn,
                          Trigger trigger,
                          java.lang.String listener)
                          throws java.sql.SQLException

Associate a listener with the given trigger.

Parameters:

conn - the DB Connection

trigger - the trigger

listener - the name of the listener to associate with the trigger

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

selectTriggerListeners

java.lang.String[] selectTriggerListeners(java.sql.Connection conn,
                                          java.lang.String triggerName,
                                          java.lang.String groupName)
                                          throws java.sql.SQLException

Select the listeners associated with a given trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

array of String trigger listener names

Throws:

java.sql.SQLException

deleteSimpleTrigger

int deleteSimpleTrigger(java.sql.Connection conn,
                        java.lang.String triggerName,
                        java.lang.String groupName)
                        throws java.sql.SQLException

Delete the simple trigger data for a trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

deleteBlobTrigger

int deleteBlobTrigger(java.sql.Connection conn,
                      java.lang.String triggerName,
                      java.lang.String groupName)
                      throws java.sql.SQLException

Delete the BLOB trigger data for a trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

deleteCronTrigger

int deleteCronTrigger(java.sql.Connection conn,
                      java.lang.String triggerName,
                      java.lang.String groupName)
                      throws java.sql.SQLException

Delete the cron trigger data for a trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

deleteTrigger

int deleteTrigger(java.sql.Connection conn,
                  java.lang.String triggerName,
                  java.lang.String groupName)
                  throws java.sql.SQLException

Delete the base trigger data for a trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

selectNumTriggersForJob

int selectNumTriggersForJob(java.sql.Connection conn,
                            java.lang.String jobName,
                            java.lang.String groupName)
                            throws java.sql.SQLException

Select the number of triggers associated with a given job.

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

the number of triggers for the given job

Throws:

java.sql.SQLException

selectJobForTrigger

JobDetail selectJobForTrigger(java.sql.Connection conn,
                              java.lang.String triggerName,
                              java.lang.String groupName,
                              ClassLoadHelper loadHelper)
                              throws java.lang.ClassNotFoundException,
                                     java.sql.SQLException

Select the job to which the trigger is associated.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the JobDetail object associated with the given trigger

Throws:

java.lang.ClassNotFoundException

java.sql.SQLException

selectStatefulJobsOfTriggerGroup

java.util.List selectStatefulJobsOfTriggerGroup(java.sql.Connection conn,
                                                java.lang.String groupName)
                                                throws java.sql.SQLException

Select the stateful jobs which are referenced by triggers in the given trigger group.

Parameters:

conn - the DB Connection

groupName - the trigger group

Returns:

a List of Keys to jobs.

Throws:

java.sql.SQLException

selectTriggersForJob

Trigger[] selectTriggersForJob(java.sql.Connection conn,
                               java.lang.String jobName,
                               java.lang.String groupName)
                               throws java.sql.SQLException,
                                      java.lang.ClassNotFoundException,
                                      java.io.IOException

Select the triggers for a job

Parameters:

conn - the DB Connection

jobName - the name of the trigger

groupName - the group containing the trigger

Returns:

an array of (@link org.quartz.Trigger) objects associated with a given job.

Throws:

java.sql.SQLException

java.lang.ClassNotFoundException

java.io.IOException

selectTriggersForCalendar

Trigger[] selectTriggersForCalendar(java.sql.Connection conn,
                                    java.lang.String calName)
                                    throws java.sql.SQLException,
                                           java.lang.ClassNotFoundException,
                                           java.io.IOException

Select the triggers for a calendar

Parameters:

conn - the DB Connection

calName - the name of the calendar

Returns:

an array of (@link org.quartz.Trigger) objects associated with the given calendar.

Throws:

java.sql.SQLException

java.lang.ClassNotFoundException

java.io.IOException

selectTrigger

Trigger selectTrigger(java.sql.Connection conn,
                      java.lang.String triggerName,
                      java.lang.String groupName)
                      throws java.sql.SQLException,
                             java.lang.ClassNotFoundException,
                             java.io.IOException

Select a trigger.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the Trigger object

Throws:

java.sql.SQLException

java.lang.ClassNotFoundException

java.io.IOException

selectTriggerJobDataMap

JobDataMap selectTriggerJobDataMap(java.sql.Connection conn,
                                   java.lang.String triggerName,
                                   java.lang.String groupName)
                                   throws java.sql.SQLException,
                                          java.lang.ClassNotFoundException,
                                          java.io.IOException

Select a trigger's JobDataMap.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the JobDataMap of the Trigger, never null, but possibly empty.

Throws:

java.sql.SQLException

java.lang.ClassNotFoundException

java.io.IOException

selectTriggerState

java.lang.String selectTriggerState(java.sql.Connection conn,
                                    java.lang.String triggerName,
                                    java.lang.String groupName)
                                    throws java.sql.SQLException

Select a trigger' state value.

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the Trigger object

Throws:

java.sql.SQLException

selectTriggerStatus

TriggerStatus selectTriggerStatus(java.sql.Connection conn,
                                  java.lang.String triggerName,
                                  java.lang.String groupName)
                                  throws java.sql.SQLException

Select a trigger' status (state & next fire time).

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

a TriggerStatus object, or null

Throws:

java.sql.SQLException

selectNumTriggers

int selectNumTriggers(java.sql.Connection conn)
                      throws java.sql.SQLException

Select the total number of triggers stored.

Parameters:

conn - the DB Connection

Returns:

the total number of triggers stored

Throws:

java.sql.SQLException

selectTriggerGroups

java.lang.String[] selectTriggerGroups(java.sql.Connection conn)
                                       throws java.sql.SQLException

Select all of the trigger group names that are stored.

Parameters:

conn - the DB Connection

Returns:

an array of String group names

Throws:

java.sql.SQLException

selectTriggersInGroup

java.lang.String[] selectTriggersInGroup(java.sql.Connection conn,
                                         java.lang.String groupName)
                                         throws java.sql.SQLException

Select all of the triggers contained in a given group.

Parameters:

conn - the DB Connection

groupName - the group containing the triggers

Returns:

an array of String trigger names

Throws:

java.sql.SQLException

selectTriggersInState

Key[] selectTriggersInState(java.sql.Connection conn,
                            java.lang.String state)
                            throws java.sql.SQLException

Select all of the triggers in a given state.

Parameters:

conn - the DB Connection

state - the state the triggers must be in

Returns:

an array of trigger Key s

Throws:

java.sql.SQLException

insertPausedTriggerGroup

int insertPausedTriggerGroup(java.sql.Connection conn,
                             java.lang.String groupName)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

deletePausedTriggerGroup

int deletePausedTriggerGroup(java.sql.Connection conn,
                             java.lang.String groupName)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

deleteAllPausedTriggerGroups

int deleteAllPausedTriggerGroups(java.sql.Connection conn)
                                 throws java.sql.SQLException

Throws:

java.sql.SQLException

isTriggerGroupPaused

boolean isTriggerGroupPaused(java.sql.Connection conn,
                             java.lang.String groupName)
                             throws java.sql.SQLException

Throws:

java.sql.SQLException

selectPausedTriggerGroups

java.util.Set selectPausedTriggerGroups(java.sql.Connection conn)
                                        throws java.sql.SQLException

Throws:

java.sql.SQLException

isExistingTriggerGroup

boolean isExistingTriggerGroup(java.sql.Connection conn,
                               java.lang.String groupName)
                               throws java.sql.SQLException

Throws:

java.sql.SQLException

insertCalendar

int insertCalendar(java.sql.Connection conn,
                   java.lang.String calendarName,
                   Calendar calendar)
                   throws java.io.IOException,
                          java.sql.SQLException

Insert a new calendar.

Parameters:

conn - the DB Connection

calendarName - the name for the new calendar

calendar - the calendar

Returns:

the number of rows inserted

Throws:

java.io.IOException - if there were problems serializing the calendar

java.sql.SQLException

updateCalendar

int updateCalendar(java.sql.Connection conn,
                   java.lang.String calendarName,
                   Calendar calendar)
                   throws java.io.IOException,
                          java.sql.SQLException

Update a calendar.

Parameters:

conn - the DB Connection

calendarName - the name for the new calendar

calendar - the calendar

Returns:

the number of rows updated

Throws:

java.io.IOException - if there were problems serializing the calendar

java.sql.SQLException

calendarExists

boolean calendarExists(java.sql.Connection conn,
                       java.lang.String calendarName)
                       throws java.sql.SQLException

Check whether or not a calendar exists.

Parameters:

conn - the DB Connection

calendarName - the name of the calendar

Returns:

true if the trigger exists, false otherwise

Throws:

java.sql.SQLException

selectCalendar

Calendar selectCalendar(java.sql.Connection conn,
                        java.lang.String calendarName)
                        throws java.lang.ClassNotFoundException,
                               java.io.IOException,
                               java.sql.SQLException

Select a calendar.

Parameters:

conn - the DB Connection

calendarName - the name of the calendar

Returns:

the Calendar

Throws:

java.lang.ClassNotFoundException - if a class found during deserialization cannot be found be found

java.io.IOException - if there were problems deserializing the calendar

java.sql.SQLException

calendarIsReferenced

boolean calendarIsReferenced(java.sql.Connection conn,
                             java.lang.String calendarName)
                             throws java.sql.SQLException

Check whether or not a calendar is referenced by any triggers.

Parameters:

conn - the DB Connection

calendarName - the name of the calendar

Returns:

true if any triggers reference the calendar, false otherwise

Throws:

java.sql.SQLException

deleteCalendar

int deleteCalendar(java.sql.Connection conn,
                   java.lang.String calendarName)
                   throws java.sql.SQLException

Delete a calendar.

Parameters:

conn - the DB Connection

calendarName - the name of the trigger

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

selectNumCalendars

int selectNumCalendars(java.sql.Connection conn)
                       throws java.sql.SQLException

Select the total number of calendars stored.

Parameters:

conn - the DB Connection

Returns:

the total number of calendars stored

Throws:

java.sql.SQLException

selectCalendars

java.lang.String[] selectCalendars(java.sql.Connection conn)
                                   throws java.sql.SQLException

Select all of the stored calendars.

Parameters:

conn - the DB Connection

Returns:

an array of String calendar names

Throws:

java.sql.SQLException

selectNextFireTime

long selectNextFireTime(java.sql.Connection conn)
                        throws java.sql.SQLException

Deprecated. Does not account for misfires.

Select the next time that a trigger will be fired.

Parameters:

conn - the DB Connection

Returns:

the next fire time, or 0 if no trigger will be fired

Throws:

java.sql.SQLException

selectTriggerForFireTime

Key selectTriggerForFireTime(java.sql.Connection conn,
                             long fireTime)
                             throws java.sql.SQLException

Select the trigger that will be fired at the given fire time.

Parameters:

conn - the DB Connection

fireTime - the time that the trigger will be fired

Returns:

a Key representing the trigger that will be fired at the given fire time, or null if no trigger will be fired at that time

Throws:

java.sql.SQLException

selectTriggerToAcquire

java.util.List selectTriggerToAcquire(java.sql.Connection conn,
                                      long noLaterThan,
                                      long noEarlierThan)
                                      throws java.sql.SQLException

Select the next trigger which will fire to fire between the two given timestamps in ascending order of fire time, and then descending by priority.

Parameters:

conn - the DB Connection

noLaterThan - highest value of getNextFireTime() of the triggers (exclusive)

noEarlierThan - highest value of getNextFireTime() of the triggers (inclusive)

Returns:

A (never null, possibly empty) list of the identifiers (Key objects) of the next triggers to be fired.

Throws:

java.sql.SQLException

insertFiredTrigger

int insertFiredTrigger(java.sql.Connection conn,
                       Trigger trigger,
                       java.lang.String state,
                       JobDetail jobDetail)
                       throws java.sql.SQLException

Insert a fired trigger.

Parameters:

conn - the DB Connection

trigger - the trigger

state - the state that the trigger should be stored in

Returns:

the number of rows inserted

Throws:

java.sql.SQLException

selectFiredTriggerRecords

java.util.List selectFiredTriggerRecords(java.sql.Connection conn,
                                         java.lang.String triggerName,
                                         java.lang.String groupName)
                                         throws java.sql.SQLException

Select the states of all fired-trigger records for a given trigger, or trigger group if trigger name is null.

Returns:

a List of FiredTriggerRecord objects.

Throws:

java.sql.SQLException

selectFiredTriggerRecordsByJob

java.util.List selectFiredTriggerRecordsByJob(java.sql.Connection conn,
                                              java.lang.String jobName,
                                              java.lang.String groupName)
                                              throws java.sql.SQLException

Select the states of all fired-trigger records for a given job, or job group if job name is null.

Returns:

a List of FiredTriggerRecord objects.

Throws:

java.sql.SQLException

selectInstancesFiredTriggerRecords

java.util.List selectInstancesFiredTriggerRecords(java.sql.Connection conn,
                                                  java.lang.String instanceName)
                                                  throws java.sql.SQLException

Select the states of all fired-trigger records for a given scheduler instance.

Returns:

a List of FiredTriggerRecord objects.

Throws:

java.sql.SQLException

selectFiredTriggerInstanceNames

java.util.Set selectFiredTriggerInstanceNames(java.sql.Connection conn)
                                              throws java.sql.SQLException

Select the distinct instance names of all fired-trigger records.

This is useful when trying to identify orphaned fired triggers (a fired trigger without a scheduler state record.)

Returns:

a Set of String objects.

Throws:

java.sql.SQLException

deleteFiredTrigger

int deleteFiredTrigger(java.sql.Connection conn,
                       java.lang.String entryId)
                       throws java.sql.SQLException

Delete a fired trigger.

Parameters:

conn - the DB Connection

entryId - the fired trigger entry to delete

Returns:

the number of rows deleted

Throws:

java.sql.SQLException

selectJobExecutionCount

int selectJobExecutionCount(java.sql.Connection conn,
                            java.lang.String jobName,
                            java.lang.String jobGroup)
                            throws java.sql.SQLException

Get the number instances of the identified job currently executing.

Parameters:

conn - the DB Connection

Returns:

the number instances of the identified job currently executing.

Throws:

java.sql.SQLException

insertSchedulerState

int insertSchedulerState(java.sql.Connection conn,
                         java.lang.String instanceId,
                         long checkInTime,
                         long interval)
                         throws java.sql.SQLException

Insert a scheduler-instance state record.

Parameters:

conn - the DB Connection

Returns:

the number of inserted rows.

Throws:

java.sql.SQLException

deleteSchedulerState

int deleteSchedulerState(java.sql.Connection conn,
                         java.lang.String instanceId)
                         throws java.sql.SQLException

Delete a scheduler-instance state record.

Parameters:

conn - the DB Connection

Returns:

the number of deleted rows.

Throws:

java.sql.SQLException

updateSchedulerState

int updateSchedulerState(java.sql.Connection conn,
                         java.lang.String instanceId,
                         long checkInTime)
                         throws java.sql.SQLException

Update a scheduler-instance state record.

Parameters:

conn - the DB Connection

Returns:

the number of updated rows.

Throws:

java.sql.SQLException

selectSchedulerStateRecords

java.util.List selectSchedulerStateRecords(java.sql.Connection conn,
                                           java.lang.String instanceId)
                                           throws java.sql.SQLException

A List of all current SchedulerStateRecords.

If instanceId is not null, then only the record for the identified instance will be returned.

Parameters:

conn - the DB Connection

Throws:

java.sql.SQLException