Method _read_load_local_packet

pymysql/connections.py:1333–1353

(self, first_packet)

        self.has_next = ok_packet.has_next

    def _read_load_local_packet(self, first_packet):
        conn: Connection = self.connection
        if not conn._local_infile:
            raise RuntimeError(
                "**WARN**: Received LOAD_LOCAL packet but local_infile option is false."
            )
        load_packet = LoadLocalPacketWrapper(first_packet)
        try:
            _send_local_file(load_packet.filename, conn)
        finally:
            # send the empty packet to signify we are done sending data
            conn.write_packet(b"")
            ok_packet = conn._read_packet()
            # If an error occurs while sending the file, exit here without handling
            # the OK packet.

        if not ok_packet.is_ok_packet():
            raise err.OperationalError(
                CR.CR_COMMANDS_OUT_OF_SYNC, "Commands Out of Sync"
            )
        self._read_ok_packet(ok_packet)

    def _check_packet_is_eof(self, packet):
        if not packet.is_eof_packet():