query.py 文件源码

def prepare(self):
        """
        Prepare the query, marshall the payload, create binary data and calculate length (size).
        """
        self.packet = dumps(self.args, methodname=self.method, allow_none=True).encode()
        self.length = len(self.packet)

        if (self.length + 8) > self._client.MAX_REQUEST_SIZE:
            raise TransportException('The prepared query is larger than the maximum request size, we will not send this query!')