(self)
| 1241 | self._finish_unbuffered_query() |
| 1242 | |
| 1243 | def read(self): |
| 1244 | try: |
| 1245 | first_packet = self.connection._read_packet() |
| 1246 | |
| 1247 | if first_packet.is_ok_packet(): |
| 1248 | self._read_ok_packet(first_packet) |
| 1249 | elif first_packet.is_load_local_packet(): |
| 1250 | self._read_load_local_packet(first_packet) |
| 1251 | else: |
| 1252 | self._read_result_packet(first_packet) |
| 1253 | finally: |
| 1254 | self.connection = None |
| 1255 | |
| 1256 | def init_unbuffered_query(self): |
| 1257 | """ |
no test coverage detected