3 (hH$@sdZyeWnek r$eZYnXdrZdZegZy"ddlZe dd eDZ d!Z Wnek rnd"Z YnXd#d$l m Z mZmZmZd#d%lmZydd&lmZdd'lmZdd(lmZdd)lmZdd*lmZdd+lmZydd,lmZejeWnek rYnXejeeed-r.ej Zd.d/l!m"Z"d.d0l!m#Z#d.d1l!m$Z$d.d2l!m%Z%d.d3l!m&Z&d.d4l!m'Z'd.d5l!m(Z(d.d6l!m)Z)d.d7l!m*Z*d.d8l!m+Z+d.d9l!m,Z,d.d:l!m-Z-iZ.x(e)j/j0j1D]\Z2Z3e3e.d;j4e2<qWx(e)j5j0j1D]\Z2Z3e3e.dj4e2<qLWx(e#j9j:j1D]\Z2Z3e3e.d?j4e2<qvWx(e#j;jj1D]\Z2Z3e3e.dAj4e2<qWx(e%j?j0j1D]\Z2Z3e3e.dBj4e2<qWx(e%j@j0j1D]\Z2Z3e3e.dCj4e2<qWx*e&jAjBjCj1D]\Z2Z3e3e.dDj4e2<qJWx*e&jAjBjDj1D]\Z2Z3e3e.dEj4e2<qvWx(e&jAjEj1D]\Z2Z3e3e.dFj4e2<qWx(e'jFj0j1D]\Z2Z3e3e.dGj4e2<qWx(e'jGj0j1D]\Z2Z3e3e.dHj4e2<qWx(e(jHjIj1D]\Z2Z3e3e.dIj4e2<qWx(e(jJjKj1D]\Z2Z3e3e.dJj4e2<qHWx(e(jLjMj1D]\Z2Z3e3e.dKj4e2<qrWx*e*jNjOj0j1D]\Z2Z3e3e.dLj4e2<qWx(e+jPjQj1D]\Z2Z3e3e.dMj4e2<qWejRZSejTeSZUeSjVejWjXe"jYjZeSjVejWjXe#jYjZeSjVejWjXe$jYjZeSjVejWjXe%jYjZeSjVejWjXe&jYjZeSjVejWjXe'jYjZeSjVejWjXe(jYjZeSjVejWjXe)jYjZeSjVejWjXe*jYjZeSjVejWjXe+jYjZeSjVejWjXe,jYjZeSjVejWjXe-jYjZe dNd eDZ d!Z[dZ\GdOdPdPe]Z^WnVeee_e`fk rZaz0d"Z[edk rXeandQZ\e spedRj4e\WYddZa[aXnXdsdtdudvdwd]ZbGd^d_d_e]ZcGd`dadae]ZddbdcZedS)xzXThis module contains the implementation of a helper class for MySQL X Protobuf messages.Mysqlx.ServerMessages.Type.OK Mysqlx.Ok Mysqlx.ServerMessages.Type.ERROR Mysqlx.Error,Mysqlx.ServerMessages.Type.CONN_CAPABILITIESMysqlx.Connection.Capabilities5Mysqlx.ServerMessages.Type.SESS_AUTHENTICATE_CONTINUE#Mysqlx.Session.AuthenticateContinue/Mysqlx.ServerMessages.Type.SESS_AUTHENTICATE_OKMysqlx.Session.AuthenticateOk!Mysqlx.ServerMessages.Type.NOTICEMysqlx.Notice.Frame5Mysqlx.ServerMessages.Type.RESULTSET_COLUMN_META_DATAMysqlx.Resultset.ColumnMetaData(Mysqlx.ServerMessages.Type.RESULTSET_ROWMysqlx.Resultset.Row/Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONEMysqlx.Resultset.FetchDone4Mysqlx.ServerMessages.Type.RESULTSET_FETCH_SUSPENDEDMysqlx.Resultset.FetchSuspended?Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONE_MORE_RESULTSETS(Mysqlx.Resultset.FetchDoneMoreResultsets.Mysqlx.ServerMessages.Type.SQL_STMT_EXECUTE_OKMysqlx.Sql.StmtExecuteOk?Mysqlx.ServerMessages.Type.RESULTSET_FETCH_DONE_MORE_OUT_PARAMS'Mysqlx.Resultset.FetchDoneMoreOutParams&Mysqlx.ServerMessages.Type.COMPRESSIONMysqlx.Connection.CompressionNcCs"g|]\}}ttj||fqS)int _mysqlxpb enum_value).0keyvalrrL/tmp/pip-install-q3hcpn_q/mysql-connector-python/mysqlx/protobuf/__init__.py Isr&TF)PY3 NUMERIC_TYPES STRING_TYPES BYTE_TYPES)encode_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}cCsg|]\}}t||fqSr) _MESSAGES)r"r#r$rrr%r&sc@s`eZdZdZejZeddZeddZ eddZ edd Z ed d Z ed d Z dS)_mysqlxpb_purez]This class implements the methods in pure Python used by the _mysqlxpb C++ extension.cCstjjtj|}|S)N)rCfactoryZ GetPrototype_DESCRIPTOR_POOLZFindMessageTypeByName)nameclsrrr% new_messages z_mysqlxpb_pure.new_messagecCst|S)N)rB)r#rrr%r!sz_mysqlxpb_pure.enum_valuecCs|jS)N)ZSerializeToString)msgrrr%serialize_messagesz _mysqlxpb_pure.serialize_messagecCs|jS)N)ZSerializePartialToString)rIrrr%serialize_partial_messagesz(_mysqlxpb_pure.serialize_partial_messagecCstj|}|j||S)N)rCrHParseFromString) msg_type_namepayloadrIrrr% parse_messages  z_mysqlxpb_pure.parse_messagecCs4tj|}|stdj|tj|}|j||S)NzUnknown msg_type: {0})SERVER_MESSAGESget ValueErrorformatrCrHrL)msg_typerNrMrIrrr%parse_server_messages    z#_mysqlxpb_pure.parse_server_messageN)__name__ __module__ __qualname____doc__r1ZMessageFactoryrD staticmethodrHr!rJrKrOrUrrrr%rCs     rCzProtobuf >=3.0.0 is requiredzProtobuf is not available: {}-Mysqlx.Prepare.Prepare.OneOfMessage.Type.FINDfind/Mysqlx.Prepare.Prepare.OneOfMessage.Type.INSERTinsert/Mysqlx.Prepare.Prepare.OneOfMessage.Type.UPDATEupdate/Mysqlx.Prepare.Prepare.OneOfMessage.Type.DELETEdelete-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@s4eZdZdZereneZer dndZe ddZ 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. FTcCsF|rt rtdjtn| r.t r.td|r6tntt_|t_ dS)zSets whether to use the C extension or pure Python implementation. Args: use_pure (bool): `True` to use pure Python implementation. zProtobuf is not available: {}z-MySQL X Protobuf C extension is not availableN) HAVE_PROTOBUF ImportErrorrSHAVE_PROTOBUF_ERRORHAVE_MYSQLXPB_CEXTrCr remysqlxpbuse_pure)rkrrr% set_use_pures   zProtobuf.set_use_pureN) rVrWrXrYrir rCrjrkrZrlrrrr%res  rec@seZdZdZd#ddZddZddZd d Zd d Zd$d dZ ddZ ddZ ddZ ddZ eddZeddZeddZeddZedd Zed!d"ZdS)%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. NcKs@|rtjj|nd|jd<x |jD]\}}|j||q$WdS)N_msg)rerjrH__dict__items __setattr__)selfrMkwargsr#valuerrr%__init__.szMessage.__init__cCstjrtr(t|tr(t|j|t|qt|ttt frHt|j||qt|t rft |j|j |qt|t rt |j|j|jqt |j|j|nt|t r|jn||j|<dS)N)rerkr( isinstancer*setattrrnr,r)r+listgetattrextendrmZ MergeFrom get_message)rrrFrtrrr%rq4s  zMessage.__setattr__c Cs:ytjs|j|St|j|Stk r4tYnXdS)N)rerkrnryKeyErrorAttributeError)rrrFrrr% __getattr__Ds  zMessage.__getattr__cCs|j||dS)N)rq)rrrFrtrrr% __setitem__KszMessage.__setitem__cCs |j|S)N)r~)rrrFrrr% __getitem__NszMessage.__getitem__cCs*tjs|jdj||St|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. rn)rerkrorQry)rrrFdefaultrrr%rQQs z Message.getcCs||jd<dS)zdSets the message. Args: msg (dict): Dictionary representing a message. rnN)ro)rrrIrrr% set_message_szMessage.set_messagecCs |jdS)zReturns the dictionary representing a message containing parsed data. Returns: dict: The dictionary representing a message containing parsed data. rn)ro)rrrrr%r{gszMessage.get_messagecCstjj|jS)zSerializes a message to a string. Returns: str: A string representing a message containing parsed data. )rerjrJrn)rrrrr%serialize_to_stringpszMessage.serialize_to_stringcCstjj|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. )rerjrKrn)rrrrr%serialize_partial_to_stringxs z#Message.serialize_partial_to_stringcCstjs|jdS|jjjS)zstring: Message type name.Z_mysqlxpb_type_name)rerkrn DESCRIPTORZ full_name)rrrrr%typesz Message.typecCstjj||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 )rerjrO)rMrNrrr%parses z Message.parsecCstjr|jStt|jS)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 )rerkZByteSizelenr,r)rIrrr% byte_sizes zMessage.byte_sizecCstjj||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. )rerjrU)rTrNrrr%parse_from_servers zMessage.parse_from_servercCs|}|jtjj|||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. )rrerjrO)rGrMrNrIrrr% from_messages zMessage.from_messagecCs|}|jtjj|||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. )rrerjrU)rGrTrNrIrrr%from_server_messages zMessage.from_server_message)N)N)rVrWrXrYrurqr~rrrQrr{rrpropertyrrZrrr classmethodrrrrrr%rm's"       rmcCs tjj|S)zReturns the value of a MySQL X Protobuf enumerator. Args: name (string): MySQL X Protobuf numerator name. Returns: int: Value of the enumerator. )rerjr!)rFrrr% mysqlxpb_enums rrrrrrrrrr r r r r rrrrrrrrrrrrrrr)rrrrrrrrrrrrrr)r[r\)r]r^)r_r`)rarb)rcrd)frYModuleNotFoundError NameErrorrgZ_SERVER_MESSAGES_TUPLESZPROTOBUF_VERSIONrxZPROTOBUF_REPEATED_TYPESr dictrPricompatr(r)r*r+helpersr,Zgoogler-Zgoogle.protobufr.r/r0r1Z#google.protobuf.internal.containersr2Zgoogle.protobuf.pyext._messager3appendhasattrr4r6r7r8r9r:r;r<r=r>r?r@rArBZClientMessagesTyperpr#r$rSZServerMessagesErrorZSeverityZ DataModelZFindZRowLockZOrderZ DirectionZUpdateOperationZ UpdateTypeZScalarZAnyZOpen ConditionZConditionOperationZKeyZ CtxOperationExprZDocumentPathItemZFrameZScopeWarningZLevelZSessionStateChanged ParameterZPrepareZ OneOfMessageZColumnMetaDataZ FieldTypeZDescriptorDatabaseZ_DESCRIPTOR_DBZDescriptorPoolrEAddZFileDescriptorProtoZ FromStringrZ serialized_pbrfrhobjectrC SyntaxError TypeErrorerrZCRUD_PREPARE_MAPPINGrermrrrrr%s8                                                  &2