org.quartz.impl.jdbcjobstore
Class StdJDBCDelegate

java.lang.Object
  |
  +--org.quartz.impl.jdbcjobstore.StdJDBCDelegate

All Implemented Interfaces:

Constants, DriverDelegate, StdJDBCConstants

Direct Known Subclasses:

CloudscapeDelegate, DB2v6Delegate, DB2v7Delegate, HSQLDBDelegate, MSSQLDelegate, OracleDelegate, PointbaseDelegate, PostgreSQLDelegate, WebLogicDelegate

public class StdJDBCDelegate

extends java.lang.Object

implements DriverDelegate, StdJDBCConstants

This is meant to be an abstract base class for most, if not all, DriverDelegate implementations. Subclasses should override only those methods that need special handling for the DBMS driver in question.

Author:

Jeffrey Wescott, James House

Field Summary

protected java.lang.String	instanceId
protected org.apache.commons.logging.Log	logger
protected java.lang.String	tablePrefix
protected boolean	useProperties

Fields inherited from interface org.quartz.impl.jdbcjobstore.StdJDBCConstants

DELETE_BLOB_TRIGGER, DELETE_CALENDAR, DELETE_CRON_TRIGGER, DELETE_FIRED_TRIGGER, DELETE_FIRED_TRIGGERS, DELETE_INSTANCES_FIRED_TRIGGERS, DELETE_JOB_DETAIL, DELETE_JOB_LISTENERS, DELETE_NO_RECOVERY_FIRED_TRIGGERS, DELETE_PAUSED_TRIGGER_GROUP, DELETE_PAUSED_TRIGGER_GROUPS, DELETE_SCHEDULER_STATE, DELETE_SIMPLE_TRIGGER, DELETE_TRIGGER, DELETE_TRIGGER_LISTENERS, DELETE_VOLATILE_FIRED_TRIGGERS, INSERT_BLOB_TRIGGER, INSERT_CALENDAR, INSERT_CRON_TRIGGER, INSERT_FIRED_TRIGGER, INSERT_JOB_DETAIL, INSERT_JOB_LISTENER, INSERT_PAUSED_TRIGGER_GROUP, INSERT_SCHEDULER_STATE, INSERT_SIMPLE_TRIGGER, INSERT_TRIGGER, INSERT_TRIGGER_LISTENER, SELECT_BLOB_TRIGGER, SELECT_CALENDAR, SELECT_CALENDAR_EXISTENCE, SELECT_CALENDARS, SELECT_CRON_TRIGGER, SELECT_FIRED_TRIGGER, SELECT_FIRED_TRIGGER_GROUP, SELECT_FIRED_TRIGGERS, SELECT_FIRED_TRIGGERS_OF_JOB, SELECT_FIRED_TRIGGERS_OF_JOB_GROUP, SELECT_INSTANCES_FIRED_TRIGGERS, SELECT_INSTANCES_RECOVERABLE_FIRED_TRIGGERS, SELECT_JOB_DETAIL, SELECT_JOB_EXECUTION_COUNT, SELECT_JOB_EXISTENCE, SELECT_JOB_FOR_TRIGGER, SELECT_JOB_GROUPS, SELECT_JOB_LISTENERS, SELECT_JOB_STATEFUL, SELECT_JOBS_IN_GROUP, SELECT_MISFIRED_TRIGGERS, SELECT_MISFIRED_TRIGGERS_IN_GROUP_IN_STATE, SELECT_MISFIRED_TRIGGERS_IN_STATE, SELECT_NEXT_FIRE_TIME, SELECT_NUM_CALENDARS, SELECT_NUM_JOBS, SELECT_NUM_TRIGGERS, SELECT_NUM_TRIGGERS_FOR_JOB, SELECT_NUM_TRIGGERS_IN_GROUP, SELECT_PAUSED_TRIGGER_GROUP, SELECT_PAUSED_TRIGGER_GROUPS, SELECT_REFERENCED_CALENDAR, SELECT_SCHEDULER_STATE, SELECT_SCHEDULER_STATES, SELECT_SIMPLE_TRIGGER, SELECT_STATEFUL_JOBS_OF_TRIGGER_GROUP, SELECT_TRIGGER, SELECT_TRIGGER_EXISTENCE, SELECT_TRIGGER_FOR_FIRE_TIME, SELECT_TRIGGER_GROUPS, SELECT_TRIGGER_LISTENERS, SELECT_TRIGGER_STATE, SELECT_TRIGGER_STATUS, SELECT_TRIGGERS_FOR_CALENDAR, SELECT_TRIGGERS_FOR_JOB, SELECT_TRIGGERS_IN_GROUP, SELECT_TRIGGERS_IN_STATE, SELECT_VOLATILE_JOBS, SELECT_VOLATILE_TRIGGERS, TABLE_PREFIX_SUBST, UPDATE_BLOB_TRIGGER, UPDATE_CALENDAR, UPDATE_CRON_TRIGGER, UPDATE_INSTANCES_FIRED_TRIGGER_STATE, UPDATE_JOB_DATA, UPDATE_JOB_DETAIL, UPDATE_JOB_TRIGGER_STATES, UPDATE_JOB_TRIGGER_STATES_FROM_OTHER_STATE, UPDATE_SIMPLE_TRIGGER, UPDATE_TRIGGER, UPDATE_TRIGGER_GROUP_STATE, UPDATE_TRIGGER_GROUP_STATE_FROM_STATE, UPDATE_TRIGGER_GROUP_STATE_FROM_STATES, UPDATE_TRIGGER_STATE, UPDATE_TRIGGER_STATE_FROM_OTHER_STATES_BEFORE_TIME, UPDATE_TRIGGER_STATE_FROM_STATE, UPDATE_TRIGGER_STATE_FROM_STATES, UPDATE_TRIGGER_STATES_FROM_OTHER_STATES

Fields inherited from interface org.quartz.impl.jdbcjobstore.Constants

ALIAS_COL_NEXT_FIRE_TIME, ALL_GROUPS_PAUSED, COL_BLOB, COL_CALENDAR, COL_CALENDAR_NAME, COL_CHECKIN_INTERVAL, COL_CRON_EXPRESSION, COL_DESCRIPTION, COL_END_TIME, COL_ENTRY_ID, COL_ENTRY_STATE, COL_FIRED_TIME, COL_INSTANCE_NAME, COL_IS_DURABLE, COL_IS_STATEFUL, COL_IS_VOLATILE, COL_JOB_CLASS, COL_JOB_DATAMAP, COL_JOB_GROUP, COL_JOB_LISTENER, COL_JOB_NAME, COL_LAST_CHECKIN_TIME, COL_LOCK_NAME, COL_MISFIRE_INSTRUCTION, COL_NEXT_FIRE_TIME, COL_PREV_FIRE_TIME, COL_RECOVERER, COL_REPEAT_COUNT, COL_REPEAT_INTERVAL, COL_REQUESTS_RECOVERY, COL_START_TIME, COL_TIME_ZONE_ID, COL_TIMES_TRIGGERED, COL_TRIGGER_GROUP, COL_TRIGGER_LISTENER, COL_TRIGGER_NAME, COL_TRIGGER_STATE, COL_TRIGGER_TYPE, DEFAULT_TABLE_PREFIX, STATE_ACQUIRED, STATE_BLOCKED, STATE_COMPLETE, STATE_DELETED, STATE_ERROR, STATE_EXECUTING, STATE_MISFIRED, STATE_PAUSED, STATE_WAITING, TABLE_BLOB_TRIGGERS, TABLE_CALENDARS, TABLE_CRON_TRIGGERS, TABLE_FIRED_TRIGGERS, TABLE_JOB_DETAILS, TABLE_JOB_LISTENERS, TABLE_LOCKS, TABLE_PAUSED_TRIGGERS, TABLE_SCHEDULER_STATE, TABLE_SIMPLE_TRIGGERS, TABLE_TRIGGER_LISTENERS, TABLE_TRIGGERS, TTYPE_BLOB, TTYPE_CRON, TTYPE_SIMPLE

Constructor Summary

StdJDBCDelegate(org.apache.commons.logging.Log logger, java.lang.String tablePrefix, java.lang.String instanceId)
Create new StdJDBCDelegate instance.

StdJDBCDelegate(org.apache.commons.logging.Log logger, java.lang.String tablePrefix, java.lang.String instanceId, java.lang.Boolean useProperties)
Create new StdJDBCDelegate instance.

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.
protected boolean	canUseProperties()
protected java.util.Map	convertFromProperty(java.util.Properties properties) convert the JobDataMap into a list of properties
protected java.util.Properties	convertToProperty(java.util.Map data) convert the JobDataMap into a list of properties
int	deleteAllPausedTriggerGroups(java.sql.Connection conn)
int	deleteBlobTrigger(java.sql.Connection conn, java.lang.String triggerName, java.lang.String groupName) Delete the cron 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.
protected java.lang.Object	getJobDetailFromBlob(java.sql.ResultSet rs, java.lang.String colName) This method should be overridden by any delegate subclasses that need special handling for BLOBs for job details.
protected java.lang.Object	getObjectFromBlob(java.sql.ResultSet rs, java.lang.String colName) This method should be overridden by any delegate subclasses that need special handling for BLOBs.
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 job) 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, java.lang.String recoverer) 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.
protected java.lang.String	rtp(java.lang.String query) Replace the table prefix in a query by replacing any occurrences of "{0}" with the table prefix.
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.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.
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.
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.
long	selectNextFireTime(java.sql.Connection conn) Select the next time that a trigger will be fired.
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.
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).
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.
protected java.io.ByteArrayOutputStream	serializeJobData(JobDataMap data) Remove the transient data from and then create a serialized java.util.ByteArrayOutputStream version of a JobDataMap.
protected java.io.ByteArrayOutputStream	serializeObject(java.lang.Object obj) Create a serialized java.util.ByteArrayOutputStream version of an Object.
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	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) Insert the job detail record.

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected org.apache.commons.logging.Log logger

tablePrefix

protected java.lang.String tablePrefix

instanceId

protected java.lang.String instanceId

useProperties

protected boolean useProperties

Constructor Detail

StdJDBCDelegate

public StdJDBCDelegate(org.apache.commons.logging.Log logger,
                       java.lang.String tablePrefix,
                       java.lang.String instanceId)

Create new StdJDBCDelegate instance.

Parameters:

logger - the logger to use during execution

tablePrefix - the prefix of all table names

StdJDBCDelegate

public StdJDBCDelegate(org.apache.commons.logging.Log logger,
                       java.lang.String tablePrefix,
                       java.lang.String instanceId,
                       java.lang.Boolean useProperties)

Create new StdJDBCDelegate instance.

Parameters:

logger - the logger to use during execution

tablePrefix - the prefix of all table names

Method Detail

canUseProperties

protected boolean canUseProperties()

updateTriggerStatesFromOtherStates

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

Insert the job detail record.

Specified by:

updateTriggerStatesFromOtherStates in interface DriverDelegate

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

selectMisfiredTriggers

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

Get the names of all of the triggers that have misfired.

Specified by:

selectMisfiredTriggers in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

selectTriggersInState

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

Select all of the triggers in a given state.

Specified by:

selectTriggersInState in interface DriverDelegate

Parameters:

conn - the DB Connection

state - the state the triggers must be in

Returns:

an array of trigger Key s

selectMisfiredTriggersInState

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

Description copied from interface: DriverDelegate

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

Specified by:

selectMisfiredTriggersInState in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

selectMisfiredTriggersInGroupInState

public 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.

Specified by:

selectMisfiredTriggersInGroupInState in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

selectTriggersForRecoveringJobs

public Trigger[] selectTriggersForRecoveringJobs(java.sql.Connection conn)
                                          throws java.sql.SQLException

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.

Specified by:

selectTriggersForRecoveringJobs in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of Trigger objects

deleteFiredTriggers

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

Delete all fired triggers.

Specified by:

deleteFiredTriggers in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the number of rows deleted

deleteFiredTriggers

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

Description copied from interface: DriverDelegate

Delete all fired triggers of the given instance.

Specified by:

deleteFiredTriggers in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the number of rows deleted

insertJobDetail

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

Insert the job detail record.

Specified by:

insertJobDetail in interface DriverDelegate

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

updateJobDetail

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

Update the job detail record.

Specified by:

updateJobDetail in interface DriverDelegate

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

selectTriggerNamesForJob

public 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.

Specified by:

selectTriggerNamesForJob in interface DriverDelegate

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

an array of Key objects

deleteJobListeners

public 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.

Specified by:

deleteJobListeners in interface DriverDelegate

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

the number of rows deleted

deleteJobDetail

public 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.

Specified by:

deleteJobDetail in interface DriverDelegate

Parameters:

conn - the DB Connection

jobName - the name of the job

groupName - the group containing the job

Returns:

the number of rows deleted

isJobStateful

public 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.

Specified by:

isJobStateful in interface DriverDelegate

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

jobExists

public 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.

Specified by:

jobExists in interface DriverDelegate

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

updateJobData

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

Update the job data map for the given job.

Specified by:

updateJobData in interface DriverDelegate

Parameters:

conn - the DB Connection

job - the job to update

Returns:

the number of rows updated

insertJobListener

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

Associate a listener with a job.

Specified by:

insertJobListener in interface DriverDelegate

Parameters:

conn - the DB Connection

job - the job to associate with the listener

listener - the listener to insert

Returns:

the number of rows inserted

selectJobListeners

public 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.

Specified by:

selectJobListeners in interface DriverDelegate

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

selectJobDetail

public 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.

Specified by:

selectJobDetail in interface DriverDelegate

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

selectNumJobs

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

Select the total number of jobs stored.

Specified by:

selectNumJobs in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the total number of jobs stored

selectJobGroups

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

Select all of the job group names that are stored.

Specified by:

selectJobGroups in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of String group names

selectJobsInGroup

public 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.

Specified by:

selectJobsInGroup in interface DriverDelegate

Parameters:

conn - the DB Connection

groupName - the group containing the jobs

Returns:

an array of String job names

insertTrigger

public 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.

Specified by:

insertTrigger in interface DriverDelegate

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

insertSimpleTrigger

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

Insert the simple trigger data.

Specified by:

insertSimpleTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows inserted

insertCronTrigger

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

Insert the cron trigger data.

Specified by:

insertCronTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows inserted

insertBlobTrigger

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

Insert the blob trigger data.

Specified by:

insertBlobTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows inserted

updateTrigger

public 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.

Specified by:

updateTrigger in interface DriverDelegate

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

updateSimpleTrigger

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

Update the simple trigger data.

Specified by:

updateSimpleTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows updated

updateCronTrigger

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

Update the cron trigger data.

Specified by:

updateCronTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows updated

updateBlobTrigger

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

Update the blob trigger data.

Specified by:

updateBlobTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger to insert

Returns:

the number of rows updated

triggerExists

public 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.

Specified by:

triggerExists in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

true if the trigger exists, false otherwise

updateTriggerState

public 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.

Specified by:

updateTriggerState in interface DriverDelegate

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

updateTriggerStateFromOtherStates

public 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.

Specified by:

updateTriggerStateFromOtherStates in interface DriverDelegate

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

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

Description copied from interface: DriverDelegate

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.

Specified by:

updateTriggerStateFromOtherStatesBeforeTime in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

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

public 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.

Specified by:

updateTriggerGroupStateFromOtherStates in interface DriverDelegate

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 -

updateTriggerStateFromOtherState

public 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.

Specified by:

updateTriggerStateFromOtherState in interface DriverDelegate

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 -

updateTriggerGroupStateFromOtherState

public 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.

Specified by:

updateTriggerGroupStateFromOtherState in interface DriverDelegate

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

public 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.

Specified by:

updateTriggerStatesForJob in interface DriverDelegate

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

updateTriggerStatesForJobFromOtherState

public 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

Description copied from interface: DriverDelegate

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

Specified by:

updateTriggerStatesForJobFromOtherState in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

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

deleteTriggerListeners

public 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.

Specified by:

deleteTriggerListeners in interface DriverDelegate

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

insertTriggerListener

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

Associate a listener with the given trigger.

Specified by:

insertTriggerListener in interface DriverDelegate

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

selectTriggerListeners

public 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.

Specified by:

selectTriggerListeners in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

array of String trigger listener names

deleteSimpleTrigger

public 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.

Specified by:

deleteSimpleTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

deleteCronTrigger

public 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.

Specified by:

deleteCronTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

deleteBlobTrigger

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

Delete the cron trigger data for a trigger.

Specified by:

deleteBlobTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

deleteTrigger

public 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.

Specified by:

deleteTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the number of rows deleted

selectNumTriggersForJob

public 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.

Specified by:

selectNumTriggersForJob in interface DriverDelegate

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

selectJobForTrigger

public 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.

Specified by:

selectJobForTrigger in interface DriverDelegate

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.sql.SQLException -

java.lang.ClassNotFoundException -

selectTriggersForJob

public 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

Specified by:

selectTriggersForJob in interface DriverDelegate

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 -

selectTriggersForCalendar

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

Description copied from interface: DriverDelegate

Select the triggers for a calendar

Specified by:

selectTriggersForCalendar in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

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 -

selectStatefulJobsOfTriggerGroup

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

Description copied from interface: DriverDelegate

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

Specified by:

selectStatefulJobsOfTriggerGroup in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

groupName - the trigger group

Returns:

a List of Keys to jobs.

selectTrigger

public 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.

Specified by:

selectTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the Trigger object

selectTriggerState

public 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.

Specified by:

selectTriggerState in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

the Trigger object

selectTriggerStatus

public 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).

Specified by:

selectTriggerStatus in interface DriverDelegate

Parameters:

conn - the DB Connection

triggerName - the name of the trigger

groupName - the group containing the trigger

Returns:

a TriggerStatus object, or null

selectNumTriggers

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

Select the total number of triggers stored.

Specified by:

selectNumTriggers in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the total number of triggers stored

selectTriggerGroups

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

Select all of the trigger group names that are stored.

Specified by:

selectTriggerGroups in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of String group names

selectTriggersInGroup

public 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.

Specified by:

selectTriggersInGroup in interface DriverDelegate

Parameters:

conn - the DB Connection

groupName - the group containing the triggers

Returns:

an array of String trigger names

insertPausedTriggerGroup

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

Specified by:

insertPausedTriggerGroup in interface DriverDelegate

deletePausedTriggerGroup

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

Specified by:

deletePausedTriggerGroup in interface DriverDelegate

deleteAllPausedTriggerGroups

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

Specified by:

deleteAllPausedTriggerGroups in interface DriverDelegate

isTriggerGroupPaused

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

Specified by:

isTriggerGroupPaused in interface DriverDelegate

isExistingTriggerGroup

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

Specified by:

isExistingTriggerGroup in interface DriverDelegate

insertCalendar

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

Insert a new calendar.

Specified by:

insertCalendar in interface DriverDelegate

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

updateCalendar

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

Update a calendar.

Specified by:

updateCalendar in interface DriverDelegate

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

calendarExists

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

Check whether or not a calendar exists.

Specified by:

calendarExists in interface DriverDelegate

Parameters:

conn - the DB Connection

calendarName - the name of the calendar

Returns:

true if the trigger exists, false otherwise

selectCalendar

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

Select a calendar.

Specified by:

selectCalendar in interface DriverDelegate

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

calendarIsReferenced

public 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.

Specified by:

calendarIsReferenced in interface DriverDelegate

Parameters:

conn - the DB Connection

calendarName - the name of the calendar

Returns:

true if any triggers reference the calendar, false otherwise

deleteCalendar

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

Delete a calendar.

Specified by:

deleteCalendar in interface DriverDelegate

Parameters:

conn - the DB Connection

calendarName - the name of the trigger

Returns:

the number of rows deleted

selectNumCalendars

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

Select the total number of calendars stored.

Specified by:

selectNumCalendars in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the total number of calendars stored

selectCalendars

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

Select all of the stored calendars.

Specified by:

selectCalendars in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of String calendar names

selectNextFireTime

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

Select the next time that a trigger will be fired.

Specified by:

selectNextFireTime in interface DriverDelegate

Parameters:

conn - the DB Connection

Returns:

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

selectTriggerForFireTime

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

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

Specified by:

selectTriggerForFireTime in interface DriverDelegate

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

insertFiredTrigger

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

Insert a fired trigger.

Specified by:

insertFiredTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

trigger - the trigger

state - the state that the trigger should be stored in

Returns:

the number of rows inserted

selectFiredTriggerRecords

public 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.

Specified by:

selectFiredTriggerRecords in interface DriverDelegate

Returns:

a List of FiredTriggerRecord objects.

selectFiredTriggerRecordsByJob

public 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.

Specified by:

selectFiredTriggerRecordsByJob in interface DriverDelegate

Returns:

a List of FiredTriggerRecord objects.

selectInstancesFiredTriggerRecords

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

Description copied from interface: DriverDelegate

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

Specified by:

selectInstancesFiredTriggerRecords in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Returns:

a List of FiredTriggerRecord objects.

deleteFiredTrigger

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

Delete a fired trigger.

Specified by:

deleteFiredTrigger in interface DriverDelegate

Parameters:

conn - the DB Connection

entryId - the fired trigger entry to delete

Returns:

the number of rows deleted

selectJobExecutionCount

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

Description copied from interface: DriverDelegate

Get the number instances of the identified job currently executing.

Specified by:

selectJobExecutionCount in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the number instances of the identified job currently executing.

deleteVolatileFiredTriggers

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

Description copied from interface: DriverDelegate

Delete all volatile fired triggers.

Specified by:

deleteVolatileFiredTriggers in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the number of rows deleted

insertSchedulerState

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

Description copied from interface: DriverDelegate

Insert a scheduler-instance state record.

Specified by:

insertSchedulerState in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the number of inserted rows.

deleteSchedulerState

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

Description copied from interface: DriverDelegate

Delete a scheduler-instance state record.

Specified by:

deleteSchedulerState in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

the number of deleted rows.

selectSchedulerStateRecords

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

Description copied from interface: DriverDelegate

A List of all current SchedulerStateRecords.

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

Specified by:

selectSchedulerStateRecords in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

rtp

protected final java.lang.String rtp(java.lang.String query)

Replace the table prefix in a query by replacing any occurrences of "{0}" with the table prefix.

Parameters:

query - the unsubstitued query

Returns:

the query, with proper table prefix substituted

serializeObject

protected java.io.ByteArrayOutputStream serializeObject(java.lang.Object obj)
                                                 throws java.io.IOException

Create a serialized java.util.ByteArrayOutputStream version of an Object.

Parameters:

obj - the object to serialize

Returns:

the serialized ByteArrayOutputStream

Throws:

java.io.IOException - if serialization causes an error

serializeJobData

protected java.io.ByteArrayOutputStream serializeJobData(JobDataMap data)
                                                  throws java.io.IOException

Remove the transient data from and then create a serialized java.util.ByteArrayOutputStream version of a JobDataMap.

Parameters:

obj - the object to serialize

Returns:

the serialized ByteArrayOutputStream

Throws:

java.io.IOException - if serialization causes an error

convertFromProperty

protected java.util.Map convertFromProperty(java.util.Properties properties)
                                     throws java.io.IOException

convert the JobDataMap into a list of properties

convertToProperty

protected java.util.Properties convertToProperty(java.util.Map data)
                                          throws java.io.IOException

convert the JobDataMap into a list of properties

getObjectFromBlob

protected java.lang.Object getObjectFromBlob(java.sql.ResultSet rs,
                                             java.lang.String colName)
                                      throws java.lang.ClassNotFoundException,
                                             java.io.IOException,
                                             java.sql.SQLException

This method should be overridden by any delegate subclasses that need special handling for BLOBs. The default implementation uses standard JDBC java.sql.Blob operations.

Parameters:

rs - the result set, already queued to the correct row

colName - the column name for the BLOB

Returns:

the deserialized Object from the ResultSet BLOB

Throws:

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

java.io.IOException - if deserialization causes an error

selectVolatileTriggers

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

Description copied from interface: DriverDelegate

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

Specified by:

selectVolatileTriggers in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

selectVolatileJobs

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

Description copied from interface: DriverDelegate

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

Specified by:

selectVolatileJobs in interface DriverDelegate

Following copied from interface: org.quartz.impl.jdbcjobstore.DriverDelegate

Parameters:

conn - the DB Connection

Returns:

an array of Key objects

getJobDetailFromBlob

protected java.lang.Object getJobDetailFromBlob(java.sql.ResultSet rs,
                                                java.lang.String colName)
                                         throws java.lang.ClassNotFoundException,
                                                java.io.IOException,
                                                java.sql.SQLException

This method should be overridden by any delegate subclasses that need special handling for BLOBs for job details. The default implementation uses standard JDBC java.sql.Blob operations.

Parameters:

rs - the result set, already queued to the correct row

colName - the column name for the BLOB

Returns:

the deserialized Object from the ResultSet BLOB

Throws:

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

java.io.IOException - if deserialization causes an error

selectPausedTriggerGroups

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

Specified by:

selectPausedTriggerGroups in interface DriverDelegate

See Also:

DriverDelegate.selectPausedTriggerGroups(java.sql.Connection)