Save This Page
Home » quartz-1.6.0 » org » quartz » impl » jdbcjobstore » [javadoc | source]
org.quartz.impl.jdbcjobstore
interface: DriverDelegate [javadoc | source]

All Known Implementing Classes:
    PostgreSQLDelegate, DB2v7Delegate, WebLogicDelegate, DB2v6Delegate, PointbaseDelegate, CloudscapeDelegate, OracleDelegate, HSQLDBDelegate, DB2v8Delegate, WebLogicOracleDelegate, StdJDBCDelegate, WebLogicOracleDelegate, MSSQLDelegate

This is the base interface for all driver delegate classes.

This interface is very similar to the org.quartz.spi.JobStore interface except each method has an additional java.sql.Connection parameter.

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

Method from org.quartz.impl.jdbcjobstore.DriverDelegate Summary:
calendarExists,   calendarIsReferenced,   countMisfiredTriggersInStates,   deleteAllPausedTriggerGroups,   deleteBlobTrigger,   deleteCalendar,   deleteCronTrigger,   deleteFiredTrigger,   deleteFiredTriggers,   deleteFiredTriggers,   deleteJobDetail,   deleteJobListeners,   deletePausedTriggerGroup,   deleteSchedulerState,   deleteSimpleTrigger,   deleteTrigger,   deleteTriggerListeners,   deleteVolatileFiredTriggers,   insertBlobTrigger,   insertCalendar,   insertCronTrigger,   insertFiredTrigger,   insertJobDetail,   insertJobListener,   insertPausedTriggerGroup,   insertSchedulerState,   insertSimpleTrigger,   insertTrigger,   insertTriggerListener,   isExistingTriggerGroup,   isJobStateful,   isTriggerGroupPaused,   jobExists,   selectCalendar,   selectCalendars,   selectFiredTriggerInstanceNames,   selectFiredTriggerRecords,   selectFiredTriggerRecordsByJob,   selectInstancesFiredTriggerRecords,   selectJobDetail,   selectJobExecutionCount,   selectJobForTrigger,   selectJobGroups,   selectJobListeners,   selectJobsInGroup,   selectMisfiredTriggers,   selectMisfiredTriggersInGroupInState,   selectMisfiredTriggersInState,   selectMisfiredTriggersInStates,   selectNextFireTime,   selectNumCalendars,   selectNumJobs,   selectNumTriggers,   selectNumTriggersForJob,   selectPausedTriggerGroups,   selectSchedulerStateRecords,   selectStatefulJobsOfTriggerGroup,   selectTrigger,   selectTriggerForFireTime,   selectTriggerGroups,   selectTriggerJobDataMap,   selectTriggerListeners,   selectTriggerNamesForJob,   selectTriggerState,   selectTriggerStatus,   selectTriggerToAcquire,   selectTriggersForCalendar,   selectTriggersForJob,   selectTriggersForRecoveringJobs,   selectTriggersInGroup,   selectTriggersInState,   selectVolatileJobs,   selectVolatileTriggers,   triggerExists,   updateBlobTrigger,   updateCalendar,   updateCronTrigger,   updateJobData,   updateJobDetail,   updateSchedulerState,   updateSimpleTrigger,   updateTrigger,   updateTriggerGroupStateFromOtherState,   updateTriggerGroupStateFromOtherStates,   updateTriggerState,   updateTriggerStateFromOtherState,   updateTriggerStateFromOtherStates,   updateTriggerStateFromOtherStatesBeforeTime,   updateTriggerStatesForJob,   updateTriggerStatesForJobFromOtherState,   updateTriggerStatesFromOtherStates
Method from org.quartz.impl.jdbcjobstore.DriverDelegate Detail:
 public boolean calendarExists(Connection conn,
    String calendarName) throws SQLException

    Check whether or not a calendar exists.

 public boolean calendarIsReferenced(Connection conn,
    String calendarName) throws SQLException

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

 public int countMisfiredTriggersInStates(Connection conn,
    String state1,
    String state2,
    long ts) throws SQLException

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

 public int deleteAllPausedTriggerGroups(Connection conn) throws SQLException
 public int deleteBlobTrigger(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Delete the BLOB trigger data for a trigger.

 public int deleteCalendar(Connection conn,
    String calendarName) throws SQLException

    Delete a calendar.

 public int deleteCronTrigger(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Delete the cron trigger data for a trigger.

 public int deleteFiredTrigger(Connection conn,
    String entryId) throws SQLException

    Delete a fired trigger.

 public int deleteFiredTriggers(Connection conn) throws SQLException

    Delete all fired triggers.

 public int deleteFiredTriggers(Connection conn,
    String instanceId) throws SQLException

    Delete all fired triggers of the given instance.

 public int deleteJobDetail(Connection conn,
    String jobName,
    String groupName) throws SQLException

    Delete the job detail record for the given job.

 public int deleteJobListeners(Connection conn,
    String jobName,
    String groupName) throws SQLException

    Delete all job listeners for the given job.

 public int deletePausedTriggerGroup(Connection conn,
    String groupName) throws SQLException
 public int deleteSchedulerState(Connection conn,
    String instanceId) throws SQLException

    Delete a scheduler-instance state record.

 public int deleteSimpleTrigger(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Delete the simple trigger data for a trigger.

 public int deleteTrigger(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Delete the base trigger data for a trigger.

 public int deleteTriggerListeners(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Delete all of the listeners associated with a given trigger.

 public int deleteVolatileFiredTriggers(Connection conn) throws SQLException

    Delete all volatile fired triggers.

 public int insertBlobTrigger(Connection conn,
    Trigger trigger) throws IOException, SQLException

    Insert the blob trigger data.

 public int insertCalendar(Connection conn,
    String calendarName,
    Calendar calendar) throws IOException, SQLException

    Insert a new calendar.

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

    Insert the cron trigger data.

 public int insertFiredTrigger(Connection conn,
    Trigger trigger,
    String state,
    JobDetail jobDetail) throws SQLException

    Insert a fired trigger.

 public int insertJobDetail(Connection conn,
    JobDetail job) throws IOException, SQLException

    Insert the job detail record.

 public int insertJobListener(Connection conn,
    JobDetail job,
    String listener) throws SQLException

    Associate a listener with a job.

 public int insertPausedTriggerGroup(Connection conn,
    String groupName) throws SQLException
 public int insertSchedulerState(Connection conn,
    String instanceId,
    long checkInTime,
    long interval) throws SQLException

    Insert a scheduler-instance state record.

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

    Insert the simple trigger data.

 public int insertTrigger(Connection conn,
    Trigger trigger,
    String state,
    JobDetail jobDetail) throws IOException, SQLException

    Insert the base trigger data.

 public int insertTriggerListener(Connection conn,
    Trigger trigger,
    String listener) throws SQLException

    Associate a listener with the given trigger.

 public boolean isExistingTriggerGroup(Connection conn,
    String groupName) throws SQLException
 public boolean isJobStateful(Connection conn,
    String jobName,
    String groupName) throws SQLException

    Check whether or not the given job is stateful.

 public boolean isTriggerGroupPaused(Connection conn,
    String groupName) throws SQLException
 public boolean jobExists(Connection conn,
    String jobName,
    String groupName) throws SQLException

    Check whether or not the given job exists.

 public Calendar selectCalendar(Connection conn,
    String calendarName) throws IOException, ClassNotFoundException, SQLException

    Select a calendar.

 public String[] selectCalendars(Connection conn) throws SQLException

    Select all of the stored calendars.

 public Set selectFiredTriggerInstanceNames(Connection conn) throws 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.)

 public List selectFiredTriggerRecords(Connection conn,
    String triggerName,
    String groupName) throws SQLException

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

 public List selectFiredTriggerRecordsByJob(Connection conn,
    String jobName,
    String groupName) throws SQLException

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

 public List selectInstancesFiredTriggerRecords(Connection conn,
    String instanceName) throws SQLException

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

 public JobDetail selectJobDetail(Connection conn,
    String jobName,
    String groupName,
    ClassLoadHelper loadHelper) throws IOException, ClassNotFoundException, SQLException

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

 public int selectJobExecutionCount(Connection conn,
    String jobName,
    String jobGroup) throws SQLException

    Get the number instances of the identified job currently executing.

 public JobDetail selectJobForTrigger(Connection conn,
    String triggerName,
    String groupName,
    ClassLoadHelper loadHelper) throws ClassNotFoundException, SQLException

    Select the job to which the trigger is associated.

 public String[] selectJobGroups(Connection conn) throws SQLException

    Select all of the job group names that are stored.

 public String[] selectJobListeners(Connection conn,
    String jobName,
    String groupName) throws SQLException

    Get all of the listeners for a given job.

 public String[] selectJobsInGroup(Connection conn,
    String groupName) throws SQLException

    Select all of the jobs contained in a given group.

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

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

 public Key[] selectMisfiredTriggersInGroupInState(Connection conn,
    String groupName,
    String state,
    long ts) throws SQLException

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

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

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

 public boolean selectMisfiredTriggersInStates(Connection conn,
    String state1,
    String state2,
    long ts,
    int count,
    List resultList) throws 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.

 public long selectNextFireTime(Connection conn) throws SQLExceptionDeprecated! Does -  not account for misfires.

    Select the next time that a trigger will be fired.

 public int selectNumCalendars(Connection conn) throws SQLException

    Select the total number of calendars stored.

 public int selectNumJobs(Connection conn) throws SQLException

    Select the total number of jobs stored.

 public int selectNumTriggers(Connection conn) throws SQLException

    Select the total number of triggers stored.

 public int selectNumTriggersForJob(Connection conn,
    String jobName,
    String groupName) throws SQLException

    Select the number of triggers associated with a given job.

 public Set selectPausedTriggerGroups(Connection conn) throws SQLException
 public List selectSchedulerStateRecords(Connection conn,
    String instanceId) throws SQLException

    A List of all current SchedulerStateRecords.

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

 public List selectStatefulJobsOfTriggerGroup(Connection conn,
    String groupName) throws SQLException

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

 public Trigger selectTrigger(Connection conn,
    String triggerName,
    String groupName) throws IOException, ClassNotFoundException, SQLException

    Select a trigger.

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

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

 public String[] selectTriggerGroups(Connection conn) throws SQLException

    Select all of the trigger group names that are stored.

 public JobDataMap selectTriggerJobDataMap(Connection conn,
    String triggerName,
    String groupName) throws IOException, ClassNotFoundException, SQLException

    Select a trigger's JobDataMap.

 public String[] selectTriggerListeners(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Select the listeners associated with a given trigger.

 public Key[] selectTriggerNamesForJob(Connection conn,
    String jobName,
    String groupName) throws SQLException

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

 public String selectTriggerState(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Select a trigger' state value.

 public TriggerStatus selectTriggerStatus(Connection conn,
    String triggerName,
    String groupName) throws SQLException

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

 public Key selectTriggerToAcquire(Connection conn,
    long noLaterThan,
    long noEarlierThan) throws 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.

 public Trigger[] selectTriggersForCalendar(Connection conn,
    String calName) throws IOException, ClassNotFoundException, SQLException

    Select the triggers for a calendar

 public Trigger[] selectTriggersForJob(Connection conn,
    String jobName,
    String groupName) throws IOException, ClassNotFoundException, SQLException

    Select the triggers for a job

 public Trigger[] selectTriggersForRecoveringJobs(Connection conn) throws ClassNotFoundException, IOException, 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 org.quartz.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.

 public String[] selectTriggersInGroup(Connection conn,
    String groupName) throws SQLException

    Select all of the triggers contained in a given group.

 public Key[] selectTriggersInState(Connection conn,
    String state) throws SQLException

    Select all of the triggers in a given state.

 public Key[] selectVolatileJobs(Connection conn) throws SQLException

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

 public Key[] selectVolatileTriggers(Connection conn) throws SQLException

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

 public boolean triggerExists(Connection conn,
    String triggerName,
    String groupName) throws SQLException

    Check whether or not a trigger exists.

 public int updateBlobTrigger(Connection conn,
    Trigger trigger) throws IOException, SQLException

    Update the blob trigger data.

 public int updateCalendar(Connection conn,
    String calendarName,
    Calendar calendar) throws IOException, SQLException

    Update a calendar.

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

    Update the cron trigger data.

 public int updateJobData(Connection conn,
    JobDetail job) throws IOException, SQLException

    Update the job data map for the given job.

 public int updateJobDetail(Connection conn,
    JobDetail job) throws IOException, SQLException

    Update the job detail record.

 public int updateSchedulerState(Connection conn,
    String instanceId,
    long checkInTime) throws SQLException

    Update a scheduler-instance state record.

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

    Update the simple trigger data.

 public int updateTrigger(Connection conn,
    Trigger trigger,
    String state,
    JobDetail jobDetail) throws IOException, SQLException

    Update the base trigger data.

 public int updateTriggerGroupStateFromOtherState(Connection conn,
    String groupName,
    String newState,
    String oldState) throws SQLException

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

 public int updateTriggerGroupStateFromOtherStates(Connection conn,
    String groupName,
    String newState,
    String oldState1,
    String oldState2,
    String oldState3) throws SQLException

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

 public int updateTriggerState(Connection conn,
    String triggerName,
    String groupName,
    String state) throws SQLException

    Update the state for a given trigger.

 public int updateTriggerStateFromOtherState(Connection conn,
    String triggerName,
    String groupName,
    String newState,
    String oldState) throws SQLException

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

 public int updateTriggerStateFromOtherStates(Connection conn,
    String triggerName,
    String groupName,
    String newState,
    String oldState1,
    String oldState2,
    String oldState3) throws SQLException

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

 public int updateTriggerStateFromOtherStatesBeforeTime(Connection conn,
    String newState,
    String oldState1,
    String oldState2,
    long time) throws 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.

 public int updateTriggerStatesForJob(Connection conn,
    String jobName,
    String groupName,
    String state) throws SQLException

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

 public int updateTriggerStatesForJobFromOtherState(Connection conn,
    String jobName,
    String groupName,
    String state,
    String oldState) throws SQLException

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

 public int updateTriggerStatesFromOtherStates(Connection conn,
    String newState,
    String oldState1,
    String oldState2) throws SQLException

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