(self)
| 1199 | self._finish_unbuffered_query() |
| 1200 | |
| 1201 | def read(self): |
| 1202 | try: |
| 1203 | first_packet = self.connection._read_packet() |
| 1204 | |
| 1205 | if first_packet.is_ok_packet(): |
| 1206 | self._read_ok_packet(first_packet) |
| 1207 | elif first_packet.is_load_local_packet(): |
| 1208 | self._read_load_local_packet(first_packet) |
| 1209 | else: |
| 1210 | self._read_result_packet(first_packet) |
| 1211 | finally: |
| 1212 | self.connection = None |
| 1213 | |
| 1214 | def init_unbuffered_query(self): |
| 1215 | """ |
no test coverage detected