|
|
@@ -56,7 +56,6 @@ CREATE PROCEDURE update_data_table(IN prevtabelId BIGINT(20))
|
|
|
IF (f_TABLEINFOID > prevtabelId)
|
|
|
|
|
|
THEN
|
|
|
- then
|
|
|
SET @table_offset_num = ifnull((SELECT offset_num FROM data_migration_offset WHERE table_name = table_migr_table_name AND start_id < f_TABLEINFOID and end_id >= f_TABLEINFOID), 0);
|
|
|
SET f_TABLEINFOID = f_TABLEINFOID + @table_offset_num;
|
|
|
|
|
|
@@ -69,7 +68,7 @@ CREATE PROCEDURE update_data_table(IN prevtabelId BIGINT(20))
|
|
|
prepare stmt from @log_sql;
|
|
|
EXECUTE stmt;
|
|
|
deallocate prepare stmt;
|
|
|
- END IF ;
|
|
|
+ END IF ;
|
|
|
|
|
|
FETCH cur INTO
|
|
|
f_TABLEINFOID,
|