have create views implement target schema

Author: James Cor

sql/information_schema/columns_table.go

@@ -384,7 +384,7 @@ func getRowsFromViews(ctx *sql.Context, catalog sql.Catalog, db DbWithNames, pri
 		}
 		privSetTbl := privSetDb.Table(view.Name)
 		curPrivSetMap := getCurrentPrivSetMapForColumn(privSetDb.ToSlice(), privSetMap)
-		for i, col := range createViewNode.Definition.Schema() {
+		for i, col := range createViewNode.TargetSchema() {
 			r := getRowFromColumn(ctx, i, col, db.CatalogName, db.SchemaName, view.Name, "", privSetTbl, curPrivSetMap)
 			if r != nil {
 				rows = append(rows, r)

sql/plan/create_view.go

@@ -29,6 +29,7 @@ import (
 type CreateView struct {
 	UnaryNode
 	database         sql.Database
+	targetSchema     sql.Schema
 	Name             string
 	IsReplace        bool
 	Definition       *SubqueryAlias
@@ -41,6 +42,7 @@ type CreateView struct {
 
 var _ sql.Node = (*CreateView)(nil)
 var _ sql.CollationCoercible = (*CreateView)(nil)
+var _ sql.SchemaTarget = (*CreateView)(nil)
 
 // NewCreateView creates a CreateView node with the specified parameters,
 // setting its catalog to nil.
@@ -135,6 +137,18 @@ func (cv *CreateView) WithDatabase(database sql.Database) (sql.Node, error) {
 	return &newCreate, nil
 }
 
+// WithTargetSchema implements the SchemaTarget interface.
+func (cv *CreateView) WithTargetSchema(sch sql.Schema) (sql.Node, error) {
+	ncv := *cv
+	ncv.targetSchema = sch
+	return &ncv, nil
+}
+
+// TargetSchema implements the SchemaTarget interface.
+func (cv *CreateView) TargetSchema() sql.Schema {
+	return cv.targetSchema
+}
+
 // GetIsUpdatableFromCreateView returns whether the view is updatable or not.
 // https://dev.mysql.com/doc/refman/8.0/en/view-updatability.html
 func GetIsUpdatableFromCreateView(cv *CreateView) bool {

sql/planbuilder/create_ddl.go

@@ -472,6 +472,8 @@ func (b *Builder) buildCreateView(inScope *scope, subQuery string, fullQuery str
 		dbName = b.ctx.GetCurrentDatabase()
 	}
 	db := b.resolveDb(dbName)
-	outScope.node = plan.NewCreateView(db, c.ViewSpec.ViewName.Name.String(), queryAlias, c.OrReplace, subQuery, c.ViewSpec.Algorithm, definer, c.ViewSpec.Security)
+	createView := plan.NewCreateView(db, c.ViewSpec.ViewName.Name.String(), queryAlias, c.OrReplace, subQuery, c.ViewSpec.Algorithm, definer, c.ViewSpec.Security)
+	outScope.node = b.modifySchemaTarget(queryScope, createView, createView.Definition.Schema())
+
 	return outScope
 }