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

use trs_data_migration;

DROP PROCEDURE IF EXISTS p_data_migration_xwcmclassinfoview;
DELIMITER $$
CREATE PROCEDURE p_data_migration_xwcmclassinfoview(IN prevClassInfoViewId BIGINT(20),
                                              IN classInfoIdOffset BIGINT(20),
                                              IN docIdOffset BIGINT(20),
                                              IN viewIdOffset BIGINT(20))
	BEGIN
	
	  DECLARE isover INT DEFAULT 0;

    DECLARE  f_CLASSINFOVIEWID int(11) DEFAULT NULL;
    DECLARE  f_CLASSINFOID int(11) DEFAULT NULL;
    DECLARE  f_METADATAID int(11) DEFAULT NULL;
    DECLARE  f_VIEWID int(11) DEFAULT NULL;
    DECLARE  f_CRUSER varchar(30) DEFAULT NULL;
    DECLARE  f_CRTIME datetime DEFAULT NULL;


  DECLARE cur CURSOR FOR
		SELECT
      CLASSINFOVIEWID,
      CLASSINFOID,
      METADATAID,
      VIEWID,
      CRUSER,
      CRTIME
    FROM trs_data_migration.xwcmclassinfoview
		ORDER BY CLASSINFOVIEWID asc;

	DECLARE CONTINUE HANDLER FOR NOT FOUND SET isover = 1;
	
	OPEN cur;
	
	FETCH cur INTO
    f_CLASSINFOVIEWID,
    f_CLASSINFOID,
    f_METADATAID,
    f_VIEWID,
    f_CRUSER,
    f_CRTIME
    ;



    WHILE isover= 0 DO

      # 断点续传
      IF (f_CLASSINFOID > prevClassInfoId)

        THEN

          SET @CLASSINFOVIEWID = f_CLASSINFOVIEWID;
          SET f_CLASSINFOVIEWID = f_CLASSINFOVIEWID + prevClassInfoViewId;
          SET f_CLASSINFOID = f_CLASSINFOID + classInfoIdOffset;
          SET f_METADATAID = f_METADATAID + docIdOffset;
          SET f_VIEWID = f_VIEWID + viewIdOffset;


            insert into trs_hycloud_iip.xwcmclassinfoview
              (
                CLASSINFOVIEWID,
                CLASSINFOID,
                METADATAID,
                VIEWID,
                CRUSER,
                CRTIME
              )
              VALUES
                (
                  f_CLASSINFOVIEWID,
                  f_CLASSINFOID,
                  f_METADATAID,
                  f_VIEWID,
                  f_CRUSER,
                  f_CRTIME
                );

          SET @sql = trs_data_migration.build_migration_log_sql('xwcmclassinfoview', @CLASSINFOVIEWID);

          prepare stmt from @sql;
          EXECUTE stmt;
          deallocate prepare stmt;
    END IF ;

		FETCH cur INTO
      f_CLASSINFOVIEWID,
      f_CLASSINFOID,
      f_METADATAID,
      f_VIEWID,
      f_CRUSER,
      f_CRTIME
      ;
		
	END WHILE;
	
	CLOSE cur;

    SET @sql = trs_data_migration.build_migration_log_sql('xwcmclassinfoview', @CLASSINFOVIEWID);

    prepare stmt from @sql;
    EXECUTE stmt;
    deallocate prepare stmt;
		
	END $$
DELIMITER ;