U 4Je@sdZddlZddlZddlmZddlmZmZmZm Z m Z m Z zddl Z dZWnek rhdZYnXzddlZdZWnek rdZYnXddlmZmZmZmZdd lmZmZmZmZmZmZdd lm Z m!Z!dd l"m"Z"dd l#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)ddl*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4ddl5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mGdddZ?GdddZ@GdddZAGdddZBdS)z3Implementation of the X protocol for MySQL servers.N)BytesIO)AnyDictListOptionalTupleUnionTF)InterfaceErrorNotSupportedErrorOperationalErrorProgrammingError) ExprParserbuild_bool_scalar build_exprbuild_int_scalar build_scalarbuild_unsigned_int_scalar)encode_to_bytesget_item_or_attr)logger)CRUD_PREPARE_MAPPINGSERVER_MESSAGESMessage mysqlxpb_enum)Column) AddStatementDeleteStatementFilterableStatement FindStatementInsertStatementModifyStatement ReadStatementRemoveStatement SqlStatementUpdateStatement) ColumnType MessageTypeProtobufMessageCextTypeProtobufMessageTypeResultBaseType SocketType StatementType StrOrBytesic@s@eZdZdZeddddZeedddZeedd d Z dS) CompressorzImplements compression/decompression using `zstd_stream`, `lz4_message` and `deflate_stream` algorithms. Args: algorithm (str): Compression algorithm. .. versionadded:: 8.0.21 N algorithmreturncCsP||_d|_d|_|dkr0t|_t|_n|dkrLt|_t|_dS)N zstd_streamZdeflate_stream) _algorithm _compressobj_decompressobjzstdZZstdCompressorZZstdDecompressorzlib compressobj decompressobjselfr0r<3/tmp/pip-unpacked-wheel-7_167w8m/mysqlx/protocol.py__init__js   zCompressor.__init__)datar1c Cs~|jdkr|j|S|jdkr\tj(}|}|||7}||7}W5QRX|S|j|}||jtj 7}|S)zCompresses data and returns it. Args: data (str, bytes or buffer object): Data to be compressed. Returns: bytes: Compressed data. r2 lz4_message) r3r4compresslz4frameZLZ4FrameCompressorbeginflushr7 Z_SYNC_FLUSH)r;r?Z compressor compressedr<r<r=rAvs     zCompressor.compressc Csf|jdkr|j|S|jdkrDtj}||}W5QRX|S|j|}||jtj7}|S)zDecompresses a frame of data and returns it as a string of bytes. Args: data (str, bytes or buffer object): Data to be compressed. Returns: bytes: Decompresssed data. r2r@) r3r5 decompressrBrCZLZ4FrameDecompressorrEr7rF)r;r?Z decompressor decompressedr<r<r=rHs     zCompressor.decompress) __name__ __module__ __qualname____doc__strr>r-bytesrArHr<r<r<r=r._s  r.c@s\eZdZdZeddddZedddZedd d Zedd d d Z e ddddZ dS) MessageReaderzImplements a Message Reader. Args: socket_stream (mysqlx.connection.SocketStream): `SocketStream` object. .. versionadded:: 8.0.21 N socket_streamr1cCs||_d|_d|_g|_dSN)_stream _compressor_msg _msg_queuer;rRr<r<r=r>szMessageReader.__init__r1c Cs|jr|jdStd|jd\}}|dkr:td|j|d}|tkr`td||dkrx|d krx| St ||}|d kr|d }t |j |d }d}||krtd|d\}} ||d} |jt | | ||d 7}q|jr|jdSdS|S)aReads X Protocol messages from the stream and returns a :class:`mysqlx.protobuf.Message` object. Raises: :class:`mysqlx.ProgrammingError`: If e connected server does not have the MySQL X protocol plugin enabled. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. rr'rhrorprNrrr<r<r<r=rPs /  rPc@sBeZdZdZeddddZeeddddZe dd d d Z dS) MessageWriterzImplements a Message Writer. Args: socket_stream (mysqlx.connection.SocketStream): `SocketStream` object. .. versionadded:: 8.0.21 NrQcCs||_d|_dSrS)rTrUrXr<r<r=r>szMessageWriter.__init__rlrnr1c Cs ||}|jr|tkrt|}td|d|}|jd||g}t d}||d<|d|d<t d}||d<dt| d d t| g} t d } tdt | d| }|j d|| gn4t|}td|d|}|j d||gd S) zWrite message. Args: msg_type (int): The message type. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. rZr r^zMysqlx.Connection.CompressionZclient_messagesr[r`raNz&Mysqlx.ClientMessages.Type.COMPRESSION)Z byte_sizerU_COMPRESSION_THRESHOLDrZserialize_to_stringrdpackrAjoinrZserialize_partial_to_stringrlenrTsendall) r;rlrnZmsg_sizeZmsg_strheaderrGZmsg_first_fieldsZ msg_payloadoutputZ msg_comp_idr<r<r= write_messages.       zMessageWriter.write_messager/cCs|r t|nd|_dS)zCreates a :class:`mysqlx.protocol.Compressor` object based on the compression algorithm. Args: algorithm (str): Compression algorithm. Nrqr:r<r<r=rr:szMessageWriter.set_compression) rJrKrLrMr+r>intr'r}rNrrr<r<r<r=rss %rsc @seZdZdZeeddddZeee dddZ e e e dd d d Zeee d d dZdUee efeeedeeeeffdddZe eddddZeee dddZe ddddZe dddZedddd ZdVe ee ee dd!d"d#Zedd$d%Z e dd&d'd(Z!ddd)d*Z"e e ee#e$e%e&e'e(fdd+d,d-Z)e e e dd+d.d/Z*e+dd0d1d2Z,e e ee efdd+d3d4Z-e e dd5d6d7Z.ee#e&fe/e e fd8d9d:Z0ee%e(fe/e e fd8d;d<Z1ee$e'fe/e e fd8d=d>Z2dWe ee e3fee4e efe/e e fd?d@dAZ5e ee6e7fe/e e fd8dBdCZ8edddDdEZ9eee ddFdGZ:eee;ddHdIZdddNdOZ?dddPdQZ@dXeeedRdSdTZAdS)YProtocolzImplements the MySQL X Protocol. Args: read (mysqlx.protocol.MessageReader): A Message Reader object. writer (mysqlx.protocol.MessageWriter): A Message Writer object. .. versionchanged:: 8.0.21 N)readerwriterr1cCs||_||_d|_g|_dSrS)_reader_writer_compression_algorithm _warnings)r;rrr<r<r=r>NszProtocol.__init__rYcCs|jS)zstr: The compresion algorithm.)r)r;r<r<r=compression_algorithmTszProtocol.compression_algorithm)rnstmtr1cCsX|jr||d<|jr*|d||jrB|d||jrT||d<dS)zApply filter. Args: msg (mysqlx.protobuf.Message): The MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. ZcriteriaordergroupingZgrouping_criteriaN) Z has_whereZget_where_exprZhas_sortextendZ get_sort_exprZ has_group_byZ get_groupingZ has_havingZ get_having)rnrr<r<r= _apply_filterYs zProtocol._apply_filter)argr1cCst|tr2td|d}tdd|d}tdd|dSt|trNtddt|dSt|tr|d krrtddt|dStddt|dSt|trt |d kr|\}}td || |d }td | gd}tdd |dSt|t st|t tfrt|d t rg}|D]h} g} | D],\} }td | | |d }| | qtd | d} tdd | d} || q td}||d<tdd|dSt|t rg} |D],\} }td | | |d }| | qtd | d} tdd | d} | SdS)zCreate any. Args: arg (object): Arbitrary object. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. zMysqlx.Datatypes.Scalar.StringvaluezMysqlx.Datatypes.Scalar)typeZv_stringMysqlx.Datatypes.Anyr )rscalarr#Mysqlx.Datatypes.Object.ObjectFieldkeyrMysqlx.Datatypes.ObjectZfldrobjzMysqlx.Datatypes.Arrayr)rarrayN) isinstancerNrboolrr~rrtuplery _create_any get_messagedictlistitemsri)r;rrrZarg_key arg_valueobj_fldrZ array_valuesrobj_fldsrmsg_objmsg_anyrnr<r<r=rjs           zProtocol._create_anyT)r is_scalarr1c sttttfdfdd |}|}|dkrHfdd|DSt|}|dg}|t|krntd|D]2\}}||krtd|||} ||| <qv|S) aReturns the binding any/scalar. Args: stmt (Statement): A `Statement` based type object. is_scalar (bool): `True` to return scalar values. Raises: :class:`mysqlx.ProgrammingError`: If unable to find placeholder for parameter. Returns: list: A list of ``Any`` or ``Scalar`` objects. )rr1csrt|S|SrS)rrrr)rr;r<r= build_values z/Protocol._get_binding_args..build_valueNcsg|] }|qSr<r<.0r)rr<r= sz.Protocol._get_binding_args..z;The number of bind parameters and placeholders do not matchz*Unable to find placeholder for parameter: ) rrr)r( get_bindingsZget_binding_mapryr r) r;rrZbindingsZ binding_mapcountargsnamerposr<)rrr;r=_get_binding_argss*   zProtocol._get_binding_args)rnresultr1cCs |ddkrRtd|d}|j|jtd|j|j||j |j|jn|ddkrptd|dn|ddkrtd |d}|d t d kr| d d |dDnP|d }|d t dkr| t|dn"|d t dkr|t|ddS)zProcess frame. Args: msg (mysqlx.protobuf.Message): A MySQL X Protobuf Message. result (Result): A `Result` based type object. rr zMysqlx.Notice.Warningraz:Protocol.process_frame Received Warning Notice code %s: %srz$Mysqlx.Notice.SessionVariableChangedrz!Mysqlx.Notice.SessionStateChangedparamzBMysqlx.Notice.SessionStateChanged.Parameter.GENERATED_DOCUMENT_IDScSs g|]}tt|ddqS)Zv_octetsr)rdecoderr<r<r=rs z+Protocol._process_frame..rz9Mysqlx.Notice.SessionStateChanged.Parameter.ROWS_AFFECTEDZv_unsigned_intz?Mysqlx.Notice.SessionStateChanged.Parameter.GENERATED_INSERT_IDN)rZ from_messagerrirnrwarningcodeZappend_warninglevelrZset_generated_idsrcZset_rows_affectedrZset_generated_insert_id)r;rnrZwarn_msgZsess_state_msgZsess_state_valuer<r<r=_process_framesJ   zProtocol._process_frame)rr1c Cs z|j}WnFtk rT}z(t|}|rDt|d||W5d}~XYnX|jdkrrt|d|d|jdkrz|||Wntt fk rYqYnXq|jdkrdS|jdkr| d q|jd kr| d q|jd kr| d qqqq|S) z`Read message. Args: result (Result): A `Result` based type object. z reason: N Mysqlx.ErrorrnrMysqlx.Notice.FramezMysqlx.Sql.StmtExecuteOkzMysqlx.Resultset.FetchDoneTz(Mysqlx.Resultset.FetchDoneMoreResultsetsMysqlx.Resultset.Row) rro RuntimeErrorreprZ get_warningsrr rAttributeErrorKeyErrorZ set_closedZset_has_more_resultsZ set_has_data)r;rrnerrwarningsr<r<r=rhs0 &          zProtocol._read_messager/cCs"||_|j||j|dS)zSets the compression algorithm to be used by the compression object, for uplink and downlink. Args: algorithm (str): Algorithm to be used in compression/decompression. .. versionadded:: 8.0.21 N)rrrrrr:r<r<r=rr3s  zProtocol.set_compressioncCsZtd}|jtd||j}|jdkr:|j}q$|jdkrVt|d|d|S)zkGet capabilities. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. z!Mysqlx.Connection.CapabilitiesGetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_GETrrrnr)rrr}rrrorr rmr<r<r=get_capabilitesAs    zProtocol.get_capabilites)kwargsr1c Ks"|sdStd}|D]\}}td}||d<t|tr|}g}|D]*}td||||d} || qFtd|d} td d | d } | |d <n|||d <|d |gqtd} || d <|j t d| z | WSt k r} z| j dkr W5d} ~ XYnXdS)zSet capabilities. Args: **kwargs: Arbitrary keyword arguments. Returns: mysqlx.protobuf.Message: MySQL X Protobuf Message. NzMysqlx.Connection.CapabilitieszMysqlx.Connection.Capabilityrrrrrrrrr capabilitiesz!Mysqlx.Connection.CapabilitiesSetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_SETi)rrrrrrirrrr}rread_okr errno)r;rrrrZ capabilityrritemrrrrnrr<r<r=set_capabilitiesUsB      zProtocol.set_capabilities)method auth_datainitial_responser1cCsFtd}||d<|dk r ||d<|dk r0||d<|jtd|dS)zSend authenticate start. Args: method (str): Message method. auth_data (Optional[str]): Authentication data. initial_response (Optional[str]): Initial response. z Mysqlx.Session.AuthenticateStartZ mech_nameNrrz2Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_STARTrrr}r)r;rrrrnr<r<r=send_auth_starts zProtocol.send_auth_startcCs:|j}|jdkr |j}q |jdkr2td|dS)zRead authenticate continue. Raises: :class:`InterfaceError`: If the message type is not `Mysqlx.Session.AuthenticateContinue` Returns: str: The authentication data. r#Mysqlx.Session.AuthenticateContinuez>Unexpected message encountered during authentication handshakerrrorr rmr<r<r=read_auth_continues    zProtocol.read_auth_continue)rr1cCs"td|d}|jtd|dS)zeSend authenticate continue. Args: auth_data (str): Authentication data. r)rz5Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_CONTINUENr)r;rrnr<r<r=send_auth_continues  zProtocol.send_auth_continuecCs0|j}|jdkrq,|jdkrt|jqdS)z~Read authenticate OK. Raises: :class:`mysqlx.InterfaceError`: If message type is `Mysqlx.Error`. zMysqlx.Session.AuthenticateOkrN)rrorr rnrmr<r<r= read_auth_oks    zProtocol.read_auth_ok)rlrnrr1c CsR|jr|jdkr|jdkr*||\}}nB|jdkrD||\}}n(|jdkr^||\}}ntd|t|}td}t d}t d||d |d <|jdkrt d||d d |d <||d <t |\}} t d} t|| d<|| | <t d} |j | d<| | d<|j td| z |Wn*tk rL} z t| W5d} ~ XYnXdS)a Send prepare statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. Raises: :class:`mysqlx.NotSupportedError`: If prepared statements are not supported. .. versionadded:: 8.0.16 Mysqlx.Crud.InsertMysqlx.Crud.FindMysqlx.Crud.UpdateMysqlx.Crud.DeletezInvalid message type: z!Mysqlx.Expr.Expr.Type.PLACEHOLDERzMysqlx.Crud.LimitExprzMysqlx.Expr.Expr)rposition row_countr offsetZ limit_expr#Mysqlx.Prepare.Prepare.OneOfMessagerzMysqlx.Prepare.Preparestmt_idrz*Mysqlx.ClientMessages.Type.PREPARE_PREPAREN) has_limitr build_find build_update build_deletergryrrrrrrr}rr r ) r;rlrnr_r placeholderZmsg_limit_expr oneof_typeoneof_op msg_oneofZ msg_preparerr<r<r=send_prepare_preparesL           zProtocol.send_prepare_preparec Cst|\}}td}t||d<|||<td}|j|d<|j|dd}|rZ|d||jr|d|| ||  g|j td|d S) a  Send execute statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. .. versionadded:: 8.0.16 rrzMysqlx.Prepare.ExecuterFrrz*Mysqlx.ClientMessages.Type.PREPARE_EXECUTEN) rrrrrrrrget_limit_row_countrget_limit_offsetrr}) r;rlrnrrrrZ msg_executerr<r<r=send_prepare_execute s&   zProtocol.send_prepare_execute)rr1cCs.td}||d<|jtd||dS)z Send prepare deallocate statement. Args: stmt_id (int): Statement ID. .. versionadded:: 8.0.16 zMysqlx.Prepare.Deallocaterz-Mysqlx.ClientMessages.Type.PREPARE_DEALLOCATEN)rrr}rr)r;rZ msg_deallocr<r<r=send_prepare_deallocate2s z Protocol.send_prepare_deallocatecCsp|jr8td}||d<|jdkr0||d<||d<|dk}|j||d}|r`|d||||d S) a) Send a message without prepared statements support. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. stmt (Statement): A `Statement` based type object. .. versionadded:: 8.0.16 zMysqlx.Crud.Limitrrrlimit+Mysqlx.ClientMessages.Type.SQL_STMT_EXECUTErrN)rrrrrrrsend_msg)r;rlrnrZ msg_limitrrr<r<r=send_msg_without_psCs   zProtocol.send_msg_without_psrtcCs|jt||dS)z Send a message. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. .. versionadded:: 8.0.16 N)rr}r)r;rlrnr<r<r=r_s zProtocol.send_msg)rr1cCst|rdnd}td|jj|jjd}td||d}|jrJ||d<|||| rltd|d <n| rtd |d <|j j d kr|j j |d <d |fS)aBuild find/read message. Args: stmt (Statement): A :class:`mysqlx.ReadStatement` or :class:`mysqlx.FindStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 Mysqlx.Crud.DataModel.DOCUMENTMysqlx.Crud.DataModel.TABLEMysqlx.Crud.Collectionrschemar data_model collection projectionz'Mysqlx.Crud.Find.RowLock.EXCLUSIVE_LOCKZlockingz$Mysqlx.Crud.Find.RowLock.SHARED_LOCKrZlocking_optionsz$Mysqlx.ClientMessages.Type.CRUD_FIND) r is_doc_basedrtargetrrZhas_projectionZget_projection_exprrZis_lock_exclusiveZis_lock_sharedZlock_contentionrr;rrrrnr<r<r=rks*     zProtocol.build_findcCst|rdnd}td|jj|jjd}td||d}||||D]P\}}td}|j |d<|j |d <|j d k rt |j |d <|d |gqPd |fS) aBuild update message. Args: stmt (Statement): A :class:`mysqlx.ModifyStatement` or :class:`mysqlx.UpdateStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 rrrrrrzMysqlx.Crud.UpdateOperation operationsourceNrz&Mysqlx.ClientMessages.Type.CRUD_UPDATE)rrrrrrrZget_update_opsrZ update_typerrrrr)r;rrrrnrZ update_oprr<r<r=rs0    zProtocol.build_updatecCsLt|rdnd}td|jj|jjd}td||d}|||d|fS)aBuild delete message. Args: stmt (Statement): A :class:`mysqlx.DeleteStatement` or :class:`mysqlx.RemoveStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 rrrrrrz&Mysqlx.ClientMessages.Type.CRUD_DELETE)rrrrrrrrr<r<r=rs" zProtocol.build_delete) namespacerfieldsr1c Cs|td||dd}|rtg}|D]*\}}td|||d}||q td|d} tdd | d } | g|d <d |fS) aBuild execute statement. Args: namespace (str): The namespace. stmt (Statement): A `Statement` based type object. fields (Optional[dict]): The message fields. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 zMysqlx.Sql.StmtExecuteF)rrZcompact_metadatarrrrrrrrr)rrrrir) r;rrrrnrrrrrrr<r<r=build_execute_statements& z Protocol.build_execute_statementc Cst|rdnd}td|jj|jjd}td||d}t|drv|jD],}t||  }|d | gqH| D]f}td }t |tr|D]}|d  t| gqn|d  t| g|d  | gq~t|d r||d <d|fS)aBuild insert statement. Args: stmt (Statement): A :class:`mysqlx.AddStatement` or :class:`mysqlx.InsertStatement` object. Returns: (tuple): Tuple containing: * `str`: Message ID string. * :class:`mysqlx.protobuf.Message`: MySQL X Protobuf Message. .. versionadded:: 8.0.16 rrrrrr_fieldsrzMysqlx.Crud.Insert.TypedRowfieldrow is_upsertZupsertz&Mysqlx.ClientMessages.Type.CRUD_INSERT)rrrrrrhasattrrrZparse_table_insert_fieldrrZ get_valuesrrrr) rrrrnrexprrrvalr<r<r= build_insert s@      zProtocol.build_insertcCs||}|dk rtddS)zClose the result. Args: result (Result): A `Result` based type object. Raises: :class:`mysqlx.OperationalError`: If message read is None. NzExpected to close the result)rhr r;rrnr<r<r= close_result>s zProtocol.close_resultcCs4||}|dkrdS|jdkr$|S|j|dS)z\Read row. Args: result (Result): A `Result` based type object. Nr)rhrrrpr r<r<r=read_rowKs   zProtocol.read_rowcCsg}||}|dkrq|jdkr0|j|q|jdkrBtdt|d|d|d|d|d |d |d |d d |dd|dd|dd|d }||q|S)zReturns column metadata. Args: result (Result): A `Result` based type object. Raises: :class:`mysqlx.InterfaceError`: If unexpected message. NrzMysqlx.Resultset.ColumnMetaDatazUnexpected msg typercatalogrtableZoriginal_tabler original_namelengthZ collationrZfractional_digitsflags content_type)rhrrrpr rgetri)r;rcolumnsrncolr<r<r=get_column_metadataYs2          zProtocol.get_column_metadatacCsD|j}|jdkr.td|d|dd|jdkr@tddS) zeRead OK. Raises: :class:`mysqlx.InterfaceError`: If unexpected message. rzMysqlx.Error: rnr)rz Mysqlx.OkzUnexpected message encounteredNrrmr<r<r=r}s    zProtocol.read_okcCstd}|jtd|dS)zSend connection close.zMysqlx.Connection.Closez$Mysqlx.ClientMessages.Type.CON_CLOSENrrmr<r<r=send_connection_closes zProtocol.send_connection_closecCstd}|jtd|dS)z Send close.zMysqlx.Session.Closez%Mysqlx.ClientMessages.Type.SESS_CLOSENrrmr<r<r= send_closes zProtocol.send_closecCsLtd}td}||d<d|d<td}|g|d<|jtd|d S) zSend expectation.z3Mysqlx.Expect.Open.Condition.Key.EXPECT_FIELD_EXISTzMysqlx.Expect.Open.ConditionZ condition_keyz6.1Zcondition_valuezMysqlx.Expect.OpenZcondz&Mysqlx.ClientMessages.Type.EXPECT_OPENN)rrrrr})r;Zcond_keyZmsg_ocZmsg_eor<r<r=send_expect_openszProtocol.send_expect_open) keep_openr1cCsttd}|dkrBz||d}Wntk r@d}YnX|rNd|d<|jtd|||rpdSdS)zSend reset session message. Returns: boolean: ``True`` if the server will keep the session open, otherwise ``False``. zMysqlx.Session.ResetNTFrz%Mysqlx.ClientMessages.Type.SESS_RESET)rrrr rr}r)r;rrnr<r<r= send_resets$ zProtocol.send_reset)T)NN)N)N)BrJrKrLrMrPrsr>propertyrrNr staticmethodr'rrrrrr$rrr)r(rr*rrhrrrrrrOrrrrrr!r"r#r%rrr~rrrrrrrr,rrrr r r r r&rrrrrrr<r<r<r=rDs K  .0!3   E %    +  *  %  *  4 $ r)CrMrdr7iortypingrrrrrrZ lz4.framerBZHAVE_LZ4 ImportErrorZ zstandardr6Z HAVE_ZSTDerrorsr r r r rrrrrrrZhelpersrrrZprotobufrrrrrrZ statementrrrrr r!r"r#r$r%typesr&r'r(r)r*r+r,r-rvr.rPrsrr<r<r<r=s6       0 ( Dd=