Read a rowdata packet for each data row in the result set.
(self)
| 1412 | self.connection = None # release reference to kill cyclic reference. |
| 1413 | |
| 1414 | def _read_rowdata_packet(self): |
| 1415 | """Read a rowdata packet for each data row in the result set.""" |
| 1416 | rows = [] |
| 1417 | while True: |
| 1418 | packet = self.connection._read_packet() |
| 1419 | if self._check_packet_is_eof(packet): |
| 1420 | self.connection = None # release reference to kill cyclic reference. |
| 1421 | break |
| 1422 | rows.append(self._read_row_from_packet(packet)) |
| 1423 | |
| 1424 | self.affected_rows = len(rows) |
| 1425 | self.rows = tuple(rows) |
| 1426 | |
| 1427 | def _read_row_from_packet(self, packet): |
| 1428 | row = [] |
no test coverage detected