クラス LocalDataSourceJobStore
java.lang.ObjectSE
org.quartz.impl.jdbcjobstore.JobStoreSupport
org.quartz.impl.jdbcjobstore.JobStoreCMT
org.springframework.scheduling.quartz.LocalDataSourceJobStore
Quartz 管理の JDBC 接続プールを使用する代わりに、Spring 管理の
DataSource
SE に委譲する Quartz の JobStoreCMT
クラスのサブクラス。この JobStore は、SchedulerFactoryBean の "dataSource" プロパティが設定されている場合使用されます。この LocalDataSourceJobStore
のカスタムサブクラスとして、または同等の JobStoreCMT
バリアントとして、明示的に構成することもできます。トランザクションおよび非トランザクションの両方の DataSource アクセスをサポートします。非 XA DataSource およびローカル Spring トランザクションの場合、単一の DataSource 引数で十分です。XA DataSource およびグローバル JTA トランザクションの場合、SchedulerFactoryBean の "nonTransactionalDataSource" プロパティを設定し、グローバルトランザクションに参加しない非 XA DataSource を渡す必要があります。
この JobStore によって実行される操作は、現在のトランザクションを認識する Spring の DataSourceUtils 接続処理メソッドを使用するため、あらゆる種類の Spring 管理トランザクションに適切に参加します。
永続的なジョブストアに影響を与えるすべての Quartz スケジューラー操作は、適切なロックを取得すると想定しているため、通常はアクティブなトランザクション内で実行する必要があります。
- 導入:
- 1.1
- 作成者:
- Juergen Hoeller
- 関連事項:
SchedulerFactoryBean.setDataSource(javax.sql.DataSource)
SchedulerFactoryBean.setNonTransactionalDataSource(javax.sql.DataSource)
SchedulerFactoryBean.getConfigTimeDataSource()
SchedulerFactoryBean.getConfigTimeNonTransactionalDataSource()
DataSourceUtils.doGetConnection(javax.sql.DataSource)
DataSourceUtils.releaseConnection(java.sql.Connection, javax.sql.DataSource)
ネストされたクラスのサマリー
クラス org.quartz.impl.jdbcjobstore.JobStoreSupport から継承されたネストクラス / インターフェース
JobStoreSupport.RecoverMisfiredJobsResult, JobStoreSupport.TransactionCallback<T extends ObjectSE>, JobStoreSupport.TransactionValidator<T extends ObjectSE>, JobStoreSupport.VoidTransactionCallback
フィールドサマリー
修飾子と型フィールド説明static final StringSE
Quartz の非トランザクション ConnectionProvider に使用される名前。static final StringSE
Quartz のトランザクション ConnectionProvider に使用される名前。クラス org.quartz.impl.jdbcjobstore.JobStoreCMT から継承されたフィールド
dontSetNonManagedTXConnectionAutoCommitFalse, nonManagedTxDsName, setTxIsolationLevelReadCommitted
クラス org.quartz.impl.jdbcjobstore.JobStoreSupport から継承されたフィールド
calendarCache, delegateClass, delegateClassName, delegateInitString, dsName, firstCheckIn, instanceId, instanceName, lastCheckin, LOCK_STATE_ACCESS, LOCK_TRIGGER_ACCESS, maxToRecoverAtATime, sigChangeForTxCompletion, tablePrefix, useProperties
インターフェース 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
コンストラクターのサマリー
方法の概要
クラス org.quartz.impl.jdbcjobstore.JobStoreCMT から継承されたメソッド
executeInLock, getNonManagedTXConnection, getNonManagedTXDataSource, isDontSetNonManagedTXConnectionAutoCommitFalse, isTxIsolationLevelReadCommitted, setDontSetNonManagedTXConnectionAutoCommitFalse, setNonManagedTXDataSource, setTxIsolationLevelReadCommitted, shutdown
クラス org.quartz.impl.jdbcjobstore.JobStoreSupport から継承されたメソッド
acquireNextTrigger, acquireNextTriggers, calcFailedIfAfter, calendarExists, canUseProperties, checkBlockedState, checkExists, checkExists, checkExists, checkExists, cleanupConnection, clearAllSchedulingData, clearAllSchedulingData, clearAndGetSignalSchedulingChangeOnTxCompletion, clusterCheckIn, clusterRecover, commitConnection, doCheckin, doRecoverMisfires, executeInNonManagedTXLock, executeWithoutLock, findFailedInstances, getAcquireRetryDelay, getAttributeRestoringConnection, getCalendarNames, getCalendarNames, getClassLoadHelper, getClusterCheckinInterval, getConnection, getDataSource, getDbRetryInterval, getDelegate, getDoubleCheckLockMisfireHandler, getDriverDelegateClass, getDriverDelegateInitString, getEstimatedTimeToReleaseAndAcquireTrigger, getFiredTriggerRecordId, getInstanceId, getInstanceName, getJobGroupNames, getJobGroupNames, getJobKeys, getJobNames, getLockHandler, getLog, getMakeThreadsDaemons, getMaxMisfiresToHandleAtATime, getMisfireThreshold, getMisfireTime, getNumberOfCalendars, getNumberOfCalendars, getNumberOfJobs, getNumberOfJobs, getNumberOfTriggers, getNumberOfTriggers, getPausedTriggerGroups, getPausedTriggerGroups, getSelectWithLockSQL, getTablePrefix, getThreadExecutor, getTriggerGroupNames, getTriggerGroupNames, getTriggerKeys, getTriggerNames, getTriggersForJob, getTriggersForJob, getTriggerState, getTriggerState, getUseDBLocks, isAcquireTriggersWithinLock, isClustered, isDontSetAutoCommitFalse, isLockOnInsert, isThreadsInheritInitializersClassLoadContext, isTxIsolationLevelSerializable, jobExists, logWarnIfNonZero, pauseAll, pauseAll, pauseJob, pauseJobs, pauseTrigger, pauseTrigger, pauseTriggerGroup, pauseTriggers, recoverJobs, recoverJobs, recoverMisfiredJobs, releaseAcquiredTrigger, releaseAcquiredTrigger, releaseLock, removeCalendar, removeCalendar, removeJob, removeJob, removeJobs, removeTrigger, removeTrigger, removeTriggers, replaceTrigger, replaceTrigger, resetTriggerFromErrorState, resumeAll, resumeAll, resumeJob, resumeJobs, resumeTrigger, resumeTrigger, resumeTriggerGroup, resumeTriggers, retrieveCalendar, retrieveCalendar, retrieveJob, retrieveJob, retrieveTrigger, retrieveTrigger, retryExecuteInNonManagedTXLock, rollbackConnection, schedulerPaused, schedulerResumed, schedulerStarted, setAcquireTriggersWithinLock, setClusterCheckinInterval, setDataSource, setDbRetryInterval, setDontSetAutoCommitFalse, setDoubleCheckLockMisfireHandler, setDriverDelegateClass, setDriverDelegateInitString, setInstanceId, setInstanceName, setIsClustered, setLockHandler, setLockOnInsert, setMakeThreadsDaemons, setMaxMisfiresToHandleAtATime, setMisfireThreshold, setSelectWithLockSQL, setTablePrefix, setThreadExecutor, setThreadPoolSize, setThreadsInheritInitializersClassLoadContext, setTxIsolationLevelSerializable, setUseDBLocks, setUseProperties, signalSchedulingChangeImmediately, signalSchedulingChangeOnTxCompletion, storeCalendar, storeCalendar, storeJob, storeJob, storeJobAndTrigger, storeJobsAndTriggers, storeTrigger, storeTrigger, supportsPersistence, triggeredJobComplete, triggeredJobComplete, triggerExists, triggerFired, triggersFired, updateMisfiredTrigger
フィールドの詳細
TX_DATA_SOURCE_PREFIX
Quartz のトランザクション ConnectionProvider に使用される名前。このプロバイダーは、ローカルの Spring 管理の DataSource に委譲します。NON_TX_DATA_SOURCE_PREFIX
Quartz の非トランザクション ConnectionProvider に使用される名前。このプロバイダーは、ローカルの Spring 管理の DataSource に委譲します。
コンストラクターの詳細
LocalDataSourceJobStore
public LocalDataSourceJobStore()
メソッドの詳細
initialize
public void initialize(ClassLoadHelper loadHelper, SchedulerSignaler signaler) throws SchedulerConfigException - 次で指定:
- インターフェース
JobStore
のinitialize
- オーバーライド:
- クラス
JobStoreCMT
のinitialize
- 例外:
SchedulerConfigException
closeConnection
- オーバーライド:
- クラス
JobStoreSupport
のcloseConnection