Skip to content

Commit a669217

Browse files
author
James Cor
committed
more fix
1 parent b78155a commit a669217

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

sql/analyzer/common_test.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -157,6 +157,8 @@ func runTestCases(t *testing.T, ctx *sql.Context, testCases []analyzerFnTestCase
157157
if expected == nil {
158158
expected = tt.node
159159
}
160+
// Schema of certain nodes aren't filled until needed
161+
expected.Schema()
160162

161163
assertNodesEqualWithDiff(t, expected, result)
162164
})

sql/planbuilder/ddl.go

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -395,11 +395,11 @@ func (b *Builder) getIndexDefs(table sql.Table) sql.IndexDefs {
395395
if !isIdxTbl {
396396
return nil
397397
}
398-
var idxDefs sql.IndexDefs
399398
idxs, err := idxTbl.GetIndexes(b.ctx)
400399
if err != nil {
401400
b.handleErr(err)
402401
}
402+
idxDefs := make(sql.IndexDefs, 0, len(idxs))
403403
for _, idx := range idxs {
404404
if idx.IsGenerated() {
405405
continue
@@ -412,10 +412,9 @@ func (b *Builder) getIndexDefs(table sql.Table) sql.IndexDefs {
412412
constraint = sql.IndexConstraint_Unique
413413
}
414414
}
415-
columns := make([]sql.IndexColumn, len(idx.Expressions()))
416-
for i, col := range idx.Expressions() {
417-
// TODO: find a better way to get only the column name if the table is present
418-
col = strings.TrimPrefix(col, idxTbl.Name()+".")
415+
exprs := idx.UnqualifiedExpressions()
416+
columns := make([]sql.IndexColumn, len(exprs))
417+
for i, col := range exprs {
419418
columns[i] = sql.IndexColumn{Name: col}
420419
}
421420
idxDefs = append(idxDefs, &sql.IndexDef{

0 commit comments

Comments
 (0)