Add "START TRANSACTION WITH CAUSAL CONSISTENCY ONLY" (#1162)

* add a start transaction without external consistency statement Signed-off-by: ekexium <[email protected]> * change the grammar to 'with causal consistency' Signed-off-by: ekexium <[email protected]> * rename WithoutExternalConsistency to CausalConsistency Signed-off-by: ekexium <[email protected]> * change syntax to 'start transaction with causal consistency only' Signed-off-by: ekexium <[email protected]> Co-authored-by: ti-srebot <[email protected]>
pingcap · Feb 3, 2021 · 32ef3e0 · 32ef3e0
1 parent 559bdbd
commit 32ef3e0
Show file tree

Hide file tree

Showing 5 changed files with 9,106 additions and 9,069 deletions.
diff --git a/ast/misc.go b/ast/misc.go
@@ -386,9 +386,10 @@ func (n *ExecuteStmt) Accept(v Visitor) (Node, bool) {
 // See https://dev.mysql.com/doc/refman/5.7/en/commit.html
 type BeginStmt struct {
 	stmtNode
-	Mode     string
-	ReadOnly bool
-	Bound    *TimestampBound
+	Mode                  string
+	ReadOnly              bool
+	Bound                 *TimestampBound
+	CausalConsistencyOnly bool
 }
 
 // Restore implements Node interface.
@@ -414,6 +415,8 @@ func (n *BeginStmt) Restore(ctx *format.RestoreCtx) error {
 					return n.Bound.Timestamp.Restore(ctx)
 				}
 			}
+		} else if n.CausalConsistencyOnly {
+			ctx.WriteKeyWord("START TRANSACTION WITH CAUSAL CONSISTENCY ONLY")
 		} else {
 			ctx.WriteKeyWord("START TRANSACTION")
 		}

diff --git a/misc.go b/misc.go
@@ -204,6 +204,7 @@ var tokenMap = map[string]int{
 	"CASCADED":                 cascaded,
 	"CASE":                     caseKwd,
 	"CAST":                     cast,
+	"CAUSAL":                   causal,
 	"CHAIN":                    chain,
 	"CHANGE":                   change,
 	"CHAR":                     charType,
@@ -233,6 +234,7 @@ var tokenMap = map[string]int{
 	"CONCURRENCY":              concurrency,
 	"CONFIG":                   config,
 	"CONNECTION":               connection,
+	"CONSISTENCY":              consistency,
 	"CONSISTENT":               consistent,
 	"CONSTRAINT":               constraint,
 	"CONSTRAINTS":              constraints,