org.quartz.impl.jdbcjobstore: public class: PostgreSQLDelegate

org.quartz.impl.jdbcjobstore
public class: PostgreSQLDelegate [javadoc | source]

java.lang.Object
   org.quartz.impl.jdbcjobstore.StdJDBCDelegate
      org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

All Implemented Interfaces:
StdJDBCConstants, DriverDelegate

This is a driver delegate for the PostgreSQL JDBC driver.

author: < - a href="mailto:jeff@binaryfeed.org">Jeffrey Wescott

Fields inherited from org.quartz.impl.jdbcjobstore.StdJDBCDelegate:
logger, tablePrefix, instanceId, useProperties

Constructor:

Constructor:
public PostgreSQLDelegate(Log log, String tablePrefix, String instanceId) { super(log, tablePrefix, instanceId); } Create new PostgreSQLDelegate instance. Parameters: `log` - the logger to use during execution `tablePrefix` - the prefix of all table names
public PostgreSQLDelegate(Log log, String tablePrefix, String instanceId, Boolean useProperties) { super(log, tablePrefix, instanceId, useProperties); } Create new PostgreSQLDelegate instance. Parameters: `log` - the logger to use during execution `tablePrefix` - the prefix of all table names `useProperties` - use java.util.Properties for storage

 public PostgreSQLDelegate(Log log,
    String tablePrefix,
    String instanceId) {
        super(log, tablePrefix, instanceId);
}

Create new PostgreSQLDelegate instance.

Parameters:

log - the logger to use during execution

tablePrefix - the prefix of all table names

 public PostgreSQLDelegate(Log log,
    String tablePrefix,
    String instanceId,
    Boolean useProperties) {
        super(log, tablePrefix, instanceId, useProperties);
}

Create new PostgreSQLDelegate instance.

Parameters:

log - the logger to use during execution

tablePrefix - the prefix of all table names

useProperties - use java.util.Properties for storage

Method from org.quartz.impl.jdbcjobstore.PostgreSQLDelegate Summary:
getJobDetailFromBlob, getObjectFromBlob

Methods from org.quartz.impl.jdbcjobstore.StdJDBCDelegate:
calendarExists, calendarIsReferenced, canUseProperties, closeResultSet, closeStatement, convertFromProperty, convertToProperty, countMisfiredTriggersInStates, deleteAllPausedTriggerGroups, deleteBlobTrigger, deleteCalendar, deleteCronTrigger, deleteFiredTrigger, deleteFiredTriggers, deleteFiredTriggers, deleteJobDetail, deleteJobListeners, deletePausedTriggerGroup, deleteSchedulerState, deleteSimpleTrigger, deleteTrigger, deleteTriggerListeners, deleteVolatileFiredTriggers, getBoolean, getBoolean, getJobDetailFromBlob, getKeyOfNonSerializableValue, getObjectFromBlob, insertBlobTrigger, insertCalendar, insertCronTrigger, insertFiredTrigger, insertJobDetail, insertJobListener, insertPausedTriggerGroup, insertSchedulerState, insertSimpleTrigger, insertTrigger, insertTriggerListener, isExistingTriggerGroup, isJobStateful, isTriggerGroupPaused, jobExists, rtp, 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, serializeJobData, serializeObject, setBoolean, setBytes, triggerExists, updateBlobTrigger, updateCalendar, updateCronTrigger, updateJobData, updateJobDetail, updateSchedulerState, updateSimpleTrigger, updateTrigger, updateTriggerGroupStateFromOtherState, updateTriggerGroupStateFromOtherStates, updateTriggerState, updateTriggerStateFromOtherState, updateTriggerStateFromOtherStates, updateTriggerStateFromOtherStatesBeforeTime, updateTriggerStatesForJob, updateTriggerStatesForJobFromOtherState, updateTriggerStatesFromOtherStates

Methods from org.quartz.impl.jdbcjobstore.StdJDBCDelegate:

calendarExists, calendarIsReferenced, canUseProperties, closeResultSet, closeStatement, convertFromProperty, convertToProperty, countMisfiredTriggersInStates, deleteAllPausedTriggerGroups, deleteBlobTrigger, deleteCalendar, deleteCronTrigger, deleteFiredTrigger, deleteFiredTriggers, deleteFiredTriggers, deleteJobDetail, deleteJobListeners, deletePausedTriggerGroup, deleteSchedulerState, deleteSimpleTrigger, deleteTrigger, deleteTriggerListeners, deleteVolatileFiredTriggers, getBoolean, getBoolean, getJobDetailFromBlob, getKeyOfNonSerializableValue, getObjectFromBlob, insertBlobTrigger, insertCalendar, insertCronTrigger, insertFiredTrigger, insertJobDetail, insertJobListener, insertPausedTriggerGroup, insertSchedulerState, insertSimpleTrigger, insertTrigger, insertTriggerListener, isExistingTriggerGroup, isJobStateful, isTriggerGroupPaused, jobExists, rtp, 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, serializeJobData, serializeObject, setBoolean, setBytes, triggerExists, updateBlobTrigger, updateCalendar, updateCronTrigger, updateJobData, updateJobDetail, updateSchedulerState, updateSimpleTrigger, updateTrigger, updateTriggerGroupStateFromOtherState, updateTriggerGroupStateFromOtherStates, updateTriggerState, updateTriggerStateFromOtherState, updateTriggerStateFromOtherStates, updateTriggerStateFromOtherStatesBeforeTime, updateTriggerStatesForJob, updateTriggerStatesForJobFromOtherState, updateTriggerStatesFromOtherStates

Methods from java.lang.Object:
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method from org.quartz.impl.jdbcjobstore.PostgreSQLDelegate Detail:
protected Object getJobDetailFromBlob(ResultSet rs, String colName) throws IOException, ClassNotFoundException, SQLException { if (canUseProperties()) { InputStream binaryInput = null; byte[] bytes = rs.getBytes(colName); if(bytes == null \|\| bytes.length == 0) { return null; } binaryInput = new ByteArrayInputStream(bytes); return binaryInput; } return getObjectFromBlob(rs, colName); }
protected Object getObjectFromBlob(ResultSet rs, String colName) throws IOException, ClassNotFoundException, SQLException { InputStream binaryInput = null; byte[] bytes = rs.getBytes(colName); Object obj = null; if(bytes != null && bytes.length != 0) { binaryInput = new ByteArrayInputStream(bytes); ObjectInputStream in = new ObjectInputStream(binaryInput); try { obj = in.readObject(); } finally { in.close(); } } return obj; } 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.

Method from org.quartz.impl.jdbcjobstore.PostgreSQLDelegate Detail:

 protected Object getJobDetailFromBlob(ResultSet rs,
    String colName) throws IOException, ClassNotFoundException, SQLException {
        if (canUseProperties()) {
            InputStream binaryInput = null;
            byte[] bytes = rs.getBytes(colName);
            if(bytes == null || bytes.length == 0) {
                return null;
            }
            binaryInput = new ByteArrayInputStream(bytes);
            return binaryInput;
        }
        return getObjectFromBlob(rs, colName);
}

 protected Object getObjectFromBlob(ResultSet rs,
    String colName) throws IOException, ClassNotFoundException, SQLException {
        InputStream binaryInput = null;
        byte[] bytes = rs.getBytes(colName);
        Object obj = null;
        if(bytes != null && bytes.length != 0) {
            binaryInput = new ByteArrayInputStream(bytes);
            ObjectInputStream in = new ObjectInputStream(binaryInput);
            try {
                obj = in.readObject();
            } finally {
                in.close();
            }
        }
        return obj;
}

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.