瀚高數(shù)據(jù)庫(kù)
目錄
環(huán)境
文檔用途
詳細(xì)信息

環(huán)境
系統(tǒng)平臺(tái)：N/A
版本：4.5
文檔用途
本文檔用于在java應(yīng)用適配hgdb時(shí)，解決定時(shí)框架Quartz遇到的問(wèn)題

詳細(xì)信息
更改HGDB腳本
應(yīng)用系統(tǒng)在適配瀚高數(shù)據(jù)庫(kù)時(shí)，數(shù)據(jù)庫(kù)往往都是通過(guò)遷移工具從mysql或oracle遷移而來(lái)，遷移之后需要更改quartz所需的表結(jié)構(gòu)，原因?yàn)?#xff0c;遷移后，源庫(kù)的boolean類型的數(shù)據(jù)存儲(chǔ)并沒(méi)有改變，遷移之后為varchar(1)，瀚高數(shù)據(jù)庫(kù)支持boolean類型，需要將所需字段類型改為boolean，如若不然，需要加隱士轉(zhuǎn)換將character varying 類型轉(zhuǎn)為boolean存儲(chǔ)。

quartz所需的表包括QRTZ_FIRED_TRIGGERS、QRTZ_PAUSED_TRIGGER_GRPS、QRTZ_SCHEDULER_STATE、QRTZ_LOCKS、QRTZ_SIMPLE_TRIGGERS、QRTZ_SIMPROP_TRIGGERS、QRTZ_CRON_TRIGGERS、QRTZ_BLOB_TRIGGERS、QRTZ_TRIGGERS、QRTZ_JOB_DETAILS、QRTZ_CALENDARS共11張表。

需要注意的是，應(yīng)用系統(tǒng)中在開發(fā)的時(shí)候，有時(shí)候會(huì)根據(jù)自己的喜好改了表名前綴，根據(jù)配置文件中tablePrefix的值，找到對(duì)應(yīng)的表進(jìn)行修改就可以。

需要更改的表字段為：

表QRTZ_JOB_DETAILS的字段IS_DURABLE類型改為boolean表QRTZ_JOB_DETAILS的字段IS_NONCONCURRENT類型改為boolean表QRTZ_JOB_DETAILS的字段IS_UPDATE_DATA類型改為boolean表QRTZ_JOB_DETAILS的字段REQUESTS_RECOVERY類型改為boolean表QRTZ_SIMPROP_TRIGGERS的字段BOOL_PROP_1類型改為boolean表QRTZ_SIMPROP_TRIGGERS的字段BOOL_PROP_2類型改為boolean表QRTZ_FIRED_TRIGGERS的字段IS_NONCONCURRENT類型改為boolean表QRTZ_FIRED_TRIGGERS的字段REQUESTS_RECOVERY類型改為boolean

替換驅(qū)動(dòng)代理
在quartz的配置文件中，更改org.quartz.jobStore.driverDelegateClass，通過(guò)該配置項(xiàng)可設(shè)置不同數(shù)據(jù)庫(kù)的“方言”。可能的選擇包括：

org.quartz.impl.jdbcjobstore.StdJDBCDelegate(完全兼容JDBC的驅(qū)動(dòng))org.quartz.impl.jdbcjobstore.MSSQLDelegate(Microsoft SQL Server和Sybase)org.quartz.impl.jdbcjobstore.PostgreSQLDelegateorg.quartz.impl.jdbcjobstore.WebLogicDelegate(WebLogic驅(qū)動(dòng))org.quartz.impl.jdbcjobstore.oracle.OracleDelegateorg.quartz.impl.jdbcjobstore.oracle.WebLogicOracleDelegate(Weblogic使用的Oracle驅(qū)動(dòng))org.quartz.impl.jdbcjobstore.oracle.weblogic.WebLogicOracleDelegate(Weblogic使用的Oracle)org.quartz.impl.jdbcjobstore.CloudscapeDelegateorg.quartz.impl.jdbcjobstore.DB2v6Delegateorg.quartz.impl.jdbcjobstore.DB2v7Delegateorg.quartz.impl.jdbcjobstore.DB2v8Delegateorg.quartz.impl.jdbcjobstore.HSQLDBDelegateorg.quartz.impl.jdbcjobstore.PointbaseDelegateorg.quartz.impl.jdbcjobstore.SybaseDelegate

適配瀚高數(shù)據(jù)庫(kù)時(shí)，需要將該項(xiàng)的值設(shè)置為

org.quartz.impl.jdbcjobstore.PostgreSQLDelegat

集群部署產(chǎn)生行鎖的解決方案
當(dāng)多個(gè)weblogic節(jié)點(diǎn)發(fā)布時(shí)，定時(shí)框架采用的是SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE獲取鎖的形式，當(dāng)能鎖住記錄則執(zhí)行定時(shí)任務(wù)。多個(gè)節(jié)點(diǎn)執(zhí)行會(huì)產(chǎn)生大量的行鎖。為了解決這個(gè)問(wèn)題SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE NOWAIT ，可以解決鎖的問(wèn)題，但會(huì)導(dǎo)致任務(wù)出錯(cuò)退出。最后通過(guò)SELECT * FROM {0}LOCKS UPDLOCK WHERE SCHED_NAME = {1} AND LOCK_NAME = ? FOR UPDATE SKIP LOCKED 可完美解決。

最終配置如下：

quartz:properties:org:quartz:scheduler:#實(shí)例名稱，缺省QuartzSchedulerinstanceName: myScheduler instanceId: AUTOjobStore:class: org.quartz.impl.jdbcjobstore.JobStoreTX# Driver代理driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate#表前綴tablePrefix: QRTZ_ isClustered: falseclusterCheckinInterval: 10000useProperties: false######################################################################在LOCKS表中選擇一行，然后在這一行放一把鎖。默認(rèn)為“SELECT * FROM #{0}LOCKS WHERE SCHED_NAME ={1} AND LOCK_NAME = ? FOR UPDATE”，#這對(duì)于大多數(shù)數(shù)據(jù)庫(kù)都適用。“{0}”由上面的配置的TABLE_PREFIX在運(yùn)行#時(shí)替換，而“{1}”由scheduler的名字替換。#####################################################################selectWithLockSQL : SELECT * FROM {0}LOCKS UPDLOCK WHERE SCHED_NAME = {1} AND LOCK_NAME = ? FOR UPDATE SKIP LOCKEDthreadPool:class: org.quartz.simpl.SimpleThreadPoolthreadCount: 10threadPriority: 5threadsInheritContextClassLoaderOfInitializingThread: truejob-store-type: jdbc

總結(jié)

以上是生活随笔為你收集整理的瀚高数据库适配定时框架Quartz的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。