(ctx *sql.Context)
| 191 | } |
| 192 | |
| 193 | func (t tabularRowIter) Next(ctx *sql.Context) (sql.Row, error) { |
| 194 | row, hasNext, err := t.tdl.nextRow(ctx, t.reader) |
| 195 | if err != nil { |
| 196 | return nil, err |
| 197 | } |
| 198 | |
| 199 | // TODO: this isn't the best way to handle the count of rows, something like a RowUpdateAccumulator would be better |
| 200 | if hasNext { |
| 201 | t.tdl.results.RowsLoaded++ |
| 202 | } else { |
| 203 | return nil, io.EOF |
| 204 | } |
| 205 | |
| 206 | return row, nil |
| 207 | } |
| 208 | |
| 209 | func (t tabularRowIter) Close(context *sql.Context) error { |
| 210 | return nil |