TRS.WCM.Developer/TRS.WCM.Developer/贵州项目/sp/1_data_migration_logger.sql

# 支持断点续迁，需要执行如下 sql

CREATE DATABASE trs_data_migration;

USE trs_data_migration;

CREATE TABLE data_migration_log(
  table_name VARCHAR(100) NOT NULL COMMENT '迁移的表名',
  prev_id BIGINT(20) NOT NULL COMMENT '上一条数据ID',
  PRIMARY KEY (table_name)
);





SET GLOBAL log_bin_trust_function_creators = TRUE;
DROP FUNCTION IF EXISTS build_migration_log_sql;
DELIMITER $$
CREATE FUNCTION build_migration_log_sql(table_name VARCHAR(100), id BIGINT(20))
  RETURNS VARCHAR(255)
  BEGIN
    DECLARE x VARCHAR(255) DEFAULT '';

    IF (id < 0)
      THEN SET id = 1000000000;
    END IF ;

    SET x =  concat('insert into ',
                    'trs_data_migration.data_migration_log (',
                    'table_name, ',
                    'prev_id',
                    ') ',
                    'values(',
                    '\'', table_name, '\',',
                    id,
                    ') ',
                    'on duplicate key update ',
                    'prev_id = ', id);
    RETURN x;
  END $$