Skip to content

Commit 01aba6e

Browse files
author
James Cor
committed
fix
1 parent b5b430b commit 01aba6e

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

sql/analyzer/inserts.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ import (
3030

3131
func resolveInsertRows(ctx *sql.Context, a *Analyzer, n sql.Node, scope *plan.Scope, sel RuleSelector, qFlags *sql.QueryFlags) (sql.Node, transform.TreeIdentity, error) {
3232
switch n.(type) {
33-
case *plan.TriggerExecutor, *plan.CreateProcedure:
33+
case *plan.CreateProcedure:
3434
return n, transform.SameTree, nil
3535
}
3636

@@ -44,10 +44,11 @@ func resolveInsertRows(ctx *sql.Context, a *Analyzer, n sql.Node, scope *plan.Sc
4444
}
4545
}
4646

47+
// TODO: when we encounter a plan.Call node we need to recurse onto the Procedure?
4748
var ctxFunc transform.CtxFunc = func(c transform.Context) (sql.Node, transform.TreeIdentity, error) {
48-
insert, ok := n.(*plan.InsertInto)
49+
insert, ok := c.Node.(*plan.InsertInto)
4950
if !ok {
50-
return n, transform.SameTree, nil
51+
return c.Node, transform.SameTree, nil
5152
}
5253

5354
source := insert.Source

0 commit comments

Comments
 (0)