U
|
¤ý°d© ã @ sp d Z ddlmZ ddlZddlZddlZddlmZmZ ddlm Z m
|
Z
|
m Z m Z m Z mZmZmZ ddlmZ ddlmZ dd lmZmZ dd
|
lmZmZ d d d dddZd d dddZ d ddddZ d ddddZ d ddddZ d d dd d Z d d dd d Z!d d!dd"d#Z"d d$dd%d&Z#d d'dd(d)Z$d d*dd+d,Z%G d-d. d.Z&G d/d0 d0Z'G d1d2 d2Z(G d3d4 d4Z)G d5d6 d6e)Z*G d7d8 d8e*Z+G d9d: d:e*Z,G d;d< d<e*Z-G d=d> d>e*Z.G d?d@ d@e*Z/G dAdB dBe*Z0G dCd d Z1G dDdE dEZ2G dFdG dGZ3G dHdI dIe3Z4G dJdK dKe3Z5G dLdM dMe5Z6G dNdO dOe6Z7G dPdQ dQe5Z8dS )Rz%Implementation of the Result classes.é )Ú annotationsN)ÚdatetimeÚ timedelta)ÚAnyÚCallableÚDictÚListÚOptionalÚSequenceÚTupleÚUnioné )ÚMYSQL_CHARACTER_SETS)ÚDbDoc)Údecode_from_bytesÚ
|
deprecated)ÚConnectionTypeÚ
|
FieldTypesÚColumnÚbytesr )ÚcolumnÚpayloadÚreturnc
|
C s t |dkrd S | ¡ tjkr.t|d d
S ztj| ¡ |W S tk
|
r } z,t j
|
| ¡ t j
|
| d¡ ¡ W Y ¢d S d }~X Y nX d S )Nr éÿÿÿÿÚhex) ÚlenÚget_typeÚ
|
ColumnTypeÚSTRINGr ÚColumnProtoTypeÚ converter_mapÚget_proto_typeÚKeyErrorÚsysÚstderrÚwriteÚencode)r r Úerr© r( úDd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysqlx/result.pyÚ from_protobuf/ s r* )r r c C s | d d
S )Nr r( ©r r( r( r) Úbytes_from_protobuf> s r, Úfloatc C s t | dkstt d| ¡d S )Né z<fr ©r ÚAssertionErrorÚstructÚunpackr+ r( r( r) Úfloat_from_protobufC s r3 c C s t | dkstt d| ¡d S )Né z<dr r/ r+ r( r( r) Údouble_from_protobufH s r5 zTuple[int, bytes]c C s t | dkrtdd}d}d}| D ]j}t|tr6|nt|}|d@ dk}|d@ }||K }||O }|r~|| |d d
f S |d7 }|d7 }q$tdd S )Nr zPayload is emptyé é r é zPayload too short)r Ú
|
ValueErrorÚ
|
isinstanceÚintÚordÚEOFError)r ÚcurÚiÚshiftÚitemÚcharZeosZcur_bitsr( r( r) Úvarint_from_protobuf_streamM s
|
rC r; c C s$ t | \}} t| dkr td|S )Nr úPayload too long©rC r r9 ©r r? r( r( r) Úvarint_from_protobufc s rG c C sL t | \}} t| dkr td|d@ r@| }|d? }|dO }n|d? }|S )Nr rD r l rE rF r( r( r) Úvarsint_from_protobufk s
|
rH z List[bytes]c C s g }zxt | \}} t| |k rLt| dkrD|dkrDt|dkrDg W S td| | d |
¡ | |d
} t| dkrzW qW q tk
|
r Y qY qX q|S )Nr r zInvalid Set encoding)rC r r9 Úappend)r Zset_pbZ field_lenr( r( r) Úset_from_protobuf{ s rJ zdecimal.Decimalc C s$ g }d }t | d tr | d n
|
t| d }| dd
} | D ]Ö}t |trL|nt|}|d@ d? }|d@ }|dk rÀ| |¡ |dk r| |¡ n0|dkr¢d} qn |dkr¶d} qntd q:|dkràd}|dksØt qq:|dkrd}|dksút qq:td
|
| q:t ||| f¡S ) Nr r éð r. é é
|
é é z Invalid BCDz Invalid BCD: )r: r; r< rI r9 r0 ÚdecimalÚDecimal)r ÚdigitsÚsignZscalerA rB Zhigh_bcdZlow_bcdr( r( r) Údecimal_from_protobuf s: "
|
|
|
rT r c C s d}d}d}d}t | \}} t | \}} t | \}} z4t | \}} t | \}} t | \}} t | \}} W n tk
|
r| Y nX t|||||||S )Nr )rC r9 r )r ÚhourÚminutesÚsecondsÚusecondsÚyearÚmonthÚdayr( r( r) Údatetime_from_protobuf´ s r\ r c C s¼ d}d}d}d}| d dk}| dd
} z4t | \}} t | \}} t | \}} t | \}} W n tk
|
rp Y nX |r¬|r|d9 }n(|r|d9 }n|r |d9 }n |r¬|d9 }t||||dS )Nr r r )ÚhoursrV rW Ú microseconds)rC r9 r )r rU rV rW rX Únegater( r( r) Útime_from_protobufÉ s8
|
|
|
ÿr` c @ s e Zd ZdZdS )Ú
|
Collationsé! N)Ú__name__Ú
|
__module__Ú __qualname__ZUTF8_GENERAL_CIr( r( r( r) ra ê s ra c @ s8 e Zd ZdZdZdZdZdZdZdZ dZ
|
d Z d
|
Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d Z!d Z"d!Z#d"Z$d#Z%e&d$d%d&d'd(Z'e&d)d$d*d+d,Z(e&d-d.d/d0d1Z)e&d-d.d/d2d3Z*e&d-d.d/d4d5Z+e&d-d.d/d6d7Z,e&d-d.d/d8d9Z-e&d-d.d/d:d;Z.d<S )=r r é é r. é é r8 r4 é rM é rN rO é rL é é é é é é é é é é é é é é é é é rb é" é# r ú Optional[str])Úneedler c C s* t | ¡ D ]\}}||kr | S q d S ©N)ÚvarsÚitems)Úclsr ÚkeyÚvaluer( r( r) Ú to_string s
|
zColumnType.to_stringÚstr)r r c C s t | | ¡ d S r )ÚgetattrÚupper)r
r r( r( r) Ú from_string s zColumnType.from_stringr; Úbool)Úcol_typer c C s || j | jfkS r )ÚCHARÚVARCHAR©r
r r( r( r) Úis_char s þzColumnType.is_charc C s || j | jfkS r )ÚBINARYÚ VARBINARYr r( r( r) Ú is_binary% s þzColumnType.is_binaryc C s || j | j| j| jfkS r )ÚTEXTÚTINYTEXTÚ
|
MEDIUMTEXTÚLONGTEXTr r( r( r) Úis_text, s üzColumnType.is_textc C s || j | j| j| j| jfkS r )ÚREALÚDOUBLEÚFLOATÚDECIMALÚNUMERICr r( r( r) Ú is_decimals5 s ûzColumnType.is_decimalsc C s || j | j| j| j| j| jfkS r )ÚBITÚTINYINTÚSMALLINTÚ MEDIUMINTÚINTÚBIGINTr r( r( r) Ú
|
is_numeric? s úzColumnType.is_numericc C s || j | jfkS r )ÚSETÚENUMr r( r( r) Ú is_finite_setJ s þzColumnType.is_finite_setN)/rc rd re r¡ r¢ r£ r¤ r¥ r¦ r r r r r ÚJSONr ÚBYTESÚTIMEÚDATEÚDATETIMEÚ TIMESTAMPr¨ r© ÚGEOMETRYÚXMLZYEARr r r r ZTINYBLOBZBLOBZ
|
MEDIUMBLOBZLONGBLOBr r r r Ú classmethodr r r r r r r§ rª r( r( r( r) r î sf
|
r c @ sr e Zd ZU dZdZdZdZdZdZdZ dZ
|
d Z d
|
Z d Z eeeeeee eeeeeeee ee
|
ee ee ei Zd ed < dS )r r rf rh ri r8 rM rN rL rm rn ro z!Dict[int, Callable[[bytes], Any]]r N)rc rd re ÚSINTÚUINTr r r¬ r r¯ r¨ r© r¡ r rH rG r, r\ r` r3 r5 rJ rT r Ú__annotations__r( r( r( r) r R sD
|
õr c @ sR e Zd ZdddddZdddd Zeddd
|
d Zejddd d d ZdS )ÚFlagsr; ÚNone)r r c C sV i | _ i | _| jj ¡ D ]2\}}| d¡r,qt|tr|| j |< || j|< q|| _d S )NÚ__) Z_allowed_flagsÚ _flag_namesÚ __class__Ú__dict__r Ú
|
startswithr: r; Ú_value)Úselfr r Úvalr( r( r) Ú__init__o s
|
|
|
zFlags.__init__r ©r c C s d}g }| j }tddD ]d}|dK }||@ }|rz| | j| ¡ W q tk
|
rz tj | j ¡ tj | jj ¡ Y qX qd
|
|¡S )Nr r é? ú,) r¾ ÚrangerI rº r" r# r$ r% r» r¼ Újoin)r¿ ÚmaskZ
|
flag_namesr Ú_Úflagr( r( r) Ú__str__z s z Flags.__str__c C s | j S r ©r¾ ©r¿ r( r( r) r s z Flags.value)rÀ r c C s
|
|| _ d S r rË )r¿ rÀ r( r( r) r s N)rc rd re rÁ rÊ Úpropertyr Úsetterr( r( r( r) r· n s r· c @ s e Zd ZdZdZdZdZdZdS )Ú ColumnFlagsrm r} é@ r6 é N)rc rd re ZNOT_NULLZ PRIMARY_KEYZ
|
UNIQUE_KEYZ MULTIPLE_KEYZAUTO_INCREMENTr( r( r( r) rÏ s
|
rÏ c @ s e Zd ZdZdS )ÚDatetimeColumnFlagsr N)rc rd re r° r( r( r( r) rÒ s rÒ c @ s e Zd ZdZdS )ÚUIntColumnFlagsr N)rc rd re ZZEROFILLr( r( r( r) rÓ ¡ s rÓ c @ s e Zd ZdZdS )ÚDoubleColumnFlagsr N©rc rd re ÚUNSIGNEDr( r( r( r) rÔ ¥ s rÔ c @ s e Zd ZdZdS )ÚFloatColumnFlagsr NrÕ r( r( r( r) r× © s r× c @ s e Zd ZdZdS )ÚBytesColumnFlagsr N)rc rd re Z RIGHT_PADr( r( r( r) rØ s rØ c @ s e Zd ZdZdZdZdS )ÚBytesContentTyper rf rg N)rc rd re r± r« r² r( r( r( r) rÙ ± s rÙ c @ s e Zd ZdZdJdddddddddddddd dd Zd
|
d d d Zdd ddZdd ddZdd ddZdd ddZ dd ddZ
|
e d
|
d ddZ e d
|
d ddZ e d
|
d d d Ze d
|
d d d Ze d
|
d d d!Ze dd d"d#Ze dd d$d%Ze dd d&d'Ze d
|
d d(d)Ze d
|
d d*d+Zd
|
d d,d-Zd
|
d d.d/Zd
|
d d0d1Zd
|
d d2d3Zd
|
d d4d5Zdd d6d7Zdd d8d9Z dd d:d;Z dd d<d=Z d
|
d d>d?Z d
|
d d@dAZ dBd dCdDZ!dEd dFdGZ"dBd dHdIZ#dS )Kr a_ Represents meta data for a table column.
|
|
Args:
|
col_type (int): The column type.
|
catalog (str): The catalog.
|
schema (str): The schema name.
|
table (str): The table name.
|
original_table (str): The original table name.
|
name (str): The column name.
|
original_name (str): The original table name.
|
length (int): The column length,
|
collation (str): The collation name.
|
fractional_digits (int): The fractional digits.
|
flags (int): The flags.
|
content_type (int): The content type.
|
|
.. versionchanged:: 8.0.12
|
Nr; r ú Optional[int]r¸ ) r ÚcatalogÚschemaÚtableÚoriginal_tableÚnameÚ original_nameÚlengthÚ collationÚfractional_digitsÚflagsÚ content_typer c C s t || _t || _t || _t || _t || _|| _d | _|| _|| _ | | _
|
|
|
| _ | | _ | | _ d| _d| _d| _d| _d | _d | _d | _| j
|
dkrè| j
|
ttkr´td| j
|
t| j
|
} | d | _| d | _d| jkpäd| jk| _| ¡ | jtjtjtj tj tj fk| _d S )NFr z No mapping found for collation r ÚbinaryZ_bin) r Ú_schemaÚ_nameÚ_original_nameÚ_tableÚ_original_tableÚ _proto_typeÚ _col_typeÚ_catalogÚ_lengthZ
|
_collationÚ_fractional_digitsÚ_flagsÚ _content_typeÚ_number_signedÚ
|
_is_paddedÚ
|
_is_binaryÚ _is_bytesÚ_collation_nameÚ_character_set_nameÚ
|
_zero_fillr r r9 Ú _map_typer r± r« r² r¬ r )r¿ r rÛ rÜ rÝ rÞ rß rà rá râ rã rä rå Úinfor( r( r) rÁ Î sH
|
|
|
|
|
|
|
|
|
ÿûzColumn.__init__r r c C s t | j| j| jt | jdS )N)r rÜ rÝ rä )r rí rç rê rñ rÌ r( r( r) rÊ s üÿzColumn.__str__c C sj | j tjkrtj| _nD| j tjkr,tj| _n.| j tjkrBtj| _n| jrRtj| _ntj | _| j
|
d@ | _ dS )z
|
Map bytes.r N) rò rÙ r± r rí r« r² rõ r¬ r rñ rô rÌ r( r( r) Ú
|
_map_bytes s
|
|
|
|
zColumn._map_bytesc C sN | j dkrtj| _n6| jtj@ dkr.tj| _n | j dkrBtj| _ntddS )z Map datetime.rM r rp z#Datetime mapping scenario unhandledN) rï r r® rí rñ rÒ r° r¯ r9 rÌ r( r( r) Ú _map_datetime s
|
|
|
|
|
zColumn._map_datetimec C sb | j dkrtj| _nD| j dkr(tj| _n0| j dkr<tj| _n | j dkrPtj| _ntj| _d| _dS )z Map int type.r. ri rj rk TN) rï r r¢ rí r£ r¤ r¥ r¦ ró rÌ r( r( r) Ú _map_int_type' s
|
|
|
|
|
|
|
|
zColumn._map_int_typec C sh | j dkrtj| _nD| j dkr(tj| _n0| j dkr<tj| _n | j dkrPtj| _ntj| _| jd@ | _ dS )zMap uint type.rg rh r4 rM r N)
|
rï r r¢ rí r£ r¤ r¥ r¦ rñ rù rÌ r( r( r) Ú_map_uint_type5 s
|
|
|
|
|
|
|
|
zColumn._map_uint_typec C sF | j tjkr| ¡ n*| j tjkr0| ¡ n| j tjkrXtj| _| j t
|
j @ dk| _ nê| j tj krtj | _| j t
|
j @ dk| _ nÂ| j tjkr¨tj| _| j t
|
j @ dk| _ n| j tjkr¾| ¡ n| j tjkrÔtj| _nn| j tjkrê| ¡ nX| j tjkrtj| _n@| j tjkrtj| _n(| j tjkr2tj| _ntd| j dS )z Map type.r zUnknown column type N)rì r r´ rþ rµ rÿ r r rí rñ r× rÖ Z_is_number_signedr r r¬ rü r r¯ rý r¨ r© r¡ r9 rÌ r( r( r) rú C s4
|
|
|
|
|
|
zColumn._map_typec C s | j S )z@str: The schema name.
|
|
.. versionadded:: 8.0.12
|
©rç rÌ r( r( r) Ú schema_namea s zColumn.schema_namec C s | j p
|
| jS )z?str: The table name.
|
|
.. versionadded:: 8.0.12
|
©rë rê rÌ r( r( r) Ú
|
table_namei s zColumn.table_namec C s | j p
|
| jS )z@str: The table label.
|
|
.. versionadded:: 8.0.12
|
©rê rë rÌ r( r( r) Ú table_labelq s zColumn.table_labelc C s | j p
|
| jS )z@str: The column name.
|
|
.. versionadded:: 8.0.12
|
©ré rè rÌ r( r( r) Ú column_namey s zColumn.column_namec C s | j p
|
| jS )zAstr: The column label.
|
|
.. versionadded:: 8.0.12
|
©rè ré rÌ r( r( r) Ú column_label s zColumn.column_labelc C s | j S )z@int: The column type.
|
|
.. versionadded:: 8.0.12
|
©rí rÌ r( r( r) Útype s z Column.typec C s | j S )zBint. The column length.
|
|
.. versionadded:: 8.0.12
|
©rï rÌ r( r( r) rá s z Column.lengthc C s | j S )zMint: The column fractional digits.
|
|
.. versionadded:: 8.0.12
|
©rð rÌ r( r( r) rã s zColumn.fractional_digitsc C s | j S )zCstr: The collation name.
|
|
.. versionadded:: 8.0.12
|
©r÷ rÌ r( r( r) Úcollation_name¡ s zColumn.collation_namec C s | j S )zGstr: The character set name.
|
|
.. versionadded:: 8.0.12
|
©rø rÌ r( r( r) Úcharacter_set_name© s zColumn.character_set_namec C s | j S )zUReturns the schema name.
|
|
Returns:
|
str: The schema name.
|
r rÌ r( r( r) Úget_schema_name± s zColumn.get_schema_namec C s | j p
|
| jS )zSReturns the table name.
|
|
Returns:
|
str: The table name.
|
r rÌ r( r( r) Úget_table_name¹ s zColumn.get_table_namec C s | j p
|
| jS )zUReturns the table label.
|
|
Returns:
|
str: The table label.
|
r rÌ r( r( r) Úget_table_labelÁ s zColumn.get_table_labelc C s | j p
|
| jS )zUReturns the column name.
|
|
Returns:
|
str: The column name.
|
r rÌ r( r( r) Úget_column_nameÉ s zColumn.get_column_namec C s | j p
|
| jS )zWReturns the column label.
|
|
Returns:
|
str: The column label.
|
r rÌ r( r( r) Úget_column_labelÑ s zColumn.get_column_labelc C s | j S )zaReturns the column proto type.
|
|
Returns:
|
int: The column proto type.
|
)rì rÌ r( r( r) r! Ù s zColumn.get_proto_typec C s | j S )zUReturns the column type.
|
|
Returns:
|
int: The column type.
|
r
|
rÌ r( r( r) r á s zColumn.get_typec C s | j S )zYReturns the column length.
|
|
Returns:
|
int: The column length.
|
r rÌ r( r( r) Ú
|
get_lengthé s zColumn.get_lengthc C s | j S )zoReturns the column fractional digits.
|
|
Returns:
|
int: The column fractional digits.
|
r rÌ r( r( r) Úget_fractional_digitsñ s z Column.get_fractional_digitsc C s | j S )z[Returns the collation name.
|
|
Returns:
|
str: The collation name.
|
r rÌ r( r( r) Úget_collation_nameù s zColumn.get_collation_namec C s | j S )zcReturns the character set name.
|
|
Returns:
|
str: The character set name.
|
r rÌ r( r( r) Úget_character_set_name s z Column.get_character_set_namer c C s | j S )zxReturns `True` if is a number signed.
|
|
Returns:
|
bool: Returns `True` if is a number signed.
|
)ró rÌ r( r( r) Úis_number_signed s zColumn.is_number_signedúUnion[bool, int]c C s | j S )zfReturns `True` if is padded.
|
|
Returns:
|
bool: Returns `True` if is padded.
|
)rô rÌ r( r( r) Ú is_padded s zColumn.is_paddedc C s | j S )zdReturns `True` if is bytes.
|
|
Returns:
|
bool: Returns `True` if is bytes.
|
)rö rÌ r( r( r) Úis_bytes s zColumn.is_bytes) NNNNNNNNNNN)$rc rd re Ú__doc__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 º sj ó(6
|
c @ sX e Zd ZdZddddddZdd d
|
d Zd d dddZeddddddZdS )ÚRowz½Represents a row element returned from a SELECT query.
|
|
Args:
|
resultset (mysqlx.SqlResult or mysqlx.RowResult): The result set.
|
fields (`list`): The list of fields.
|
z!Union[BufferingResult, RowResult]zSequence[FieldTypes]r¸ )Ú resultsetÚfieldsr c C s || _ || _d S r )Ú_fieldsÚ
|
_resultset)r¿ r! r" r( r( r) rÁ * s z Row.__init__r r c C s
|
t | jS r )Úreprr# rÌ r( r( r) Ú__repr__0 s z Row.__repr__zUnion[int, str]r ©Úindexr c C sd t |tr| j |¡n|}|dkr<t |tr<td| d|t| jksR|dk rZtd| j| S )z\Returns the value of a column by name or index.
|
|
.. versionchanged:: 8.0.12
|
r ú Column name 'ú ' not foundr zIndex out of range)r: r r$ Úindex_ofr9 r r# Ú
|
IndexError)r¿ r( Ú int_indexr( r( r) Ú __getitem__3 s zRow.__getitem__ú8.0.12)Ú str_indexr c C sH | j |¡}|t| jkr"td|dkr:td| dt| j| S )zReturns the value using the column name.
|
|
Args:
|
str_index (str): The column name.
|
|
.. deprecated:: 8.0.12
|
zArgument out of ranger r) r* )r$ r+ r r# r, r9 r )r¿ r0 r- r( r( r) Ú
|
get_string? s zRow.get_stringN) rc rd re r rÁ r& r. r r1 r( r( r( r) r " s r c @ s e Zd ZdZdddddZddd d
|
Zd dd d ZddddZdddddZdddddddZ dddddZ
|
ddd d d Z ddd d d!Z d"S )#Ú
|
BaseResultzProvides base functionality for result objects.
|
|
Args:
|
connection (mysqlx.connection.Connection): The Connection object.
|
r r¸ ©Ú
|
connectionr c C sH || _ d| _d| _d| _g | _g | _|d kr4d | _n|j| _| ¡ d S ©NFr r ) Ú _connectionÚ_closedÚ_rows_affectedÚ _generated_idÚ_generated_idsÚ _warningsÚ _protocolÚprotocolZfetch_active_result©r¿ r4 r( r( r) rÁ W s zBaseResult.__init__r; r c C s | j S )zReturns the number of affected items for the last operation.
|
|
Returns:
|
int: The number of affected items.
|
©r8 rÌ r( r( r) Úget_affected_items_counte s z#BaseResult.get_affected_items_countz List[Dict[str, Union[int, str]]]c C s | j S )zZReturns the warnings.
|
|
Returns:
|
`list`: The list of warnings.
|
)r; rÌ r( r( r) Ú get_warningsm s zBaseResult.get_warningsc C s
|
t | jS )zcReturns the number of warnings.
|
|
Returns:
|
int: The number of warnings.
|
)r r; rÌ r( r( r) Úget_warnings_countu s z BaseResult.get_warnings_countr ©rÉ r c C s
|
|| _ dS )z Sets if resultset fetch is done.N)r7 ©r¿ rÉ r( r( r) Ú
|
set_closed} s zBaseResult.set_closedr )ÚlevelÚcodeÚmsgr c C s | j |||d¡ dS )z«Append a warning.
|
|
Args:
|
level (int): The warning level.
|
code (int): The warning code.
|
msg (str): The warning message.
|
)rF rG rH N)r; rI )r¿ rF rG rH r( r( r) Úappend_warning s zBaseResult.append_warningú List[int])Ú generated_idsr c C s
|
|| _ dS )zSets the generated ids.N©r: )r¿ rK r( r( r) Úset_generated_ids s z BaseResult.set_generated_ids)Ú generated_idr c C s
|
|| _ dS )z Sets the generated insert id.N©r9 )r¿ rN r( r( r) Úset_generated_insert_id s z"BaseResult.set_generated_insert_id)Útotalr c C s
|
|| _ dS )z!Sets the number of rows affected.Nr? )r¿ rQ r( r( r) Úset_rows_affected s z BaseResult.set_rows_affectedN) rc rd re r rÁ r@ rA rB rE rI rM rP rR r( r( r( r) r2 P s
|
r2 c st e Zd ZdZddddd fdd Zd d
|
d d Zed dd
|
ddZed d d
|
ddZdd
|
ddZ Z
|
S )ÚResulta Allows retrieving information about non query operations performed on
|
the database.
|
|
Args:
|
connection (mysqlx.connection.Connection): The Connection object.
|
ids (`list`): A list of IDs.
|
NzOptional[ConnectionType]zOptional[List[int]]r¸ )r4 Úidsr c s* t |¡ || _|d k r&| j | ¡ d S r )ÚsuperrÁ Ú_idsr6 Z close_result)r¿ r4 rT ©r» r( r) rÁ ¡ s zResult.__init__r; r c C s | j S )zjReturns the last insert id auto generated.
|
|
Returns:
|
int: The last insert id.
|
rO rÌ r( r( r) Úget_autoincrement_value¬ s z Result.get_autoincrement_valuer/ rÚ c C s& | j dkst| j dkr dS | j d S )zdReturns ID of the last document inserted into a collection.
|
|
.. deprecated:: 8.0.12
|
Nr )rV r rÌ r( r( r) Úget_document_id´ s zResult.get_document_idc C s | j S )zIReturns the generated insert id.
|
|
.. deprecated:: 8.0.12
|
rO rÌ r( r( r) Úget_generated_insert_id¾ s z Result.get_generated_insert_idrJ c C s | j S )zReturns the generated ids.rL rÌ r( r( r) Úget_generated_idsÆ s zResult.get_generated_ids)NN) rc rd re r rÁ rX r rY rZ r[ Ú __classcell__r( r( rW r) rS s
|
ý rS c s e Zd ZdZddd fdd Zddd d
|
d Zedd d dZdd ddZdddddZ dd ddZ
|
ddddd Z dd d d Z d d d d!Z ddd"d#d$Zddd"d%d&Z ZS )'ÚBufferingResultzãProvides base functionality for buffering result objects.
|
|
Args:
|
connection (mysqlx.connection.Connection): The Connection object.
|
ids (`list`): A list of IDs.
|
r r¸ r3 c s< t |¡ g | _d| _d| _g | _d| _d| _| ¡ d S r5 ) rU rÁ Ú_columnsÚ _has_dataÚ_has_more_resultsÚ_itemsÚ
|
_page_sizeÚ _positionÚ _init_resultr> rW r( r) rÁ Ó s zBufferingResult.__init__r; zUnion[Row, DbDoc]r' c C s
|
| j | S r )ra )r¿ r( r( r( r) r. Ý s zBufferingResult.__getitem__r c C s
|
t | jS )zint: The total of items.)r ra rÌ r( r( r) Úcountà s zBufferingResult.countc C sJ | j | ¡| _t| jdk| _g | _d| _d| _| j | jr@| nd¡ dS )zInitialize the result.r rq r N) r6 Zget_column_metadatar^ r Z_has_more_datara rb rc Zset_active_resultrÌ r( r( r) rd å s z BufferingResult._init_resultr zOptional[Union[Row, DbDoc]]©Údumpingr c C sn | j | ¡}|dkrdS dgt|d }|sdtt|d D ]$}| j| }t||d | ||< q>t| |S )zRead item.
|
|
Args:
|
dumping (bool): `True` for dumping.
|
|
Returns:
|
:class:`mysqlx.Row`: A `Row` object.
|
NÚfield)r6 Zread_rowr rÅ r^ r* r )r¿ rg ÚrowrA r r r( r( r) Ú
|
_read_itemî s
|
zBufferingResult._read_itemr c C sL | j r
|
dS d}t| jD ].}| d¡}|dkr2 qH| j |¡ |d7 }q|S )zSReads the page items.
|
|
Returns:
|
int: Total items read.
|
Fr Nr )r7 rÅ rb rj ra rI )r¿ re rÈ rA r( r( r) Ú_page_in_items s
|
|
z BufferingResult._page_in_itemsr )Úcol_namer c C s0 d}| j D ] }| ¡ |kr"| S |d7 }q
|
dS )zeReturns the index of the column.
|
|
Returns:
|
int: The index of the column.
|
r r r )r^ r )r¿ rl r( Úcolr( r( r) r+ s
|
|
zBufferingResult.index_ofc C s | j r
|
dS | d¡S )zuFetch one item.
|
|
Returns:
|
:class:`mysqlx.Row` or :class:`mysqlx.DbDoc`: one result item.
|
NF)r7 rj rÌ r( r( r) Ú fetch_one s zBufferingResult.fetch_onezList[Union[Row, DbDoc]]c C s | ¡ s q q | jS )zFetch all items.
|
|
Returns:
|
`list`: The list of items of :class:`mysqlx.DbDoc` or
|
:class:`mysqlx.Row`.
|
)rk ra rÌ r( r( r) Ú fetch_all+ s zBufferingResult.fetch_allrC c C s
|
|| _ dS )zdSets if result has data.
|
|
Args:
|
flag (bool): `True` if result has data.
|
N©r_ rD r( r( r) Ú set_has_data7 s z BufferingResult.set_has_datac C s
|
|| _ dS )zfSets if has more results.
|
|
Args:
|
flag (bool): `True` if has more results.
|
N)r` rD r( r( r) Úset_has_more_results? s z$BufferingResult.set_has_more_results)rc rd re r rÁ r. rÍ re rd rj rk r+ rn ro rq rr r\ r( r( rW r) r] Ë s
|
r] c @ s0 e Zd ZdZeddddZddddZdS ) Ú RowResultz¡Allows traversing the Row objects returned by a Table.select operation.
|
|
Args:
|
connection (mysqlx.connection.Connection): The Connection object.
|
z List[Column]r c C s | j S )z `list`: The list of columns.©r^ rÌ r( r( r) ÚcolumnsO s zRowResult.columnsc C s | j S )zReturns the list of columns.
|
|
Returns:
|
`list`: The list of columns.
|
|
.. versionadded:: 8.0.12
|
rt rÌ r( r( r) Ú get_columnsT s zRowResult.get_columnsN)rc rd re r rÍ ru rv r( r( r( r) rs H s rs c @ s: e Zd ZdZddddZddddZddd d
|
Zd S ) Ú SqlResultzRepresents a result from a SQL statement.
|
|
Args:
|
connection (mysqlx.connection.Connection): The Connection object.
|
r; r c C s | j S )zReturns the identifier for the last record inserted.
|
|
Returns:
|
str: The identifier of the last record inserted.
|
rO rÌ r( r( r) rX f s z!SqlResult.get_autoincrement_valuer c C s | j r
|
dS d| _| ¡ dS )zjProcess the next result.
|
|
Returns:
|
bool: Returns `True` if the fetch is done.
|
FT)r7 r` rd rÌ r( r( r) Ú next_resultn s
|
zSqlResult.next_resultc C s | j S )zReturns True if result has data.
|
|
Returns:
|
bool: Returns `True` if result has data.
|
|
.. versionadded:: 8.0.12
|
rp rÌ r( r( r) Úhas_dataz s zSqlResult.has_dataN)rc rd re r rX rx ry r( r( r( r) rw _ s rw c s( e Zd ZdZddd fdd Z ZS )Ú DocResultzªAllows traversing the DbDoc objects returned by a Collection.find
|
operation.
|
|
Args:
|
connection (mysqlx.connection.Connection): The Connection object.
|
r r rf c s( t |¡}|dkrdS tt|d S )zRead item.
|
|
Args:
|
dumping (bool): `True` for dumping.
|
|
Returns:
|
:class:`mysqlx.DbDoc`: A `DbDoc` object.
|
Nr )rU rj r r )r¿ rg ri rW r( r) rj s zDocResult._read_item)rc rd re r rj r\ r( r( rW r) rz
s rz )9r Ú
|
__future__r rP r1 r# r r Útypingr r r r r r
|
r r Zcharsetsr Zdbdocr Zhelpersr r Útypesr r r* r, r3 r5 rC rG rH rJ rT r\ r` ra r r r· rÏ rÒ rÓ rÔ r× rØ rÙ r r r2 rS r] rs rw rz r( r( r( r) Ú<module> sT ( $!d ' j.H3}&
|
