删除流程相关数据sql

--每次清理1000条，清理180天以前的

--流程上下文数据

delete  t_wfr_procinstdata

WHERE FPROCINSTID IN (SELECT top 1000 FPROCINSTID

                      FROM t_wfr_procinstdata wrid

                      WHERE EXISTS(SELECT fprocinstid

                                   FROM t_wfr_procinst pid

                                   WHERE (fstate = 'closed.completed' OR fstate = 'closed.aborted') AND

                                         pid.fprocinstid = wrid.fprocinstid) AND DATEDIFF(DD, ftime, NOW()) >= 180);

--流程上下历史  

DELETE t_wfr_procinstdatahst

WHERE FPROCINSTID IN (SELECT top 1000 FPROCINSTID

                      FROM t_wfr_procinstdatahst wrid

                      WHERE EXISTS(SELECT fprocinstid

                                   FROM t_wfr_procinst pid

                                   WHERE (fstate = 'closed.completed' OR fstate = 'closed.aborted') AND

                                         pid.fprocinstid = wrid.fprocinstid) AND DATEDIFF(DD, ftime, NOW()) >= 180);

--清理运行数据

DELETE T_WFR_Runtime

WHERE FPROCINSTID IN (SELECT top 1000 FPROCINSTID

                      FROM T_WFR_Runtime wrid

                      WHERE EXISTS(SELECT fprocinstid

                                   FROM t_wfr_procinst pid

                                   WHERE (fstate = 'closed.completed' OR fstate = 'closed.aborted') AND

                                         pid.fprocinstid = wrid.fprocinstid) AND

                            DATEDIFF(DD, FLASTUPDATEDTIME, NOW()) >= 180) ;

--清理不存在引用的流程定义数据

DELETE t_wfr_procdef

WHERE FMD5HASH IN (SELECT top 1000 FMD5HASH

                   FROM t_wfr_procdef prd

                   WHERE NOT EXISTS(SELECT

                                      pci.fprocdefid,

                                      fprocdefver,

                                      fprocdefhash

                                    FROM t_wfr_procinst pci

                                    WHERE pci.fprocdefhash = prd.fmd5hash) AND EXISTS(SELECT procdefid

                                                                                      FROM (SELECT

                                                                                              MAX(

                                                                                                  pdb.finnerve