(self)
| 469 | return bool(self.server_status & SERVER_STATUS.SERVER_STATUS_AUTOCOMMIT) |
| 470 | |
| 471 | def _read_ok_packet(self): |
| 472 | pkt = self._read_packet() |
| 473 | if not pkt.is_ok_packet(): |
| 474 | raise err.OperationalError( |
| 475 | CR.CR_COMMANDS_OUT_OF_SYNC, |
| 476 | "Command Out of Sync", |
| 477 | ) |
| 478 | ok = OKPacketWrapper(pkt) |
| 479 | self.server_status = ok.server_status |
| 480 | return ok |
| 481 | |
| 482 | def _send_autocommit_mode(self): |
| 483 | """Set whether or not to commit after every execute().""" |