HJ 719-2014 环境信息系统数据库访问接口规范.pdf

1、中华人民共和国国家环境保护标准 HJ 7192014 环境信息系统数据库访问 接口规范 Specification for database access interface of environmental information system 2014-12-25发布 2015-03-01实施 环 境 保 护 部 发 布 HJ 7192014 i 中华人民共和国环境保护部 公 告 2014年 第87号 为贯彻中华人民共和国环境保护法，规范环境信息化工作，现批准环境信息共享互联互通平 台总体框架技术规范等十二项标准为国家环境保护标准，并予发布。 标准名称、编号如下： 一、环境信息共享互联互通

2、平台总体框架技术规范（HJ 7182014）； 二、环境信息系统数据库访问接口规范（HJ 7192014）； 三、环境信息元数据规范（HJ 7202014）； 四、环境数据集加工汇交流程（HJ 7212014）； 五、环境数据集说明文档格式（HJ 7222014）； 六、环境信息数据字典规范（HJ 7232014）； 七、环境基础空间数据加工处理技术规范（HJ 7242014）； 八、环境信息网络验收规范（HJ 7252014）； 九、环境空间数据交换技术规范（HJ 7262014）； 十、环境信息交换技术规范（HJ 7272014）； 十一、环境信息系统测试与验收规范软件部分（HJ 7282

3、014）； 十二、环境信息系统安全技术规范（HJ 7292014）。 以上标准自 2015 年 3 月 1 日起实施，由中国环境出版社出版，标准内容可登录环境保护部网站 （）查询。 特此公告。 环境保护部 2014年12月25日 HJ 7192014 ii HJ 7192014 iii 目 次 前 言.iv 1 适用范围.1 2 术语和定义.1 3 数据库访问接口框架.2 4 数据库访问接口方式.2 5 环境信息系统数据库访问接口推荐访问方式.6 6 数据库访问条件.7 附录A（资料性附录） 触发器方式数据库接口的SQL脚本（Microsoft SQL Server）.8 附录B（资料性附录）

4、 触发器方式数据库接口的SQL脚本（Oracle）.12 附录C（资料性附录） 时间戳方式数据库接口的SQL脚本（Microsoft SQL Server）.15 附录D（资料性附录） 时间戳方式数据库接口的SQL脚本（Oracle）.16 附录E（资料性附录） 环境信息系统数据库访问示例.17 HJ 7192014 iv 前 言 为贯彻中华人民共和国环境保护法，促进环境信息化工作，明确关系型数据库的访问接口，推 动环境信息资源建设，制定本标准。 本标准规定了环境信息系统中关系型数据库的访问接口，确定了数据库访问接口的基本架构以及数 据库访问接口方式、数据库访问工作流程。 本标准附录A、附录B

5、、附录C、附录D、附录E为资料性附录。 本标准为首次发布。 本标准由环境保护部科技标准司组织制订。 本标准主要起草单位：环境保护部信息中心、深圳市环境保护宣传教育信息中心。 本标准由环境保护部2014年12月25日批准。 本标准自2015年3月1日起实施。 本标准由环境保护部解释。 HJ 7192014 1 环境信息系统数据库访问接口规范 1 适用范围 本标准规定了环境信息系统中关系型数据库的访问接口，确定了数据库访问接口的基本架构以及数 据库访问接口方式、数据库访问工作流程。 本标准适用于同一局域网内的数据库访问，以及环境信息系统的关系型数据库访问接口的建设。 2 术语和定义 下列术语和定义

6、适用于本标准。 2.1 环境信息 environmental information 环境管理、环境科学、环境技术、环境保护产业等与环境保护相关的数据、指令和信号等，以及其 相关动态变化信息；包括文字、数字、符号、图形、图像、影像和声音等各种表达形式。 2.2 数据库 database 按照概念结构组织的数据的汇集，它描述这些数据的特征及与数据对应的实体间的关系，并支持一 个或多个应用领域。 2.3 数据库适配器 database adapter 按指定要求和标准规范进行数据库访问的功能组件，通过对配置文件的解析和处理，完成数据库访 问，实现数据采集和交换。 2.4 数据库访问接口 datab

7、ase access interface 嵌入各环保业务数据库中、专门针对外部应用访问所做的配置。数据库访问接口与适配器相适应， 能够实现外部应用对环保业务数据库内容的访问。 2.5 存储过程 stored procedure 一组为了完成特定功能的SQL（Structured Query Language）语句集合，经编译后存储在数据库中。 2.6 触发器 trigger 特殊的存储过程，它的执行只由事件触发，如对一个数据库表进行插入、删除、更新操作（insert， delete，update）时激活它执行。 2.7 时间戳 timestamp 指明时间上相对于通用时标、精确到秒级的某一时间

8、点的数据项。 HJ 7192014 2 3 数据库访问接口框架 在环境信息系统数据管理中，数据库访问接口用于获取同域内的各个业务应用的数据库内容。对各 个业务系统提供的数据库访问接口统一规定，便于其他业务应用系统出于数据传输或数据集成的目的进 行数据库访问。 环境信息系统数据库访问接口框架见图1。 图1 环境信息系统数据库访问接口框架 环境信息系统数据库访问者通过数据库访问接口访问不同的环境信息系统数据库。数据库访问者与 嵌入在环境信息系统数据库中的数据库访问接口进行交互，获取环境业务应用数据库的内容。 4 数据库访问接口方式 4.1 数据库视图方式 在实际业务中，对环境信息系统数据库进行访问

9、，需定制数据与其访问需求有关的数据内容，同时 须保证被访问的原始业务数据的安全性。 数据库视图是从一个或几个基本表中根据用户需要而制作的虚拟表，能够为数据提供一定的逻辑独 立性，其数据内容可以随着基表的更新而更新。同时，用户对视图不能随意更改和删除，可以保证数据 的安全性。 故对环境信息系统的数据库进行全库访问时，可采用数据库视图的访问接口方式。 4.1.1 接口方式描述 根据访问者的访问需要，在环境信息系统数据库中分别创建数据库视图，并对视图赋予相应访问权限。 4.1.2 接口配置方式 使用环境信息系统数据库标准的创建视图语句。 HJ 7192014 3 4.1.3 工作流程 数据库视图工作

10、方式见图2。 图2 数据库视图工作方式 a）将环境信息系统数据表的数据内容根据访问者需要，通过数据库视图创建命令创建相应的数据库视图； b）访问者根据需要访问数据库视图获取所需要的环境信息系统数据。 4.2 触发器方式 4.2.1 接口方式描述 触发器方式是指在源数据库的业务应用数据表中添加触发器，监控数据表的新增、修改、删除操作。 当操作成功时，触发相应的触发器将该记录的主键等信息插入指定的访问接口中间表，然后数据库访问 者从访问接口中间表中获得业务数据内容的变更情况，从而达到实时的数据库增量访问效果。 4.2.2 接口配置方式 a）在被访问的环境信息系统数据库中建立一张访问接口中间表，用于

11、存放相关触发器和临时交换 记录。不同的环境信息系统临时交换记录都采用统一的中间表格式，具体包括： T_Oth_Msg b）创建一个对访问接口中间表做操作的存储过程，用于执行相关的触发操作，具体包括： P_QueueMsg c）针对要实时访问的数据表建立新增和修改、删除的触发器，用于触发操作，具体包括： TR_AddTrigger_I TR_UpdateTrigger_U TR_DeleteTrigger_D 由于触发器方式只是对业务应用数据表进行操作监控，且只对访问接口中间表进行操作，因此不会 对被监控的业务应用数据表造成任何影响。 中间表的格式内容和存储过程参见附录A、附录B。 4.2.3

12、工作流程 环境信息系统数据库的实时访问是指当业务应用数据内容发生变化（包括新增、更新、删除等操作） 时，实时地触发数据库访问者，对业务应用数据库内容进行访问，实时获取业务数据的变化情况。 环境信息系统数据库的实时访问采用触发器方式的数据库访问接口，具体流程见图3。 HJ 7192014 4 图3 数据库触发器访问流程 a）信息系统数据表的内容在执行相关操作的时候，通过触发器将受影响的记录直接推送到数据 库访问接口的中间表中。如果受影响记录的字段数未超过中间表的字段数，则将受影响记录的所有信 息推送。 b）数据库访问者从访问接口中间表中获得业务数据内容的变更情况。 c）当受影响的记录字段数超过中

13、间表的字段数时，仅将受影响记录的主键等唯一标识信息推送到 中间表。数据库访问者也可以根据中间表中的数据内容，直接访问业务应用数据表，获得业务应用数据 内容。 4.3 时间戳方式 4.3.1 接口方式描述 时间戳方式是指在数据表中配置时间字段，定时轮询数据库是否发生新增或更新的操作，以达到数 据增量同步的作用。采用时间戳方式的数据库访问者将上次执行的时间与当前数据表中的时间字段进行 比较，甄别在上一时间周期内发生了新增或更新操作的数据库记录，从而达到访问数据的目的。 4.3.2 接口配置方式 a）在被访问的环境信息系统数据表中，创建用于比较的时间戳字段：Create_Time、Update_Ti

14、me。 b）每个被访问的环境信息系统数据表都必须有两个用于轮询的时间字段作为时间戳。一个用于记 录创建时间，另一个用于记录修改时间：Create_Time、Update_Time。时间戳字段的数据类型为业务应 用数据库的时间类型，格式必须为：年月日 时分秒（例如：2009-8-20 12：00：00）。 每 次 查询数据表时，对表中所有的数据按时间进行遍历查询，取出最新的记录。这样，如果源数据 库中数据过多，进行定时轮询时就会对交换的性能造成影响。 填入时间戳的方式有多种，如通过数据库结构化查询语句（Structure Query Language）填入值、触 发器方式自动填入值等。建议采取建

15、立触发器方式，自动获取当前操作时间并填入到对应的字段中。 时间戳触发器编写方式参见附录C、附录D。 4.3.3 工作流程 环境信息系统数据库的定时访问是指数据库访问者按照预定的时间周期，定时访问环境信息系统数 据库，并根据系统数据表的时间戳，获取上一时间周期里的环境信息系统数据库所发生的变化内容（包 HJ 7192014 5 括新增、更新、删除等操作）。 环境信息系统数据库的定时访问通常采用时间戳方式的数据库访问接口。具体流程见图4。 图4 数据库时间戳定时访问流程 a）业务应用数据表在新增、更新的同时，更新时间戳字段的内容； b）数据库访问者定时访问业务应用数据表，根据时间戳字段所记录的新增

16、和更新时间戳，获取上 个时间周期里的业务应用数据库的变化内容。 4.4 应用服务接口方式 专用于应用层面数据库访问，建议采用在线应用服务（webservice）接口方式。 4.4.1 接口方式描述 通过在线应用服务接口对环境信息数据库中数据进行访问，从而获取所需要的信息。 4.4.2 接口配置方式 被访问的环境信息系统根据访问者需要，专门开发一套只用于当前环境信息系统访问的在线应用服 务软件。 开发的应用服务软件安装在访问者可访问到的运行环境中。 4.4.3 工作流程 应用服务接口方式见图5。 图5 应用服务接口工作方式 HJ 7192014 6 a）访问者在访问环境信息系统数据库中数据时，调

17、用在线应用服务接口； b）应用服务接口根据应用者要求，访问信息系统数据，并将访问结果反馈给访问者。 5 环境信息系统数据库访问接口推荐访问方式 环境信息系统数据库访问按照访问的环境信息数据内容可分为全部环境信息数据访问和增量环境 信息数据访问。全部环境信息数据访问建议采用数据库视图的接口方式，增量环境信息数据访问建议采 用触发器和时间戳的接口方式。 数据库访问方式参见附录E。 在应用层面数据库访问方式中，建议采用应用服务接口方式。 不同的环境信息系统采取不同的数据库体系，本规范针对部分主要环境信息系统关系型数据库访问 方式进行说明。具体推荐方案见表1。 表1 环境信息系统推荐数据库访问方式 序

18、号 类型 环境信息系统 推荐访问方式 实时数据 触发器 河流水质自动监测 历史数据 时间戳 实时数据 触发器 空气质量自动监测 历史数据 时间戳 实时数据 触发器 饮用水水源自动监测 历史数据 时间戳 实时数据 触发器 污染源在线监控 历史数据 时间戳 实时数据 触发器 机动车尾气自动检测 历史数据 时间戳 实时数据 触发器 辐射环境监控 历史数据 时间戳 实时数据 触发器 危险废弃物在线监控 历史数据 时间戳 1 自动监控类 其他 建设项目管理 应用服务接口 排污许可证管理 时间戳 排污收费管理 时间戳 环保移动执法管理 时间戳 环境信访投诉管理 应用服务接口 行政处罚管理 应用服务接口 公

19、文文件管理 触发器 2 业务管理类 其他 环境统计 数据库视图 全国城市环境综合整治定量考核 数据库视图 污染源普查 数据库视图 3 统计考核类 其他 HJ 7192014 7 6 数据库访问条件 对某一数据库进行访问时，在网络连通的情况下，需具备以下条件： a）获取数据库管理系统（DBMS）类型； b）获取被访问的数据库所在服务器的网络地址； c）获取被访问的数据库的实例名； d）获取数据库的用户名及口令。 HJ 7192014 8 附 录 A （资料性附录） 触发器方式数据库接口的SQL脚本（Microsoft SQL Server） A.1 触发器方式数据库接口的中间表创建脚本 CREA

20、TE TABLE dbo.T_Oth_Msg（ PK_MsgId numeric（28,0） IDENTITY（1,1） NOT NULL， MsgQueuedAt datetime NOT NULL， MsgStatus varchar（10） COLLATE Chinese_PRC_CI_AS NOT NULL， MsgDeliveredAt datetime NULL， MsgFailedText varchar（255） COLLATE Chinese_PRC_CI_AS NULL， OperationType varchar（10） COLLATE Chinese_PRC_CI_AS

21、 NULL， MsgParam1 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam2 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam3 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam4 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam5 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam6 varchar（

22、255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam7 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam8 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam9 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， MsgParam10 varchar（255） COLLATE Chinese_PRC_CI_AS NULL， ） ON PRIMARY GO 表字段说明见表A.1。 表A.1 字段说明表 字段名

23、 字段中文名 应用意义 PK_MsgId 临时记录id 中间表的主键 MsgQueuedAt 临时记录推送的时间 临时记录从中间表中推送的时间 MsgStatus 临时记录的状态 标识临时记录是否为待推送的信息 MsgDeliveredAt 临时记录推送到目的地的时间 临时记录推送到目的地的时间 MsgFailedText 临时记录推送失败的提示信息 临时记录推送失败的详细信息 OperationType 临时记录的操作类型 临时记录在业务数据表中执行的操作（新增、更新、删除） MsgParam1 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam2 临时记录信息 临

24、时记录的具体信息，来源于存储过程中的参数值 MsgParam3 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 HJ 7192014 9 续表 字段名 字段中文名 应用意义 MsgParam4 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam5 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam6 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam7 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam8 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgPara

25、m9 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam10 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 A.2 触发器方式数据库接口的存储过程脚本 create proc dbo.P_Trigger_业务应用数据表名 OperationType varchar（10）， MsgParam1 varchar（255） = NULL， MsgParam2 varchar（255） = NULL， MsgParam3 varchar（255） = NULL， MsgParam4 varchar（255） = NULL， MsgParam5 varchar（

26、255） = NULL， MsgParam6 varchar（255） = NULL， MsgParam7 varchar（255） = NULL， MsgParam8 varchar（255） = NULL， MsgParam9 varchar（255） = NULL， MsgParam10 varchar（255） = NULL as BEGIN declare ErrorCode int，ErrorMessage varchar（255）， NumRows int select ErrorCode = 0 insert T_Oth_Msg（MsgQueuedAt，MsgStatus，Ms

27、gDeliveredAt，MsgFailedText，OperationType， MsgParam1，MsgParam2，MsgParam3，MsgParam4，MsgParam5，MsgParam6，MsgParam7，MsgParam8， MsgParam9，MsgParam10） select getdate()，NEW，NULL，NULL，OperationType，MsgParam1， MsgParam2，MsgParam3，MsgParam4，MsgParam5，MsgParam6，MsgParam7，MsgParam8， MsgParam9，MsgParam10 select

28、ErrorCode = error，NumRows = rowcount return ErrorCode END GO 存储过程参数设置说明见表A.2。 表A.2 存储过程参数表 参数名 参数含义 MsgQueuedAt 临时记录从中间表中推送的时间 MsgStatus 标识临时记录是否为待推送的信息 HJ 7192014 10 续表 参数名 参数含义 MsgDeliveredAt 临时记录推送到目的地的时间 MsgFailedText 临时记录推送失败的详细信息 OperationType 临时记录在业务数据表中执行的操作（新增、更新、删除） MsgParam1 业务数据表中受影响记录的具

29、体信息 MsgParam2 业务数据表中受影响记录的具体信息 MsgParam3 业务数据表中受影响记录的具体信息 MsgParam4 业务数据表中受影响记录的具体信息 MsgParam5 业务数据表中受影响记录的具体信息 MsgParam6 业务数据表中受影响记录的具体信息 MsgParam7 业务数据表中受影响记录的具体信息 MsgParam8 业务数据表中受影响记录的具体信息 MsgParam9 业务数据表中受影响记录的具体信息 MsgParam10 业务数据表中受影响记录的具体信息 A.3 触发器方式数据库接口的触发器脚本 CREATE TRIGGER TR_业务应用数据表名_I ON

30、 dbo.业务应用数据表名 FOR insert AS BEGIN declare 表字段1，表字段2，表字段3 declare cursor_insert cursor for select 表主键 from inserted open cursor_insert fetch cursor_insert into 表字段1，表字段2，表字段3 while fetch_status=0 BEGIN exec P_Trigger_业务应用数据表名OperationType =insert，MsgParam1= 表字段1， MsgParam2= 表字段2，MsgParam3= 表字段3 fetch

31、 cursor_insert into 表字段1，表字段2，表字段3 END close cursor_insert deallocate cursor_insert END GO CREATE TRIGGER TR_业务应用数据表名_U ON dbo.表名 FOR update AS BEGIN declare 表字段1，表字段2，表字段3 declare cursor_insert cursor for select 表主键 from inserted open cursor_insert fetch cursor_insert into 表字段1，表字段2，表字段3 while fetc

32、h_status=0 HJ 7192014 11 BEGIN exec P_Trigger_业务应用数据表名 OperationType =update，MsgParam1= 表字段1， MsgParam2= 表字段2，MsgParam3= 表字段3 fetch cursor_insert into 表字段1，表字段2，表字段3 END close cursor_insert deallocate cursor_insert END GO CREATE TRIGGER TR_业务应用数据表名_D ON dbo.表名 FOR delete AS BEGIN declare 表字段1，表字段2，表

33、字段3 declare cursor_insert cursor for select 表主键 from deleted open cursor_insert fetch cursor_insert into 表字段1，表字段2，表字段3 while fetch_status=0 BEGIN exec P_Trigger_业务应用数据表名 OperationTypeName = delete，MsgParam1= 表字段1， MsgParam2= 表字段2，MsgParam3= 表字段3 fetch cursor_insert into 表字段1，表字段2，表字段3 END close cur

34、sor_insert deallocate cursor_insert END 触发器参数设置说明： 触发器中使用的参数与存储过程、中间表中使用的字段含义一致。 触发器方式的数据库访问接口由中间表、存储过程、触发器之间相互配合完成，具体流程为： 由触发器对业务数据表进行实时监控。当业务数据表有变化时，对应的触发器对发生的变化进行捕 获，并调用相应的存储过程，将发生的变化信息存储到中间表中。 HJ 7192014 12 附 录 B （资料性附录） 触发器方式数据库接口的SQL脚本（Oracle） B.1 触发器方式数据库接口的中间表创建脚本 drop table T_Oth_Msg cascad

35、e constraints； create table T_Oth_Msg （ PK_MsgId bigint not null， MsgQueuedAt datetime， MsgStatus varchar（10）， MsgDeliveredAt datetime NULL， MsgFailedText varchar（255） NULL， OperationType varchar（10） NULL， MsgParam1 varchar（255） NULL， MsgParam2 varchar（255） NULL， MsgParam3 varchar（255） NULL， MsgPara

36、m4 varchar（255） NULL， MsgParam5 varchar（255） NULL， MsgParam6 varchar（255） NULL， MsgParam7 varchar（255） NULL， MsgParam8 varchar（255） NULL， MsgParam9 varchar（255） NULL， MsgParam10 varchar（255） NULL， constraint PK_T_OTH_MSG primary key（PK_MsgId） ）； create sequence seq_t_oth_msg minvalue 1000 maxvalue 9

37、9999999 start with 1000 increment by 1 nocache； 表字段说明见表B.1。 表B.1 字段说明表 字段名 字段中文名 应用意义 PK_MsgId 临时记录id 中间表的主键 MsgQueuedAt 临时记录推送的时间 临时记录从中间表中推送的时间 MsgStatus 临时记录的状态 标识临时记录是否为待推送的信息 MsgDeliveredAt 临时记录推送到目的地的时间 临时记录推送到目的地的时间 MsgFailedText 临时记录推送失败的提示信息 临时记录推送失败的详细信息 OperationType 临时记录的操作类型 临时记录在业务数据表中

38、执行的操作（新增、更新、删除） MsgParam1 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 HJ 7192014 13 续表 字段名 字段中文名 应用意义 MsgParam2 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam3 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam4 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam5 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam6 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam7 临时

39、记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam8 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam9 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 MsgParam10 临时记录信息 临时记录的具体信息，来源于存储过程中的参数值 B.2 触发器方式数据库接口的存储过程脚本 create or replace procedure P_QueueMsg_业务应用数据表名（ OperateType in varchar2， MsgParam1 in varchar2， MsgParam2 in varchar2， MsgParam3

40、 in varchar2， MsgParam4 in varchar2， MsgParam5 in varchar2， MsgParam6 in varchar2， MsgParam7 in varchar2， MsgParam8 in varchar2， MsgParam9 in varchar2， MsgParam10 in varchar2 ） as begin insert into T_Oth_Msg（PK_MsgId，MsgQueuedAt，MsgStatus，MsgDeliveredAt，MsgFailedText， OperationType，MsgParam1，MsgPara

41、m2，MsgParam3，MsgParam4，MsgParam5，MsgParam6，MsgParam7， MsgParam8，MsgParam9，MsgParam10） values（seq_t_oth_msg.nextval，sysdate，NEW，NULL，NULL，OperationType，MsgParam1， MsgParam2，MsgParam3，MsgParam4，MsgParam5，MsgParam6，MsgParam7，MsgParam8，MsgParam9， MsgParam10）； end P_Trigger_业务应用数据表名； 存储过程参数设置说明见表B.2。 表B.

42、2 存储过程参数设置说明 参数名 参数含义 MsgQueuedAt 临时记录从中间表中推送的时间 MsgStatus 标识临时记录是否为待推送的信息 HJ 7192014 14 续表 参数名 参数含义 MsgDeliveredAt 临时记录推送到目的地的时间 MsgFailedText 临时记录推送失败的详细信息 OperationType 临时记录在业务数据表中执行的操作（新增、更新、删除） MsgParam1 业务数据表中受影响记录的具体信息 MsgParam2 业务数据表中受影响记录的具体信息 MsgParam3 业务数据表中受影响记录的具体信息 MsgParam4 业务数据表中受影响记

43、录的具体信息 MsgParam5 业务数据表中受影响记录的具体信息 MsgParam6 业务数据表中受影响记录的具体信息 MsgParam7 业务数据表中受影响记录的具体信息 MsgParam8 业务数据表中受影响记录的具体信息 MsgParam9 业务数据表中受影响记录的具体信息 MsgParam10 业务数据表中受影响记录的具体信息 B.3 触发器方式数据库接口的触发器脚本 create or replace trigger 触发器名 before insert|update|delete on 业务应用数据表名 for each row begin P_QueueMsg_业务应用数据表名

44、（insert|update|delete，表字段1，表字段2，.）； end 触发器参数设置说明： 触发器中使用的参数与存储过程、中间表中使用的字段含义一致。 触发器方式的数据库访问接口由中间表、存储过程、触发器之间相互配合完成，具体流程为： 由触发器对业务数据表进行实时监控。当业务数据表有变化时，对应的触发器对发生的变化进行捕 获，并调用相应的存储过程，将发生的变化信息存储到中间表中。 HJ 7192014 15 附 录 C （资料性附录） 时间戳方式数据库接口的SQL脚本（Microsoft SQL Server） 时间戳方式数据库接口的触发器脚本。 CREATE TRIGGER 触发器

45、名 ON 表名 FOR INSERT | UPDATE AS Update 表名 set create_time | update_time =getdate()； 触发器参数设置说明见表C.1。 表C.1 触发器参数表 参数名 参数中文名 应用意义 create_time 业务数据的创建时间 业务数据表中的字段，用于记录表中数据的创建时间 update_time 业务数据的更新时间 业务数据表中的字段，用于记录表中数据的更新时间 时间戳方式数据库接口的触发器工作流程为： 触发器对业务数据表进行实时监控，当业务数据表有变化时，触发该触发器对发生变化的时间进行 记录，并插入对应的业务数据表时间字段中。 HJ 7192014 16 附 录 D （资料性附录） 时