executor: add testcase to cover stale read and prepare stmt (#33270)

ref #31550
pingcap · Mar 21, 2022 · 0d160fb · 0d160fb
1 parent 49f291d
commit 0d160fb
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/executor/stale_txn_test.go b/executor/stale_txn_test.go
@@ -1051,6 +1051,16 @@ func TestStaleReadPrepare(t *testing.T) {
 	tk.MustExec(fmt.Sprintf(`set transaction read only as of timestamp '%s'`, time1.Format("2006-1-2 15:04:05.000")))
 	_, err = tk.Exec("execute p1")
 	require.Error(t, err)
+	tk.MustExec("execute p2")
+
+	tk.MustExec("create table t1 (id int, v int)")
+	tk.MustExec("insert into t1 values (1,10)")
+	tk.MustExec("set @a=now(6)")
+	time.Sleep(5 * time.Millisecond)
+	tk.MustExec("update t1 set v=100 where id=1")
+	tk.MustQuery("select * from t1").Check(testkit.Rows("1 100"))
+	tk.MustExec("prepare s1 from 'select * from t1 as of timestamp @a where id=1'")
+	tk.MustQuery("execute s1").Check(testkit.Rows("1 10"))
 }
 
 func TestStmtCtxStaleFlag(t *testing.T) {