Skip to content

Commit 6065f04

Browse files
committed
Support create and drop view with schema name
1 parent 587e936 commit 6065f04

File tree

2 files changed

+3
-6
lines changed

2 files changed

+3
-6
lines changed

sql/planbuilder/create_ddl.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -470,11 +470,7 @@ func (b *Builder) buildCreateView(inScope *scope, subQuery string, fullQuery str
470470
queryAlias = queryAlias.WithColumnNames(columnsToStrings(c.ViewSpec.Columns))
471471
}
472472

473-
dbName := c.ViewSpec.ViewName.DbQualifier.String()
474-
if dbName == "" {
475-
dbName = b.ctx.GetCurrentDatabase()
476-
}
477-
db := b.resolveDb(dbName)
473+
db := b.resolveDbForTable(c.ViewSpec.ViewName)
478474
createView := plan.NewCreateView(db, c.ViewSpec.ViewName.Name.String(), queryAlias, c.OrReplace, subQuery, c.ViewSpec.Algorithm, definer, c.ViewSpec.Security)
479475
outScope.node = b.modifySchemaTarget(queryScope, createView, createView.Definition.Schema())
480476

sql/planbuilder/ddl.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,8 @@ func (b *Builder) buildDDL(inScope *scope, subQuery string, fullQuery string, c
169169
if len(c.FromViews) != 0 {
170170
plans := make([]sql.Node, len(c.FromViews))
171171
for i, v := range c.FromViews {
172-
plans[i] = plan.NewSingleDropView(b.currentDb(), v.Name.String())
172+
db := b.resolveDbForTable(v)
173+
plans[i] = plan.NewSingleDropView(db, v.Name.String())
173174
}
174175
outScope.node = plan.NewDropView(plans, c.IfExists)
175176
return

0 commit comments

Comments
 (0)