org.quartz.impl.jdbcjobstore.oracle
Class OracleDelegate

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

All Implemented Interfaces:

Constants, DriverDelegate, StdJDBCConstants

public class OracleDelegate

extends StdJDBCDelegate

This is a driver delegate for the Oracle JDBC driver. To use this delegate, jdbcDriverVendor should be configured as 'Oracle' with any jdbcDriverVersion.

Author:

James House, Patrick Lightbody

Field Summary

static java.lang.String	INSERT_ORACLE_CALENDAR
static java.lang.String	INSERT_ORACLE_JOB_DETAIL
static java.lang.String	SELECT_ORACLE_CALENDAR_BLOB
static java.lang.String	SELECT_ORACLE_JOB_DETAIL_BLOB
static java.lang.String	UPDATE_ORACLE_CALENDAR_BLOB
static java.lang.String	UPDATE_ORACLE_JOB_DETAIL
static java.lang.String	UPDATE_ORACLE_JOB_DETAIL_BLOB
static java.lang.String	UPDATE_ORACLE_JOB_DETAIL_EMPTY_BLOB

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

instanceId, logger, tablePrefix, 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

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

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

Method Summary

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

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

calendarExists, calendarIsReferenced, canUseProperties, convertFromProperty, convertToProperty, deleteAllPausedTriggerGroups, deleteBlobTrigger, deleteCalendar, deleteCronTrigger, deleteFiredTrigger, deleteFiredTriggers, deleteFiredTriggers, deleteJobDetail, deleteJobListeners, deletePausedTriggerGroup, deleteSchedulerState, deleteSimpleTrigger, deleteTrigger, deleteTriggerListeners, deleteVolatileFiredTriggers, insertBlobTrigger, insertCronTrigger, insertFiredTrigger, insertJobListener, insertPausedTriggerGroup, insertSchedulerState, insertSimpleTrigger, insertTrigger, insertTriggerListener, isExistingTriggerGroup, isJobStateful, isTriggerGroupPaused, jobExists, rtp, selectCalendar, selectCalendars, selectFiredTriggerRecords, selectFiredTriggerRecordsByJob, selectInstancesFiredTriggerRecords, selectJobDetail, selectJobExecutionCount, selectJobForTrigger, selectJobGroups, selectJobListeners, selectJobsInGroup, selectMisfiredTriggers, selectMisfiredTriggersInGroupInState, selectMisfiredTriggersInState, selectNextFireTime, selectNumCalendars, selectNumJobs, selectNumTriggers, selectNumTriggersForJob, selectPausedTriggerGroups, selectSchedulerStateRecords, selectStatefulJobsOfTriggerGroup, selectTrigger, selectTriggerForFireTime, selectTriggerGroups, selectTriggerListeners, selectTriggerNamesForJob, selectTriggersForCalendar, selectTriggersForJob, selectTriggersForRecoveringJobs, selectTriggersInGroup, selectTriggersInState, selectTriggerState, selectTriggerStatus, selectVolatileJobs, selectVolatileTriggers, serializeJobData, serializeObject, triggerExists, updateBlobTrigger, updateCronTrigger, updateSimpleTrigger, updateTrigger, updateTriggerGroupStateFromOtherState, updateTriggerGroupStateFromOtherStates, updateTriggerState, updateTriggerStateFromOtherState, updateTriggerStateFromOtherStates, updateTriggerStateFromOtherStatesBeforeTime, updateTriggerStatesForJob, updateTriggerStatesForJobFromOtherState, updateTriggerStatesFromOtherStates

Methods inherited from class java.lang.Object

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

Field Detail

INSERT_ORACLE_JOB_DETAIL

public static final java.lang.String INSERT_ORACLE_JOB_DETAIL

UPDATE_ORACLE_JOB_DETAIL

public static final java.lang.String UPDATE_ORACLE_JOB_DETAIL

UPDATE_ORACLE_JOB_DETAIL_BLOB

public static final java.lang.String UPDATE_ORACLE_JOB_DETAIL_BLOB

UPDATE_ORACLE_JOB_DETAIL_EMPTY_BLOB

public static final java.lang.String UPDATE_ORACLE_JOB_DETAIL_EMPTY_BLOB

SELECT_ORACLE_JOB_DETAIL_BLOB

public static final java.lang.String SELECT_ORACLE_JOB_DETAIL_BLOB

INSERT_ORACLE_CALENDAR

public static final java.lang.String INSERT_ORACLE_CALENDAR

SELECT_ORACLE_CALENDAR_BLOB

public static final java.lang.String SELECT_ORACLE_CALENDAR_BLOB

UPDATE_ORACLE_CALENDAR_BLOB

public static final java.lang.String UPDATE_ORACLE_CALENDAR_BLOB

Constructor Detail

OracleDelegate

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

Create new OrcaleDelegate instance.

Parameters:

logger - the logger to use during execution

tablePrefix - the prefix of all table names

OracleDelegate

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

Create new OrcaleDelegate instance.

Parameters:

logger - the logger to use during execution

tablePrefix - the prefix of all table names

useProperties - use java.util.Properties for storage

Method Detail

getObjectFromBlob

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

Description copied from class: StdJDBCDelegate

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.

Overrides:

getObjectFromBlob in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.StdJDBCDelegate

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

insertJobDetail

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

Description copied from class: StdJDBCDelegate

Insert the job detail record.

Overrides:

insertJobDetail in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.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

getJobDetailFromBlob

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

Description copied from class: StdJDBCDelegate

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.

Overrides:

getJobDetailFromBlob in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.StdJDBCDelegate

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

updateJobDetail

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

Description copied from class: StdJDBCDelegate

Update the job detail record.

Overrides:

updateJobDetail in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.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

insertCalendar

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

Description copied from class: StdJDBCDelegate

Insert a new calendar.

Overrides:

insertCalendar in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.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

updateCalendar

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

Description copied from class: StdJDBCDelegate

Update a calendar.

Overrides:

updateCalendar in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.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

updateJobData

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

Description copied from class: StdJDBCDelegate

Update the job data map for the given job.

Overrides:

updateJobData in class StdJDBCDelegate

Following copied from class: org.quartz.impl.jdbcjobstore.StdJDBCDelegate

Parameters:

conn - the DB Connection

job - the job to update

Returns:

the number of rows updated