123456789101112131415161718192021222324252627282930313233 |
- # 支持断点续迁,需要执行如下 sql
- CREATE TABLE data_migration_log(
- table_name VARCHAR(100) NOT NULL COMMENT '迁移的表名',
- prev_id BIGINT(20) NOT NULL COMMENT '上一条数据ID',
- migration_time datetime NOT NULL default CURRENT_TIMESTAMP,
- PRIMARY KEY (table_name)
- );
- DROP FUNCTION IF EXISTS build_migration_log_sql;
- DELIMITER $$
- CREATE FUNCTION build_migration_log_sql(table_name VARCHAR(100), id BIGINT(20), curtime datetime)
- RETURNS VARCHAR(255)
- BEGIN
- DECLARE x VARCHAR(255) DEFAULT '';
- SET x = concat('insert into ',
- 'data_migration_log (',
- 'table_name, ',
- 'prev_id,',
- 'migration_time',
- ') ',
- 'values(',
- '\'', table_name, '\',',
- id, ',',
- '\'', curtime, '\'',
- ') ',
- 'on duplicate key update ',
- 'prev_id = ', id);
- RETURN x;
- END $$
|