Adds Planning and Parsing Support for Truncate, Rename, Drop Index and Flush

go/test/endtoend/vtgate/misc_test.go

@@ -496,6 +496,15 @@ func TestCreateView(t *testing.T) {
 	assertMatches(t, conn, "select * from v1", `[[INT64(1) INT64(1)] [INT64(2) INT64(2)] [INT64(3) INT64(3)] [INT64(4) INT64(4)] [INT64(5) INT64(5)]]`)
 }
 
+func TestFlush(t *testing.T) {
+	defer cluster.PanicHandler(t)
+	ctx := context.Background()
+	conn, err := mysql.Connect(ctx, &vtParams)
+	require.NoError(t, err)
+	defer conn.Close()
+	exec(t, conn, "flush local tables t1, t2")
+}
+
 func assertMatches(t *testing.T, conn *mysql.Conn, query, expected string) {
 	t.Helper()
 	qr := exec(t, conn, query)

go/vt/sqlparser/analyzer.go

@@ -59,6 +59,7 @@ const (
 	StmtVStream
 	StmtLockTables
 	StmtUnlockTables
+	StmtFlush
 )
 
 //ASTToStatementType returns a StatementType from an AST stmt
@@ -100,6 +101,8 @@ func ASTToStatementType(stmt Statement) StatementType {
 		return StmtLockTables
 	case *UnlockTables:
 		return StmtUnlockTables
+	case *Flush:
+		return StmtFlush
 	default:
 		return StmtUnknown
 	}
@@ -187,8 +190,10 @@ func Preview(sql string) StatementType {
 		return StmtRollback
 	}
 	switch loweredFirstWord {
-	case "create", "alter", "rename", "drop", "truncate", "flush":
+	case "create", "alter", "rename", "drop", "truncate":
 		return StmtDDL
+	case "flush":
+		return StmtFlush
 	case "set":
 		return StmtSet
 	case "show":
@@ -255,6 +260,8 @@ func (s StatementType) String() string {
 		return "LOCK_TABLES"
 	case StmtUnlockTables:
 		return "UNLOCK_TABLES"
+	case StmtFlush:
+		return "FLUSH"
 	default:
 		return "UNKNOWN"
 	}

go/vt/sqlparser/analyzer_test.go

@@ -75,6 +75,7 @@ func TestPreview(t *testing.T) {
 		{"grant", StmtPriv},
 		{"revoke", StmtPriv},
 		{"truncate", StmtDDL},
+		{"flush", StmtFlush},
 		{"unknown", StmtUnknown},
 
 		{"/* leading comment */ select ...", StmtSelect},