(self)
| 1329 | self._read_rowdata_packet() |
| 1330 | |
| 1331 | def _read_rowdata_packet_unbuffered(self): |
| 1332 | # Check if in an active query |
| 1333 | if not self.unbuffered_active: |
| 1334 | return |
| 1335 | |
| 1336 | # EOF |
| 1337 | packet = self.connection._read_packet() |
| 1338 | if self._check_packet_is_eof(packet): |
| 1339 | self.unbuffered_active = False |
| 1340 | self.connection = None |
| 1341 | self.rows = None |
| 1342 | return |
| 1343 | |
| 1344 | row = self._read_row_from_packet(packet) |
| 1345 | self.affected_rows = 1 |
| 1346 | self.rows = (row,) # rows should tuple of row for MySQL-python compatibility. |
| 1347 | return row |
| 1348 | |
| 1349 | def _finish_unbuffered_query(self): |
| 1350 | # After much reading on the MySQL protocol, it appears that there is, |
no test coverage detected