(connection, rows)
| 191 | } |
| 192 | |
| 193 | _getRows(connection, rows) { |
| 194 | connection.execute({ |
| 195 | portal: this.portal, |
| 196 | rows: rows, |
| 197 | }) |
| 198 | // if we're not reading pages of rows send the sync command |
| 199 | // to indicate the pipeline is finished |
| 200 | if (!rows) { |
| 201 | connection.sync() |
| 202 | } else { |
| 203 | // otherwise flush the call out to read more rows |
| 204 | connection.flush() |
| 205 | } |
| 206 | } |
| 207 | |
| 208 | // http://developer.postgresql.org/pgdocs/postgres/protocol-flow.html#PROTOCOL-FLOW-EXT-QUERY |
| 209 | prepare(connection) { |
no test coverage detected