skip create view / drop view

alter view is not recognized

Author: ffffwh

drivers/mysql/mysql/binlog/binlog_reader.go

@@ -1023,6 +1023,8 @@ func (b *BinlogReader) resolveQuery(currentSchema string, sql string,
 		setTable(v.Table, false)
 	case *ast.CreateTableStmt:
 		setTable(v.Table, false)
+	case *ast.CreateViewStmt:
+		result.isSkip = true
 	case *ast.AlterTableStmt:
 		setTable(v.Table, false)
 	case *ast.RevokeStmt, *ast.RevokeRoleStmt:
@@ -1041,27 +1043,31 @@ func (b *BinlogReader) resolveQuery(currentSchema string, sql string,
 	case *ast.AlterProcedureStmt:
 		result.isExpand = true
 	case *ast.DropTableStmt:
-		var newTables []*ast.TableName
-		for _, t := range v.Tables {
-			mayLowerTable(t)
-			schema := g.StringElse(t.Schema.String(), currentSchema)
-			if !skipFunc(schema, t.Name.String()) {
-				isExtraTable := len(newTables) > 0
-				setTable(t, isExtraTable)
-				newTables = append(newTables, t)
-				b.logger.Debug("resolveQuery. DropTableStmt. include",
-					"schema", t.Schema, "table", t.Name, "use", currentSchema)
+		if v.IsView {
+			result.isSkip = true
+		} else {
+			var newTables []*ast.TableName
+			for _, t := range v.Tables {
+				mayLowerTable(t)
+				schema := g.StringElse(t.Schema.String(), currentSchema)
+				if !skipFunc(schema, t.Name.String()) {
+					isExtraTable := len(newTables) > 0
+					setTable(t, isExtraTable)
+					newTables = append(newTables, t)
+					b.logger.Debug("resolveQuery. DropTableStmt. include",
+						"schema", t.Schema, "table", t.Name, "use", currentSchema)
+				}
 			}
-		}
 
-		if len(newTables) == 0 {
-			newTables = v.Tables[:1]
-			setTable(v.Tables[0], false)
-		}
+			if len(newTables) == 0 {
+				newTables = v.Tables[:1]
+				setTable(v.Tables[0], false)
+			}
 
-		if len(newTables) != len(v.Tables) {
-			v.Tables = newTables
-			rewrite = true
+			if len(newTables) != len(v.Tables) {
+				v.Tables = newTables
+				rewrite = true
+			}
 		}
 	case *ast.CreateUserStmt, *ast.GrantStmt, *ast.DropUserStmt, *ast.AlterUserStmt:
 		setTable(&ast.TableName{

helper/tryparser/tryparser.go

@@ -7,9 +7,9 @@ import (
 	tast "github.com/pingcap/tidb/parser/ast"
 	"github.com/pingcap/tidb/parser/format"
 	"github.com/pingcap/tidb/parser/model"
-	"golang.org/x/text/encoding/simplifiedchinese"
-	"golang.org/x/text/transform"
-	"strings"
+	//"golang.org/x/text/encoding/simplifiedchinese"
+	//"golang.org/x/text/transform"
+	//"strings"
 
 	"fmt"
 	_ "github.com/pingcap/tidb/types/parser_driver"
@@ -26,14 +26,18 @@ func main() {
 	//sql := "create table b.t1 (id int primary key auto_increment, val timestamp not null default 0)"
 	//sql := "create table b.t1 (id int primary key auto_increment, val varchar(64) not null default 'hello')"
 
-	sb := strings.Builder{}
-	gbkStr, _, err := transform.String(simplifiedchinese.GBK.NewEncoder(),
-		"create table s中文.t中文 (id中文 int primary key auto_increment,\n ")
-	u.PanicIfErr(err)
-	sb.WriteString(gbkStr)
-	sb.WriteString("val varchar(50) default _utf8mb4\"aa中文\")")
-	sql := sb.String()
-	ast, err := p.ParseOneStmt(sql, "gbk", "gbk_chinese_ci")
+	//sb := strings.Builder{}
+	//gbkStr, _, err := transform.String(simplifiedchinese.GBK.NewEncoder(),
+	//	"create table s中文.t中文 (id中文 int primary key auto_increment,\n ")
+	//u.PanicIfErr(err)
+	//sb.WriteString(gbkStr)
+	//sb.WriteString("val varchar(50) default _utf8mb4\"aa中文\")")
+	//sql := sb.String()
+
+	//sql := "drop view a.v1"
+	sql := "alter view a.v1 as select * from a.a"
+
+	ast, err := p.ParseOneStmt(sql, "", "")
 
 	u.PanicIfErr(err)