org.quartz.impl.jdbcjobstore

Class PointbaseDelegate

java.lang.Object

org.quartz.impl.jdbcjobstore.StdJDBCDelegate

org.quartz.impl.jdbcjobstore.PointbaseDelegate

All Implemented Interfaces:

Constants, StdJDBCConstants

public class PointbaseDelegate
extends StdJDBCDelegate

This is a driver delegate for the Pointbase JDBC driver.

Author:

Gregg Freeman

Field Summary

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

COUNT_MISFIRED_TRIGGERS_IN_STATES, 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_TRIGGER_INSTANCE_NAMES, 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_MISFIRED_TRIGGERS_IN_STATES, SELECT_NEXT_FIRE_TIME, SELECT_NEXT_TRIGGER_TO_ACQUIRE, 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_DATA, 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_SCHEDULER_STATE, UPDATE_SIMPLE_TRIGGER, UPDATE_TRIGGER, UPDATE_TRIGGER_GROUP_STATE, UPDATE_TRIGGER_GROUP_STATE_FROM_STATE, UPDATE_TRIGGER_GROUP_STATE_FROM_STATES, UPDATE_TRIGGER_SKIP_DATA, 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_PRIORITY, 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_PAUSED_BLOCKED, 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

Constructors

Constructor and Description
PointbaseDelegate(org.apache.commons.logging.Log logger, java.lang.String tablePrefix, java.lang.String instanceId) Create new PointbaseJDBCDelegate instance.
PointbaseDelegate(org.apache.commons.logging.Log logger, java.lang.String tablePrefix, java.lang.String instanceId, java.lang.Boolean useProperties) Create new PointbaseJDBCDelegate instance.

Method Summary

Methods

Modifier and Type	Method and Description
int	insertCalendar(java.sql.Connection conn, java.lang.String calendarName, Calendar calendar) Insert a new calendar.
int	insertJobDetail(java.sql.Connection conn, JobDetail job) Insert the job detail record.
int	insertTrigger(java.sql.Connection conn, Trigger trigger, java.lang.String state, JobDetail jobDetail) Insert the base trigger data.
int	updateCalendar(java.sql.Connection conn, java.lang.String calendarName, Calendar calendar) Update a calendar.
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	updateTrigger(java.sql.Connection conn, Trigger trigger, java.lang.String state, JobDetail jobDetail) Update the base trigger data.

Methods inherited from class org.quartz.impl.jdbcjobstore.StdJDBCDelegate

calendarExists, calendarIsReferenced, countMisfiredTriggersInStates, deleteAllPausedTriggerGroups, deleteBlobTrigger, deleteCalendar, deleteCronTrigger, deleteFiredTrigger, deleteFiredTriggers, deleteFiredTriggers, deleteJobDetail, deleteJobListeners, deletePausedTriggerGroup, deleteSchedulerState, deleteSimpleTrigger, deleteTrigger, deleteTriggerListeners, deleteVolatileFiredTriggers, insertBlobTrigger, insertCronTrigger, insertFiredTrigger, insertJobListener, insertPausedTriggerGroup, insertSchedulerState, insertSimpleTrigger, 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, selectTriggersForCalendar, selectTriggersForJob, selectTriggersForRecoveringJobs, selectTriggersInGroup, selectTriggersInState, selectTriggerState, selectTriggerStatus, selectTriggerToAcquire, selectVolatileJobs, selectVolatileTriggers, triggerExists, updateBlobTrigger, updateCronTrigger, updateSchedulerState, updateSimpleTrigger, updateTriggerGroupStateFromOtherState, updateTriggerGroupStateFromOtherStates, updateTriggerState, updateTriggerStateFromOtherState, updateTriggerStateFromOtherStates, updateTriggerStateFromOtherStatesBeforeTime, updateTriggerStatesForJob, updateTriggerStatesForJobFromOtherState, updateTriggerStatesFromOtherStates

Methods inherited from class java.lang.Object

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

Constructor Detail

PointbaseDelegate

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

Create new PointbaseJDBCDelegate instance.

Parameters:

logger - the logger to use during execution

tablePrefix - the prefix of all table names

PointbaseDelegate

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

Create new PointbaseJDBCDelegate instance.

Parameters:

logger - the logger to use during execution

tablePrefix - the prefix of all table names

Method Detail

insertJobDetail

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

Insert the job detail record.

Overrides:

insertJobDetail in class StdJDBCDelegate

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

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

Update the job detail record.

Overrides:

updateJobDetail in class StdJDBCDelegate

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

insertTrigger

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

Description copied from class: StdJDBCDelegate

Insert the base trigger data.

Overrides:

insertTrigger in class StdJDBCDelegate

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

updateTrigger

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

Description copied from class: StdJDBCDelegate

Update the base trigger data.

Overrides:

updateTrigger in class StdJDBCDelegate

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

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.

Overrides:

updateJobData in class StdJDBCDelegate

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

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.

Overrides:

insertCalendar in class StdJDBCDelegate

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

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

Update a calendar.

Overrides:

updateCalendar in class StdJDBCDelegate

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