"iHdZ en #e$reZYnwxYwdZdZegZ ddlZe deDZ dZ n #e$rdZ YnwxYwddl m Z mZmZ dd lmZdd lmZdd lmZdd lmZdd lmZddlmZ ddlmZeen #e$rYnwxYweeeedrejZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddlm&Z&ddlm'Z'ddlm(Z(ddlm)Z)ddlm*Z*iZ+e&j,j-.D]\Z/Z0e0e+d1e/<e&j2j-.D]\Z/Z0e0e+d1e/<e&j3j4.D]\Z/Z0e0e+d 1e/<e j5.D]\Z/Z0e0e+d!1e/<e j6j7.D]\Z/Z0e0e+d"1e/<e j8j9.D]\Z/Z0e0e+d#1e/<e j:j;.D]\Z/Z0e0e+d$1e/<e"j<j-.D]\Z/Z0e0e+d%1e/<e"j=j-.D]\Z/Z0e0e+d&1e/<e#j>j?j@.D]\Z/Z0e0e+d'1e/<e#j>j?jA.D]\Z/Z0e0e+d(1e/<e#j>jB.D]\Z/Z0e0e+d)1e/<e$jCj-.D]\Z/Z0e0e+d*1e/<e$jDj-.D]\Z/Z0e0e+d+1e/<e%jEjF.D]\Z/Z0e0e+d,1e/<e%jGjH.D]\Z/Z0e0e+d-1e/<e%jIjJ.D]\Z/Z0e0e+d.1e/<e'jKjLj-.D]\Z/Z0e0e+d/1e/<e(jMjN.D]\Z/Z0e0e+d01e/<ejOZPejQePZRePSejTUejVjWePSejTUe jVjWePSejTUe!jVjWePSejTUe"jVjWePSejTUe#jVjWePSejTUe$jVjWePSejTUe%jVjWePSejTUe&jVjWePSejTUe'jVjWePSejTUe(jVjWePSejTUe)jVjWePSejTUe*jVjWe d1eDZ dZXdZYGd2d3eZZ[n>#eee\e]f$r2Z^dZXee^nd4ZYe sed51eYYdZ^[^ndZ^[^wwxYwd6d7d8d9d:d;Z_Gd<d=eZZ`Gd>d?eZZad@ZbdS)AzXThis module contains the implementation of a helper class for MySQL X Protobuf messages.))zMysqlx.ServerMessages.Type.OKz Mysqlx.Ok)z Mysqlx.ServerMessages.Type.ERRORz Mysqlx.Error)z,Mysqlx.ServerMessages.Type.CONN_CAPABILITIESzMysqlx.Connection.Capabilities)z5Mysqlx.ServerMessages.Type.SESS_AUTHENTICATE_CONTINUEz#Mysqlx.Session.AuthenticateContinue)z/Mysqlx.ServerMessages.Type.SESS_AUTHENTICATE_OKzMysqlx.Session.AuthenticateOk)z!Mysqlx.ServerMessages.Type.NOTICEzMysqlx.Notice.Frame)z5Mysqlx.ServerMessages.Type.RESULTSET_COLUMN_META_DATAzMysqlx.Resultset.ColumnMetaData)z(Mysqlx.ServerMessages.Type.RESULTSET_ROWzMysqlx.Resultset.Row)z/Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONEzMysqlx.Resultset.FetchDone)z4Mysqlx.ServerMessages.Type.RESULTSET_FETCH_SUSPENDEDzMysqlx.Resultset.FetchSuspended)z?Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONE_MORE_RESULTSETSz(Mysqlx.Resultset.FetchDoneMoreResultsets)z.Mysqlx.ServerMessages.Type.SQL_STMT_EXECUTE_OKzMysqlx.Sql.StmtExecuteOk)z?Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONE_MORE_OUT_PARAMSz'Mysqlx.Resultset.FetchDoneMoreOutParams)z&Mysqlx.ServerMessages.Type.COMPRESSIONzMysqlx.Connection.CompressionNcZg|](\}}ttj||f)S)int _mysqlxpb enum_value.0keyvals P/srv/django_bis/venv311/lib/python3.11/site-packages/mysqlx/protobuf/__init__.py r IsJEEE (S!!5c!:!:;;SAEEETF) BYTE_TYPES NUMERIC_TYPESencode_to_bytes)protobuf)descriptor_database)descriptor_pb2)descriptor_pool)message_factory)RepeatedCompositeFieldContainer)RepeatedCompositeContainer __version__)mysqlx_connection_pb2)mysqlx_crud_pb2)mysqlx_cursor_pb2)mysqlx_datatypes_pb2)mysqlx_expect_pb2)mysqlx_expr_pb2)mysqlx_notice_pb2) mysqlx_pb2)mysqlx_prepare_pb2)mysqlx_resultset_pb2)mysqlx_session_pb2)mysqlx_sql_pb2zMysqlx.ClientMessages.Type.{0}zMysqlx.ServerMessages.Type.{0}zMysqlx.Error.Severity.{0}zMysqlx.Crud.DataModel.{0}zMysqlx.Crud.Find.RowLock.{0}zMysqlx.Crud.Order.Direction.{0}z*Mysqlx.Crud.UpdateOperation.UpdateType.{0}z Mysqlx.Datatypes.Scalar.Type.{0}zMysqlx.Datatypes.Any.Type.{0}z3Mysqlx.Expect.Open.Condition.ConditionOperation.{0}z$Mysqlx.Expect.Open.Condition.Key.{0}z#Mysqlx.Expect.Open.CtxOperation.{0}zMysqlx.Expr.Expr.Type.{0}z%Mysqlx.Expr.DocumentPathItem.Type.{0}zMysqlx.Notice.Frame.Scope.{0}zMysqlx.Notice.Warning.Level.{0}z/Mysqlx.Notice.SessionStateChanged.Parameter.{0}z,Mysqlx.Prepare.Prepare.OneOfMessage.Type.{0}z-Mysqlx.Resultset.ColumnMetaData.FieldType.{0}c2g|]\}}t||fSr _MESSAGESrs r r r s%GGG83)C.# GGGrceZdZdZejZedZedZ edZ edZ edZ edZ dS) _mysqlxpb_purez]This class implements the methods in pure Python used by the _mysqlxpb C++ extension.ctjt|}|SN)r,factory GetPrototype_DESCRIPTOR_POOLFindMessageTypeByName)nameclss r new_messagez_mysqlxpb_pure.new_messages6 (55 66t<<>>C355Lrct|Sr.r))r s r rz_mysqlxpb_pure.enum_values S> !rc*|Sr.)SerializeToStringmsgs r serialize_messagez _mysqlxpb_pure.serialize_messages((** *rc*|Sr.)SerializePartialToStringr9s r serialize_partial_messagez(_mysqlxpb_pure.serialize_partial_messages//11 1rcdt|}|||Sr.)r,r5ParseFromString) msg_type_namepayloadr:s r parse_messagez_mysqlxpb_pure.parse_messages. ,,];;C    ( ( (Jrct|}|s"td|t|}|||S)NzUnknown msg_type: {0})SERVER_MESSAGESget ValueErrorformatr,r5r@)msg_typerBrAr:s r parse_server_messagez#_mysqlxpb_pure.parse_server_messagesg+//99M  K !8!?!?!I!IJJJ ,,];;C    ( ( (JrN)__name__ __module__ __qualname____doc__rMessageFactoryr/ staticmethodr5rr;r>rCrJrrr r,r,s $ $1/022       " "  "  + +  +  2 2  2            rr,zProtobuf >=3.0.0 is requiredProtobuf is not available: {})z-Mysqlx.Prepare.Prepare.OneOfMessage.Type.FINDfind)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.INSERTinsert)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.UPDATEupdate)z/Mysqlx.Prepare.Prepare.OneOfMessage.Type.DELETEdelete)z-Mysqlx.Prepare.Prepare.OneOfMessage.Type.STMT stmt_execute)z$Mysqlx.ClientMessages.Type.CRUD_FINDz&Mysqlx.ClientMessages.Type.CRUD_INSERTz&Mysqlx.ClientMessages.Type.CRUD_UPDATEz&Mysqlx.ClientMessages.Type.CRUD_DELETEz+Mysqlx.ClientMessages.Type.SQL_STMT_EXECUTEc@eZdZdZereneZerdndZe dZ dS)ProtobufzProtobuf class acts as a container of the Protobuf message class. It allows the switch between the C extension and pure Python implementation message handlers, by patching the `mysqlxpb` class attribute. FTc|r.ts'tdt|ststd|rt nt t_|t_ dS)zSets whether to use the C extension or pure Python implementation. Args: use_pure (bool): `True` to use pure Python implementation. rQz-MySQL X Protobuf C extension is not availableN) HAVE_PROTOBUF ImportErrorrHHAVE_PROTOBUF_ERRORHAVE_MYSQLXPB_CEXTr,rrXmysqlxpbuse_pure)r_s r set_use_purezProtobuf.set_use_puresz  OM O!!'(;!> > O"4 OMNN N.6ENNI$rN) rKrLrMrNr]rr,r^r_rPr`rrr rXrXsU/ByyNH*4uuH % %\ % % %rrXceZdZdZddZdZdZdZdZddZ d Z d Z d Z d Z ed ZedZedZedZedZedZdS)MessagezHelper class for interfacing with the MySQL X Protobuf extension. Args: msg_type_name (string): Protobuf type name. **kwargs: Arbitrary keyword arguments with values for the message. Nc |rtj|nd|jd<|D]\}}|||dS)N_msg)rXr^r5__dict__items __setattr__)selfrAkwargsr values r __init__zMessage.__init__-sm!' 1 = =m L L L"& f ,,.. ) )JC   S% ( ( ( ( ) )rctjr(t|tr%t |j|t |dSt|ttfrt |j||dSt|tr*t|j| |dSt|tr?? : 4/////E4(( : 4((//66666E7++ : 4((2253D3D3F3FGGGGG 4((22599999eW--9e//11138 IdOOOrc tjs |j|nt|j|S#t$rt wxYwr.)rXr_rdrqKeyErrorAttributeErrorrhr3s r __getattr__zMessage.__getattr__CsQ !*2*;.49T??TY-- . ! ! !  !s -0Ac2|||dSr.)rgrus r __setitem__zMessage.__setitem__Js u%%%%%rc,||Sr.)rzrys r __getitem__zMessage.__getitem__Ms%%%rctjs!|jd||nt |jd||S)a Returns the value of an element of the message dictionary. Args: name (string): Key name. default (object): The default value if the key does not exists. Returns: object: The value of the provided key name. rd)rXr_rerFrq)rhr3defaults r rFz Message.getPsH$Bt}V$((w777DM&14AA Brc||jd<dS)zdSets the message. Args: msg (dict): Dictionary representing a message. rdNre)rhr:s r set_messagezMessage.set_message^s !$ frc|jdS)zReturns the dictionary representing a message containing parsed data. Returns: dict: The dictionary representing a message containing parsed data. rdrrhs r rtzMessage.get_messagefs}V$$rcJtj|jS)zSerializes a message to a string. Returns: str: A string representing a message containing parsed data. )rXr^r;rdrs r serialize_to_stringzMessage.serialize_to_stringos  2249===rcJtj|jS)zSerializes the protocol message to a binary string. This method is similar to serialize_to_string but doesn't check if the message is initialized. Returns: str: A string representation of the partial message. )rXr^r>rdrs r serialize_partial_to_stringz#Message.serialize_partial_to_stringws ::49EEErcVtjs |jdn|jjjS)zstring: Message type name._mysqlxpb_type_name)rXr_rd DESCRIPTOR full_namers r typez Message.types-8@7H0ty.//%/ 0rcBtj||S)a>Creates a new message, initialized with parsed data. Args: msg_type_name (string): Message type name. payload (string): Serialized message data. Returns: dict: The dictionary representing a message containing parsed data. .. versionadded:: 8.0.21 )rXr^rC)rArBs r parsez Message.parses ..}gFFFrctjr|n-tt |S)zReturns the size of the message in bytes. Args: msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. Returns: int: Size of the message in bytes. .. versionadded:: 8.0.21 )rXr_ByteSizelenrrr9s r byte_sizezMessage.byte_sizesA"*!2As||~~~_S%<%<%>%>??@@ ArcBtj||S)aCreates a new server-side message, initialized with parsed data. Args: msg_type (int): Message type. payload (string): Serialized message data. Returns: dict: The dictionary representing a message containing parsed data. )rXr^rJ)rIrBs r parse_from_serverzMessage.parse_from_servers 55hHHHrc|}|tj|||S)aCreates a new message, initialized with parsed data and returns a :class:`mysqlx.protobuf.Message` object. Args: msg_type_name (string): Message type name. payload (string): Serialized message data. Returns: mysqlx.protobuf.Message: The Message representing a message containing parsed data. )rrXr^rC)r4rArBr:s r from_messagezMessage.from_messages9cee )77 wOOPPP rc|}|tj|||S)aCreates a new server-side message, initialized with parsed data and returns a :class:`mysqlx.protobuf.Message` object. Args: msg_type (int): Message type. payload (string): Serialized message data. Returns: mysqlx.protobuf.Message: The Message representing a message containing parsed data. )rrXr^rJ)r4rIrBr:s r from_server_messagezMessage.from_server_messagesCcee    2 28W E E G G G rr.)rKrLrMrNrkrgrzr|r~rFrrtrrpropertyrrPrrr classmethodrrrrr rbrb&sp )))) 999 !!!&&&&&& B B B B$$$%%%>>> F F F00X0  G G\ G A A\ A I I\ I[ [rrbc@tj|S)zReturns the value of a MySQL X Protobuf enumerator. Args: name (string): MySQL X Protobuf numerator name. Returns: int: Value of the enumerator. )rXr^r)r3s r mysqlxpb_enumrs   ' ' - --r)crNModuleNotFoundError NameErrorr[_SERVER_MESSAGES_TUPLESPROTOBUF_VERSIONrpPROTOBUF_REPEATED_TYPESrdictrEr]helpersrrrgooglergoogle.protobufrrrr#google.protobuf.internal.containersrgoogle.protobuf.pyext._messagerappendhasattrrrrrrr r!r"r#r$r%r&r'r*ClientMessagesTyperfr r rHServerMessagesErrorSeverity DataModelFindRowLockOrder DirectionUpdateOperation UpdateTypeScalarAnyOpen ConditionConditionOperationKey CtxOperationExprDocumentPathItemFrameScopeWarningLevelSessionStateChanged ParameterPrepare OneOfMessageColumnMetaData FieldTypeDescriptorDatabase_DESCRIPTOR_DBDescriptorPoolr1AddFileDescriptorProto FromStringr serialized_pbrZr\objectr, SyntaxError TypeErrorerrCRUD_PREPARE_MAPPINGrXrbrrrr rs8 :&&&&%&>&dEE,CEEEFFOA@@@@@@@@@m:333333......////////////))))))  ( ( ( ( ( (&&'ABBBB      ""#BCCCwx''0#/''''''!!!!!!######&&&&&&######!!!!!!######$$$$$$&&&&&&$$$$$$      I-288::FFSBE 299#>>??-288::FFSBE 299#>>??$-3355AAS=@ -44S99::$-3355AAS=@ -44S99::#(06688DDS@C 077<<==#)399;;GGSCF 3::3??@@#3>DDFFRRSNQ >EEcJJKK)/4::<<HHSDG 4;;C@@AA(,17799EESAD 188==>>&*4GMMOO((S$' VC[[ " "%*48>>@@((S$' VC[[ " "%*7==??KKSGJ 7>>sCCDD$(-3355AAS=@ -44S99::#49??AAMMSIL 9@@EEFF&+17799EESAD 188==>>%-399;;GGSCF 3::3??@@%9CIIKK((S$' VC[[ " "'.;@FFHH((S$' VC[[ " ")7AGGIIUUSQT AHHMMNN<(;==N55nEE~9DD(688999~9DD"022333~9DD$244555~9DD'577888~9DD$244555~9DD"022333~9DD$244555~9DD+--...~9DD%355666~9DD'577888~9DD%355666~9DD!/11222dGG/FGGGOM%%%%%%%%%L (+yA:::M!1!=## + :k#V$788:: :::::: :-A/E/E/E4I  %%%%%v%%%0nnnnnfnnnb . . . . .sX8AA$a'5Ba'Ba'B_ a'' b"0(bb"