(self)
| 1371 | self._read_rowdata_packet() |
| 1372 | |
| 1373 | def _read_rowdata_packet_unbuffered(self): |
| 1374 | # Check if in an active query |
| 1375 | if not self.unbuffered_active: |
| 1376 | return |
| 1377 | |
| 1378 | # EOF |
| 1379 | packet = self.connection._read_packet() |
| 1380 | if self._check_packet_is_eof(packet): |
| 1381 | self.unbuffered_active = False |
| 1382 | self.connection = None |
| 1383 | self.rows = None |
| 1384 | return |
| 1385 | |
| 1386 | row = self._read_row_from_packet(packet) |
| 1387 | self.affected_rows = 1 |
| 1388 | self.rows = (row,) # rows should tuple of row for MySQL-python compatibility. |
| 1389 | return row |
| 1390 | |
| 1391 | def _finish_unbuffered_query(self): |
| 1392 | # After much reading on the MySQL protocol, it appears that there is, |
no test coverage detected