Package org.openbravo.scheduling.quartz

Class OpenbravoPostgreJDBCDelegate

  • All Implemented Interfaces:
    OpenbravoJDBCDelegate, org.quartz.impl.jdbcjobstore.Constants, org.quartz.impl.jdbcjobstore.DriverDelegate, org.quartz.impl.jdbcjobstore.StdJDBCConstants
    public class OpenbravoPostgreJDBCDelegate
extends org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
implements OpenbravoJDBCDelegate
    Quartz Openbravo JDBC delegate that handles PostgreSQL database connections

    • Field Summary

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

        classLoadHelper, instanceId, logger, schedName, tablePrefix, triggerPersistenceDelegates, useProperties

      • 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_NONCONCURRENT, COL_IS_UPDATE_DATA, COL_IS_VOLATILE, COL_JOB_CLASS, COL_JOB_DATAMAP, COL_JOB_GROUP, 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_SCHED_TIME, COL_SCHEDULER_NAME, COL_START_TIME, COL_TIME_ZONE_ID, COL_TIMES_TRIGGERED, COL_TRIGGER_GROUP, 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_LOCKS, TABLE_PAUSED_TRIGGERS, TABLE_SCHEDULER_STATE, TABLE_SIMPLE_TRIGGERS, TABLE_TRIGGERS, TTYPE_BLOB, TTYPE_CAL_INT, TTYPE_CRON, TTYPE_DAILY_TIME_INT, TTYPE_SIMPLE

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

        COUNT_MISFIRED_TRIGGERS_IN_STATE, DELETE_ALL_BLOB_TRIGGERS, DELETE_ALL_CALENDARS, DELETE_ALL_CRON_TRIGGERS, DELETE_ALL_JOB_DETAILS, DELETE_ALL_PAUSED_TRIGGER_GRPS, DELETE_ALL_SIMPLE_TRIGGERS, DELETE_ALL_SIMPROP_TRIGGERS, DELETE_ALL_TRIGGERS, DELETE_BLOB_TRIGGER, DELETE_CALENDAR, DELETE_CRON_TRIGGER, DELETE_FIRED_TRIGGER, DELETE_FIRED_TRIGGERS, DELETE_INSTANCES_FIRED_TRIGGERS, DELETE_JOB_DETAIL, DELETE_NO_RECOVERY_FIRED_TRIGGERS, DELETE_PAUSED_TRIGGER_GROUP, DELETE_PAUSED_TRIGGER_GROUPS, DELETE_SCHEDULER_STATE, DELETE_SIMPLE_TRIGGER, DELETE_TRIGGER, INSERT_BLOB_TRIGGER, INSERT_CALENDAR, INSERT_CRON_TRIGGER, INSERT_FIRED_TRIGGER, INSERT_JOB_DETAIL, INSERT_PAUSED_TRIGGER_GROUP, INSERT_SCHEDULER_STATE, INSERT_SIMPLE_TRIGGER, INSERT_TRIGGER, SCHED_NAME_SUBST, 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_HAS_MISFIRED_TRIGGERS_IN_STATE, 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_NONCONCURRENT, SELECT_JOBS_IN_GROUP, SELECT_JOBS_IN_GROUP_LIKE, SELECT_MISFIRED_TRIGGERS, SELECT_MISFIRED_TRIGGERS_IN_GROUP_IN_STATE, SELECT_MISFIRED_TRIGGERS_IN_STATE, 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_TRIGGER, SELECT_TRIGGER_DATA, SELECT_TRIGGER_EXISTENCE, SELECT_TRIGGER_FOR_FIRE_TIME, SELECT_TRIGGER_GROUPS, SELECT_TRIGGER_GROUPS_FILTERED, SELECT_TRIGGER_STATE, SELECT_TRIGGER_STATUS, SELECT_TRIGGERS_FOR_CALENDAR, SELECT_TRIGGERS_FOR_JOB, SELECT_TRIGGERS_IN_GROUP, SELECT_TRIGGERS_IN_GROUP_LIKE, SELECT_TRIGGERS_IN_STATE, TABLE_PREFIX_SUBST, UPDATE_BLOB_TRIGGER, UPDATE_CALENDAR, UPDATE_CRON_TRIGGER, UPDATE_FIRED_TRIGGER, 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_FROM_STATE, UPDATE_TRIGGER_GROUP_STATE_FROM_STATES, UPDATE_TRIGGER_SKIP_DATA, UPDATE_TRIGGER_STATE, UPDATE_TRIGGER_STATE_FROM_STATE, UPDATE_TRIGGER_STATE_FROM_STATES, UPDATE_TRIGGER_STATES_FROM_OTHER_STATES

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      protected void addDefaultTriggerPersistenceDelegates()  
      protected boolean getBoolean​(ResultSet rs, int columnIndex)
      Use 'Y' and 'N' Varchar fields instead of Bool to be consistent with Openbravo standards and to allow DBSourceManager to manage the data structures
      protected boolean getBoolean​(ResultSet rs, String columnName)
      Use 'Y' and 'N' Varchar fields instead of Bool to be consistent with Openbravo standards and to allow DBSourceManager to manage the data structures
      boolean schedulersStarted​(Connection conn)
      Gets if scheduler has been started in the cluster
      List<org.quartz.TriggerKey> selectTriggerToAcquire​(Connection conn, long noLaterThan, long noEarlierThan, int maxCount)  
      protected void setBoolean​(PreparedStatement ps, int index, boolean val)
      Use 'Y' and 'N' Varchar fields instead of Bool to be consistent with Openbravo standards and to allow DBSourceManager to manage the data structures
      int updateSchedulerStatus​(Connection conn, String theInstanceId, long checkInTime, String status)
      Updates scheduler status to provided status

      • Methods inherited from class org.quartz.impl.jdbcjobstore.PostgreSQLDelegate

        getJobDataFromBlob, getObjectFromBlob

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

        addTriggerPersistenceDelegate, calendarExists, calendarIsReferenced, canUseProperties, clearData, closeResultSet, closeStatement, convertFromProperty, convertToProperty, countMisfiredTriggersInState, deleteAllPausedTriggerGroups, deleteBlobTrigger, deleteCalendar, deleteFiredTrigger, deleteFiredTriggers, deleteFiredTriggers, deleteJobDetail, deletePausedTriggerGroup, deletePausedTriggerGroup, deleteSchedulerState, deleteTrigger, deleteTriggerExtension, findTriggerPersistenceDelegate, findTriggerPersistenceDelegate, getKeyOfNonSerializableValue, getSchedulerNameLiteral, hasMisfiredTriggersInState, initialize, insertBlobTrigger, insertCalendar, insertFiredTrigger, insertJobDetail, insertPausedTriggerGroup, insertSchedulerState, insertTrigger, isExistingTriggerGroup, isJobNonConcurrent, isMatcherEquals, isTriggerGroupPaused, jobExists, rtp, selectCalendar, selectCalendars, selectFiredTriggerInstanceNames, selectFiredTriggerRecords, selectFiredTriggerRecordsByJob, selectInstancesFiredTriggerRecords, selectJobDetail, selectJobExecutionCount, selectJobForTrigger, selectJobForTrigger, selectJobGroups, selectJobsInGroup, selectMisfiredTriggers, selectMisfiredTriggersInGroupInState, selectMisfiredTriggersInState, selectNextFireTime, selectNumCalendars, selectNumJobs, selectNumTriggers, selectNumTriggersForJob, selectPausedTriggerGroups, selectSchedulerStateRecords, selectTrigger, selectTriggerForFireTime, selectTriggerGroups, selectTriggerGroups, selectTriggerJobDataMap, selectTriggerKeysForJob, selectTriggersForCalendar, selectTriggersForJob, selectTriggersForRecoveringJobs, selectTriggersInGroup, selectTriggersInState, selectTriggerState, selectTriggerStatus, selectTriggerToAcquire, serializeJobData, serializeObject, setBytes, toSqlEqualsClause, toSqlLikeClause, triggerExists, updateBlobTrigger, updateCalendar, updateFiredTrigger, updateJobData, updateJobDetail, updateSchedulerState, updateTrigger, updateTriggerGroupStateFromOtherState, updateTriggerGroupStateFromOtherStates, updateTriggerState, updateTriggerStateFromOtherState, updateTriggerStateFromOtherStates, updateTriggerStatesForJob, updateTriggerStatesForJobFromOtherState, updateTriggerStatesFromOtherStates

    • Constructor Detail

      • OpenbravoPostgreJDBCDelegate

        public OpenbravoPostgreJDBCDelegate()

    • Method Detail

      • addDefaultTriggerPersistenceDelegates

        protected void addDefaultTriggerPersistenceDelegates()
        Overrides:
        addDefaultTriggerPersistenceDelegates in class org.quartz.impl.jdbcjobstore.StdJDBCDelegate

      • setBoolean

        protected void setBoolean​(PreparedStatement ps,
                          int index,
                          boolean val)
                   throws SQLException
        Use 'Y' and 'N' Varchar fields instead of Bool to be consistent with Openbravo standards and to allow DBSourceManager to manage the data structures
        Overrides:
        setBoolean in class org.quartz.impl.jdbcjobstore.StdJDBCDelegate
        Throws:
        SQLException

      • getBoolean

        protected boolean getBoolean​(ResultSet rs,
                             String columnName)
                      throws SQLException
        Use 'Y' and 'N' Varchar fields instead of Bool to be consistent with Openbravo standards and to allow DBSourceManager to manage the data structures
        Overrides:
        getBoolean in class org.quartz.impl.jdbcjobstore.StdJDBCDelegate
        Throws:
        SQLException

      • getBoolean

        protected boolean getBoolean​(ResultSet rs,
                             int columnIndex)
                      throws SQLException
        Use 'Y' and 'N' Varchar fields instead of Bool to be consistent with Openbravo standards and to allow DBSourceManager to manage the data structures
        Overrides:
        getBoolean in class org.quartz.impl.jdbcjobstore.StdJDBCDelegate
        Throws:
        SQLException

      • updateSchedulerStatus

        public int updateSchedulerStatus​(Connection conn,
                                 String theInstanceId,
                                 long checkInTime,
                                 String status)
                          throws SQLException
        Description copied from interface: OpenbravoJDBCDelegate
        Updates scheduler status to provided status
        Specified by:
        updateSchedulerStatus in interface OpenbravoJDBCDelegate
        Parameters:
        conn - Connection to DB
        theInstanceId - Instance id of the scheduler
        checkInTime - Time stamp when status has been updated
        status - Target status
        Returns:
        Number of columns updated in DB (more than 0, scheduler status updated)
        Throws:
        SQLException - In case of SQL error

      • selectTriggerToAcquire

        public List<org.quartz.TriggerKey> selectTriggerToAcquire​(Connection conn,
                                                          long noLaterThan,
                                                          long noEarlierThan,
                                                          int maxCount)
                                                   throws SQLException
        Specified by:
        selectTriggerToAcquire in interface org.quartz.impl.jdbcjobstore.DriverDelegate
        Overrides:
        selectTriggerToAcquire in class org.quartz.impl.jdbcjobstore.StdJDBCDelegate
        Throws:
        SQLException