(self, first_packet)
| 1279 | self.unbuffered_active = True |
| 1280 | |
| 1281 | def _read_ok_packet(self, first_packet): |
| 1282 | ok_packet = OKPacketWrapper(first_packet) |
| 1283 | self.affected_rows = ok_packet.affected_rows |
| 1284 | self.insert_id = ok_packet.insert_id |
| 1285 | self.server_status = ok_packet.server_status |
| 1286 | self.warning_count = ok_packet.warning_count |
| 1287 | self.message = ok_packet.message |
| 1288 | self.has_next = ok_packet.has_next |
| 1289 | |
| 1290 | def _read_load_local_packet(self, first_packet): |
| 1291 | if not self.connection._local_infile: |
no test coverage detected