3_sp_data_migration_xwcmviewinfo.sql 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215
  1. DROP PROCEDURE IF EXISTS sp_data_migration_xwcmviewinfo;
  2. DELIMITER $$
  3. CREATE PROCEDURE sp_data_migration_xwcmviewinfo(IN citySuffix VARCHAR(20),
  4. IN prevViewId BIGINT(20),
  5. IN viewIdOffset BIGINT(20),
  6. IN mainTableIdOffset BIGINT(20))
  7. BEGIN
  8. DECLARE isover INT DEFAULT 0;
  9. DECLARE migr_table_name varchar(255) DEFAULT 'xwcmviewinfo';
  10. DECLARE tabel_migr_table_name varchar(255) DEFAULT 'xwcmtableinfo';
  11. DECLARE f_VIEWINFOID int(11) DEFAULT NULL;
  12. DECLARE f_VIEWNAME varchar(100) DEFAULT NULL;
  13. DECLARE f_VIEWDESC varchar(400) DEFAULT NULL;
  14. DECLARE f_MAINTABLENAME varchar(50) DEFAULT NULL;
  15. DECLARE f_MAINTABLEID int(11) DEFAULT NULL;
  16. DECLARE f_CRUSER varchar(30) DEFAULT NULL;
  17. DECLARE f_CRTIME datetime DEFAULT NULL;
  18. DECLARE f_OWNERTYPE int(11) DEFAULT '1';
  19. DECLARE f_OWNERID int(11) DEFAULT '4';
  20. DECLARE f_HIDDENAPPENDIX smallint(6) DEFAULT '0';
  21. DECLARE f_ISSPECIAL int(11) DEFAULT NULL;
  22. DECLARE f_VIEWCLASSID int(11) DEFAULT NULL;
  23. DECLARE f_VIEWDESCCON varchar(500) DEFAULT NULL;
  24. DECLARE f_METASYNFIELDS varchar(500) DEFAULT NULL;
  25. DECLARE f_TEMPLATEPATH varchar(50) DEFAULT NULL;
  26. DECLARE f_HIDDENFILEAPPENDIX smallint(6) DEFAULT '0';
  27. DECLARE f_HIDDENIMGAPPENDIX smallint(6) DEFAULT '0';
  28. DECLARE f_HIDDENLINKAPPENDIX smallint(6) DEFAULT '0';
  29. DECLARE f_Attribute varchar(500) DEFAULT NULL;
  30. DECLARE cur CURSOR FOR
  31. SELECT
  32. VIEWINFOID,
  33. VIEWNAME,
  34. VIEWDESC,
  35. MAINTABLENAME,
  36. MAINTABLEID,
  37. CRUSER,
  38. CRTIME,
  39. OWNERTYPE,
  40. OWNERID,
  41. HIDDENAPPENDIX,
  42. ISSPECIAL,
  43. VIEWCLASSID,
  44. VIEWDESCCON,
  45. METASYNFIELDS,
  46. 'templateDynamic',
  47. 1,
  48. 1,
  49. 1,
  50. null
  51. FROM xwcmviewinfo
  52. ORDER BY VIEWINFOID asc;
  53. DECLARE CONTINUE HANDLER FOR NOT FOUND SET isover = 1;
  54. OPEN cur;
  55. FETCH cur INTO
  56. f_VIEWINFOID,
  57. f_VIEWNAME,
  58. f_VIEWDESC,
  59. f_MAINTABLENAME,
  60. f_MAINTABLEID,
  61. f_CRUSER,
  62. f_CRTIME,
  63. f_OWNERTYPE,
  64. f_OWNERID,
  65. f_HIDDENAPPENDIX,
  66. f_ISSPECIAL,
  67. f_VIEWCLASSID,
  68. f_VIEWDESCCON,
  69. f_METASYNFIELDS,
  70. f_TEMPLATEPATH,
  71. f_HIDDENFILEAPPENDIX,
  72. f_HIDDENIMGAPPENDIX,
  73. f_HIDDENLINKAPPENDIX,
  74. f_Attribute
  75. ;
  76. select concat('开始迁移 ', migr_table_name) info;
  77. WHILE isover= 0 DO
  78. # 断点续传
  79. IF (f_VIEWINFOID > prevViewId)
  80. THEN
  81. SET @VIEWINFOID = f_VIEWINFOID;
  82. SET f_VIEWINFOID = f_VIEWINFOID + viewIdOffset;
  83. SET @table_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = tabel_migr_table_name AND start_id < f_MAINTABLEID and end_id >= f_MAINTABLEID), mainTableIdOffset);
  84. SET f_MAINTABLEID = f_MAINTABLEID + @table_offset_num;
  85. insert into trs_hycloud_iip.xwcmviewinfo
  86. (
  87. VIEWINFOID,
  88. VIEWNAME,
  89. VIEWDESC,
  90. MAINTABLENAME,
  91. MAINTABLEID,
  92. CRUSER,
  93. CRTIME,
  94. OWNERTYPE,
  95. OWNERID,
  96. HIDDENAPPENDIX,
  97. ISSPECIAL,
  98. VIEWCLASSID,
  99. VIEWDESCCON,
  100. METASYNFIELDS,
  101. TEMPLATEPATH,
  102. HIDDENFILEAPPENDIX,
  103. HIDDENIMGAPPENDIX,
  104. HIDDENLINKAPPENDIX,
  105. Attribute
  106. )
  107. VALUES
  108. (
  109. f_VIEWINFOID,
  110. concat(f_VIEWNAME, citySuffix),
  111. concat(f_VIEWDESC, citySuffix),
  112. concat(f_MAINTABLENAME, citySuffix),
  113. f_MAINTABLEID,
  114. f_CRUSER,
  115. f_CRTIME,
  116. f_OWNERTYPE,
  117. f_OWNERID,
  118. f_HIDDENAPPENDIX,
  119. f_ISSPECIAL,
  120. f_VIEWCLASSID,
  121. f_VIEWDESCCON,
  122. f_METASYNFIELDS,
  123. f_TEMPLATEPATH,
  124. f_HIDDENFILEAPPENDIX,
  125. f_HIDDENIMGAPPENDIX,
  126. f_HIDDENLINKAPPENDIX,
  127. f_Attribute
  128. );
  129. SET @v_gpId = ifnull((SELECT max(METAVIEWFIELDGROUPID) from trs_hycloud_iip.xwcmmetaviewfieldgroup), 0);
  130. SET @savefieldgroup_sql = concat('insert into ',
  131. 'trs_hycloud_iip.xwcmmetaviewfieldgroup (',
  132. 'METAVIEWFIELDGROUPID,',
  133. 'GROUPNAME,',
  134. 'METAVIEWID,',
  135. 'PARENTID,',
  136. 'CRUSER,',
  137. 'CRTIME,',
  138. 'GROUPORDER',
  139. ') ',
  140. 'values(',
  141. (@v_gpId + 1), ',',
  142. '\'', '基本属性', '\',',
  143. f_VIEWINFOID, ',',
  144. 0,',',
  145. '\'', 'admin', '\',',
  146. '\'', now(), '\',',
  147. '1',
  148. ') ');
  149. prepare stmt from @savefieldgroup_sql;
  150. EXECUTE stmt;
  151. deallocate prepare stmt;
  152. SET @log_sql = build_migration_log_sql(migr_table_name, @VIEWINFOID, now());
  153. prepare stmt from @log_sql;
  154. EXECUTE stmt;
  155. deallocate prepare stmt;
  156. call setOffset(migr_table_name, viewIdOffset, prevViewId, @VIEWINFOID);
  157. END IF ;
  158. FETCH cur INTO
  159. f_VIEWINFOID,
  160. f_VIEWNAME,
  161. f_VIEWDESC,
  162. f_MAINTABLENAME,
  163. f_MAINTABLEID,
  164. f_CRUSER,
  165. f_CRTIME,
  166. f_OWNERTYPE,
  167. f_OWNERID,
  168. f_HIDDENAPPENDIX,
  169. f_ISSPECIAL,
  170. f_VIEWCLASSID,
  171. f_VIEWDESCCON,
  172. f_METASYNFIELDS,
  173. f_TEMPLATEPATH,
  174. f_HIDDENFILEAPPENDIX,
  175. f_HIDDENIMGAPPENDIX,
  176. f_HIDDENLINKAPPENDIX,
  177. f_Attribute
  178. ;
  179. END WHILE;
  180. CLOSE cur;
  181. select concat('完成迁移 ', migr_table_name) info;
  182. END $$
  183. DELIMITER ;