ITPub博客

首页 > 数据库 > 国内数据库 > 瀚高数据库适配定时框架Quartz

瀚高数据库适配定时框架Quartz

原创 国内数据库 作者:瀚高PG实验室 时间:2022-10-25 16:46:51 0 删除 编辑

瀚高数据库

环境
系统平台: N/A
版本: 4.5
详细信息

更改HGDB脚本

应用系统在适配瀚高数据库时,数据库往往都是通过迁移工具从mysql或oracle迁移而来,迁移之后需要更改quartz所需的表结构,原因为,迁移后,源库的boolean类型的数据存储并没有改变,迁移之后为varchar(1),瀚高数据库支持boolean类型,需要将所需字段类型改为boolean,如若不然,需要加隐士转换将character varying 类型转为boolean存储。

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张表。需要注意的是,应用系统中在开发的时候,有时候会根据自己的喜好改了表名前缀,根据配置文件中tablePrefix的值,找到对应的表进行修改就可以。

需要更改的表字段为:

表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


替换驱动代理

在quartz的配置文件中,更改org.quartz.jobStore.driverDelegateClass,通过该配置项可设置不同数据库的“方言”。可能的选择包括:
org.quartz.impl.jdbcjobstore.StdJDBCDelegate(完全兼容JDBC的驱动)
org.quartz.impl.jdbcjobstore.MSSQLDelegate(Microsoft SQL Server和Sybase)
org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
org.quartz.impl.jdbcjobstore.WebLogicDelegate(WebLogic驱动)
org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
org.quartz.impl.jdbcjobstore.oracle.WebLogicOracleDelegate(Weblogic使用的Oracle驱动)
org.quartz.impl.jdbcjobstore.oracle.weblogic.WebLogicOracleDelegate(Weblogic使用的Oracle)
org.quartz.impl.jdbcjobstore.CloudscapeDelegate
org.quartz.impl.jdbcjobstore.DB2v6Delegate
org.quartz.impl.jdbcjobstore.DB2v7Delegate
org.quartz.impl.jdbcjobstore.DB2v8Delegate
org.quartz.impl.jdbcjobstore.HSQLDBDelegate
org.quartz.impl.jdbcjobstore.PointbaseDelegate
org.quartz.impl.jdbcjobstore.SybaseDelegate
适配瀚高数据库时,需要将该项的值设置为org.quartz.impl.jdbcjobstore.PostgreSQLDelegat

集群部署产生行锁的解决方案

当多个weblogic节点发布时,定时框架采用的是SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE获取锁的形式,当能锁住记录则执行定时任务。多个节点执行会产生大量的行锁。 为了解决这个问题SELECT * FROM SP_QRTZ_LOCKS WHERE LOCK_NAME = :1 FOR UPDATE NOWAIT ,可以解决锁的问题,但会导致任务出错退出。 最后通过SELECT * FROM {0}LOCKS UPDLOCK WHERE SCHED_NAME = {1} AND LOCK_NAME = ? FOR UPDATE SKIP LOCKED 可完美解决。

最终配置如下:



quartz:
  properties:
    org:
      quartz:
        scheduler:
          #实例名称,缺省QuartzScheduler
          instanceName: myScheduler 
          instanceId: AUTO
        jobStore:
          class: org.quartz.impl.jdbcjobstore.JobStoreTX
          # Driver代理
          driverDelegateClass: org.quartz.impl.jdbcjobstore.PostgreSQLDelegate
          #表前缀
          tablePrefix: QRTZ_  
          isClustered: false
          clusterCheckinInterval: 10000
          useProperties: false
          #####################################################################
          #在LOCKS表中选择一行,然后在这一行放一把锁。默认为“SELECT * FROM 
          #{0}LOCKS WHERE SCHED_NAME ={1} AND LOCK_NAME = ? FOR UPDATE”,
          #这对于大多数数据库都适用。“{0}”由上面的配置的TABLE_PREFIX在运行
          #时替换,而“{1}”由scheduler的名字替换。
          #####################################################################
          selectWithLockSQL : SELECT * FROM {0}LOCKS UPDLOCK WHERE SCHED_NAME = {1} AND LOCK_NAME = ? FOR UPDATE SKIP LOCKED
        threadPool:
          class: org.quartz.simpl.SimpleThreadPool
          threadCount: 10
          threadPriority: 5
          threadsInheritContextClassLoaderOfInitializingThread: true
    job-store-type: jdbc



来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/69994931/viewspace-2920232/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论
瀚高PG实验室(Highgo PG Lab)依托于瀚高DBA运维团队及瀚高数据库PG内核研发团队,旨在深入研究PostgreSQL技术、使用技巧、内核探秘、PG教学等,并进行分享。欢迎大家关注、交流。

注册时间:2021-02-18

  • 博文量
    184
  • 访问量
    126025