Read a rowdata packet for each data row in the result set.
(self)
| 1370 | self.connection = None # release reference to kill cyclic reference. |
| 1371 | |
| 1372 | def _read_rowdata_packet(self): |
| 1373 | """Read a rowdata packet for each data row in the result set.""" |
| 1374 | rows = [] |
| 1375 | while True: |
| 1376 | packet = self.connection._read_packet() |
| 1377 | if self._check_packet_is_eof(packet): |
| 1378 | self.connection = None # release reference to kill cyclic reference. |
| 1379 | break |
| 1380 | rows.append(self._read_row_from_packet(packet)) |
| 1381 | |
| 1382 | self.affected_rows = len(rows) |
| 1383 | self.rows = tuple(rows) |
| 1384 | |
| 1385 | def _read_row_from_packet(self, packet): |
| 1386 | row = [] |
no test coverage detected