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