数据迁移的存储过程[18][支持恢复到迁移前，并重新迁移]

TRS.WCM.Developer/贵州项目/3_sp_data_migration_xwcmviewfieldinfo.sql

@@ -4,8 +4,8 @@ use trs_data_migration;
 DROP PROCEDURE IF EXISTS sp_data_migration_xwcmviewfieldinfo;
 DELIMITER $$
 CREATE PROCEDURE sp_data_migration_xwcmviewfieldinfo(IN citySuffix VARCHAR(20),
-                                              IN prevViewFieldId BIGINT(20),
-                                              IN viewFieldIdOffset BIGINT(20),
+                                              IN prevViewFieldInfoId BIGINT(20),
+                                              IN viewFieldInfoIdOffset BIGINT(20),
                                               IN tableInfoIdOffset BIGINT(20),
                                               IN classIdOffset BIGINT(20),
                                               IN dbFieldIdOffset BIGINT(20),
@@ -167,12 +167,12 @@ CREATE PROCEDURE sp_data_migration_xwcmviewfieldinfo(IN citySuffix VARCHAR(20),
     WHILE isover= 0 DO
 
       # 断点续传
-      IF (f_VIEWFIELDINFOID > prevViewFieldId)
+      IF (f_VIEWFIELDINFOID > prevViewFieldInfoId)
 
         THEN
 
             SET @VIEWFIELDINFOID = f_VIEWFIELDINFOID;
-            SET f_VIEWFIELDINFOID = f_VIEWFIELDINFOID + viewFieldIdOffset;
+            SET f_VIEWFIELDINFOID = f_VIEWFIELDINFOID + viewFieldInfoIdOffset;
             SET f_TABLEID = f_TABLEID + tableInfoIdOffset;
             SET f_CLASSID = f_CLASSID + classIdOffset;
             SET f_VIEWID = f_VIEWID + viewIdOffset;

TRS.WCM.Developer/贵州项目/4_sp_city_n.sql

@@ -29,7 +29,7 @@ CREATE PROCEDURE sp_city_n(IN n INT)
     SET @prevFieldId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmdbfieldinfo'), 0);
     SET @prevMetaViewEmployerId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmmetaviewemployer'), 0);
     SET @prevTableInfoId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmtableinfo'), 0);
-    SET @prevViewFieldId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmviewfieldinfo'), 0);
+    SET @prevViewFieldInfoId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmviewfieldinfo'), 0);
     SET @prevViewId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmviewinfo'), 0);
     SET @prevMetaViewFieldGroupId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'xwcmmetaviewfieldgroup'), 0);
     SET @prevAppendixId = ifnull((SELECT prev_id from trs_data_migration.data_migration_log where table_name = 'wcmappendix'), 0);
@@ -37,16 +37,16 @@ CREATE PROCEDURE sp_city_n(IN n INT)
 
 
     # xx ID 偏移量，为了和海云系统中的 xx ID 错开一段距离
-    SET @siteIdOffset = 10000 * @n;
-    SET @viewIdOffset = 10000 * @n;
-    SET @tableInfoIdOffset = 10000 * @n;
-    SET @metaViewFieldGroupIdOffset = 10000 * @n;
+    SET @siteIdOffset = 100000 * @n;
+    SET @viewIdOffset = 100000 * @n;
+    SET @tableInfoIdOffset = 100000 * @n;
+    SET @metaViewFieldGroupIdOffset = 100000 * @n;
 
     SET @classInfoViewIdOffset = 100000 * @n;
     SET @classInfoIdOffset = 100000 * @n;
     SET @fieldIdOffset = 1000000 * @n;
     SET @metaViewEmployerIdOffset = 100000 * @n;
-    SET @viewFieldIdOffset = 100000 * @n;
+    SET @viewFieldInfoIdOffset = 100000 * @n;
     SET @dbFieldIdOffset = 100000 * @n;
 
     SET @channelIdOffset = 1000000 * @n;
@@ -84,7 +84,7 @@ CREATE PROCEDURE sp_city_n(IN n INT)
     call sp_data_migration_xwcmmetaviewemployer(@prevMetaViewEmployerId, @metaViewEmployerIdOffset, @viewIdOffset, @siteIdOffset, @channelIdOffset);
     call sp_data_migration_xwcmmetaviewfieldgroup(@prevMetaViewFieldGroupId, @metaViewFieldGroupIdOffset, @viewIdOffset);
     call sp_data_migration_xwcmtableinfo(@citySuffix, @prevTableInfoId, @tableInfoIdOffset);
-    call sp_data_migration_xwcmviewfieldinfo(@citySuffix, @prevViewFieldId, @viewFieldIdOffset, @tableInfoIdOffset, @prevClassInfoId, @dbFieldIdOffset, @metaViewFieldGroupIdOffset, @viewIdOffset, @viewIdOffset);
+    call sp_data_migration_xwcmviewfieldinfo(@citySuffix, @prevViewFieldInfoId, @viewFieldInfoIdOffset, @tableInfoIdOffset, @prevClassInfoId, @dbFieldIdOffset, @metaViewFieldGroupIdOffset, @viewIdOffset, @viewIdOffset);
     call sp_data_migration_xwcmviewinfo(@citySuffix, @prevViewId, @viewIdOffset, @tableInfoIdOffset);
     call sp_data_migration_wcmmetatable(@prevTableInfoId, @prevDocId, @docIdOffset, @channelIdOffset);
 

TRS.WCM.Developer/贵州项目/6_recover.sql

@@ -0,0 +1,35 @@
+
+
+
+delete from trs_hycloud_iip.wcmwebsite where siteid > 100000;
+delete from trs_hycloud_iip.xwcmviewinfo where viewinfoid > 100000;
+delete from trs_hycloud_iip.xwcmtableinfo where tableinfoid > 100000;
+delete from trs_hycloud_iip.xwcmmetaviewfieldgroup where metaviewfieldgroupid > 100000;
+
+delete from trs_hycloud_iip.xwcmclassinfoview where classinfoviewid > 100000;
+delete from trs_hycloud_iip.xwcmclassinfo where classinfoid > 100000;
+delete from trs_hycloud_iip.xwcmdbfieldinfo where dbfieldinfoid > 100000;
+delete from trs_hycloud_iip.xwcmmetaviewemployer where metaviewemployerid > 100000;
+delete from trs_hycloud_iip.xwcmviewfieldinfo where viewfieldinfoid > 100000;
+delete from trs_hycloud_iip.xwcmdbfieldinfo where dbfieldinfoid > 100000;
+
+
+
+delete from trs_hycloud_iip.wcmchannel where channelid > 1000000;
+delete from trs_hycloud_iip.wcmchannelsyn where channelsynid > 1000000;
+delete from trs_hycloud_iip.wcmtemplate where tempid > 1000000;
+delete from trs_hycloud_iip.wcmfolderpublishconfig where folderpublishconfigid > 1000000;
+delete from trs_hycloud_iip.wcmtemplateargument where templateargumentid > 1000000;
+delete from trs_hycloud_iip.wcmtemplateemploy where templateemployid > 1000000;
+delete from trs_hycloud_iip.wcmtemplatenest where templatenestid > 1000000;
+delete from trs_hycloud_iip.wcmtemplatequote where templatequoteid > 1000000;
+
+
+delete from trs_hycloud_iip.wcmappendix where appendixid > 10000000;
+delete from trs_hycloud_iip.wcmchnldoc where recid > 10000000;
+delete from trs_hycloud_iip.wcmdocument where docid > 10000000;
+
+delete from trs_mas.mas_masid where id > 1000000;
+delete from trs_mas.mas_masvideo where id > 1000000;
+
+delete from trs_data_migration.data_migration_log;