materialized-view-lifecycle

Summary:

- Support `refresh materialized view`.
- `TEXT` token added.
- Support `DROP MATERIALIZED VIEW`.
- Added placeholder for `select` statement in `refresh materialized view` node.

Author: general-kroll-4-life

go/vt/sqlparser/ast.go

@@ -206,6 +206,13 @@ type (
 		Charset     string
 	}
 
+	RefreshMaterializedView struct {
+		Concurrently   bool
+		ViewName       TableName
+		WithData       bool
+		ImplicitSelect SelectStatement // This is mutated during analysis.
+	}
+
 	// DDL represents a CREATE, ALTER, DROP, RENAME, TRUNCATE or ANALYZE statement.
 	DDL struct {
 		Action string
@@ -333,38 +340,39 @@ type (
 	OtherAdmin struct{}
 )
 
-func (*Union) iStatement()             {}
-func (*Select) iStatement()            {}
-func (*Stream) iStatement()            {}
-func (*Insert) iStatement()            {}
-func (*Update) iStatement()            {}
-func (*Delete) iStatement()            {}
-func (*Set) iStatement()               {}
-func (*SetTransaction) iStatement()    {}
-func (*DBDDL) iStatement()             {}
-func (*DDL) iStatement()               {}
-func (*Show) iStatement()              {}
-func (*Use) iStatement()               {}
-func (*Begin) iStatement()             {}
-func (*Commit) iStatement()            {}
-func (*Rollback) iStatement()          {}
-func (*SRollback) iStatement()         {}
-func (*Savepoint) iStatement()         {}
-func (*Release) iStatement()           {}
-func (*Explain) iStatement()           {}
-func (*OtherRead) iStatement()         {}
-func (*Auth) iStatement()              {}
-func (*Registry) iStatement()          {}
-func (*AuthRevoke) iStatement()        {}
-func (*Exec) iStatement()              {}
-func (*Purge) iStatement()             {}
-func (*NativeQuery) iStatement()       {}
-func (*DescribeTable) iStatement()     {}
-func (*OtherAdmin) iStatement()        {}
-func (*Select) iSelectStatement()      {}
-func (*Union) iSelectStatement()       {}
-func (*ParenSelect) iSelectStatement() {}
-func (*Sleep) iStatement()             {}
+func (*Union) iStatement()                   {}
+func (*Select) iStatement()                  {}
+func (*Stream) iStatement()                  {}
+func (*Insert) iStatement()                  {}
+func (*Update) iStatement()                  {}
+func (*Delete) iStatement()                  {}
+func (*Set) iStatement()                     {}
+func (*SetTransaction) iStatement()          {}
+func (*DBDDL) iStatement()                   {}
+func (*DDL) iStatement()                     {}
+func (*Show) iStatement()                    {}
+func (*Use) iStatement()                     {}
+func (*Begin) iStatement()                   {}
+func (*Commit) iStatement()                  {}
+func (*Rollback) iStatement()                {}
+func (*SRollback) iStatement()               {}
+func (*Savepoint) iStatement()               {}
+func (*Release) iStatement()                 {}
+func (*Explain) iStatement()                 {}
+func (*OtherRead) iStatement()               {}
+func (*Auth) iStatement()                    {}
+func (*Registry) iStatement()                {}
+func (*AuthRevoke) iStatement()              {}
+func (*Exec) iStatement()                    {}
+func (*Purge) iStatement()                   {}
+func (*NativeQuery) iStatement()             {}
+func (*DescribeTable) iStatement()           {}
+func (*OtherAdmin) iStatement()              {}
+func (*Select) iSelectStatement()            {}
+func (*Union) iSelectStatement()             {}
+func (*ParenSelect) iSelectStatement()       {}
+func (*RefreshMaterializedView) iStatement() {}
+func (*Sleep) iStatement()                   {}
 
 // ParenSelect can actually not be a top level statement,
 // but we have to allow it because it's a requirement
@@ -1138,6 +1146,18 @@ func (node *DBDDL) Format(buf *TrackedBuffer) {
 	}
 }
 
+func (node *RefreshMaterializedView) Format(buf *TrackedBuffer) {
+	if node.Concurrently {
+		buf.astPrintf(node, "refresh materialized view concurrently %v", node.ViewName)
+		return
+	}
+	if !node.WithData {
+		buf.astPrintf(node, "refresh materialized view %v with no data", node.ViewName)
+		return
+	}
+	buf.astPrintf(node, "refresh materialized view %v", node.ViewName)
+}
+
 // Format formats the node.
 func (node *DDL) Format(buf *TrackedBuffer) {
 	switch node.Action {

go/vt/sqlparser/external_visitor.go

@@ -75,6 +75,7 @@ func (node *NativeQuery) Accept(vis SQLAstVisitor) error              { return v
 func (node *RangeCond) Accept(vis SQLAstVisitor) error                { return vis.Visit(node) }
 func (node ReferenceAction) Accept(vis SQLAstVisitor) error           { return vis.Visit(node) }
 func (node *Registry) Accept(vis SQLAstVisitor) error                 { return vis.Visit(node) }
+func (node *RefreshMaterializedView) Accept(vis SQLAstVisitor) error  { return vis.Visit(node) }
 func (node *Release) Accept(vis SQLAstVisitor) error                  { return vis.Visit(node) }
 func (node *Rollback) Accept(vis SQLAstVisitor) error                 { return vis.Visit(node) }
 func (node *SQLVal) Accept(vis SQLAstVisitor) error                   { return vis.Visit(node) }