U
|
¤ý°d § ã @ s¨ d Z ddlZddlZddlmZ ddlmZmZmZm Z m
|
Z
|
m Z zddl Z dZW n ek
|
rh dZY nX zddlZdZW n ek
|
r dZY nX ddlmZmZmZmZ dd lmZmZmZm Z m Z m Z dd
|
l m Z m!Z! dd l"m"Z" dd l#m$Z$m%Z%m&Z&m'Z'm(Z( dd l)m*Z* ddl+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5 ddl6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z> dZ?G dd dZ@G dd dZAG dd dZBG dd dZCdS )z3Implementation of the X protocol for MySQL servers.é N)ÚBytesIO)ÚAnyÚDictÚListÚOptionalÚTupleÚUnionTFé )ÚInterfaceErrorÚNotSupportedErrorÚOperationalErrorÚProgrammingError)Ú
|
ExprParserÚbuild_bool_scalarÚ
|
build_exprÚbuild_int_scalarÚ build_scalarÚbuild_unsigned_int_scalar)Úencode_to_bytesÚget_item_or_attr)Úlogger)ÚCRUD_PREPARE_MAPPINGÚPROTOBUF_REPEATED_TYPESÚSERVER_MESSAGESÚMessageÚ mysqlxpb_enum)ÚColumn)
|
Ú AddStatementÚDeleteStatementÚFilterableStatementÚ FindStatementÚInsertStatementÚModifyStatementÚ ReadStatementÚRemoveStatementÚ SqlStatementÚUpdateStatement)Ú
|
ColumnTypeÚ MessageTypeÚProtobufMessageCextTypeÚProtobufMessageTypeÚResultBaseTypeÚ
|
SocketTypeÚ StatementTypeÚ
|
StrOrBytesiè c @ s@ e Zd ZdZeddddZeedddZeedd d
|
Z dS ) Ú
|
CompressorzËImplements compression/decompression using `zstd_stream`, `lz4_message`
|
and `deflate_stream` algorithms.
|
|
Args:
|
algorithm (str): Compression algorithm.
|
|
.. versionadded:: 8.0.21
|
|
N©Ú algorithmÚreturnc C sP || _ d | _d | _|dkr0t ¡ | _t ¡ | _n |dkrLt ¡ | _t ¡ | _d S )NÚ zstd_streamZdeflate_stream) Ú
|
_algorithmÚ _compressobjÚ_decompressobjÚzstdZZstdCompressorZZstdDecompressorÚzlibÚ compressobjÚ decompressobj©Úselfr1 © r= úFd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysqlx/protocol.pyÚ__init__p s
|
|
zCompressor.__init__)Údatar2 c C s~ | j dkr| j |¡S | j dkr\tj ¡ (}| ¡ }|| |¡7 }|| ¡ 7 }W 5 Q R X |S | j |¡}|| j tj ¡7 }|S )z´Compresses data and returns it.
|
|
Args:
|
data (str, bytes or buffer object): Data to be compressed.
|
|
Returns:
|
bytes: Compressed data.
|
r3 Ú lz4_message)
|
r4 r5 ÚcompressÚlz4ÚframeZLZ4FrameCompressorÚbeginÚflushr8 Ú Z_SYNC_FLUSH)r< r@ Z
|
compressorÚ
|
compressedr= r= r> rB | s
|
|
zCompressor.compressc C sf | j dkr| j |¡S | j dkrDtj ¡ }| |¡}W 5 Q R X |S | j |¡}|| j tj¡7 }|S )zÙDecompresses 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.
|
r3 rA ) r4 r6 Ú
|
decompressrC rD ZLZ4FrameDecompressorrF r8 rG )r< r@ Z decompressorÚ decompressedr= r= r> rI s
|
|
zCompressor.decompress)
|
Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ústrr? r. ÚbytesrB rI r= r= r= r> r/ e s
|
r/ c @ s\ e Zd ZdZeddddZedddZedd 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_streamr2 c C s || _ d | _d | _g | _d S ©N)Ú_streamÚ _compressorÚ_msgÚ
|
_msg_queue©r< rS r= r= r> r? ² s zMessageReader.__init__©r2 c C s | j r| j d¡S t d| j d¡¡\}}|dkr:td| j |d ¡}|tkr`td| |dkrx|d krx| ¡ S t
|
||¡}|d
|
kr|d }t | j |d ¡}d}||k rüt d| d¡¡\}} | |d ¡}
|
| j t
|
| |
|
¡¡ ||d 7 }q®| j r| j d¡S dS |S )a¦ Reads 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.
|
r ú<LBé é
|
z[The connected server does not have the MySQL X protocol plugin enabled or protocol mismatchr zUnknown message type: é ó é Úuncompressed_sizeÚpayloadé N)rX ÚpopÚstructÚunpackrU Úreadr r Ú
|
ValueErrorÚ _read_messager Zfrom_server_messager rV rI Úappend) r< Ú
|
frame_sizeZ
|
frame_typeZ frame_payloadZ frame_msgra ÚstreamZbytes_processedZ payload_sizeÚmsg_typerb r= r= r> ri ¸ s0 ÿ
|
zMessageReader._read_messagec C s" | j dk r| j }d| _ |S | ¡ S )zgRead message.
|
|
Returns:
|
mysqlx.protobuf.Message: MySQL X Protobuf Message.
|
N)rW ri ©r< Úmsgr= r= r> Ú read_messageç s
|
|
zMessageReader.read_message)ro r2 c C s | j dk rtd|| _ dS )zÇPush message.
|
|
Args:
|
msg (mysqlx.protobuf.Message): MySQL X Protobuf Message.
|
|
Raises:
|
:class:`mysqlx.OperationalError`: If message push slot is full.
|
NzMessage push slot is full)rW r rn r= r= r> Ú push_messageó s
|
zMessageReader.push_messager0 c C s |r t |nd| _dS )zÏCreates a :class:`mysqlx.protocol.Compressor` object based on the
|
compression algorithm.
|
|
Args:
|
algorithm (str): Compression algorithm.
|
|
.. versionadded:: 8.0.21
|
|
N©r/ rV r; r= r= r> Úset_compression s
|
z MessageReader.set_compression) rK rL rM rN r, r? r( ri rp rq rO rs r= r= r= r> rQ © s / rQ c @ sB e Zd ZdZeddddZeeddddZe dd d
|
d Z
|
dS ) Ú MessageWriterzImplements a Message Writer.
|
|
Args:
|
socket_stream (mysqlx.connection.SocketStream): `SocketStream` object.
|
|
.. versionadded:: 8.0.21
|
|
NrR c C s || _ d | _d S rT )rU rV rY r= r= r> r? s zMessageWriter.__init__©rm ro r2 c C s | |¡}| jrÔ|tkrÔt| ¡ }t d|d |¡}| j d ||g¡¡}t d}||d< |d |d< t d}||d< d t|
|
¡ d d
|
t|
|
¡ g¡} t d }
|
t dt | d |
|
¡}| j d || g¡¡ n4t| ¡ }t d|d |¡}| j d ||g¡¡ d S ) zWrite message.
|
|
Args:
|
msg_type (int): The message type.
|
msg (mysqlx.protobuf.Message): MySQL X Protobuf Message.
|
r[ r r_ z Mysqlx.Connection.CompressionZclient_messagesr\ ra rb Néþÿÿÿz&Mysqlx.ClientMessages.Type.COMPRESSION)Z byte_sizerV Ú_COMPRESSION_THRESHOLDr Zserialize_to_stringre ÚpackrB Újoinr Zserialize_partial_to_stringr ÚlenrU Úsendall) r< rm ro Zmsg_sizeZmsg_strÚheaderrH Zmsg_first_fieldsZ msg_payloadÚoutputZ msg_comp_idr= r= r> Ú write_message s.
|
ÿ
|
üÿ zMessageWriter.write_messager0 c C s |r t |nd| _dS )z¬Creates a :class:`mysqlx.protocol.Compressor` object based on the
|
compression algorithm.
|
|
Args:
|
algorithm (str): Compression algorithm.
|
Nrr r; r= r= r> rs @ s z MessageWriter.set_compression) rK rL rM rN r, r? Úintr( r~ rO rs r= r= r= r> rt s %rt c @ sæ e Zd ZdZeeddddZeee dddZ
|
e e e dd d
|
d Zeee d d dZdUee ef eeed eeeef f dddZe eddddZeee dddZe ddddZe dd d Z edd d d Z dVe ee ee dd!d"d#Z e dd$d%Z e dd&d'd(Z!ddd)d*Z"e e ee#e$e%e&e'e(f dd+d,d-Z)e e e dd+d.d/Z*e+dd0d1d2Z,e e ee ef dd+d3d4Z-e e dd5d6d7Z.ee#e&f e/e e f d8d9d:Z0ee%e(f e/e e f d8d;d<Z1ee$e'f e/e e f d8d=d>Z2dWe ee e3f ee4e ef e/e e f d?d@dAZ5e ee6e7f e/e e f d8dBdCZ8edddDdEZ9eee ddFdGZ:eee; ddHdIZ<dddJdKZ=dddLdMZ>dddNdOZ?dddPdQZ@dXee edRdSdTZAdS )YÚProtocolzàImplements 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)ÚreaderÚwriterr2 c C s || _ || _d | _g | _d S rT )Ú_readerÚ_writerÚ_compression_algorithmÚ _warnings)r< r r r= r= r> r? T s zProtocol.__init__rZ c C s | j S )z str: The compresion algorithm.)r
)r< r= r= r> Úcompression_algorithmZ s z Protocol.compression_algorithm)ro Ústmtr2 c C sX |j r| ¡ | 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.
|
ZcriteriaÚorderÚgroupingZgrouping_criteriaN) Z has_whereZget_where_exprZhas_sortÚextendZ get_sort_exprZ has_group_byZ get_groupingZ
|
has_havingZ
|
get_having)ro r r= r= r> Ú _apply_filter_ s zProtocol._apply_filter)Úargr2 c C sö t |tr2td|d}tdd|d}tdd|dS t |trNtddt|dS t |tr|d k rrtddt|dS tddt|dS t |trÖt |d
|
krÖ|\}}td ||
|
|¡d }td | ¡ gd}tdd
|
|dS t |t st |t tfrt |d t rg }|D ]h} g }
|
| ¡ D ],\} }td | |
|
|¡d }|
|
| ¡ ¡ qtd |
|
d} tdd
|
| d} | | ¡ ¡ q
|
td}||d< tdd|dS t |t ròg }
|
|D ],\} }td | |
|
|¡d }|
|
| ¡ ¡ q¦td |
|
d} tdd
|
| d} | S dS )z Create any.
|
|
Args:
|
arg (object): Arbitrary object.
|
|
Returns:
|
mysqlx.protobuf.Message: MySQL X Protobuf Message.
|
z Mysqlx.Datatypes.Scalar.String©ÚvaluezMysqlx.Datatypes.Scalaré )ÚtypeZv_stringúMysqlx.Datatypes.Anyr )r Úscalarr é ú#Mysqlx.Datatypes.Object.ObjectField©Úkeyr úMysqlx.Datatypes.Object©Zfld©r ÚobjzMysqlx.Datatypes.Arrayr é )r ÚarrayN)Ú
|
isinstancerO r Úboolr r r r Útuplerz Ú _create_anyÚ get_messageÚdictÚlistÚitemsrj )r< r r r Zarg_keyÚ arg_valueÚobj_fldr Z array_valuesr¥ Úobj_fldsr Úmsg_objÚmsg_anyro r= r= r> r¡ p s
|
|
ÿ
|
ýýý ÿ ÿý ý zProtocol._create_anyT)r Ú is_scalarr2 c
|
s® t tttf dfdd | ¡ }| ¡ }|dkrH fdd|D S t|}|dg }|t|krntd| ¡ D ]2\}}||krtd| || } ||| < qv|S ) a Returns 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.
|
)r r2 c s rt | ¡ S | ¡ ¡ S rT )r r¢ r¡ r )r« r< r= r> Ú build_valueË s z/Protocol._get_binding_args.<locals>.build_valueNc s g | ] } |qS r= r= ©Ú.0r )r¬ r= r> Ú
|
<listcomp>× s z.Protocol._get_binding_args.<locals>.<listcomp>z;The number of bind parameters and placeholders do not matchz*Unable to find placeholder for parameter: ) r r r* r) Ú get_bindingsZget_binding_maprz r r¥ )
|
r< r r« ZbindingsZ binding_mapÚcountÚargsÚnamer Úposr= )r¬ r« r< r> Ú_get_binding_argsº s*
|
þ
|
ÿÿzProtocol._get_binding_args)ro Úresultr2 c C s( |d dkrRt d|d ¡}| j |j¡ t d|j|j¡ | |j |j|j¡ nÒ|d dkrpt d|d ¡ n´|d dkr$t d |d ¡}|d
|
t
|
d kr¸| d d |d D ¡ nlt |d t trÖ|d d n|d }|d
|
t
|
dkr| t|d¡ n"|d
|
t
|
dkr$| t|d¡ dS )z¨Process frame.
|
|
Args:
|
msg (mysqlx.protobuf.Message): A MySQL X Protobuf Message.
|
result (Result): A `Result` based type object.
|
r r zMysqlx.Notice.Warningrb z:Protocol.process_frame Received Warning Notice code %s: %sr z$Mysqlx.Notice.SessionVariableChangedr z!Mysqlx.Notice.SessionStateChangedÚparamzBMysqlx.Notice.SessionStateChanged.Parameter.GENERATED_DOCUMENT_IDSc S s g | ]}t t |d d ¡ qS )Zv_octetsr )r Údecoder r= r= r> r¯ s
|
ý ÿz+Protocol._process_frame.<locals>.<listcomp>r r z9Mysqlx.Notice.SessionStateChanged.Parameter.ROWS_AFFECTEDZv_unsigned_intz?Mysqlx.Notice.SessionStateChanged.Parameter.GENERATED_INSERT_IDN)r Z from_messager rj ro r ÚwarningÚcodeZappend_warningÚlevelr Zset_generated_idsr r r Zset_rows_affectedr Zset_generated_insert_id)r< ro r¶ Zwarn_msgZsess_state_msgZsess_state_valuer= r= r> Ú_process_frameè sV ý ÿÿüÿ ÿÿûÿÿÿÿzProtocol._process_frame)r¶ r2 c
|
C s z| j ¡ }W nF tk
|
rT } z(t| ¡ }|rDt| d| |W 5 d}~X Y nX |jdkrrt|d |d |jdkr¬z| ||¡ W n tt fk
|
r¨ Y q Y nX q |jdkrºdS |jdkrÐ|
|
d ¡ q |jd
|
kræ| d ¡ q |jd kr| d ¡ qq qq |S ) z`Read message.
|
|
Args:
|
result (Result): A `Result` based type object.
|
z reason: Nú Mysqlx.Errorro rº úMysqlx.Notice.FramezMysqlx.Sql.StmtExecuteOkzMysqlx.Resultset.FetchDoneTz(Mysqlx.Resultset.FetchDoneMoreResultsetsúMysqlx.Resultset.Row) r rp Ú RuntimeErrorÚreprZ get_warningsr r r¼ ÚAttributeErrorÚKeyErrorZ
|
set_closedZset_has_more_resultsZ set_has_data)r< r¶ ro ÚerrÚwarningsr= r= r> ri s0 &
|
|
|
|
|
|
zProtocol._read_messager0 c C s" || _ | j |¡ | j |¡ dS )zðSets 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)r
r rs r r; r= r= r> rs ? s
|
zProtocol.set_compressionc C sZ t d}| j td|¡ | 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_GETr¾ r½ ro rº )r r r~ r r rp r r rn r= r= r> Úget_capabilitesM s þ
|
|
|
zProtocol.get_capabilites)Úkwargsr2 c
|
K s" |sdS t d}| ¡ D ]¤\}}t d}||d< t|tr|}g }|D ]*}t d|| || ¡d} | | ¡ ¡ qFt d|d}
|
t d d
|
|
|
d } | ¡ |d < n| |¡|d < |d | ¡ g¡ qt d} || d < | j t
|
d| ¡ z
|
| ¡ W S t k
|
r } z| j dkr W 5 d} ~ X Y nX dS )zSet capabilities.
|
|
Args:
|
**kwargs: Arbitrary keyword arguments.
|
|
Returns:
|
mysqlx.protobuf.Message: MySQL X Protobuf Message.
|
Nz Mysqlx.Connection.Capabilitiesz Mysqlx.Connection.Capabilityr³ r r r r r r r r Ú capabilitiesz!Mysqlx.Connection.CapabilitiesSetz/Mysqlx.ClientMessages.Type.CON_CAPABILITIES_SETi )r r¥ r r£ r¡ rj r¢ r r r~ r Úread_okr
|
Úerrno)r< rÇ rÈ r r Z
|
capabilityr¥ r¨ Úitemr§ r© rª ro rÄ r= r= r> Úset_capabilitiesa sB
|
ý þ
|
zProtocol.set_capabilities)ÚmethodÚ auth_dataÚinitial_responser2 c C sF t d}||d< |dk r ||d< |dk r0||d< | j td|¡ dS )zÖSend authenticate start.
|
|
Args:
|
method (str): Message method.
|
auth_data (Optional[str]): Authentication data.
|
initial_response (Optional[str]): Initial response.
|
z Mysqlx.Session.AuthenticateStartZ mech_nameNrÎ rÏ z2Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_START©r r r~ r )r< rÍ rÎ rÏ ro r= r= r> Úsend_auth_start s þzProtocol.send_auth_startc C s: | j ¡ }|jdkr | j ¡ }q
|
|jdkr2td|d S )züRead 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 handshakerÎ ©r rp r r
|
rn r= r= r> Úread_auth_continue© s
|
|
|
|
ÿzProtocol.read_auth_continue)rÎ r2 c C s" t d|d}| j td|¡ dS )zeSend authenticate continue.
|
|
Args:
|
auth_data (str): Authentication data.
|
rÒ )rÎ z5Mysqlx.ClientMessages.Type.SESS_AUTHENTICATE_CONTINUENrÐ )r< rÎ ro r= r= r> Úsend_auth_continue¼ s
|
þzProtocol.send_auth_continuec C s0 | j ¡ }|jdkrq,|jdkr t|jq dS )z~Read authenticate OK.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If message type is `Mysqlx.Error`.
|
z Mysqlx.Session.AuthenticateOkr½ N)r rp r r
|
ro rn r= r= r> Ú read_auth_okÈ s
|
|
|
|
zProtocol.read_auth_ok)rm ro r r2 c
|
C sR |j rÂ|jdkrÂ|jdkr*| |¡\}}nB|jdkrD| |¡\}}n(|jdkr^| |¡\}}ntd| t| ¡ }td}t d}t d||d |d
|
< |jdkrºt d||d d |d < ||d < t
|
| \}} t d}
|
t||
|
d< ||
|
| < t d} |j | d< |
|
| d< | j td| ¡ z | ¡ W n* tk
|
rL } z
|
t| W 5 d} ~ X Y nX dS )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.InsertúMysqlx.Crud.FindúMysqlx.Crud.UpdateúMysqlx.Crud.DeletezInvalid message type: z!Mysqlx.Expr.Expr.Type.PLACEHOLDERzMysqlx.Crud.LimitExprzMysqlx.Expr.Expr)r ÚpositionÚ row_countr ÚoffsetZ
|
limit_exprú#Mysqlx.Prepare.Prepare.OneOfMessager zMysqlx.Prepare.PrepareÚstmt_idr z*Mysqlx.ClientMessages.Type.PREPARE_PREPAREN)Ú has_limitr Ú
|
build_findÚ build_updateÚ build_deleterh rz r° r r r rß r r~ rÉ r
|
r ) r< rm ro r Ú_rÛ Ú placeholderZmsg_limit_exprÚ
|
oneof_typeÚoneof_opÚ msg_oneofZ msg_preparerÄ r= r= r> Úsend_prepare_prepareÕ sL
|
|
|
ÿ
|
|
ÿ
|
|
þ z Protocol.send_prepare_preparec C s¤ t | \}}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
|
rÞ r zMysqlx.Prepare.Executerß F©r« r² z*Mysqlx.ClientMessages.Type.PREPARE_EXECUTEN) r r r rß rµ r rà r¡ Úget_limit_row_countr¢ Úget_limit_offsetr r~ ) r< rm ro r ræ rç rè Z msg_executer² r= r= r> Úsend_prepare_execute s&
|
þÿþz Protocol.send_prepare_execute)rß r2 c C s. t d}||d< | j td|¡ | ¡ dS )z
|
Send prepare deallocate statement.
|
|
Args:
|
stmt_id (int): Statement ID.
|
|
.. versionadded:: 8.0.16
|
zMysqlx.Prepare.Deallocaterß z-Mysqlx.ClientMessages.Type.PREPARE_DEALLOCATEN)r r r~ r rÉ )r< rß Z msg_deallocr= r= r> Úsend_prepare_deallocate> s þz Protocol.send_prepare_deallocatec C sp |j r8td}| ¡ |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.LimitrÜ rØ rÝ Úlimitú+Mysqlx.ClientMessages.Type.SQL_STMT_EXECUTErê r² N)rà r rë r rì rµ r Úsend_msg)r< rm ro r Z msg_limitr« r² r= r= r> Úsend_msg_without_psO s
|
z Protocol.send_msg_without_psru c C s | j t||¡ 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)r r~ r )r< rm ro r= r= r> rñ k s
|
zProtocol.send_msg)r r2 c C s t | ¡ rdnd}td|jj|jjd}td||d}|jrJ| ¡ |d< | ||¡ | ¡ rlt d|d < n|
|
¡ rt d
|
|d < |j j d kr|j j |d < d |fS )a Build 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.DOCUMENTúMysqlx.Crud.DataModel.TABLEúMysqlx.Crud.Collection©r³ ÚschemarØ ©Ú
|
data_modelÚ
|
collectionÚ
|
projectionz'Mysqlx.Crud.Find.RowLock.EXCLUSIVE_LOCKÚlockingz$Mysqlx.Crud.Find.RowLock.SHARED_LOCKr Zlocking_optionsz$Mysqlx.ClientMessages.Type.CRUD_FIND) r Ú is_doc_basedr Útargetr³ r÷ Zhas_projectionZget_projection_exprr Zis_lock_exclusiveZis_lock_sharedZlock_contentionr ©r< r rù rú ro r= r= r> rá w s* ÿýý zProtocol.build_findc C sª t | ¡ rdnd}td|jj|jjd}td||d}| ||¡ | ¡ ¡ D ]P\}}td}|j |d< |j
|
|d < |j d
|
k rt |j |d < |d | ¡ g¡ qPd |fS ) a Build 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
|
ró rô rõ rö rÙ rø zMysqlx.Crud.UpdateOperationÚ operationÚsourceNr z&Mysqlx.ClientMessages.Type.CRUD_UPDATE)r rý r rþ r³ r÷ r Zget_update_opsr¥ Z update_typer r r r r¢ )r< r rù rú ro rä Z update_opr r= r= r> râ ¡ s0 ÿýý ÿ
|
|
|
zProtocol.build_updatec C sL t | ¡ rdnd}td|jj|jjd}td||d}| ||¡ d|fS )a Build 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
|
ró rô rõ rö rÚ rø z&Mysqlx.ClientMessages.Type.CRUD_DELETE)r rý r rþ r³ r÷ r rÿ r= r= r> rã Ê s" ÿýý ÿ zProtocol.build_delete)Ú namespacer Úfieldsr2 c C s| t d||dd}|rtg }| ¡ D ]*\}}t d|| |¡d}| | ¡ ¡ q t d|d} t dd | d
|
}
|
|
|
¡ g|d < d |fS ) aª Build 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)r r Zcompact_metadatar r r r r r r r² rð )r r¥ r¡ rj r¢ ) r< r r r ro r¨ r r r§ r© rª r= r= r> Úbuild_execute_statementë s& üý z Protocol.build_execute_statementc C s t | ¡ rdnd}td| jj| jjd}td||d}t| drv| jD ],}t|| ¡ ¡ }|d
|
| ¡ g¡ qH| ¡ D ]f}td }t |tr¸|D ] }|d
|
|
t| ¡ g¡ qn|d
|
|
t| ¡ g¡ |d
|
| ¡ g¡ q~t| d rü| ¡ |d < d|fS )a Build 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
|
ró rô rõ rö r× rø Ú_fieldsrû zMysqlx.Crud.Insert.TypedRowÚfieldÚrowÚ is_upsertZupsertz&Mysqlx.ClientMessages.Type.CRUD_INSERT)r rý r rþ r³ r÷ Úhasattrr r Zparse_table_insert_fieldr r¢ Z
|
get_valuesr r¤ r r ) r rù rú ro r Úexprr r Úvalr= r= r> Ú build_insert s@ ÿýý ÿ
|
|
ÿ
|
|
zProtocol.build_insertc C s | |¡}|dk rtddS )z¼Close the result.
|
|
Args:
|
result (Result): A `Result` based type object.
|
|
Raises:
|
:class:`mysqlx.OperationalError`: If message read is None.
|
Nz Expected to close the result)ri r ©r< r¶ ro r= r= r> Ú close_resultJ s
|
zProtocol.close_resultc C s4 | |¡}|dkrdS |jdkr$|S | j |¡ dS )z\Read row.
|
|
Args:
|
result (Result): A `Result` based type object.
|
Nr¿ )ri r r rq r r= r= r> Úread_rowW s
|
|
zProtocol.read_rowc C s² g }| |¡}|dkrq®|jdkr0| j |¡ q®|jdkrBtdt|d |d |d |d |d |d
|
|d | d d ¡| dd¡| dd¡| dd¡| d¡ }| |¡ q|S )z¿Returns column metadata.
|
|
Args:
|
result (Result): A `Result` based type object.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If unexpected message.
|
Nr¿ z Mysqlx.Resultset.ColumnMetaDatazUnexpected msg typer Úcatalogr÷ ÚtableZoriginal_tabler³ Ú original_nameÚlengthé Z collationr Zfractional_digitsÚflagsé Ú content_type)ri r r rq r
|
r Úgetrj )r< r¶ Úcolumnsro Úcolr= r= r> Úget_column_metadatae s2
|
|
|
|
|
|
|
ô z Protocol.get_column_metadatac C sD | j ¡ }|jdkr.td|d |d d|jdkr@tddS ) zeRead OK.
|
|
Raises:
|
:class:`mysqlx.InterfaceError`: If unexpected message.
|
r½ zMysqlx.Error: ro rº )rÊ z Mysqlx.Okz Unexpected message encounteredNrÓ rn r= r= r> rÉ s
|
|
|
|
zProtocol.read_okc C s t d}| j td|¡ dS )zSend connection close.zMysqlx.Connection.Closez$Mysqlx.ClientMessages.Type.CON_CLOSENrÐ rn r= r= r> Úsend_connection_close s
|
ÿz Protocol.send_connection_closec C s t d}| j td|¡ dS )z Send close.zMysqlx.Session.Closez%Mysqlx.ClientMessages.Type.SESS_CLOSENrÐ rn r= r= r> Ú
|
send_close s
|
ÿzProtocol.send_closec C sL t d}td}||d< d|d< td}| ¡ g|d< | j t d|¡ d S )
|
zSend expectation.z3Mysqlx.Expect.Open.Condition.Key.EXPECT_FIELD_EXISTz Mysqlx.Expect.Open.ConditionZ condition_keyz6.1Zcondition_valuezMysqlx.Expect.OpenZcondz&Mysqlx.ClientMessages.Type.EXPECT_OPENN)r r r¢ r r~ )r< Zcond_keyZmsg_ocZmsg_eor= r= r> Úsend_expect_open£ s ÿzProtocol.send_expect_open)Ú keep_openr2 c C st t d}|dkrBz| ¡ | ¡ d}W n tk
|
r@ d}Y nX |rNd|d< | j td|¡ | ¡ |rpdS dS )z¨Send reset session message.
|
|
Returns:
|
boolean: ``True`` if the server will keep the session open,
|
otherwise ``False``.
|
zMysqlx.Session.ResetNTFr z%Mysqlx.ClientMessages.Type.SESS_RESET)r r rÉ r
|
r r~ r )r< r ro r= r= r> Ú
|
send_reset± s$
|
ÿzProtocol.send_reset)T)NN)N)N)BrK rL rM rN rQ rt r? Úpropertyr rO r Ú staticmethodr( r r r r¡ r r% r r r* r) rµ r+ r¼ ri rs rÆ rÌ rÑ rP rÔ rÕ rÖ r r r" r# r$ r& ré rí r rî rò rñ r rá râ rã r- r r r r! r r r r' r rÉ r r r r r= r= r= r> r J s¤ K ÿ
|
þ .6!3 üû ûÿô E þ %
|
û
|
|
þ +
|
|
þ *
|
|
þ % ü
|
|
û *
|
|
þ4 $ r )DrN re r8 Úior Útypingr r r r r r Z lz4.framerC ZHAVE_LZ4Ú ImportErrorZ zstandardr7 Z HAVE_ZSTDÚerrorsr
|
r r r r
|
r r r r r r Zhelpersr r r Zprotobufr r r r r r¶ r Z statementr r r r r! r" r# r$ r% r& Útypesr' r( r) r* r+ r, r- r. rw r/ rQ rt r r= r= r= r> Ú<module> s6
|
|
0 ( Dd=
|
