Skip to content

Commit feef082

Browse files
author
James Cor
committed
tidy
1 parent ab4d1ac commit feef082

File tree

1 file changed

+2
-5
lines changed

1 file changed

+2
-5
lines changed

server/handler.go

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -499,9 +499,6 @@ func (h *Handler) doQuery(
499499
r, processedAtLeastOneBatch, err = h.resultForValueRowIter(sqlCtx, c, schema, vr, resultFields, buf, callback, more)
500500
} else {
501501
r, processedAtLeastOneBatch, err = h.resultForDefaultIter(sqlCtx, c, schema, rowIter, callback, resultFields, more, buf)
502-
if err != nil {
503-
return remainder, err
504-
}
505502
}
506503
if err != nil {
507504
return remainder, err
@@ -665,11 +662,11 @@ func (h *Handler) resultForDefaultIter(ctx *sql.Context, c *mysql.Conn, schema s
665662
}
666663
}
667664

665+
iter, projs := GetDeferredProjections(iter)
666+
668667
wg := sync.WaitGroup{}
669668
wg.Add(3)
670669

671-
iter, projs := GetDeferredProjections(iter)
672-
673670
// Read rows off the row iterator and send them to the row channel.
674671
var rowChan = make(chan sql.Row, 512)
675672
eg.Go(func() (err error) {

0 commit comments

Comments
 (0)