脚本支持增量更新数据2

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

@@ -39,7 +39,7 @@ CREATE PROCEDURE sp_data_migration_wcmmetatable(IN citySuffix VARCHAR(20),
 
       THEN
 
-        
+
         SET @metaTableExists = (SELECT count(1) from information_schema.tables where table_schema = 'trs_hycloud_iip' and table_name = concat('wcmmetatable', f_TABLENAME, citySuffix) );
 
         IF (@metaTableExists > 0)
@@ -53,12 +53,14 @@ CREATE PROCEDURE sp_data_migration_wcmmetatable(IN citySuffix VARCHAR(20),
             EXECUTE stmt;
             deallocate prepare stmt;
 
-            SET @doc_sql = concat('INSERT INTO trs_data_migration.meta_data(metadat_id, channel_id) SELECT MetaDataId,ChannelId FROM trs_hycloud_iip.wcmmetatable', f_TABLENAME,
-                              ' WHERE MetaDataId >  ', prevDocId);
+            SET @doc_sql = concat('INSERT INTO trs_data_migration.meta_data(metadat_id, channel_id) SELECT MetaDataId,ChannelId FROM trs_hycloud_iip.wcmmetatable',
+             f_TABLENAME, citySuffix, ' WHERE MetaDataId >  ', prevDocId);
             prepare stmt from @doc_sql;
             EXECUTE stmt;
             deallocate prepare stmt;
 
+            call sp_data_migration_wcmmetablexx(concat('wcmmetatable', f_TABLENAME, citySuffix), prevDocId, docIdOffset, channelIdOffset);
+
             select concat('完成更新 ', 'wcmmetatable', f_TABLENAME, citySuffix, '.MetaDataId & ChannelId') info;
         END IF ;