1_data_migration_logger.sql 1021 B

123456789101112131415161718192021222324252627282930313233
  1. # 支持断点续迁,需要执行如下 sql
  2. CREATE TABLE data_migration_log(
  3. table_name VARCHAR(100) NOT NULL COMMENT '迁移的表名',
  4. prev_id BIGINT(20) NOT NULL COMMENT '上一条数据ID',
  5. migration_time datetime NOT NULL default CURRENT_TIMESTAMP,
  6. PRIMARY KEY (table_name)
  7. );
  8. DROP FUNCTION IF EXISTS build_migration_log_sql;
  9. DELIMITER $$
  10. CREATE FUNCTION build_migration_log_sql(table_name VARCHAR(100), id BIGINT(20), curtime datetime)
  11. RETURNS VARCHAR(255)
  12. BEGIN
  13. DECLARE x VARCHAR(255) DEFAULT '';
  14. SET x = concat('insert into ',
  15. 'data_migration_log (',
  16. 'table_name, ',
  17. 'prev_id,',
  18. 'migration_time',
  19. ') ',
  20. 'values(',
  21. '\'', table_name, '\',',
  22. id, ',',
  23. '\'', curtime, '\'',
  24. ') ',
  25. 'on duplicate key update ',
  26. 'prev_id = ', id);
  27. RETURN x;
  28. END $$