2020Datablau數(shù)據(jù)資產(chǎn)管理平臺用戶使用手冊-V5.0.2

Datablau數(shù)據(jù)資產(chǎn)管理平臺用戶使用手冊2021年02月數(shù)據(jù)資產(chǎn)管理平臺用戶使用手冊數(shù)據(jù)資產(chǎn)管理平臺用戶使用手冊PAGE100PAGE100目錄一、 引言 6編寫的 6讀者體 6內(nèi)容圍 6名詞釋 6參考檔 6編寫范 6二、 使用引 7產(chǎn)品述 7功能述 7登錄統(tǒng) 7三、 系統(tǒng)理 9用戶理 9添加戶 10編輯戶 11修改碼 11忘記碼 12禁用戶 13角色理 14添加色 15編輯色 18刪除色 19系統(tǒng)務 20查看務 21編輯務 21系統(tǒng)置 22郵件置 22參數(shù)表 23遠程務控 23同義列表 23控制板 24四、 數(shù)據(jù)準 25數(shù)據(jù)準 25添加據(jù)準 26導入據(jù)準 26導出據(jù)準 29標準核程 30廢棄據(jù)準 34刪除據(jù)準 36訂閱據(jù)準 37數(shù)據(jù)準標代碼 38數(shù)據(jù)準元據(jù)射 39數(shù)據(jù)準地 40標準碼 40添加準碼 40導入準碼 42導出準碼 43廢棄準碼 43刪除準碼 46命名典 46添加名典 47導入名典 48導出名典 49刪除名典 49指標系 50查看標 51導入標 52維度系 52添加度 52刪除度 52標準碼為度 52五、 元數(shù)據(jù) 52應用統(tǒng) 52添加統(tǒng) 53編輯統(tǒng) 54導入統(tǒng) 56搜索統(tǒng) 58刪除統(tǒng) 59系統(tǒng)用 60數(shù)據(jù)源 62添加據(jù)源 63離線產(chǎn)（OfflineDump） 64搜索據(jù)源 65刪除據(jù)源 66更新?lián)?67BI67永洪68IBMCognos 68元數(shù)據(jù) 69查看數(shù)據(jù) 70搜索數(shù)據(jù) 70導出數(shù)據(jù) 71元數(shù)與據(jù)準射 72血緣理 78導入緣件 78定時集緣件 81查看析果 82標簽理 83添加錄 83添加簽 84編輯/除簽 84標簽引信息 85六、 數(shù)據(jù)量 85駕駛艙 85業(yè)務則理 86添加務則 87導入務則 87導出務則 88編輯務則 88搜索務則 89刪除務則 89技術則理 90添加術則 90導入術則 91導出術規(guī)則 92編輯術則 92搜索術則 92刪除術則 92質量查務 93添加量查務 93編輯量查務 94搜索量查務 95刪除量查務 95查看務行果 95質量復務 96添加量復務 96編輯量復務 97搜索量復務 97查看下修任結果 97刪除量復務 98知識管理 98添加識條目 99編輯識條目 100刪除識條目 100七、 數(shù)據(jù)型 101設計型理 101模型索 101模型情 102基本息 1031.4 主題 106八、 數(shù)據(jù)求/據(jù)務 107數(shù)據(jù)求 107數(shù)據(jù)務 109九、 數(shù)據(jù)能 113業(yè)務性別 113業(yè)務性現(xiàn) 116十、 業(yè)務程 118業(yè)務程 118業(yè)務體 122十一、 數(shù)據(jù)全理 1231. 數(shù)據(jù)全 123十二、 數(shù)據(jù)錄 124目錄覽 124目錄理 124十三、 附錄 124公司介 124Groovy語樣例 125Groovy使實例 125參數(shù)關操作 133QuartZCron表135OfflineDump線產(chǎn)庫 136IBMDataStage出dsx和isx文件 145FAQ部分 146聯(lián)系們 147一、引言Datablau數(shù)據(jù)資產(chǎn)管理平）編寫目的atalau（DADatablau）讀者群體DAM內(nèi)容范圍 DAMDAM和《數(shù)語科技DAM名詞解釋名詞釋義Datablau北京數(shù)語科技有限公司DAMDataAssetManagement數(shù)據(jù)資產(chǎn)管理平臺參考文檔無編寫規(guī)范DaabluLOODBA注意注意二、使用指引產(chǎn)品概述DAMDAM功能概述依據(jù)不用的用戶權限，使用者能夠在本系統(tǒng)中完成以下工作：ER登錄系統(tǒng)（Chrom65DMURL，例如3/dam/login.jsp，即可進入DAM平臺的登錄入口界面。后，即可進入DAMDAM（1-1.3三、系統(tǒng)管理用戶管理DAM功能入口：操作角色：adminEmail用戶加功面動跳到戶表界并某用添成功DAM的示，擊取】按取編操跳回用列無示。DAMDAM注意：通過郵箱重置登錄的密碼的兩個前置條件： DAM DAM ，方可顯示點擊被禁用用戶后面的【啟用】按鈕，該用戶即可正常登錄DAM平臺。 注意：系統(tǒng)初始化后默認創(chuàng)建的admin 角色管理DAM功能入口：操作角色：點擊【角色管理】模塊頁面右上角的【添加】按鈕，即可進入角色添加頁面。 權限與DAM平臺的功能模塊息息相關，共包含以下19種：?超級系統(tǒng)運維管理（擁有除了數(shù)據(jù)源外的全部權限）?普通訪問瀏覽（可以登錄此系統(tǒng)，可以訪問公共資源，沒有編輯權限）?查看報表（能訪問報表）?管理數(shù)據(jù)標準（能創(chuàng)建和編輯數(shù)據(jù)標準相關內(nèi)容）?管理生產(chǎn)模型（能編輯數(shù)據(jù)資產(chǎn)相關內(nèi)容）?管理數(shù)據(jù)源（能創(chuàng)建和編輯數(shù)據(jù)源，以及創(chuàng)建檢查任務）?管理數(shù)據(jù)流轉（可以導入和編輯血緣關系）?管理業(yè)務質量規(guī)則（能創(chuàng)建和編輯業(yè)務質量規(guī)則）?管理技術質量規(guī)則（能創(chuàng)建和編輯數(shù)據(jù)質量規(guī)則）?查看質量檢查任務（能讀取質量檢查任務）?管理質量修復任務（能修改所屬系統(tǒng)的質量修復任務和下載結果）?查看質量修復任務（能讀取全部質量修復任務）數(shù)據(jù)標準瀏覽（）數(shù)據(jù)模型瀏覽（）元數(shù)據(jù)瀏覽）數(shù)據(jù)質量瀏覽（）管理知識庫）管理指標（）管理數(shù)據(jù)需求和應用） 點擊【角色管理】菜單進入角色列表頁面后，點擊某角色后面的【編輯】按鈕，即可進入角色編輯頁面，可以對角色的信息和權限進行修改，包括增刪擁有該角色的用戶。的提框點【消】鈕消輯作轉回戶表提。 DAM會彈的示。系統(tǒng)任務功能入口：操作角色： DAMDashboard）（）Dashboard（Dashboard）BI（BI更新DDCDDC）（））（）（）（）QuartZCron 系統(tǒng)設置 DAM 參數(shù)列表中的參數(shù)主要用于數(shù)據(jù)質量任務，作為變量用于編寫技術質量規(guī)則。DAMDAMDAM-Agent DAM-AgentIPDAMDDM在【控制面板】中，可以對系統(tǒng)的功能進行參數(shù)設置，如開啟或關閉某個功能比如下面的選項，false代表不開啟強密碼功能，true代表開啟強密碼。設置成功后，鼠標離開焦點，會出現(xiàn)修改成功的提示信息，代表設置成功。四、數(shù)據(jù)標準數(shù)據(jù)標準功能入口：操作角色：關聯(lián)任務：DashboardDAMExcel1.2進入【基礎標準】的【數(shù)據(jù)標準】功能模塊，點擊標準“開發(fā)中”狀態(tài)右側的“...”按鈕，在彈出的菜單中選擇【添加標準】即可進入數(shù)據(jù)標準添加頁面。為了提高數(shù)據(jù)標準的添加效率，我們建議您借助Excel數(shù)據(jù)標準模塊的形式批量導入數(shù)據(jù)標準到平臺中去。進入【基礎標準】的【數(shù)據(jù)標準】功能模塊，點擊標準“開發(fā)中”狀態(tài)右側的“...”按鈕，在彈出的菜單中選擇【下載模版】，即可將數(shù)據(jù)標準的模版下載到本地磁盤中。根據(jù)數(shù)據(jù)標準模版中的信息項填寫數(shù)據(jù)標準的標準編號、標準主題、一級分類等信息。填寫指導請您參考【填寫說明】Sheet頁。ExcelDAM進入【基礎標準】的【數(shù)據(jù)標準】功能模塊，點擊標準“開發(fā)中”狀態(tài)右側的“...”按鈕，在彈出的菜單中選擇【批量導出】即可將平臺中已存在的數(shù)據(jù)標準批量導出。 ID DAM 公有數(shù)據(jù)標準。 進入【開發(fā)中】狀態(tài)的數(shù)據(jù)標準頁面，可以查看已經(jīng)廢棄的數(shù)據(jù)標準列表。點進具體的數(shù)據(jù)標準中，也可以在生命周期中看到該數(shù)據(jù)標準為【廢棄】狀態(tài)?！景l(fā)態(tài)數(shù)標準以擊據(jù)準列右訂標以閱該數(shù)據(jù)準訂成后彈出 的提框點擊數(shù)據(jù)標準的【引用代碼】，可以展示該引用代碼的取值列表。在數(shù)據(jù)標準的【資產(chǎn)引用】中，可以查看到引用該數(shù)據(jù)的生產(chǎn)元數(shù)據(jù)列表。標準代碼功能介紹：功能入口：操作角色：進入【基礎標準】的【標準代碼】功能模塊，點擊搜索框右側的“...”按鈕，在彈出的菜單中選擇【添加代碼】即可進入標準代碼添加頁面。 根據(jù)頁面提示填寫代碼編號、中文名稱、英文名稱、標準主題、編碼取值等信息，填寫完畢擊確】鈕標準碼加功彈出 的提框 Excel進入【基礎標準】的【標準代碼】功能模塊，點擊搜索框右側的“...”按鈕，在彈出的菜單中選擇【下載模版】，即可將標準代碼的模版下載到本地磁盤中。Sheet進入【基礎標準】的【標準代碼】功能模塊，點擊搜索框右側的“...”按鈕，在彈出的菜單中選擇【批量導出】即可將平臺中已存在的標準代碼批量導出。同數(shù)據(jù)標準一樣，標準代碼亦具有時效性，勾選需要廢棄的標準代碼，點擊頁面下方的【廢棄】按鈕，可廢棄選中的標準代碼。如果需要恢復該廢棄的標準代碼，勾選需要恢復的標準代碼，點擊頁面下方的【恢復】按鈕，即可恢復該標準代碼。命名詞典功能介紹：功能入口：操作角色：必填、（為了提高命名詞典的添加效率，我們建議您借助Excel命名詞典模塊的形式批量導入命名詞典到平臺中去。模版填寫完成后點擊頁面右上角的【批量導入】按鈕。指標體系功能介紹：功能入口：操作角色：原子指標派生指標維度體系功能介紹：功能入口：操作角色：標準代碼轉為維度五、元數(shù)據(jù)應用系統(tǒng)功能入口：操作角色： （IT部門、Excel（IT點擊系統(tǒng)名錄編輯頁面下方的【選擇成員】按鈕，可以增刪該系統(tǒng)名錄下的用戶。為了提高添加系統(tǒng)名錄的效率，DAM平臺支持用Excel模塊批量導入系統(tǒng)名錄。 ExcelExcel（ITExcel點擊【系統(tǒng)名錄】主界面右上角的【導入】按鈕，選擇本地剛剛編輯保存好的系統(tǒng)名錄Excel文件，將系統(tǒng)名錄批量錄入到DAM平臺中去。 系統(tǒng)錄Excel文導成功提，系名的【統(tǒng)寫已存于DAM臺會，請查Excel件誤再行導操。 在【系統(tǒng)名錄】主界面左側的復選框中勾選，然后點擊頁面下方的【刪除】按鈕進行刪除操作。刪除【系統(tǒng)名錄】時系統(tǒng)會彈出確認框，點擊【確定】后方可刪除系統(tǒng)。如系名除功會若系下數(shù)據(jù)則除敗提示系統(tǒng)調用功能介紹：功能入口：操作角色：點擊【添加調用】-》【創(chuàng)建調用】，打開添加調用頁面填寫發(fā)起調用系統(tǒng)、被調用系統(tǒng)、引用方式等信息，并點【確定】，即可創(chuàng)建系統(tǒng)調用關系。添加完畢后，在【數(shù)據(jù)資產(chǎn)】-》【數(shù)據(jù)地圖】中，即可查看到系統(tǒng)間的調用關系圖。除了單個添加調用外，也可以通過下載系統(tǒng)調用模板，填寫好信息后，進行批量導入。數(shù)據(jù)源功能介紹：OracleSQLServerMySQLOceanBasePostgreSQLGaussDBGreenplumDB2（DB2foriSeries）GBaseHanaMaxCompute（ODPS）TeradataOfflineDump非關系型數(shù)據(jù)庫：HBaseHIVEImpalaMongoDBElasticSearch文件類型數(shù)據(jù)：Excel（CSV、DataDictionary）Tableau操作角色：DBA關聯(lián)任務：Dashboard通連的頁會彈的示數(shù)據(jù)源測試連接成功后，系統(tǒng)會開始采集該數(shù)據(jù)源的元數(shù)據(jù)信息。采集過來的元數(shù)據(jù)信息，在【元數(shù)據(jù)】模塊展示。（OfflineDump）OfflineDumpDAMOracleMySQLOfflineDumpDUMP_TABLES （DUMP_VIEWS （DUMP_COLUMNS （DUMP_PKS （DUMP_INDEXES （DUMP_ROUTINES（Offline（ORACLE_MYSQL_DAMOrale或ySQ填寫畢點測按接息寫后會提示SchemaDUMP_XXXXSchemaSchema在搜索框中輸入關鍵字，可以對數(shù)據(jù)源的名稱進行快速搜索。勾選需要刪除的數(shù)據(jù)源，點擊頁面下方的【刪除】按鈕，即可刪除指定的數(shù)據(jù)源。 點擊【更新任務】按鈕，即可進入指定數(shù)據(jù)源的任務配置界面，點擊【立即運行任務】那會立即執(zhí)行一遍數(shù)據(jù)源的更新任務，也可通過計劃任務定期去更新數(shù)據(jù)源。 BI工具BusnessnteigncB功能入口：操作角色：關聯(lián)任務：BI永洪BI是永洪科技出品的一款商業(yè)智能軟件，DAM平臺支持接入該BI工具。IBMCognosIBMCognosIBMCognosCognosCognosURICognos DispacheURCognsognos為分布式部署請?zhí)顚慍onos管理服務器的地址。 GatewayURICognos Cognos Cognos Cognos注意：CognosIBMCognosConfiguration，在【LocalConfigurationEnvironmentGategoryURIDispatchcerURI。②在WEBCognos—切換到【個人】選項卡—在【名稱空間】處可查看名稱空間。元數(shù)據(jù)功能介紹：功能入口：操作角色： 點擊頁面右下角的【下載全部】按鈕，可下載該數(shù)據(jù)源的全部元數(shù)據(jù)信息到本地磁盤。 Sheet SheetExcel血緣管理（Data功能入口：操作角色：關聯(lián)任務： DAMKettle (PentahoDataIntegration)SSIS(MicrosoftSQLServerIntegrationServices)Excel(DatablauDataStage (IBMDataStage)PowerCenterXML(InformaticaPowerCenterETLFile)SQLApacheSqoopMapping)Tableau (TableauReportFile)TSQLScript (MicrosoftSQLServerSQL)PL/SQLScript(OracleSQL)HiveSQLScript(ApacheHiveSQL)進入元數(shù)據(jù)模塊的血緣管理頁面，點擊頁面右上角的【導入血緣文件】按鈕。根據(jù)需要選擇具體的血緣文件類型，并上傳本地的血緣文件。上傳完成后，系統(tǒng)會自動去解析該血緣文件。 標簽管理功能介紹：功能入口：操作角色：添加標簽前，需先【添加目錄】。添加完目錄后，點擊【添加標簽】。輸入標簽名稱、描述等信息，關聯(lián)標簽及目錄，點擊【確定】即可完成添加。/已添加的標簽可以進行【編輯】和【刪除】操作。如果該標簽已被表、字段等引用，可以在此處看到引用信息。六、數(shù)據(jù)質量駕駛艙TOP10TOP5功能入口：操作角色：關聯(lián)任務：Dashboard業(yè)務規(guī)則管理功能入口：操作角色：關聯(lián)任務：Dashboard （ExcelExcel填寫完畢，點擊頁面右上角的【導入】按鈕，即可將錄入好的業(yè)務規(guī)則批量導入平臺中去。點擊頁面右上角的【導出】按鈕即可將平臺中已有的業(yè)務規(guī)則全部導出，下載到本地。對于已經(jīng)創(chuàng)建好的業(yè)務規(guī)則，如需對其進行修改，可點擊對應業(yè)務規(guī)則后面的【編輯】按鈕。技術規(guī)則管理功能入口：操作角色：關聯(lián)任務：Dashboard進入技術規(guī)則管理頁面，點擊右上角的【添加規(guī)則】按鈕，進入技術規(guī)則添加頁面。（SQLGroovy（SQLGroovyExcelExcel點擊頁面右上角的【導出】按鈕即可將平臺中已有的技術規(guī)則全部導出，下載到本地。對于已經(jīng)創(chuàng)建好的技術規(guī)則，如需對其進行修改，可點擊對應技術規(guī)則后面的【編輯】按鈕。質量檢查任務功能入口：操作角色：關聯(lián)任務：Dashboard在檢查任務管理頁面，點擊右上角的【創(chuàng)建任務】按鈕，進入檢查任務添加頁面。填寫或選擇檢查任務的任務名稱、調度方式、所屬系統(tǒng)、數(shù)據(jù)源、負責人等信息對于已經(jīng)創(chuàng)建好的技術規(guī)則，如需對其進行修改，可點擊對應檢查任務后面的【編輯】按鈕?？梢酝ㄟ^任務名稱關鍵字搜索定位到需要查看的任務。點擊【運行結果】按鈕，可以查看檢查任務的運行結果。質量修復任務功能入口：操作角色：關聯(lián)任務：Dashboard在修復任務管理頁面，點擊右上角的【創(chuàng)建任務】按鈕，進入檢查任務添加頁面。對于已經(jīng)創(chuàng)建好的修復任務，如需對其進行修改，可點擊對應修復任務后面的【編輯】按鈕?？梢酝ㄟ^狀態(tài)、任務名稱關鍵字、系統(tǒng)，日期搜索定位到需要查看的任務。通過任務后面的“…”，可以查看或下載修復任務的結果。知識庫管理功能入口：操作角色：點擊【添加】按鈕，打開添加頁面。對于已經(jīng)創(chuàng)建好的知識庫條目，如需對其進行修改，可點擊對應知識庫后面的【編輯】按鈕。七、數(shù)據(jù)模型設計模型管理功能介紹：DAMDDM功能入口：操作角色：在搜索框中輸入模型名稱，可以快速定位到目標模型。點擊模型，可以進入模型詳情，進行瀏覽和編輯模型。包括【模型摘要】【數(shù)據(jù)實體】【報告】【歷史版本】【評論】【主題】?；拘畔ⅰ灸Ｐ透乓靠梢詾g覽模型的一些基本信息。//以對表并且需要DDM【報告】模塊可以通過創(chuàng)建并發(fā)布報告，生成版本之間的差異報告【歷史版本】可以查看各個版本之間的修改記錄?！驹u論】可以對模型進行評論。主題【主題】模塊可以查看模型的ER圖和實體，可以對模型的表/視圖進行編輯、刪除操作。DDM客戶端開啟可以對模型的表、視圖、字段等進行關鍵字搜索。也可以對模型規(guī)范進行檢查。八、數(shù)據(jù)需求/數(shù)據(jù)服務數(shù)據(jù)需求功能入口：點擊【添加需求】-》【創(chuàng)建需求】按鈕，可以打開添加需求頁面。已經(jīng)添加的需求，可以進行【查看】和【刪除】操作。同時，需求也支持批量導入功能，需先下載模板，并按照模板格式填寫，然后導入即可。數(shù)據(jù)服務功能介紹：DDC功能入口：操作角色：普通用戶普通用戶進入菜單導航欄-》【目錄瀏覽】進行搜索提交申請管理員登錄-》個人工作臺-》流程控制-》我的待辦-》【辦理】點【新建視圖】點【測試】（測試通過后，才可點擊【確定】按鈕）測試通過后，點擊【確定】按鈕選擇創(chuàng)建的視圖，點擊【通過】。審核通過后，切換到普通用戶賬號，即可在【數(shù)據(jù)服務】看到此數(shù)據(jù)。九、數(shù)據(jù)智能業(yè)務屬性識別功能入口：操作角色：關聯(lián)任務：業(yè)務屬性識別可以掃描系統(tǒng)中的業(yè)務屬性，并為業(yè)務屬性推薦合適的數(shù)據(jù)標準?？梢赃x擇掃描的數(shù)據(jù)范圍也可以勾選多個業(yè)務屬性，進行【批量接受】和【批量拒絕】操作。業(yè)務屬性發(fā)現(xiàn)功能介紹：功能入口：操作角色：關聯(lián)任務：【業(yè)務屬性發(fā)現(xiàn)】列出了沒有相匹配的數(shù)據(jù)標準的相似業(yè)務屬性。點擊【查看】，可以查看業(yè)務屬性所屬的數(shù)據(jù)源、所屬表、數(shù)據(jù)類型等信息。十、業(yè)務流程功能介紹：功能入口：操作角色：業(yè)務流程點擊【業(yè)務流程】，打開添加業(yè)務流程頁面。已保存的業(yè)務流程，可以【新增業(yè)務活動】同時也可對業(yè)務活動進行【修改】和【刪除】點擊【查看數(shù)據(jù)對象】，可以添加【業(yè)務實體】中已保存的業(yè)務實體數(shù)據(jù)。業(yè)務實體點擊【添加業(yè)務實體】，打開添加業(yè)務實體的頁面。輸入業(yè)務實體名稱，可以關聯(lián)模型，并且添加物理表。點擊【保存】，即可保存實體。已保存的實體可以進行【修改】和【刪除】操作。業(yè)務實體創(chuàng)建完后，可以在相應的元數(shù)據(jù)表詳情中，查看關聯(lián)的業(yè)務實體。十一、 數(shù)據(jù)安全管理1. 數(shù)據(jù)安全功能介紹：功能入口：操作角色：十二、 數(shù)據(jù)目錄目錄瀏覽目錄管理十三、 附錄公司簡介Datablau）201611CACEOerwinCTOerwinDatablauDAMADatablauDDMDatablauDAMDDM。 2018，Datablau得的“最佳大數(shù)據(jù)產(chǎn)品”獎。Groovy語法樣例Groovy“Goovrooy代碼->Tips：初階操作：importimportgroovy.sql.Sqldefurl='jdbc:hsqldb:mem:yourDB'defuser='sa'defpassword=''defdriver='org.hsqldb.jdbcDriver'defsql=Sql.newInstance(url,user,password,driver)//use'sql'instance...sql.close()importimportgroovy.sql.Sqlimportorg.hsqldb.jdbc.JDBCDataSourcedefdataSource=newJDBCDataSource(database:'jdbc:hsqldb:mem:yourDB',user:'sa',password:'')defsql=newSql(dataSource)//usethenclose'sql'instance...新建表：//...create'sql'instance//...create'sql'instancesql.execute'''CREATETABLEAuthor(idINTEGERGENERATEDBYDEFAULTASIDENTITY,firstname VARCHAR(64),lastnameVARCHAR(64));'''//close'sql'instance...插入值：defdefinsertSql='INSERTINTOAuthor(firstname,lastname)VALUES(?,?)'defparams=['Jon','Skeet']defkeys=sql.executeInsertinsertSql,paramsassertkeys[0]==[1]查詢：defdefexpected=['DierkKoenig','JonSkeet','GuillaumeLaforge']defrowNum=0sql.query('SELECTfirstname,lastnameFROMAuthor'){resultSet->while(resultSet.next()){deffirst=resultSet.getString(1)deflast=resultSet.getString('lastname')assertexpected[rowNum++]=="$first$last"}}}更新行：def def updateSql = "UPDATE Author SET lastname='Pragt' lastname='Thorvaldsson'"defupdateCount=sql.executeUpdateupdateSqlassertupdateCount==1defrow=sql.firstRow"SELECT*FROMAuthorwherefirstname='Erik'"assert"${row.firstname}${row.lastname}"=='ErikPragt'刪除特定行：assertsql.firstRow('SELECTCOUNT(*)asnumFROMAuthor').num==3sql.execute"DELETEFROMAuthorWHERElastname='Skeet'"assertsql.firstRow('SELECTCOUNT(*)asnumFROMAuthor').num==2高階操作：事務處理：assertsql.firstRow('SELECTCOUNT(*)asnumFROMAuthor').num==0sql.withTransaction{sql.execute"INSERTINTOAuthor(firstname,lastname)VALUES('Dierk','Koenig')"sql.execute"INSERTINTOAuthor(firstname,lastname)VALUES('Jon','Skeet')"}assertsql.firstRow('SELECTCOUNT(*)asnumFROMAuthor').num==2批處理：sqlsql.withBatch(3){stmt->stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Dierk','Koenig')"stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Paul','King')"stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Guillaume','Laforge')"stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Hamlet','D''Arcy')"stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Cedric','Champeau')"stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Erik','Pragt')"stmt.addBatch"INSERTINTOAuthor(firstname,lastname)VALUES('Jon','Skeet')"}defdefqry='SELECT*FROMAuthor'assertsql.rows(qry,1,3)*.firstname==['Dierk','Paul','Guillaume']assertsql.rows(qry,4,3)*.firstname==['Hamlet','Cedric','Erik']assertsql.rows(qry,7,3)*.firstname==['Jon']分頁處理：defdefqry='SELECT*FROMAuthor'assertsql.rows(qry,1,3)*.firstname==['Dierk','Paul','Guillaume']assertsql.rows(qry,4,3)*.firstname==['Hamlet','Cedric','Erik']assertassertsql.rows(qry,7,3)*.firstname==['Jon']獲取元數(shù)據(jù)：sqlsql.eachRow("SELECT*FROMAuthorWHEREfirstname='Dierk'"){row->defmd=row.getMetaData()assertmd.getTableName(1)=='AUTHOR'assert(1..md.columnCount).collect{md.getColumnName(it)}==['ID','FIRSTNAME','LASTNAME']assert(1..md.columnCount).collect{md.getColumnTypeName(it)}==['INTEGER','VARCHAR','VARCHAR']}創(chuàng)建存儲過程：sqlsql.execute"""CREATEFUNCTIONSELECT_AUTHOR_INITIALS()RETURNSTABLE(firstInitialVARCHAR(1),lastInitialVARCHAR(1))READSSQLDATARETURNTABLE(SELECTLEFT(Author.firstname,1)asfirstInitial,LEFT(Author.lastname,1)aslastInitialFROMAuthor)"""defdefresult=[]sql.eachRow('CALLSELECT_AUTHOR_INITIALS()'){resultresult<<"$it.firstInitial$it.lastInitial"}assertresult==['DK','JS','GL']帶參數(shù)得存儲過程及調用：sqlsql.execute"""CREATEFUNCTIONFULL_NAME(p_lastnameVARCHAR(64))RETURNSVARCHAR(100)READSSQLDATABEGINATOMICDECLAREansVARCHAR(100);SELECTCONCAT(firstname,'',lastname)INTOansFROMAuthorWHERElastname=p_lastname;RETURNans;END"""defresult=sql.firstRow("{?=callFULL_NAME(?)}",['Koenig'])assertresult[0]=='DierkKoenig'創(chuàng)建帶輸入，輸出參數(shù)的存儲過程，以及調用實例：sqlsql.execute"""CREATEPROCEDURECONCAT_NAME(OUTfullnameVARCHAR(100),INfirstVARCHAR(50),INlastVARCHAR(50))BEGINATOMICSETfullname=CONCAT(first,'',last);END"""END"""sql.call("{callCONCAT_NAME(?,?,?)}",[Sql.VARCHAR,'Dierk','Koenig']){fullname->assertfullname=='DierkKoenig'}Groovy常用代碼：importgroovy.sql.GroovyRowResultimportgroovy.sql.SqldefexecuteQulityRuleXXX(){//datasource變量已經(jīng)定義在上下文中,為質量檢測任務中制定的數(shù)據(jù)源//defdatasource=Sql.newInstance("jdbc:mysql://localhost:3306/sakila","root","root","com.mysql.jdbc.Driver")//需要返回List<List<Object>>作為檢測出的問題數(shù)據(jù)deflist=[]//第一行表示問題數(shù)據(jù)的元數(shù)據(jù)/表頭defcolMeta=["id","ProductCode"]list.add(colMeta)// sql語句可以:// datasource.eachRow("select*fromcountry"){//// row->// defvalue=[]// value.add(row.getAt(0))// value.add(row.getAt(1))// list.add(value)// }// 若只需要執(zhí)行一段事務可以:// try{// datasource.withTransaction{// //正確語句// datasource.execute("DELETEFROMCOUNTRYWHERECOUNTRY='test'")// datasource.execute("DELETEFROMCOUNTRYWHERECOUNTRY='test2'")// datasource.executeInsert("INSERTINTOcountry(country)VALUES('test')")// datasource.executeInsert("INSERTINTOcountry(country)VALUES('test2')")// }// }catch(ignore){// println(ignore.message)// }//規(guī)則:個人險種表【LCProduct】中的產(chǎn)品編碼【ProductCode】對應險種定義表【LMProduct】的產(chǎn)品編碼【ProductCode】。//以下將輸出不對應的ProductCodeList<GroovyRowResult>rows1=datasource.rows("SELECTDISTINCTProductCodeFROMLCProduct");List<GroovyRowResult>rows2=datasource.rows("SELECTDISTINCTProductCodeFROMProductCode");intcnt=0;rows1.removeAll(rows2);rows1.each{row->cnt++defvalue=[]value.add(cnt)value.add(row.getAt(0))list.add(value)}returnlist}參數(shù)在技術質量規(guī)則中的應用實例：CountNumCountNum“CountNum#]]QuartZCron表達式名稱是否必須允許值特殊字符秒是0-59,-*/分是0-59,-*/時是0-23,-*/日是1-31,-*?/LWC月是1-12或JAN-DEC,-*/周是1-7或SUN-SAT,-*?/LC#年否空或1970-2099,-*/特殊字符含義：“/n/mn“LX“W。6#33示例：5*/5**1：0*/1**23：023*101*11：0011*230023L1001?*262933026,29,33**0131821：00,13,18,21*721007-21*OfflineDump離線生產(chǎn)庫Oracle數(shù)據(jù)庫：類型中轉庫建表語句數(shù)據(jù)采集平臺查詢語句表表名：DUMP_TABLESCREATETABLEDUMP_TABLES(TABLE_CATVARCHAR2(128BYTE),TABLE_SCHEM BYTE),TABLE_NAME BYTE)NOTNULLENABLE,TABLE_TYPEVARCHAR2(19BYTE),REMARKSVARCHAR2(4000BYTE),SELECTNULLAStable_cat,o.ownerAStable_schem,o.object_nameAStable_name,o.object_typeAStable_type,mentsASremarks,<數(shù)據(jù)庫標記>ASdatabase_infoFROMdba_objectso,dba_tab_commentscWHEREo.owner=:1ANDo.object_typeIN('TABLE')ANDo.owner=c.owner(+)DATABASE_INFO VARCHAR2(50BYTE))ANDo.object_name=c.table_name(+)ORDERBYtable_type,table_schem,table_name視圖表名：DUMP_VIEWSCREATETABLEDUMP_VIEWS(TABLE_CATVARCHAR2(128BYTE),TABLE_SCHEM BYTE)NOTNULLENABLE,TABLE_NAME BYTE)NOTNULLENABLE,REMARKSVARCHAR2(4000BYTE),TEXTCLOB,DATABASE_INFO BYTE))selectNULLAStable_cat,v.ownerastable_schem,v.view_nameastable_name,mentsASremarks,v.text,<數(shù)據(jù)庫標記>ASdatabase_infofromsys.dba_viewsv,sys.dba_tab_commentscwherev.owner=:1andv.owner=c.ownerandv.view_name=c.table_nameorderbytable_schem,table_name字段字段:DUMP_COLUMNSCREATETABLEDUMP_COLUMNS(TABLE_SCHEM BYTE)NOTNULLENABLE,TABLE_NAME BYTE)NOTNULLENABLE,COLUMN_NAME BYTE)NOTNULLENABLE,DATA_TYPENUMBER,TYPE_NAME BYTE),COLUMN_SIZENUMBER,BUFFER_LENGTHNUMBER,DECIMAL_DIGITSNUMBER,NUM_PREC_RADIXNUMBER,NULLABLENUMBER,REMARKSVARCHAR2(4000BYTE),COLUMN_DEFCLOB,SQL_DATA_TYPENUMBER,SQL_DATETIME_SUBNUMBER,CHAR_OCTET_LENGTHNUMBER,ORDINAL_POSITIONNUMBER,IS_NULLABLEVARCHAR2(3BYTE),IS_AUTOINCREMENT BYTE),SELECTNULLAStable_cat,t.ownerAStable_schem,t.table_nameAStable_name,t.column_nameAScolumn_name,DECODE((SELECTa.typecodeFROMdba_TYPESAWHEREa.type_name=t.data_type),'OBJECT',2002,'COLLECTION',2003,DECODE(substr(t.data_type,1,9),'TIMESTAMP',DECODE(substr(t.data_type,10,1),'(',DECODE(substr(t.data_type,19,5),'LOCAL',-102,'TIME',-101,93),DECODE(substr(t.data_type,16,5),'LOCAL',-102,'TIME',-101,93)),'INTERVAL',DECODE(substr(t.data_type,10,3),'DAY',-104,'YEA',-103),DECODE(t.data_type,'BINARY_DOUBLE',101,'BINARY_FLOAT',100,'BFILE',-13,'BLOB',2004,'CHAR',1,TABLE_CATVARCHAR2(30BYTE),SCOPE_CATALOG BYTE),SCOPE_SCHEMA VARCHAR2(30BYTE),SCOPE_TABLE VARCHAR2(30BYTE),SOURCE_DATA_TYPEVARCHAR2(30BYTE),DATABASE_INFO BYTE))'CLOB',2005,'COLLECTION',2003,'DATE',93,'FLOAT',6,'LONG',-1,'LONGRAW',-4,'NCHAR',-15,'NCLOB',2011,'NUMBER',3,'NVARCHAR',-9,'NVARCHAR2',-9,'OBJECT',2002,'OPAQUE/XMLTYPE',2009,'RAW',-3,'REF',2006,'ROWID',-8,'SQLXML',2009,'UROWID',-8,'VARCHAR2',12,'VARRAY',2003,'XMLTYPE',2009,1111)))ASdata_type,t.data_typeAStype_name,DECODE (t.data_precision,null, 'NUMBER', null,0 38), DECODE(t.data_type,'CHAR',t.char_length, t.char_length, t.char_length,'NVARCHAR2', t.char_length,'NCHAR', t.char_length,'NUMBER', 0,t.data_length) ),t.data_precision)AScolumn_size,0ASbuffer_length,DECODE 'NUMBER', DECODE(t.data_precision,null, null, -127, t.data_scale),t.data_scale), t.data_scale)decimal_digits,10ASnum_prec_radix,DECODE(t.nullable,'N',0,1)ASnullable,mentsASremarks,t.data_defaultAScolumn_def,0ASsql_data_type,0ASsql_datetime_sub,t.data_lengthASchar_octet_length,t.column_idASordinal_position,DECODE(t.nullable,'N','NO','YES')ASis_nullable,nullasSCOPE_CATALOG,nullasSCOPE_SCHEMA,nullasSCOPE_TABLE,nullasSOURCE_DATA_TYPE,'NO'asIS_AUTOINCREMENT,<數(shù)據(jù)庫標記>ASdatabase_infoFROMdba_tab_columnst,dba_col_commentscWHEREt.owner=:1ANDt.owner=c.owner(+)ANDt.table_name=c.table_name(+)ANDt.column_name=c.column_name(+)ORDER BY table_schem, table_name,ordinal_position主鍵表名:DUMP_PKSCREATETABLEDUMP_PKS(TABLE_CATVARCHAR2(128BYTE),TABLE_SCHEM BYTE)NOTNULLENABLE,TABLE_NAME BYTE)NOTNULLENABLE,COLUMN_NAME VARCHAR2(4000BYTE),KEY_SEQNUMBER,PK_NAME VARCHAR2(128NOTNULLENABLE,DATABASE_INFO BYTE))SELECTNULLAStable_cat,c.ownerAStable_schem,c.table_name,c.column_name,c.positionASkey_seq,c.constraint_nameASpk_name,<數(shù)據(jù)庫標記>ASdatabase_infoFROMsys.dba_cons_columnsc,sys.dba_constraintskWHEREk.constraint_type='P'ANDk.owner=:1ANDk.constraint_name=c.constraint_nameANDk.table_name=c.table_nameANDk.owner=c.ownerORDERBYtable_name,key_seq索引表名：DUMP_INDEXESCREATETABLEDUMP_INDEXES(TABLE_CATVARCHAR2(128BYTE),TABLE_SCHEM BYTE)NOTNULLENABLE,TABLE_NAME BYTE)NOTNULLENABLE,NON_UNIQUENUMBER,INDEX_QUALIFIER BYTE),INDEX_NAME VARCHAR2(128BYTE)NOTNULLENABLE,TYPENUMBER,ORDINAL_POSITION NOTNULLENABLE,COLUMN_NAME VARCHAR2(4000BYTE),ASC_OR_DESC VARCHAR2(30BYTE),CARDINALITYNUMBER,PAGESNUMBER,FILTER_CONDITIONVARCHAR2(30BYTE),DATABASE_INFO BYTE))selectnullastable_cat,i.ownerastable_schem,i.table_name,decode(i.uniqueness,'UNIQUE',0,1)asnon_unique,nullasindex_qualifier,i.index_name,1astype,c.column_positionasordinal_position,c.column_name,nullasasc_or_desc,i.distinct_keysascardinality,i.leaf_blocksaspages,nullasfilter_condition,<數(shù)據(jù)庫標記>ASdatabase_infofromsys.dba_indexesi,sys.dba_ind_columnscwherei.owner=:1andi.index_name=c.index_nameandi.table_owner=c.table_ownerandi.table_name=c.table_nameandi.owner=c.index_ownerorder by table_name, ordinal_position/函數(shù)表名：DUMP_ROUTINESCREATETABLEDUMP_ROUTINES(ROUTINE_CAT VARCHAR2(128BYTE),ROUTINE_SCHEM VARCHAR2(128BYTE),ROUTINE_NAME VARCHAR2(128BYTE),ROUTINE_TYPE VARCHAR2(30BYTE),LINENUMBER,TEXTVARCHAR2(4000BYTE),DATABASE_INFO selectnullasroutine_cat,ownerasroutine_schem,nameasroutine_name,typeasroutine_type,line,text,<數(shù)據(jù)庫標記>ASdatabase_infofromsys.dba_sourcewhereowner=:1andtypein('FUNCTION','PROCEDURE')orderbyroutine_schem,routine_name,lineBYTE))MySQL數(shù)據(jù)庫：類型中轉庫建表語句數(shù)據(jù)采集平臺查詢語句表表名：DUMP_TABLESCREATETABLEDUMP_TABLES(TABLE_CAT BINARY(0) DEFAULTNULL,TABLE_SCHEMVARCHAR(64)NOTNULLDEFAULT'',TABLE_NAME VARCHAR(64)NOTNULLDEFAULT'',TABLE_TYPE VARCHAR(64)NOTNULLDEFAULT'',REMARKS VARCHAR(2048)NULLDEFAULT'',DATABLAU_INFO VARCHAR(50)NOTNULLDEFAULT'')SELECTNULLAStable_cat,o.TABLE_SCHEMAAStable_schem,o.TABLE_NAMEAStable_name,o.TABLE_TYPEAStable_type,o.TABLE_COMMENTASremarks,ASdatabase_infoFROMinformation_schema.TABLESoWHEREo.TABLE_SCHEMA1ANDo.TABLE_NAMELIKE'%'ANDo.TABLE_TYPEIN('BASETABLE')ORDERBYtable_schem,table_name視圖表名：DUMP_VIEWSCREATETABLEDUMP_VIEWS(TABLE_CAT BINARY(0) DEFAULTNULL,TABLE_SCHEMVARCHAR(64)NOTNULLDEFAULT'',TABLE_NAME VARCHAR(64)NOTNULLDEFAULT'',REMARKS BINARY(0) DEFAULTNULL,TEXTLONGTEXTNOTNULL,DATABLAU_INFO VARCHAR(50)NOTNULLDEFAULT'')selectNULLAStable_cat,v.TABLE_SCHEMAastable_schem,v.TABLE_NAMEastable_name,NULLASremarks,v.VIEW_DEFINITIONastext,<數(shù)據(jù)庫標記>ASdatabase_infofrominformation_schema.viewsvwherev.TABLE_SCHEMA=:1orderbytable_schem,table_name字段表名：DUMP_COLUMNSCREATETABLEDUMP_COLUMNS(TABLE_CAT BINARY(0) DEFAULTNULL,TABLE_SCHEMVARCHAR(64)NOTNULLDEFAULT'',TABLE_NAME VARCHAR(64)NOTSELECTnullasTABLE_CAT,c.TABLE_SCHEMAasTABLE_SCHEM,c.TABLE_NAMEasTABLE_NAME,c.COLUMN_NAMEasCOLUMN_NAME,0asDATA_TYPE,c.COLUMN_TYPEasTYPE_NAME,0asCOLUMN_SIZE,NULLDEFAULT'',COLUMN_NAME NOTNULLDEFAULT'',DATA_TYPE INT(1)NOTNULLDEFAULT'0',TYPE_NAME LONGTEXT NULL,COLUMN_SIZE INT(1)NOTDEFAULT'0',DECIMAL_DIGITS INT(1) NULLDEFAULT'0',REMARKS VARCHAR(1024)NULLDEFAULT'',COLUMN_DEF NULL,ORDINAL_POSITION UNSIGNEDNOTNULLDEFAULT'0',IS_NULLABLE VARCHAR(3)NULLDEFAULT'',IS_AUTOINCREMENT NOTNULLDEFAULT'',DATABLAU_INFO VARCHAR(50)NOTNULLDEFAULT'')0asDECIMAL_DIGITS,c.COLUMN_COMMENTasREMARKS,c.COLUMN_DEFAULTasCOLUMN_DEF,c.ORDINAL_POSITION ORDINAL_POSITION,c.IS_NULLABLEasIS_NULLABLE,casec.EXTRAWHEN'auto_increment'THEN'YES'ELSE'NO'endIS_AUTOINCREMENT,<數(shù)據(jù)庫標記>ASdatabase_infoFROMinformation_schema.COLUMNScWHEREc.TABLE_SCHEMA=:1ORDER BY table_schem, table_name,ordinal_position主鍵表名：DUMP_PKSCREATETABLEDUMP_PKS(TABLE_CAT BINARY(0) DEFAULTNULL,TABLE_SCHEMVARCHAR(64)NOTNULLDEFAULT'',TABLE_NAME VARCHAR(64)NOTNULLDEFAULT'',COLUMN_NAME NOTNULLDEFAULT'',KEY_SEQ BIGINT(2)NOTNULLDEFAULT'0',PK_NAME VARCHAR(64)NOTNULLDEFAULT'',DATABLAU_INFO VARCHAR(50)NOTNULLDEFAULT'')selectnullasTABLE_CAT,pk.TABLE_SCHEMAasTABLE_SCHEM,pk.TABLE_NAME,pk.COLUMN_NAME,pk.SEQ_IN_INDEXasKEY_SEQ,pk.INDEX_NAMEasPK_NAME,<數(shù)據(jù)庫標記>ASdatabase_infofrominformation_schema.statisticspkwhere(index_name='PRIMARY'orindex_name='PRI')andtable_schema=:1orderbyTABLE_NAME,KEY_SEQ索引表名：DUMP_INDEXESCREATETABLEDUMP_INDEXES(selectnullasTABLE_CAT,idx.TABLE_SCHEMAasTABLE_SCHEM,TABLE_CAT BINARY(0) DEFAULTNULL,TABLE_SCHEMVARCHAR(64)NOTNULLDEFAULT'',TABLE_NAME VARCHAR(64)NOTNULLDEFAULT'',NON_UNIQUE INT(1)NOTNULLDEFAULT'0',INDEX_QUALIFIER NULLDEFAULTNULL,INDEX_NAME VARCHAR(64)NOTNULLDEFAULT'',TYPE INT(1)NOTNULLDEFAULT'0',ORDINAL_POSITION NOTNULLDEFAULT'0',COLUMN_NAME NOTNULLDEFAULT'',ASC_OR_DESC VARCHAR(1)NULLDEFAULTNULL,CARDINALITY BIGINT(21)NULLDEFAULTNULL,PAGESINT(1)NOTNULLDEFAULT'0',FILTER_CONDITION NULLDEFAULTNULL,DATABLAU_INFO VARCHAR(50)NOTNULLDEFAULT'')idx.TABLE_NAME,CASEWHENidx.NON_UNIQUE=1THENtrueELSEfalseENDasNON_UNIQUE,nullasINDEX_QUALIFIER,idx.INDEX_NAME,3asTYPE,idx.SEQ_IN_INDEXasORDINAL_POSITION,idx.COLUMN_NAME,idx.COLLATIONasASC_OR_DESC,idx.CARDINALITY,0asPAGES,nullasFILTER_CONDITION,<數(shù)據(jù)庫標記>ASdatabase_infofrom`information_schema`.`statistics`idxwheretable_schema=:1order by TABLE_SCHEM, INDEX_NAME,ORDINAL_POSITION存儲過程/函數(shù)表名：DUMP_ROUTINESCREATETABLEDUMP_ROUTINES(ROUTINE_CAT BINARY(0)NULLDEFAULTNULL,ROUTINE_SCHEM NOTNULLDEFAULT'',ROUTINE_NAME NOTNULLDEFAULT'',ROUTINE_