標準分享吧中華人民共和國國家環(huán)境保護標準HJ719-2014Specificationfordatabaseaccessinterfaceofenvironmentinformationsystem（發(fā)布稿）2014-12-25發(fā)布2015-03-01實施 1 1 1 2 6 7 8 13 19I本標準規(guī)定了環(huán)境信息系統(tǒng)中關系型數據庫的訪問接口，確定了數據庫訪問接口的基本本標準規(guī)定了環(huán)境信息系統(tǒng)中關系型數據庫的訪問接口，確定了數據庫訪問接口的基本本標準適用于同一局域網內的數據庫訪問，以及環(huán)境信息系統(tǒng)的關系型數據庫訪問接口2.1環(huán)境信息environment環(huán)境管理、環(huán)境科學、環(huán)境技術、環(huán)境保護產業(yè)等與環(huán)境保護相關的數據、指令和信號等，以及其相關動態(tài)變化信息；包括文字、數字、符號、圖形、圖像、影像和聲音等各種表按指定要求和標準規(guī)范進行數據庫訪問的功能組件，通過對配置文件的解析和處理，完2.4數據庫訪問接口database嵌入各環(huán)保業(yè)務數據庫中、專門針對外部應用訪問所做的配置。數據庫訪問接口與適配一組為了完成特定功能的SQL（StructuredQueryLangua特殊的存儲過程，它的執(zhí)行只由事件觸發(fā)，如對一個數據庫表進行插入、刪除、更新操在環(huán)境信息系統(tǒng)數據管理中，數據庫訪問接口用于獲取同域內的各個業(yè)務應用的數據庫內容。對各個業(yè)務系統(tǒng)提供的數據庫訪問接口統(tǒng)一規(guī)定，便于其他業(yè)務應用系統(tǒng)出于數據傳1標準分享吧其他環(huán)保環(huán)境信息系統(tǒng)數據庫訪問者通過數據庫訪問接口訪問不同的環(huán)境信息系統(tǒng)數據庫。數據庫訪問者與嵌入在環(huán)境信息系統(tǒng)數據庫中的數據庫訪問接口進行交互，獲取環(huán)境業(yè)務應用數在實際業(yè)務中，對環(huán)境信息系統(tǒng)數據庫進行訪問，需定制數據與其訪問需求有關的數據數據庫視圖是從一個或幾個基本表中根據用戶需要而制作的虛擬表，能夠為數據提供一定的邏輯獨立性，其數據內容可以隨著基表的更新而更新。同時，用戶對視圖不能隨意更改根據訪問者的訪問需要，在環(huán)境信息系統(tǒng)數據庫中分別創(chuàng)建數據庫視圖，并對視圖賦予2b)數據庫視b)數據庫視訪問者信息系統(tǒng)信息系統(tǒng)數據表a)a）將環(huán)境信息系統(tǒng)數據表的數據內容根據訪問者刪除操作。當操作成功時，觸發(fā)相應的觸發(fā)器將該記錄的主鍵等信息插入到指定的訪問接口中間表，然后數據庫訪問者從訪問接口中間表中獲得業(yè)務數據內容的變更情況，從而達到實a)在被訪問的環(huán)境信息系統(tǒng)數據庫中建立一張訪問接口中間表，用于存放相關觸發(fā)器和臨時交換記錄。不同的環(huán)境信息系統(tǒng)臨時交換記錄都采用統(tǒng)一的中間表格式，具b)創(chuàng)建一個對訪問接口中間表做操作的存儲過程，用于執(zhí)行相關的觸發(fā)操作，具體包c)針對要實時訪問的數據表建立新增和修改、刪除的觸發(fā)器，用于觸發(fā)操作，具體包3環(huán)境信息系統(tǒng)數據庫的實時訪問是指當業(yè)務應用數據內容發(fā)生變化（包括新增、更新、刪除等操作）時，實時地觸發(fā)數據庫訪問者，對業(yè)務應用數據庫內容進行訪問，實時獲取業(yè)b中間環(huán)境信息系統(tǒng)數C)b中間環(huán)境信息系統(tǒng)數C)訪問A)數據數據a)信息系統(tǒng)數據表的內容在執(zhí)行相關操作的時候，通過觸發(fā)器將受影響的記錄直接推c)當受影響的記錄字段數超過中間表的字段數時，僅將受影響記錄的主鍵等唯一標識信息推送到中間表。數據庫訪問者也可以根據中間表中的數據內容，直接訪問業(yè)務以達到數據增量同步的作用。采用時間戳方式的數據庫訪問者將上次執(zhí)行的時間與當前數據表中的時間字段進行比較，甄別在上一時間周期內發(fā)生了新增或更新操作的數據庫記錄，從a)在被訪問的環(huán)境信息系統(tǒng)數據表中，創(chuàng)建用于比較的時間戳字段：Create_Time、b)每個被訪問的環(huán)境信息系統(tǒng)數據表都必須有兩個用于輪詢的時間字段作為時間戳。一個用于記錄創(chuàng)建時間，另一個用于記錄修改時間：Create_Time、Update_Time。4每次查詢數據表時，對表中所有的數據按時間進行遍歷查詢，取出最新的記錄。這樣，填入時間戳的方式有多種，如通過數據庫結構化查詢語句填入值、觸發(fā)器方式自動填入值等。建議采取建立觸發(fā)器方式，自動獲取當前操作時間并填環(huán)境信息系統(tǒng)數據庫的定時訪問是指數據庫訪問者按照預定的時間周期，定時訪問環(huán)境信息系統(tǒng)數據庫，并根據系統(tǒng)數據表的時間戳，獲取上一時間周期里的環(huán)境信息系統(tǒng)數據庫環(huán)境信息系統(tǒng)數據庫的定時訪問通常采用時間戳方式的數據庫訪問接口。具體流程見圖▲b)a)時間翟沒業(yè)務應i用環(huán)境信息系統(tǒng)數據庫b)a)時間翟沒業(yè)務應i用環(huán)境信息系統(tǒng)數據庫b)數據庫訪問者定時訪問業(yè)務應用數據表，根據時間戳字段所記錄的新增和更新時間被訪問的環(huán)境信息系統(tǒng)根據訪問者需要，專門開發(fā)一套只用于當前環(huán)境信息系統(tǒng)訪問的5訪問a)訪問a)b)環(huán)境信息系統(tǒng)數據庫環(huán)境信息系統(tǒng)數據庫訪問按照訪問的環(huán)境信息數據內容可分為全部數據訪問和增量數據訪問。全部環(huán)境信息數據訪問建議采用數據庫視圖的接口方式，增量環(huán)境信息數據訪問建議162378A.1觸發(fā)器方式數據庫接口的中間表創(chuàng)建腳本9A.2觸發(fā)器方式數據庫接口的存儲過程腳本declare@ErrorCodeint,@ErrorMessagevarchar(255),@NumRowinsertT_Oth_Msg(MsgQueuedAt,MsgStatus,MMsgFailedText,OperationType,MsgParam1,MsgParam2,MsgParam3,MsgParam6,MsgParam7,MsgParam8,MsgParam9,MsgParam10)selectgetdate(),'NEW',NULL,NULL,@OperationType,@MsgParam1,@MsgParam2,@MsgParam5,@MsgParam6,@MsgParam7,@MsgParam8,@MsgParam9,@Msselect@ErrorCode=@@erroA.3觸發(fā)器方式數據庫接口的觸發(fā)器腳本declarecursor_insertcurwhile@@fetch_statusexecP_Trigger_業(yè)務應用數據表名@Operationdeclarecursor_insertcurwhile@@fetch_statusexecP_Trigger_業(yè)務應用數據declarecursor_insertcursorwhile@@fetch_status觸發(fā)器方式的數據庫訪問接口由中間表、存儲過程、觸發(fā)器之間相互配合完成，具體流由觸發(fā)器對業(yè)務數據表進行實時監(jiān)控。當業(yè)務數據表有變化時，對應的觸發(fā)器對發(fā)生的B.1觸發(fā)器方式數據庫接口的中間表創(chuàng)建腳本droptable"T_Oth_Msg""PK_MsgId"bi"MsgQueuedAt""MsgStatus""MsgParam1"varchar"MsgParam2"varchar"MsgParam3"varchar"MsgParam4"varchar"MsgParam5"varchar"MsgParam6"varchar"MsgParam7"varchar"MsgParam8"varchar"MsgParam9"varchar"MsgParam10"varcharconstraintPK_T_OTH_MSGprimarykey("PB.2觸發(fā)器方式數據庫接口的存儲過程腳本createorreplaceprocedureP_QueueMsg_業(yè)務應用數據表名(begininsertintoT_Oth_Msg(PK_MsgId,MsgQueuedAt,MsgStatus,MsgDeliveredAMsgFailedText,OperationType,MsgParam1,MsgParam2,MsgParam3,MsgParam6,MsgParam7,MsgParam8,MsgParam9,MsgParam10)values(seqtoth_msg.nextval,sysdate,'NEW'MsgParam2,MsgParam3,MsgParam4,MsgParam5,MsgParam6,MsgMsgParam9,MsgParam10);B.3觸發(fā)器方式數據庫接口的觸發(fā)器腳本createorreplacetriggbefore[insert|update|dbeginP_QueueMsg_業(yè)務應用數據表名(['insert'|觸發(fā)器方式的數據庫訪問接口由中間表、存儲過程、觸發(fā)器之間相互配合完成，具體流由觸發(fā)器對業(yè)務數據表進行實時監(jiān)控。當業(yè)務數據表有變化時，對應的觸發(fā)器對發(fā)生的ASUpdate表名set[creupdate_time觸發(fā)器對業(yè)務數據表進行實時監(jiān)控，當業(yè)務數據表有變化時，觸發(fā)該觸發(fā)器對發(fā)生變化createorreplacetriggbeginasupdate