Skip to content

Commit

Permalink
executor: add sleep after execute a statement
Browse files Browse the repository at this point in the history
pass test
  • Loading branch information
coocood committed Sep 13, 2016
1 parent 1fdbfa5 commit a62b19f
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions executor/executor_binlog_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -82,6 +82,7 @@ func (s *testSuite) TestBinlog(c *C) {
// Test table primary key is not integer.
tk.MustExec("create table local_binlog2 (name varchar(64) primary key)")
tk.MustExec("insert local_binlog2 values ('abc'), ('def')")
time.Sleep(time.Millisecond)
tk.MustExec("delete from local_binlog2 where name = 'def'")
time.Sleep(time.Millisecond)
prewriteVal = getLatestBinlogPrewriteValue(c, pump)
Expand All @@ -91,6 +92,7 @@ func (s *testSuite) TestBinlog(c *C) {
// Test Table don't have primary key.
tk.MustExec("create table local_binlog3 (c1 int, c2 int)")
tk.MustExec("insert local_binlog3 values (1, 2), (1, 3), (2, 3)")
time.Sleep(time.Millisecond)
tk.MustExec("delete from local_binlog3 where c2 = 3")
time.Sleep(time.Millisecond)
prewriteVal = getLatestBinlogPrewriteValue(c, pump)
Expand Down

0 comments on commit a62b19f

Please sign in to comment.