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

TRS.WCM.Developer/sp/call_p.sql

@@ -1,14 +1,21 @@
 
 
 # ！！！执行存储过程前，需要提前将所有元数据表（结构+数据）直接复制至海云
-# ！！！执行存储过程前，需要提前将所有元数据表（结构+数据）直接复制至海云
-# ！！！执行存储过程前，需要提前将所有元数据表（结构+数据）直接复制至海云
-# ！！！如果存在重名的元数据表，则终止，并反馈给研发
+# 并按照city1-city6给所有元数据表加上后缀 '_city1', '_city2', '_city3', '_city4', '_city5', '_city6'
 
 
 pager cat >> /tmp/p_data_migration.log;
 
 
+# 每迁移一个wcm节点，@n 必须手动 +1
+SET @n = 1;
+
+# 每个wcm节点，元数据表需要加上后缀，以区分同名元数据表
+SET @citySuffix = concat('_city', @n);
+
+
+
+
 # 支持断点续传，上一次迁移的最后一个 xx ID
 SET @prevSiteId = 0;
 SET @prevChannelId = 0;
@@ -31,27 +38,29 @@ SET @prevViewId = 0;
 SET @prevMetaViewFieldGroupId = 0;
 
 
+
 # xx ID 偏移量，为了和海云系统中的 xx ID 错开一段距离
-SET @siteIdOffset = 1000;
-SET @channelIdOffset = 100000;
-SET @channelSynIdOffset = 100000;
-SET @templateIdOffset = 100000;
-SET @recIdOffset = 1000000;
-SET @docIdOffset = 1000000;
-SET @viewIdOffset = 1000;
-SET @folderPublishConfigIdOffset = 100000;
-SET @templateArgIdOffset = 100000;
-SET @templateEmployIdOffset = 100000;
-SET @templateNestIdOffset = 100000;
-SET @templateQuoteIdOffset = 100000;
-SET @classInfoIdOffset = 10000;
-SET @fieldIdOffset = 100000;
-SET @tableInfoIdOffset = 1000;
-SET @metaViewEmployerIdOffset = 100000;
-SET @viewFieldIdOffset = 100000;
-SET @dbFieldIdOffset = 100000;
-SET @fieldGroupIdOffset = 1000;
-SET @metaViewFieldGroupIdOffset = 1000;
+SET @siteIdOffset = 1000 * @n;
+SET @channelIdOffset = 100000 * @n;
+SET @channelSynIdOffset = 100000 * @n;
+SET @templateIdOffset = 100000 * @n;
+SET @recIdOffset = 10000000 * @n;
+SET @docIdOffset = 10000000 * @n;
+SET @viewIdOffset = 1000 * @n;
+SET @folderPublishConfigIdOffset = 100000 * @n;
+SET @templateArgIdOffset = 100000 * @n;
+SET @templateEmployIdOffset = 1000000 * @n;
+SET @templateNestIdOffset = 100000 * @n;
+SET @templateQuoteIdOffset = 1000000 * @n;
+SET @classInfoIdOffset = 10000 * @n;
+SET @fieldIdOffset = 100000 * @n;
+SET @tableInfoIdOffset = 1000 * @n;
+SET @metaViewEmployerIdOffset = 100000 * @n;
+SET @viewFieldIdOffset = 100000 * @n;
+SET @dbFieldIdOffset = 100000 * @n;
+SET @fieldGroupIdOffset = 1000 * @n;
+SET @metaViewFieldGroupIdOffset = 1000 * @n;
+
 
 
 call p_data_migration_wcmchannel(@prevChannelId, @siteIdOffset, @channelIdOffset);
@@ -68,13 +77,13 @@ call p_data_migration_wcmtemplatequote(@prevTemplateQuoteId, @templateQuoteIdOff
 call p_data_migration_wcmwebsite(@prevSiteId, @siteIdOffset);
 call p_data_migration_xwcmclassinfo(@prevClassInfoId, @classInfoIdOffset);
 call p_data_migration_xwcmclassinfoview(@prevClassInfoViewId, @classInfoIdOffset, @docIdOffset, @viewIdOffset);
-call p_data_migration_xwcmdbinfo(@prevFieldId, @fieldIdOffset, @prevClassInfoId, @tableInfoIdOffset);
+call p_data_migration_xwcmdbinfo(@citySuffix, @prevFieldId, @fieldIdOffset, @prevClassInfoId, @tableInfoIdOffset);
 call p_data_migration_xwcmmetaviewemployer(@prevMetaViewEmployerId, @metaViewEmployerIdOffset, @channelIdOffset);
-call p_data_migration_xwcmtableinfo(@prevTableInfoId, @tableInfoIdOffset);
-call p_data_migration_wcmmetatable(@prevTableInfoId, @prevDocId, @docIdOffset, @channelIdOffset);
-call p_data_migration_xwcmviewfieldinfo(@prevViewFieldId, @viewFieldIdOffset, @tableInfoIdOffset, @prevClassInfoId, @dbFieldIdOffset, @fieldGroupIdOffset, @viewIdOffset, @viewIdOffset);
-call p_data_migration_xwcmviewinfo(@prevViewId, @viewIdOffset, @mainTableIdOffset);
 call p_data_migration_xwcmmetaviewfieldgroup(@prevMetaViewFieldGroupId, @metaViewFieldGroupIdOffset, @viewIdOffset);
+call p_data_migration_xwcmtableinfo(@citySuffix, @prevTableInfoId, @tableInfoIdOffset);
+call p_data_migration_xwcmviewfieldinfo(@citySuffix, @prevViewFieldId, @viewFieldIdOffset, @tableInfoIdOffset, @prevClassInfoId, @dbFieldIdOffset, @fieldGroupIdOffset, @viewIdOffset, @viewIdOffset);
+call p_data_migration_xwcmviewinfo(@citySuffix, @prevViewId, @viewIdOffset, @mainTableIdOffset);
+call p_data_migration_wcmmetatable(@prevTableInfoId, @prevDocId, @docIdOffset, @channelIdOffset);
 
 
 nopager;

TRS.WCM.Developer/sp/p_data_migration_xwcmdbinfo.sql

@@ -1,7 +1,8 @@
 
 DROP PROCEDURE IF EXISTS p_data_migration_xwcmdbfieldinfo;
 DELIMITER $$
-CREATE PROCEDURE p_data_migration_xwcmdbfieldinfo(IN prevFieldId BIGINT(20),
+CREATE PROCEDURE p_data_migration_xwcmdbfieldinfo(IN citySuffix VARCHAR(20),
+                                              IN prevFieldId BIGINT(20),
                                               IN fieldIdOffset BIGINT(20),
                                               IN classInfoIdOffset BIGINT(20),
                                               IN tableIdOffset BIGINT(20))
@@ -119,7 +120,7 @@ CREATE PROCEDURE p_data_migration_xwcmdbfieldinfo(IN prevFieldId BIGINT(20),
               VALUES
                 (
                   f_DBFIELDINFOID,
-                  f_TABLENAME,
+                  concat(f_TABLENAME, citySuffix),
                   f_TABLEID,
                   f_FIELDNAME,
                   f_ANOTHERNAME,

TRS.WCM.Developer/sp/p_data_migration_xwcmtableinfo.sql

@@ -1,7 +1,8 @@
 
 DROP PROCEDURE IF EXISTS p_data_migration_xwcmtableinfo;
 DELIMITER $$
-CREATE PROCEDURE p_data_migration_xwcmtableinfo(IN prevTableInfoId BIGINT(20),
+CREATE PROCEDURE p_data_migration_xwcmtableinfo(IN citySuffix VARCHAR(20),
+                                              IN prevTableInfoId BIGINT(20),
                                               IN tableInfoIdOffset BIGINT(20))
 	BEGIN 
 	
@@ -71,9 +72,9 @@ CREATE PROCEDURE p_data_migration_xwcmtableinfo(IN prevTableInfoId BIGINT(20),
               VALUES
                 (
                   f_TABLEINFOID,
-                  f_TABLENAME,
-                  f_ANOTHERNAME,
-                  f_TABLEDESC,
+                  concat(f_TABLENAME, citySuffix),
+                  concat(f_ANOTHERNAME, citySuffix),
+                  concat(f_TABLEDESC, citySuffix),
                   f_CRUSER,
                   f_CRTIME,
                   f_OWNERTYPE,

TRS.WCM.Developer/sp/p_data_migration_xwcmviewfieldinfo.sql

@@ -1,7 +1,8 @@
 
 DROP PROCEDURE IF EXISTS p_data_migration_xwcmviewfieldinfo;
 DELIMITER $$
-CREATE PROCEDURE p_data_migration_xwcmviewfieldinfo(IN prevViewFieldId BIGINT(20),
+CREATE PROCEDURE p_data_migration_xwcmviewfieldinfo(IN citySuffix VARCHAR(20),
+                                              IN prevViewFieldId BIGINT(20),
                                               IN viewFieldIdOffset BIGINT(20),
                                               IN tableInfoIdOffset BIGINT(20),
                                               IN classIdOffset BIGINT(20),
@@ -220,7 +221,7 @@ CREATE PROCEDURE p_data_migration_xwcmviewfieldinfo(IN prevViewFieldId BIGINT(20
               VALUES
                 (
                   f_VIEWFIELDINFOID,
-                  f_TABLENAME,
+                  concat(f_TABLENAME, citySuffix),
                   f_TABLEID,
                   f_FIELDNAME,
                   f_DBFIELDNAME,

TRS.WCM.Developer/sp/p_data_migration_xwcmviewinfo.sql

@@ -1,7 +1,8 @@
 
 DROP PROCEDURE IF EXISTS p_data_migration_xwcmviewinfo;
 DELIMITER $$
-CREATE PROCEDURE p_data_migration_xwcmviewinfo(IN prevViewId BIGINT(20),
+CREATE PROCEDURE p_data_migration_xwcmviewinfo(IN citySuffix VARCHAR(20),
+                                              IN prevViewId BIGINT(20),
                                               IN viewIdOffset BIGINT(20),
                                               IN mainTableIdOffset BIGINT(20))
 	BEGIN 
@@ -117,9 +118,9 @@ CREATE PROCEDURE p_data_migration_xwcmviewinfo(IN prevViewId BIGINT(20),
               VALUES
                 (
                   f_VIEWINFOID,
-                  f_VIEWNAME,
-                  f_VIEWDESC,
-                  f_MAINTABLENAME,
+                  concat(f_VIEWNAME, citySuffix),
+                  concat(f_VIEWDESC, citySuffix),
+                  concat(f_MAINTABLENAME, citySuffix),
                   f_MAINTABLEID,
                   f_CRUSER,
                   f_CRTIME,