()
| 266 | } |
| 267 | |
| 268 | func (br *batchResults) nextQueryAndArgs() (query string, args []any, ok bool) { |
| 269 | if br.b != nil && br.qqIdx < len(br.b.QueuedQueries) { |
| 270 | bi := br.b.QueuedQueries[br.qqIdx] |
| 271 | query = bi.SQL |
| 272 | args = bi.Arguments |
| 273 | ok = true |
| 274 | br.qqIdx++ |
| 275 | } |
| 276 | return query, args, ok |
| 277 | } |
| 278 | |
| 279 | type pipelineBatchResults struct { |
| 280 | ctx context.Context |