p_data_migration_xwcmdbinfo.sql 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177
  1. use trs_hycloud_iip;
  2. DROP PROCEDURE IF EXISTS p_data_migration_xwcmdbfieldinfo;
  3. DELIMITER $$
  4. CREATE PROCEDURE p_data_migration_xwcmdbfieldinfo(IN citySuffix VARCHAR(20),
  5. IN prevFieldId BIGINT(20),
  6. IN fieldIdOffset BIGINT(20),
  7. IN classInfoIdOffset BIGINT(20),
  8. IN tableIdOffset BIGINT(20))
  9. BEGIN
  10. DECLARE isover INT DEFAULT 0;
  11. DECLARE f_DBFIELDINFOID int(11) DEFAULT NULL;
  12. DECLARE f_TABLENAME varchar(50) DEFAULT '0';
  13. DECLARE f_TABLEID int(11) DEFAULT '0';
  14. DECLARE f_FIELDNAME varchar(50) DEFAULT '0';
  15. DECLARE f_ANOTHERNAME varchar(200) DEFAULT '0';
  16. DECLARE f_FIELDTYPE int(11) DEFAULT '0';
  17. DECLARE f_DBTYPE int(11) DEFAULT '0';
  18. DECLARE f_DBLENGTH int(11) DEFAULT '0';
  19. DECLARE f_DEFAULTVALUE varchar(200) DEFAULT NULL;
  20. DECLARE f_ENMVALUE varchar(1000) DEFAULT NULL;
  21. DECLARE f_NOTNULL smallint(6) DEFAULT NULL;
  22. DECLARE f_CLASSID int(11) DEFAULT '0';
  23. DECLARE f_DBSCALE int(11) DEFAULT '0';
  24. DECLARE f_CRUSER varchar(30) DEFAULT NULL;
  25. DECLARE f_CRTIME datetime DEFAULT NULL;
  26. DECLARE f_VALIDATOR varchar(200) DEFAULT NULL;
  27. DECLARE f_RADORCHK smallint(6) DEFAULT NULL;
  28. DECLARE f_NOTEDIT smallint(6) DEFAULT '0';
  29. DECLARE f_HIDDENFIELD smallint(6) DEFAULT '0';
  30. DECLARE cur CURSOR FOR
  31. SELECT
  32. DBFIELDINFOID,
  33. TABLENAME,
  34. TABLEID,
  35. FIELDNAME,
  36. ANOTHERNAME,
  37. FIELDTYPE,
  38. DBTYPE,
  39. DBLENGTH,
  40. DEFAULTVALUE,
  41. ENMVALUE,
  42. NOTNULL,
  43. CLASSID,
  44. DBSCALE,
  45. CRUSER,
  46. CRTIME,
  47. VALIDATOR,
  48. RADORCHK,
  49. NOTEDIT,
  50. HIDDENFIELD
  51. FROM v_wcm.xwcmdbfieldinfo
  52. ORDER BY DBFIELDINFOID asc;
  53. DECLARE CONTINUE HANDLER FOR NOT FOUND SET isover = 1;
  54. OPEN cur;
  55. FETCH cur INTO
  56. f_DBFIELDINFOID,
  57. f_TABLENAME,
  58. f_TABLEID,
  59. f_FIELDNAME,
  60. f_ANOTHERNAME,
  61. f_FIELDTYPE,
  62. f_DBTYPE,
  63. f_DBLENGTH,
  64. f_DEFAULTVALUE,
  65. f_ENMVALUE,
  66. f_NOTNULL,
  67. f_CLASSID,
  68. f_DBSCALE,
  69. f_CRUSER,
  70. f_CRTIME,
  71. f_VALIDATOR,
  72. f_RADORCHK,
  73. f_NOTEDIT,
  74. f_HIDDENFIELD
  75. ;
  76. WHILE isover= 0 DO
  77. # 断点续传
  78. IF (f_DBFIELDINFOID > prevFieldId)
  79. THEN
  80. SET @DBFIELDINFOID = f_DBFIELDINFOID;
  81. SET f_DBFIELDINFOID = f_DBFIELDINFOID + fieldIdOffset;
  82. SET f_TABLEID = f_TABLEID + tableIdOffset;
  83. SET f_CLASSID = f_CLASSID + classInfoIdOffset;
  84. insert into trs_hycloud_iip.xwcmtableinfo
  85. (
  86. DBFIELDINFOID,
  87. TABLENAME,
  88. TABLEID,
  89. FIELDNAME,
  90. ANOTHERNAME,
  91. FIELDTYPE,
  92. DBTYPE,
  93. DBLENGTH,
  94. DEFAULTVALUE,
  95. ENMVALUE,
  96. NOTNULL,
  97. CLASSID,
  98. DBSCALE,
  99. CRUSER,
  100. CRTIME,
  101. VALIDATOR,
  102. RADORCHK,
  103. NOTEDIT,
  104. HIDDENFIELD
  105. )
  106. VALUES
  107. (
  108. f_DBFIELDINFOID,
  109. concat(f_TABLENAME, citySuffix),
  110. f_TABLEID,
  111. f_FIELDNAME,
  112. f_ANOTHERNAME,
  113. f_FIELDTYPE,
  114. f_DBTYPE,
  115. f_DBLENGTH,
  116. f_DEFAULTVALUE,
  117. f_ENMVALUE,
  118. f_NOTNULL,
  119. f_CLASSID,
  120. f_DBSCALE,
  121. f_CRUSER,
  122. f_CRTIME,
  123. f_VALIDATOR,
  124. f_RADORCHK,
  125. f_NOTEDIT,
  126. f_HIDDENFIELD
  127. );
  128. SELECT CONCAT('成功迁移 xwcmdbfieldinfo[DBFIELDINFOID=', @DBFIELDINFOID, ']') ;
  129. END IF ;
  130. FETCH cur INTO
  131. f_DBFIELDINFOID,
  132. f_TABLENAME,
  133. f_TABLEID,
  134. f_FIELDNAME,
  135. f_ANOTHERNAME,
  136. f_FIELDTYPE,
  137. f_DBTYPE,
  138. f_DBLENGTH,
  139. f_DEFAULTVALUE,
  140. f_ENMVALUE,
  141. f_NOTNULL,
  142. f_CLASSID,
  143. f_DBSCALE,
  144. f_CRUSER,
  145. f_CRTIME,
  146. f_VALIDATOR,
  147. f_RADORCHK,
  148. f_NOTEDIT,
  149. f_HIDDENFIELD
  150. ;
  151. END WHILE;
  152. CLOSE cur;
  153. SELECT '迁移 xwcmdbfieldinfo 完毕';
  154. END $$
  155. DELIMITER ;