From 042ccf49ef1b48628afbea624317a82efbfb4974 Mon Sep 17 00:00:00 2001 From: WangXiangUSTC Date: Sat, 4 May 2019 22:53:48 +0800 Subject: [PATCH] fix bug --- reparo/syncer/translate.go | 4 ++-- tests/reparo/run.sh | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/reparo/syncer/translate.go b/reparo/syncer/translate.go index 65681609e..5603c7e8e 100644 --- a/reparo/syncer/translate.go +++ b/reparo/syncer/translate.go @@ -48,11 +48,11 @@ func pbBinlogToTxn(binlog *pb.Binlog) (txn *loader.Txn, err error) { return nil, errors.Trace(err) } - _, newDatum, err := codec.DecodeOne(col.Value) + _, oldDatum, err := codec.DecodeOne(col.Value) if err != nil { return nil, errors.Trace(err) } - _, oldDatum, err := codec.DecodeOne(col.ChangedValue) + _, newDatum, err := codec.DecodeOne(col.ChangedValue) if err != nil { return nil, errors.Trace(err) } diff --git a/tests/reparo/run.sh b/tests/reparo/run.sh index 3d2882a9a..65a04869f 100755 --- a/tests/reparo/run.sh +++ b/tests/reparo/run.sh @@ -20,7 +20,7 @@ run_sql "CREATE TABLE \`reparo_test\`.\`test\`(\`id\` int, \`name\` varchar(10), run_sql "INSERT INTO \`reparo_test\`.\`test\` VALUES(1, 'a', 'a'), (2, 'b', 'b')" run_sql "INSERT INTO \`reparo_test\`.\`test\` VALUES(3, 'c', 'c'), (4, 'd', 'c')" run_sql "UPDATE \`reparo_test\`.\`test\` SET \`name\` = 'bb' where \`id\` = 2" -run_sql "DELETE FROM \`reparo_test\`.\`test\` WHERE \`name\` = 'bb'" +run_sql "DELETE FROM \`reparo_test\`.\`test\` WHERE \`id\` = '1'" run_sql "INSERT INTO \`reparo_test\`.\`test\` VALUES(5, 'e', 'e')" sleep 5