数据迁移的存储过程[9]

TRS.WCM.Developer/贵州项目/MigrationSteps.md

@@ -1,38 +1,44 @@
 
-# 运行 sp 目录下的所有 p_data_migration_... 存储过程
+# 进入海云数据库，运行 sp 目录下的所有 p_data_migration_... 存储过程
 
-# 迁移第一个节点 
-##### 查看海云数据库中是否有 schema 名称为 v_wcm，如果有，则删除
-##### 借助 navicat 工具，将 cmwcm_city1 数据库中的所有数据（结构+数据）复制到海云数据库，schema 命名为 v_wcm
-##### 将 cmwcm_city1 数据库中的所有元数据表重命名（加上后缀 '_city1'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+# 迁移第一个 wcm 节点 
+##### 在海云数据库中新建一个空的名称为 v_wcm 的 schema
+##### 借助 navicat 工具，将 cmwcm_city1 数据库中的所有数据（结构+数据）复制到海云数据库，schema 是 v_wcm
+##### 将 v_wcm 数据库中的所有元数据表重命名（加上后缀 '_city1'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 在 v_wcm 库上执行 IIP_V8.0.15.0_bigtable_full.sql 和 IIP_V8.0.15.0_full.sql，将 v_wcm 升级到海云采编迭代十五
 ##### 在linux环境下SQL命令行中执行 call_p_city1.sql
 
-# 迁移第二个节点 
-##### 查看海云数据库中是否有 schema 名称为 v_wcm，如果有，则删除
+# 迁移第二个 wcm 节点 
+##### 在海云数据库中新建一个空的名称为 v_wcm 的 schema
 ##### 借助 navicat 工具，将 cmwcm_city2 数据库中的所有数据（结构+数据）复制到海云数据库，schema 命名为 v_wcm
-##### 将 cmwcm_city2 数据库中的所有元数据表重命名（加上后缀 '_city2'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 将 v_wcm 数据库中的所有元数据表重命名（加上后缀 '_city2'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 在 v_wcm 库上执行 IIP_V8.0.15.0.sql，将 v_wcm 升级到海云采编迭代十五
 ##### 在linux环境下SQL命令行中执行 call_p_city2.sql
 
-# 迁移第三个节点 
-##### 查看海云数据库中是否有 schema 名称为 v_wcm，如果有，则删除
+# 迁移第三个 wcm 节点 
+##### 在海云数据库中新建一个空的名称为 v_wcm 的 schema
 ##### 借助 navicat 工具，将 cmwcm_city3 数据库中的所有数据（结构+数据）复制到海云数据库，schema 命名为 v_wcm
-##### 将 cmwcm_city3 数据库中的所有元数据表重命名（加上后缀 '_city3'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 将 v_wcm 数据库中的所有元数据表重命名（加上后缀 '_city3'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 在 v_wcm 库上执行 IIP_V8.0.15.0_bigtable_full.sql 和 IIP_V8.0.15.0_full.sql，将 v_wcm 升级到海云采编迭代十五
 ##### 在linux环境下SQL命令行中执行 call_p_city3.sql
 
-# 迁移第四个节点
-##### 查看海云数据库中是否有 schema 名称为 v_wcm，如果有，则删除
+# 迁移第四个 wcm 节点
+##### 在海云数据库中新建一个空的名称为 v_wcm 的 schema
 ##### 借助 navicat 工具，将 cmwcm_city4 数据库中的所有数据（结构+数据）复制到海云数据库，schema 命名为 v_wcm
-##### 将 cmwcm_city4 数据库中的所有元数据表重命名（加上后缀 '_city4'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 将 v_wcm 数据库中的所有元数据表重命名（加上后缀 '_city4'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 在 v_wcm 库上执行 IIP_V8.0.15.0_bigtable_full.sql 和 IIP_V8.0.15.0_full.sql，将 v_wcm 升级到海云采编迭代十五
 ##### 在linux环境下SQL命令行中执行 call_p_city4.sql
 
-# 迁移第五个节点
-##### 查看海云数据库中是否有 schema 名称为 v_wcm，如果有，则删除
+# 迁移第五个 wcm 节点
+##### 在海云数据库中新建一个空的名称为 v_wcm 的 schema
 ##### 借助 navicat 工具，将 cmwcm_city5 数据库中的所有数据（结构+数据）复制到海云数据库，schema 命名为 v_wcm
-##### 将 cmwcm_city5 数据库中的所有元数据表重命名（加上后缀 '_city5'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 将 v_wcm 数据库中的所有元数据表重命名（加上后缀 '_city5'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 在 v_wcm 库上执行 IIP_V8.0.15.0_bigtable_full.sql 和 IIP_V8.0.15.0_full.sql，将 v_wcm 升级到海云采编迭代十五
 ##### 在linux环境下SQL命令行中执行 call_p_city5.sql
 
-# 迁移第六个节点
-##### 查看海云数据库中是否有 schema 名称为 v_wcm，如果有，则删除
+# 迁移第六个 wcm 节点
+##### 在海云数据库中新建一个空的名称为 v_wcm 的 schema
 ##### 借助 navicat 工具，将 cmwcm_city6 数据库中的所有数据（结构+数据）复制到海云数据库，schema 命名为 v_wcm
-##### 将 cmwcm_city6 数据库中的所有元数据表重命名（加上后缀 '_city6'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 将 v_wcm 数据库中的所有元数据表重命名（加上后缀 '_city6'），并复制（结构+数据）至海云trs_hycloud_iip数据库下
+##### 在 v_wcm 库上执行 IIP_V8.0.15.0_bigtable_full.sql 和 IIP_V8.0.15.0_full.sql，将 v_wcm 升级到海云采编迭代十五
 ##### 在linux环境下SQL命令行中执行 call_p_city6.sql

TRS.WCM.Developer/贵州项目/sp/call_p_city1.sql

@@ -34,6 +34,7 @@ SET @prevTableInfoId = 0;
 SET @prevViewFieldId = 0;
 SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
+SET @prevAppendixId = 0;
 
 
 
@@ -58,9 +59,11 @@ SET @viewFieldIdOffset = 100000 * @n;
 SET @dbFieldIdOffset = 100000 * @n;
 SET @fieldGroupIdOffset = 1000 * @n;
 SET @metaViewFieldGroupIdOffset = 1000 * @n;
+SET @appendixIdOffset = 10000000 * @n;
 
 
 
+call p_data_migration_wcmchannel(@prevAppendixId, @appendixIdOffset, @docIdOffset);
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelchildindexquote(@templateIdOffset, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelsyn(@prevChannelSynId, @channelSynIdOffset, @channelIdOffset);

TRS.WCM.Developer/贵州项目/sp/call_p_city2.sql

@@ -5,7 +5,6 @@ pager cat >> /home/p_data_migration_city2.log;
 
 use trs_hycloud_iip;
 
-
 # 每迁移一个wcm节点，@n 必须手动 +1
 SET @n = 2;
 
@@ -35,6 +34,7 @@ SET @prevTableInfoId = 0;
 SET @prevViewFieldId = 0;
 SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
+SET @prevAppendixId = 0;
 
 
 
@@ -59,9 +59,11 @@ SET @viewFieldIdOffset = 100000 * @n;
 SET @dbFieldIdOffset = 100000 * @n;
 SET @fieldGroupIdOffset = 1000 * @n;
 SET @metaViewFieldGroupIdOffset = 1000 * @n;
+SET @appendixIdOffset = 10000000 * @n;
 
 
 
+call p_data_migration_wcmchannel(@prevAppendixId, @appendixIdOffset, @docIdOffset);
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelchildindexquote(@templateIdOffset, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelsyn(@prevChannelSynId, @channelSynIdOffset, @channelIdOffset);

TRS.WCM.Developer/贵州项目/sp/call_p_city3.sql

@@ -5,7 +5,6 @@ pager cat >> /home/p_data_migration_city3.log;
 
 use trs_hycloud_iip;
 
-
 # 每迁移一个wcm节点，@n 必须手动 +1
 SET @n = 3;
 
@@ -35,6 +34,7 @@ SET @prevTableInfoId = 0;
 SET @prevViewFieldId = 0;
 SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
+SET @prevAppendixId = 0;
 
 
 
@@ -59,9 +59,11 @@ SET @viewFieldIdOffset = 100000 * @n;
 SET @dbFieldIdOffset = 100000 * @n;
 SET @fieldGroupIdOffset = 1000 * @n;
 SET @metaViewFieldGroupIdOffset = 1000 * @n;
+SET @appendixIdOffset = 10000000 * @n;
 
 
 
+call p_data_migration_wcmchannel(@prevAppendixId, @appendixIdOffset, @docIdOffset);
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelchildindexquote(@templateIdOffset, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelsyn(@prevChannelSynId, @channelSynIdOffset, @channelIdOffset);

TRS.WCM.Developer/贵州项目/sp/call_p_city4.sql

@@ -5,7 +5,6 @@ pager cat >> /home/p_data_migration_city4.log;
 
 use trs_hycloud_iip;
 
-
 # 每迁移一个wcm节点，@n 必须手动 +1
 SET @n = 4;
 
@@ -35,6 +34,7 @@ SET @prevTableInfoId = 0;
 SET @prevViewFieldId = 0;
 SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
+SET @prevAppendixId = 0;
 
 
 
@@ -59,9 +59,11 @@ SET @viewFieldIdOffset = 100000 * @n;
 SET @dbFieldIdOffset = 100000 * @n;
 SET @fieldGroupIdOffset = 1000 * @n;
 SET @metaViewFieldGroupIdOffset = 1000 * @n;
+SET @appendixIdOffset = 10000000 * @n;
 
 
 
+call p_data_migration_wcmchannel(@prevAppendixId, @appendixIdOffset, @docIdOffset);
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelchildindexquote(@templateIdOffset, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelsyn(@prevChannelSynId, @channelSynIdOffset, @channelIdOffset);

TRS.WCM.Developer/贵州项目/sp/call_p_city5.sql

@@ -5,7 +5,6 @@ pager cat >> /home/p_data_migration_city5.log;
 
 use trs_hycloud_iip;
 
-
 # 每迁移一个wcm节点，@n 必须手动 +1
 SET @n = 5;
 
@@ -35,6 +34,7 @@ SET @prevTableInfoId = 0;
 SET @prevViewFieldId = 0;
 SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
+SET @prevAppendixId = 0;
 
 
 
@@ -59,9 +59,11 @@ SET @viewFieldIdOffset = 100000 * @n;
 SET @dbFieldIdOffset = 100000 * @n;
 SET @fieldGroupIdOffset = 1000 * @n;
 SET @metaViewFieldGroupIdOffset = 1000 * @n;
+SET @appendixIdOffset = 10000000 * @n;
 
 
 
+call p_data_migration_wcmchannel(@prevAppendixId, @appendixIdOffset, @docIdOffset);
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelchildindexquote(@templateIdOffset, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelsyn(@prevChannelSynId, @channelSynIdOffset, @channelIdOffset);

TRS.WCM.Developer/贵州项目/sp/call_p_city6.sql

@@ -5,7 +5,6 @@ pager cat >> /home/p_data_migration_city6.log;
 
 use trs_hycloud_iip;
 
-
 # 每迁移一个wcm节点，@n 必须手动 +1
 SET @n = 6;
 
@@ -35,6 +34,7 @@ SET @prevTableInfoId = 0;
 SET @prevViewFieldId = 0;
 SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
+SET @prevAppendixId = 0;
 
 
 
@@ -59,9 +59,11 @@ SET @viewFieldIdOffset = 100000 * @n;
 SET @dbFieldIdOffset = 100000 * @n;
 SET @fieldGroupIdOffset = 1000 * @n;
 SET @metaViewFieldGroupIdOffset = 1000 * @n;
+SET @appendixIdOffset = 10000000 * @n;
 
 
 
+call p_data_migration_wcmchannel(@prevAppendixId, @appendixIdOffset, @docIdOffset);
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelchildindexquote(@templateIdOffset, @siteIdOffset, @channelIdOffset);
 call p_data_migration_wcmchannelsyn(@prevChannelSynId, @channelSynIdOffset, @channelIdOffset);

TRS.WCM.Developer/贵州项目/sp/p_data_migration_wcmappendix.sql

@@ -0,0 +1,211 @@
+
+use trs_hycloud_iip;
+
+DROP PROCEDURE IF EXISTS p_data_migration_wcmappendix;
+DELIMITER $$
+CREATE PROCEDURE p_data_migration_wcmappendix(IN prevAppendixId BIGINT(20),
+                                              IN appendixIdOffset BIGINT(20),
+                                              IN docIdOffset BIGINT(20))
+	BEGIN
+	
+	DECLARE isover INT DEFAULT 0;
+
+    DECLARE f_APPENDIXID int(11) DEFAULT 0;
+    DECLARE f_APPDOCID int(11) DEFAULT 0;
+    DECLARE f_APPFILE varchar(255) DEFAULT 0;
+    DECLARE f_APPFILETYPE int(11) DEFAULT '-1';
+    DECLARE f_APPDESC varchar(400) DEFAULT NULL;
+    DECLARE f_APPLINKALT varchar(255) DEFAULT NULL;
+    DECLARE f_APPSERN int(11) DEFAULT NULL;
+    DECLARE f_APPPROP int(11) DEFAULT NULL;
+    DECLARE f_APPFLAG smallint(6) DEFAULT NULL;
+    DECLARE f_APPTIME datetime DEFAULT NULL;
+    DECLARE f_APPAUTHOR varchar(100) DEFAULT NULL;
+    DECLARE f_APPEDITOR varchar(100) DEFAULT NULL;
+    DECLARE f_ATTRIBUTE varchar(500) DEFAULT NULL;
+    DECLARE f_USEDVERSIONS decimal(30,0) DEFAULT '1';
+    DECLARE f_CRUSER varchar(50) DEFAULT NULL;
+    DECLARE f_CRTIME datetime DEFAULT NULL;
+    DECLARE f_SRCFILE varchar(400) DEFAULT NULL;
+    DECLARE f_FILEEXT varchar(20) DEFAULT NULL;
+    DECLARE f_ISIMPORTTOIMAGELIB int(11) DEFAULT '0';
+    DECLARE f_RELATEDCOLUMN varchar(200) DEFAULT NULL;
+    DECLARE f_RELATEPHOTOIDS varchar(100) DEFAULT NULL;
+    DECLARE f_APPDESC2 varchar(300) DEFAULT NULL;
+    DECLARE f_ATTRIBUTES varchar(800) DEFAULT NULL;
+    DECLARE f_AppFromType int(11) DEFAULT '0';
+    DECLARE f_AppFromId int(11) DEFAULT '0';
+
+
+
+  DECLARE cur CURSOR FOR
+		SELECT
+      APPENDIXID,
+      APPDOCID,
+      APPFILE,
+      APPFILETYPE,
+      APPDESC,
+      APPLINKALT,
+      APPSERN,
+      APPPROP,
+      APPFLAG,
+      APPTIME,
+      APPAUTHOR,
+      APPEDITOR,
+      ATTRIBUTE,
+      USEDVERSIONS,
+      CRUSER,
+      CRTIME,
+      SRCFILE,
+      FILEEXT,
+      ISIMPORTTOIMAGELIB,
+      RELATEDCOLUMN,
+      RELATEPHOTOIDS,
+      APPDESC2,
+      ATTRIBUTES,
+      AppFromType,
+      AppFromId
+    FROM v_wcm.wcmappendix
+		ORDER BY APPENDIXID asc;
+
+	DECLARE CONTINUE HANDLER FOR NOT FOUND SET isover = 1;
+	
+	OPEN cur;
+	
+	FETCH cur INTO
+    f_APPENDIXID,
+    f_APPDOCID,
+    f_APPFILE,
+    f_APPFILETYPE,
+    f_APPDESC,
+    f_APPLINKALT,
+    f_APPSERN,
+    f_APPPROP,
+    f_APPFLAG,
+    f_APPTIME,
+    f_APPAUTHOR,
+    f_APPEDITOR,
+    f_ATTRIBUTE,
+    f_USEDVERSIONS,
+    f_CRUSER,
+    f_CRTIME,
+    f_SRCFILE,
+    f_FILEEXT,
+    f_ISIMPORTTOIMAGELIB,
+    f_RELATEDCOLUMN,
+    f_RELATEPHOTOIDS,
+    f_APPDESC2,
+    f_ATTRIBUTES,
+    f_AppFromType,
+    f_AppFromId
+    ;
+
+
+
+    WHILE isover = 0 DO
+
+      # 断点续传
+      IF (f_APPENDIXID > prevAppendixId)
+
+        THEN
+
+            SET @APPENDIXID = f_APPENDIXID;
+            SET f_APPENDIXID = f_APPENDIXID + appendixIdOffset;
+            SET f_APPDOCID = f_APPDOCID + docIdOffset;
+
+            insert into trs_hycloud_iip.wcmappendix
+              (
+                APPENDIXID,
+                APPDOCID,
+                APPFILE,
+                APPFILETYPE,
+                APPDESC,
+                APPLINKALT,
+                APPSERN,
+                APPPROP,
+                APPFLAG,
+                APPTIME,
+                APPAUTHOR,
+                APPEDITOR,
+                ATTRIBUTE,
+                USEDVERSIONS,
+                CRUSER,
+                CRTIME,
+                SRCFILE,
+                FILEEXT,
+                ISIMPORTTOIMAGELIB,
+                RELATEDCOLUMN,
+                RELATEPHOTOIDS,
+                APPDESC2,
+                ATTRIBUTES,
+                AppFromType,
+                AppFromId
+              )
+              VALUES
+                (
+                  f_APPENDIXID,
+                  f_APPDOCID,
+                  f_APPFILE,
+                  f_APPFILETYPE,
+                  f_APPDESC,
+                  f_APPLINKALT,
+                  f_APPSERN,
+                  f_APPPROP,
+                  f_APPFLAG,
+                  f_APPTIME,
+                  f_APPAUTHOR,
+                  f_APPEDITOR,
+                  f_ATTRIBUTE,
+                  f_USEDVERSIONS,
+                  f_CRUSER,
+                  f_CRTIME,
+                  f_SRCFILE,
+                  f_FILEEXT,
+                  f_ISIMPORTTOIMAGELIB,
+                  f_RELATEDCOLUMN,
+                  f_RELATEPHOTOIDS,
+                  f_APPDESC2,
+                  f_ATTRIBUTES,
+                  f_AppFromType,
+                  f_AppFromId
+                );
+
+            SELECT CONCAT('成功迁移 wcmappendix[APPENDIXID=', @APPENDIXID, ']') ;
+    END IF ;
+
+		FETCH cur INTO
+      f_APPENDIXID,
+      f_APPDOCID,
+      f_APPFILE,
+      f_APPFILETYPE,
+      f_APPDESC,
+      f_APPLINKALT,
+      f_APPSERN,
+      f_APPPROP,
+      f_APPFLAG,
+      f_APPTIME,
+      f_APPAUTHOR,
+      f_APPEDITOR,
+      f_ATTRIBUTE,
+      f_USEDVERSIONS,
+      f_CRUSER,
+      f_CRTIME,
+      f_SRCFILE,
+      f_FILEEXT,
+      f_ISIMPORTTOIMAGELIB,
+      f_RELATEDCOLUMN,
+      f_RELATEPHOTOIDS,
+      f_APPDESC2,
+      f_ATTRIBUTES,
+      f_AppFromType,
+      f_AppFromId
+      ;
+		
+	END WHILE;
+	
+	CLOSE cur;
+
+  SELECT '迁移 wcmappendix 完毕';
+		
+	END $$
+DELIMITER ;