資料庫清除工作流程 database-cleanup-workflow

使用下列SQL查詢復原要刪除的清單：

SELECT iGroupId, sLabel, iType FROM NmsGroup WHERE iDeleteStatus <> 0 OR tsExpirationDate <= GetDate()

每個清單都有數個連結至其他表格。 所有這些連結都會使用下列查詢大量刪除：

DELETE FROM $(relatedTable) WHERE iGroupId=$(l) IN (SELECT iGroupId FROM $(relatedTable) WHERE iGroupId=$(l) LIMIT 5000)

位置 $(relatedTable) 是相關資料表 NmsGroup 和 $(l) 是清單識別碼。

當清單是「清單」型別清單時，會使用以下查詢刪除關聯的表格：

DROP TABLE grp$(l)

每 選取 透過作業復原的型別清單會使用以下查詢刪除：

DELETE FROM NmsGroup WHERE iGroupId=$(l)

位置 $(l) 是清單識別碼

此 Database cleanup 工作流程會選取符合以下條件的所有傳遞： deleteStatus 欄位具有 Yes 或 Recycled 而且其刪除日期早於 Deleted deliveries (NmsCleanup_RecycledDeliveryPurgeDelay)欄位。 有關詳細資訊，請參閱 部署精靈. 此期間是根據目前的伺服器日期計算。

對於每個中間來源伺服器，任務會選取要刪除的傳遞清單。

此 Database cleanup 工作流程會刪除傳遞記錄、附件、映象頁面資訊和所有其他相關資料。

永久刪除傳送之前，工作流程會永久刪除下清單格中的連結資訊：

• 在傳遞排除表格中(NmsDlvExclusion)，則使用下列查詢：

  code language-sql
  DELETE FROM NmsDlvExclusion WHERE iDeliveryId=$(l)

  位置 $(l) 是傳遞的識別碼。

• 在抵用券表格中(NmsCouponValue)，則使用下列查詢（包含大量刪除）：

  code language-sql
  DELETE FROM NmsCouponValue WHERE iMessageId IN (SELECT iMessageId FROM NmsCouponValue WHERE EXISTS (SELECT B.iBroadLogId FROM $(BroadLogTableName) B WHERE B.iDeliveryId = $(l) AND B.iBroadLogId = iMessageId ) LIMIT 5000)

  位置 $(l) 是傳遞的識別碼。

• 在傳遞記錄表格中(NmsBroadlogXxx)，大量刪除會以20,000筆記錄的批次執行。

• 在優惠方案主張表格中(NmsPropositionXxx)，大量刪除會以20,000筆記錄的批次執行。

• 在追蹤記錄檔表格中(NmsTrackinglogXxx)，大量刪除會以20,000筆記錄的批次執行。

• 在傳遞片段表格中(NmsDeliveryPart)，大量刪除會以500,000筆記錄的批次執行。 此表格包含其餘要傳送之訊息的個人化資訊。

• 在映象頁面資料片段表格中(NmsMirrorPageInfo)，大量刪除會針對過期的傳遞部分以及已完成或已取消的部分，以20,000筆記錄的批次執行。 此表格包含用於產生映象頁面之所有訊息的個人化資訊。

• 在映象頁面搜尋表格中(NmsMirrorPageSearch)，大量刪除會以20,000筆記錄的批次執行。 此表格為搜尋索引，可讓您存取儲存在 NmsMirrorPageInfo 表格。

• 在批次處理記錄表中(XtkJobLog)，大量刪除會以20,000筆記錄的批次執行。 此表格包含要刪除的傳遞記錄。

• 在傳遞URL追蹤表格中(NmsTrackingUrl)，則使用下列查詢：

  code language-sql
  DELETE FROM NmsTrackingUrl WHERE iDeliveryId=$(l)

  位置 $(l) 是傳遞的識別碼。

  此表格包含在要刪除以啟用其追蹤的傳遞中找到的URL。

傳遞會從傳遞表格中刪除(NmsDelivery)：

DELETE FROM NmsDelivery WHERE iDeliveryId = $(l)

位置 $(l) 是傳遞的識別碼。

為此，工作流程會檢查每個傳送是否非作用中（根據其狀態）。 如果傳送處於作用中狀態，則會在刪除之前停止。 檢查會透過執行以下查詢來執行：

SELECT iState FROM NmsDelivery WHERE iDeliveryId = $(l) AND iState <> 100;

位置 $(l) 是傳遞的識別碼。

如果狀態的值為 Start pending ， In progress ， Recovery pending ， Recovery in progress ， Pause requested ， Pause in progress ，或 Paused （值為51、55、61、62、71、72、75），傳送會停止且工作會清除連結的資訊。

此 Database cleanup 工作流程會建立已過期的傳遞清單。 此清單包含所有狀態為「 」以外的過期傳遞 Finished ，以及最近停止的傳遞，其中包含超過10,000則未處理的訊息。 使用下列查詢：

SELECT iDeliveryId, iState FROM NmsDelivery WHERE iDeleteStatus=0 AND iIsModel=0 AND iDeliveryMode=1 AND ( (iState >= 51 AND iState < 85 AND tsValidity IS NOT NULL AND tsValidity < $(currentDate) ) OR (iState = 85 AND DateMinusDays(15) < tsLastModified AND iToDeliver - iProcessed >= 10000 ))

位置 delivery mode 1 符合 Mass delivery 模式， state 51 符合 Start pending 州別， state 85 符合 Stopped 而傳送伺服器上大量更新的傳送記錄最高數量等於10,000。

然後，工作流程會包含使用中間來源的最近過期傳遞清單。 會排除尚未透過中間來源伺服器復原傳遞記錄的傳遞。

使用下列查詢：

SELECT iDeliveryId, tsValidity, iMidRemoteId, mData FROM NmsDelivery WHERE (iDeliveryMode = 4 AND (iState = 85 OR iState = 95) AND tsValidity IS NOT NULL AND (tsValidity < SubDays(GetDate() , 15) OR tsValidity < $(DateOfLastLogPullUp)) AND tsLastModified > SubDays(GetDate() , 15))

下列查詢可用來偵測外部帳戶是否仍在作用中，以依日期篩選傳遞：

SELECT iExtAccountId FROM NmsExtAccount WHERE iActive<>0 AND sName=$(providerName)

在過期的傳遞清單中，其狀態為的傳遞記錄 Pending ，切換至 Delivery cancelled ，而此清單中的所有傳送都會切換至 Finished .

使用下列查詢：

UPDATE $(BroadLogTableName) SET tsLastModified=$(curdate), iStatus=7, iMsgId=$(bl) WHERE iDeliveryId=$(dl) AND iStatus=6

位置 $(curdate)是資料庫伺服器的目前日期， $(bl) 是傳遞記錄訊息的識別碼， $(dl) 是傳遞識別碼， delivery status 6 符合 Pending 狀態和 delivery status 7 符合 Delivery cancelled 狀態。

UPDATE NmsDelivery SET iState = 95, tsLastModified = $(curdate), tsBroadEnd = tsValidity WHERE iDeliveryId = $(dl)

位置 delivery state 95 符合 Finished 狀態，和 $(dl) 是傳遞的識別碼。

所有片段(deliveryParts)的過時傳送，並刪除進行中通知傳送的所有過時片段。 這兩個任務都會使用大量刪除。

使用下列查詢：

DELETE FROM NmsDeliveryPart WHERE iDeliveryPartId IN (SELECT iDeliveryPartId FROM NmsDeliveryPart WHERE iDeliveryId IN (SELECT iDeliveryId FROM NmsDelivery WHERE iState=95 OR iState=85) LIMIT 5000)

DELETE FROM NmsDeliveryPart WHERE iDeliveryPartId IN (SELECT iDeliveryPartId FROM NmsDeliveryPart WHERE tsValidity < $(curDate) LIMIT 500000)

位置 delivery state 95 符合 Finished 狀態， delivery state 85 符合 Stopped 狀態，和 $(curDate) 是目前的伺服器日期。

首先，使用以下查詢來復原要清除的傳遞清單：

SELECT iDeliveryId, iNeedMirrorPage FROM NmsDelivery WHERE iWebResPurged = 0 AND tsWebValidity IS NOT NULL AND tsWebValidity < $(curdate)

位置 $(curDate) 是目前的伺服器日期。

此 NmsMirrorPageInfo 如有必要，系統會使用先前復原的傳遞識別碼，清除表格。 大量刪除用於產生下列查詢：

DELETE FROM NmsMirrorPageInfo WHERE iMirrorPageInfoId IN (SELECT iMirrorPageInfoId FROM NmsMirrorPageInfo WHERE iDeliveryId = $(dl)) LIMIT 5000

DELETE FROM NmsMirrorPageSearch WHERE iMessageId IN (SELECT iMessageId FROM NmsMirrorPageSearch WHERE iDeliveryId = $(dl)) LIMIT 5000

位置 $(dl) 是傳遞的識別碼。

然後，專案會新增至傳遞記錄。

接著會識別已清除的傳送，以避免稍後必須重新處理。 會執行以下查詢：

UPDATE NmsDelivery SET iWebResPurged = 1 WHERE iDeliveryId IN ($(strIn))

位置 $(strIn) 是傳遞識別碼的清單。

名稱以開頭的表格清單 wkDlv_ 會先透過下列查詢(postgresql)復原：

SELECT relname FROM pg_class WHERE relname LIKE Lower('wkDlv_%') ESCAPE E'\\' AND relkind IN ('r','v') AND pg_get_userbyid(relowner)<>'postgres'

然後會排除進行中工作流程使用的表格。 若要這麼做，請使用下列查詢復原進行中的傳遞清單：

SELECT iDeliveryId FROM NmsDelivery WHERE iDeliveryId<>0 AND iDeleteStatus=0 AND iState NOT IN (0,85,100);

位置 0 是與 Being edited 傳遞狀態， 85 符合 Stopped 狀態和 100 符合 Deleted 狀態。

不再使用的表格將透過下列查詢刪除：

DROP TABLE wkDlv_15487_1;

大量刪除會針對 XtkReject 具有下列查詢的表格：

DELETE FROM XtkReject WHERE iRejectId IN (SELECT iRejectId FROM XtkReject WHERE tsLog < $(curDate)) LIMIT $(l)

位置 $(curDate) 是目前的伺服器日期，從中減去為定義的期間。 NmsCleanup_RejectsPurgeDelay 選項(請參閱 部署精靈)和 $(l) 是要大量刪除的記錄數上限。

然後使用以下查詢刪除所有孤立拒絕：

DELETE FROM XtkReject WHERE iJobId NOT IN (SELECT iJobId FROM XtkJob)

若要復原要刪除的工作流程清單，請使用以下查詢：

SELECT iWorkflowId, iHistory FROM XtkWorkflow WHERE iWorkflowId<>0

此查詢會產生工作流程清單，用於透過下列查詢刪除所有連結的記錄、完成的任務和完成的事件：

DELETE FROM XtkWorkflowLog WHERE iWorkflowId=$(lworkflow) AND tsLog < DateMinusDays($(lhistory))

DELETE FROM XtkWorkflowTask WHERE iWorkflowId=$(lworkflow) AND iStatus<>0 AND tsCompletion < DateMinusDays($(lhistory))

DELETE FROM XtkWorkflowEvent WHERE iWorkflowId=$(l) AND iStatus>2 AND tsProcessing < DateMinusDays($(lHistory))

位置 $(lworkflow) 是工作流程的識別碼，並 $(lhistory) 是歷程記錄的識別碼。

刪除所有未使用的表格。 為此目的，收集所有表格得益於 wkf% 使用下列查詢(postgresql)輸入遮色片：

SELECT relname FROM pg_class WHERE relname LIKE Lower('wkf%') ESCAPE E'\\' AND relkind IN ('r','v') AND pg_get_userbyid(relowner)<>'postgres'

然後會排除擱置工作流程執行個體使用的所有表格。 使用下列查詢可復原使用中工作流程的清單：

SELECT iWorkflowId FROM XtkWorkflow WHERE iWorkflowId<>0 AND iState<>20

接著，系統會復原每個工作流程識別碼，以尋找進行中工作流程所使用的表格名稱。 這些名稱會從先前復原的資料表清單中排除。

使用下列查詢排除「增量查詢」型別活動歷史記錄表格：

SELECT relname FROM pg_class WHERE relname LIKE Lower('wkfhisto%') ESCAPE E'\\' AND relkind IN ('r','v') AND pg_get_userbyid(relowner)<>'postgres'

SELECT iWorkflowId FROM XtkWorkflow WHERE iWorkflowId IN ($(strCondition))

位置 $(strcondition) 是符合「 」的表格清單 wkfhisto% 遮色片。

剩餘的表格會使用下列查詢刪除：

DROP TABLE wkf15487_12;

首先，使用下列查詢來復原追蹤記錄表清單：

SELECT distinct(sTrackingLogSchema) FROM NmsDeliveryMapping WHERE sTrackingLogSchema IS NOT NULL;

整批刪除用於清除先前復原的表格清單中的所有表格。 使用下列查詢：

DELETE FROM NmsTrackingLogRcp WHERE iTrackingLogId IN (SELECT iTrackingLogId FROM NmsTrackingLogRcp WHERE tsLog < $(tsDate) LIMIT 5000)

位置 $(tsDate) 是目前的伺服器日期，從中減去為定義的期間。 NmsCleanup_TrackingLogPurgeDelay 選項。

會使用大量刪除來清除追蹤統計資料表。 使用下列查詢：

DELETE FROM NmsTrackingStats WHERE iTrackingStatsId IN (SELECT iTrackingStatsId FROM NmsTrackingStats WHERE tsStart < $(tsDate) LIMIT 5000)

位置 $(tsDate) 是目前的伺服器日期，從中減去為定義的期間。 NmsCleanup_TrackingStatPurgeDelay 選項。

為此目的，會使用下列查詢復原傳遞記錄結構描述清單：

SELECT distinct(sBroadLogSchema) FROM NmsDeliveryMapping WHERE sBroadLogSchema IS NOT NULL UNION SELECT distinct(sBroadLogExclSchema) FROM NmsDeliveryMapping WHERE sBroadLogExclSchema IS NOT NULL

使用中間來源時， NmsBroadLogMid 傳遞對應中未參考資料表。 此 nms：broadLogMid 結構描述會新增到上一個查詢復原的清單中。

此 資料庫清理 然後工作流程會從先前復原的表格中清除過時的資料。 使用下列查詢：

DELETE FROM $(tableName) WHERE iBroadLogId IN (SELECT iBroadLogId FROM $(tableName) WHERE tsLastModified < $(option) LIMIT 5000)

位置 $(tableName) 是結構清單中每個表格的名稱，以及 $(option) 是為定義的日期 NmsCleanup_BroadLogPurgeDelay 選項(請參閱 部署精靈)。

最後，工作流程會檢查 NmsProviderMsgId 表格已存在。 若是如此，則會使用下列查詢刪除所有過時資料：

DELETE FROM NmsProviderMsgId WHERE iBroadLogId IN (SELECT iBroadLogId FROM NmsProviderMsgId WHERE tsCreated < $(option) LIMIT 5000)

位置 $(option) 符合為定義的日期 NmsCleanup_BroadLogPurgeDelay 選項(請參閱 部署精靈)。

執行以下查詢以僅保留超過特定臨界值（等於20）的錯誤：

SELECT iMXIP, iPublicId, SUM(iTotalConnections), SUM(iTotalErrors), SUM(iMessageErrors), SUM(iAbortedConnections), SUM(iFailedConnections), SUM(iRefusedConnections), SUM(iTimeoutConnections) FROM NmsEmailErrorStat WHERE tsDate>=$(start ) AND tsDate<$(end ) GROUP BY iMXIP, iPublicId HAVING SUM(iTotalErrors) >= 20

此 coalescingErrors 訊息便會顯示。

建立新連線以刪除在開始和結束日期之間發生的所有錯誤。 使用下列查詢：

DELETE FROM NmsEmailErrorStat WHERE tsDate>=$(start) AND tsDate<$(end)

每個錯誤都儲存在 NmsEmailErrorStat 使用下列查詢的表格：

INSERT INTO NmsEmailErrorStat(iMXIP, iPublicId, tsDate, iTotalConnections, iTotalErrors, iTimeoutConnections, iRefusedConnections, iAbortedConnections, iFailedConnections, iMessageErrors) VALUES($(lmxip ), $(lpublicId ), $(tsstart ), $(lconnections ), $(lconnectionErrors ),$(ltimeoutConnections ), $(lrefusedConnections ), $(labortedConnections ), $(lfailedConnections ), $(lmessageErrors))

其中每個變數都符合由先前查詢復原的值。

此 開始 變數會以前一個處理序的值更新，以完成回圈。

若要復原需要清理的模擬清單，請使用下列查詢：

SELECT iSimulationId FROM NmsSimulation WHERE iSimulationId<>0

要刪除的表格名稱會由 西摩_ 前置詞後接模擬的識別碼(例如： wkSimu_456831_aggr)：

DROP TABLE wkSimu_456831_aggr