(self)
| 1284 | self._finish_unbuffered_query() |
| 1285 | |
| 1286 | def read(self): |
| 1287 | try: |
| 1288 | first_packet = self.connection._read_packet() |
| 1289 | |
| 1290 | if first_packet.is_ok_packet(): |
| 1291 | self._read_ok_packet(first_packet) |
| 1292 | elif first_packet.is_load_local_packet(): |
| 1293 | self._read_load_local_packet(first_packet) |
| 1294 | else: |
| 1295 | self._read_result_packet(first_packet) |
| 1296 | finally: |
| 1297 | self.connection = None |
| 1298 | |
| 1299 | def init_unbuffered_query(self): |
| 1300 | """ |
no test coverage detected