U
|
£ý°d¤ ã @ sò d Z ddlmZ ddlZddlZddlZddlmZ ddlm Z m
|
Z
|
m Z m Z m Z mZmZmZmZmZmZ ddlmZ ddlmZmZ dd lmZmZmZm Z m Z m Z m Z m Z m!Z! dd
|
l"m#Z#m$Z$m%Z% dd l&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ dd l0m1Z1 dd l2m3Z3m4Z4m5Z5m6Z6m7Z7 dZ8G dd dZ9G dd de%Z:G dd de:Z;G dd de:Z<G dd de;Z=G dd de:Z>G dd d e;Z?G d d d e:Z@G d d d e;ZAG d!d" d"e:ZBG d#d$ d$e>eBZCG d%d& d&e@eBZDG d'd( d(eBZEdS ))z%Cursor classes using the C Extension.é )Ú annotationsN)Ú
|
namedtuple) ÚAnyÚDictÚ GeneratorÚIteratorÚListÚNoReturnÚOptionalÚSequenceÚTupleÚTypeÚUnion)ÚCallableProxyType)ÚMySQLInterfaceErrorÚ MySQLPrepStmté ) ÚCextEofPacketTypeÚCextResultTypeÚDescriptionTypeÚParamsSequenceOrDictTypeÚParamsSequenceTypeÚRowTypeÚ
|
StrOrBytesÚToPythonOutputTypesÚ WarningType)ÚNAMED_TUPLE_CACHEÚMySQLConnectionAbstractÚMySQLCursorAbstract) Ú RE_PY_PARAMÚRE_SQL_COMMENTÚRE_SQL_FIND_PARAMÚRE_SQL_INSERT_STMTÚRE_SQL_INSERT_VALUESÚRE_SQL_ON_DUPLICATEÚ RE_SQL_PYTHON_CAPTURE_PARAM_NAMEÚRE_SQL_PYTHON_REPLACE_PARAMÚRE_SQL_SPLIT_STMTS)ÚCR_NO_RESULT_SET)ÚErrorÚInterfaceErrorÚNotSupportedErrorÚProgrammingErrorÚget_mysql_exceptionzNo result set to fetch fromc @ sB e Zd ZdZdddddZddd d
|
d Zed d ddZdS )Ú_ParamSubstitutorz4
|
Substitutes parameters into SQL statement.
|
zSequence[bytes]ÚNone)ÚparamsÚreturnc C s || _ d| _d S )Nr )r0 Úindex)Úselfr0 © r4 úRd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysql/connector/cursor_cext.pyÚ__init__f s z_ParamSubstitutor.__init__ÚobjectÚbytes)Úmatchobjr1 c C sD | j }| j d7 _ z | j| W S tk
|
r> tdd Y nX d S )Nr z+Not enough parameters for the SQL statement)r2 r0 Ú
|
IndexErrorr, )r3 r9 r2 r4 r4 r5 Ú__call__j s ÿþz_ParamSubstitutor.__call__Úint©r1 c C s t | j| j S )z8Returns number of parameters remaining to be substituted)Úlenr0 r2 ©r3 r4 r4 r5 Ú remainingt s z_ParamSubstitutor.remainingN)Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r6 r; Úpropertyr@ r4 r4 r4 r5 r. ` s
|
|
r. c sî e Zd ZU dZdZded< dZded< dZded< ddd d
|
d Zd]ddd fdd Z ddddZ
|
ddddZ ddddZ dddddZ ddd d Zddd d Zd dd!d"Zd^d$d%dd&d'd(d)Zd*d+d,d-d.d/Zd*d+d&d-d0d1Zed2dd3d4Zed5dd6d7Zddd8d9Zd_d*d:d;d<d=d>Zd?dd@dAZdBddCdDZd`d5dBdFdGdHZdIddJdKZ dLddMdNZ d ddOdPZ dQddRdSZ edTddUdVZ ed*ddWdXZ!edddYdZZ"d*dd[d\Z# Z$S )aÚ CMySQLCursorz;Default cursor for interacting with MySQL using C ExtensionFÚboolÚ_rawÚ _bufferedÚ_raw_as_stringú Type[MySQLConnectionAbstract]r/ )Ú
|
connectionr1 c C s@ t | ¡ d| _d| _d| _t|ts0tddt |¡| _
|
dS )Ú
|
Initializeéÿÿÿÿ©NNi ©ÚerrnoN) r r6 Ú_affected_rowsÚ _rowcountÚ_nextrowÚ
|
isinstancer r* ÚweakrefÚproxyÚ_cnx©r3 rL r4 r4 r5 r6 s
|
|
|
ÿzCMySQLCursor.__init__T©Úfreer1 c s^ d| _ d| _d| _d| _d| _d| _d| _d| _d| _g | _|rP| jrP| j ¡ t
|
¡ dS )zXReset the cursor
|
|
When free is True (default) the result will be freed.
|
rN Nr ) rS rT rR Ú_last_insert_idÚ_warning_countÚ _warningsÚ _descriptionZ_executed_listrX Ú free_resultÚsuperÚreset©r3 r[ ©Ú __class__r4 r5 rb s
|
|
zCMySQLCursor.resetr= c C s | j dkrttdS )zsCheck if the statement has been executed.
|
|
Raises an error if the statement has not been executed.
|
N)Ú _executedr* ÚERR_NO_RESULT_TO_FETCHr? r4 r4 r5 Ú_check_executed¦ s
|
z CMySQLCursor._check_executedzOptional[List[WarningType]]c
|
C s¬ g }z2| j ¡ | j d¡}| j ¡ d }| j ¡ W nh tk
|
rn } zt|j|j|jd|W 5 d}~X Y n2 t k
|
r } zt
|
d| dW 5 d}~X Y nX |r¨|S dS )a Fetch warnings
|
|
Fetch warnings doing a SHOW WARNINGS. Can be called after getting
|
the result.
|
|
Returns a result set or None when there were no warnings.
|
|
Raises Error (or subclass) on errors.
|
|
Returns list of tuples or None.
|
z SHOW WARNINGSr ©ÚmsgrQ ÚsqlstateNzFailed getting warnings; ) rX Zconsume_resultsÚ cmd_queryÚget_rowsr r- rj rQ rk Ú Exceptionr* )r3 ZwarnsÚ_Úerrr4 r4 r5 Ú_fetch_warnings® s&
|
ÿþ"z CMySQLCursor._fetch_warningsc C sf | j jr| jr| ¡ | _| js"dS t| jd dd
d| j j i}| j jrP|tjt |dd dS )zHandle possible warnings after all results are consumed.
|
|
Raises:
|
Error: Also raises exceptions if raise_on_warnings is set.
|
Nr r é Úwarningé )Ú
|
stacklevel)
|
rX Z get_warningsr] rq r^ r- Zraise_on_warningsÚwarningsÚwarnÚstr)r3 rp r4 r4 r5 Ú_handle_warningsÍ s
|
ÿÿz CMySQLCursor._handle_warningsz(Union[CextEofPacketType, CextResultType])Úresultr1 c C sR d|kr"|d | _ d| _| ¡ n,|d | _|d | _|d | _d| _| ¡ dS )z,Handles the result after statement executionÚcolumnsr Z insert_idÚ warning_countZ affected_rowsrN N)r_ rS Ú_handle_resultsetr\ r] rR ry ©r3 rz r4 r4 r5 Ú_handle_resultá s
|
|
|
|
|
zCMySQLCursor._handle_resultc C s dS )úHandle a result setNr4 r? r4 r4 r5 r} î s z CMySQLCursor._handle_resultsetc C s( | j j| _| ¡ | j js$| j ¡ dS )zMHandle end of reading the result
|
|
Raises an Error on errors.
|
N)rX r| r] ry Ú more_resultsr` r? r4 r4 r5 Ú _handle_eofñ s
|
zCMySQLCursor._handle_eofz#Generator[CMySQLCursor, None, None]c
|
c sº t | j¡}d}|| | _| V z| ¡ s.tW nB tk
|
r^ } z|jtkrN W 5 d}~X Y n tk
|
rr Y dS X |d7 }z|| ¡ | _W n t k
|
r¬ |d | _Y nX | V q dS )a Generator returns MySQLCursor objects for multiple statements
|
|
Deprecated: use nextset() method directly.
|
|
This method is only used when multiple statements are executed
|
by the execute() method. It uses zip() to make an iterator from the
|
given query_iter (result of MySQLConnection.cmd_query_iter()) and
|
the list of statements that were executed.
|
r Nr )
|
r' Úsplitrf ÚnextsetÚ StopIterationr* rQ r( Ústripr: )r3 Z executed_listÚirp r4 r4 r5 Ú _execute_iterû s&
|
|
|
zCMySQLCursor._execute_iterr4 r r z-Optional[Generator[CMySQLCursor, None, None]]©Ú operationr0 Úmultir1 c
|
C sÀ |sdS z| j r| j ¡ r tW n2 ttfk
|
rR } ztdd|W 5 d}~X Y nX | j ¡ d}| ¡ z"t|tr| | j j ¡}n|}W n4 t
|
t fk
|
rÀ } ztt||W 5 d}~X Y nX |rD| j |¡}t|t r | ¡ D ] \}}| d| d ¡ |¡}qèn8t|ttfrDt|} t | |¡}| jdkrDtdz | j j|| j| j| jd }
|
W n: tk
|
r } zt|j |j |j d
|
|W 5 d}~X Y nX || _ | |
|
¡ |r¼| !¡ S dS ) z²Execute given statement using given parameters
|
|
Deprecated: The multi argument is not needed and nextset() should
|
be used to handle multiple result sets.
|
NúCursor is not connectedé Ú ú%(ú)sr ú1Not all parameters were used in the SQL statement)ÚrawZbufferedÚ raw_as_stringri )"rX Ú is_closedr, ÚReferenceErrorÚhandle_unread_resultrb rU rx ÚencodeÚpython_charsetÚUnicodeDecodeErrorÚUnicodeEncodeErrorÚprepare_for_mysqlÚdictÚitemsÚreplaceÚlistÚtupler. r Úsubr@ rl rH rI rJ r r- rj rQ rk rf r r ) r3 r r0 r rp ÚstmtÚpreparedÚkeyÚvalueÚpsubrz r4 r4 r5 Úexecute s`
|
|
ÿü
|
ÿþ
|
zCMySQLCursor.executerx z"Sequence[ParamsSequenceOrDictType]zOptional[bytes]©r Ú
|
seq_paramsr1 c
|
C s ddddd}t tdt t||¡¡}t t|¡}|s@td| d¡ | j j
|
¡}g }zÌ| | j j
|
¡}|D ]} |}| j | ¡}
|
t |
|
t r¶|
|
¡ D ] \} } | d | d
|
¡ | ¡}qn4t |
|
ttfrêt|
|
} t | |¡}| jd krêtd | |¡ ql||kr | |d |¡d¡}|| _|W S W dS ttfk
|
rZ } ztt||W 5 d}~X Y n4 t k
|
r } ztd| dW 5 d}~X Y nX dS )zImplements multi row insertzre.Matchrx )Úmatchr1 c S s | d¡rdS | d¡S )a Remove comments from INSERT statements.
|
|
This function is used while removing comments from INSERT
|
statements. If the matched string is a comment not enclosed
|
by quotes, it returns an empty string, else the string itself.
|
r r é )Úgroup)rª r4 r4 r5 Úremove_commentsd s
|
z3CMySQLCursor._batch_insert.<locals>.remove_commentsr zAFailed rewriting statement for multi-row INSERT. Check SQL syntaxr r r r r ó ,Nú Failed executing the operation; ) Úrer¡ r$ r Úsearchr# r* r¬ r rX r r rU r r r r r r. r r@ r, ÚappendÚjoinrf r r rx rn )r3 r r© r ÚtmpÚmatchesÚfmtÚvaluesr¢ r0 r£ r¤ r¥ r¦ rp r4 r4 r5 Ú _batch_insert] sL ý ÿ
|
|
ÿ
|
zCMySQLCursor._batch_insertc
|
C s8 |r|s dS z| j stW n0 ttfk
|
rJ } ztd|W 5 d}~X Y nX | j ¡ t|ttfsltdt t |¡rª|sd| _
|
dS | ||¡}|dk rª|| _ | |¡S d}zF|D ]<}| ||¡ | jrÚ| j jrÚ| ¡ || jrè| j
|
n| j7 }q´W n8 ttfk
|
r, } ztd| dW 5 d}~X Y nX || _
|
dS )aÆ Execute the given operation multiple times
|
|
The executemany() method will execute the operation iterating
|
over the list of parameters in seq_params.
|
|
Example: Inserting 3 new employees and their phone number
|
|
data = [
|
('Jane','555-001'),
|
('Joe', '555-001'),
|
('John', '555-003')
|
]
|
stmt = "INSERT INTO employees (name, phone) VALUES ('%s','%s)"
|
cursor.executemany(stmt, data)
|
|
INSERT statements are optimized by batching the data, that is
|
using the MySQL multiple rows syntax.
|
|
Results are discarded! If they are needed, consider looping over
|
data using the execute() method.
|
Nr z+Parameters for query must be list or tuple.r r¯ )rX r, r r rU r r r° rª r" rS r¸ rf r§ Ú with_rowsÚ unread_resultÚfetchallÚ descriptionrR Ú
|
ValueErrorÚ TypeErrorr* )r3 r r© rp r¢ Úrowcntr0 r4 r4 r5 Ú executemany s:
|
|
"zCMySQLCursor.executemanyz Optional[List[DescriptionType]]c C s | j S )z*Returns description of columns in a result)r_ r? r4 r4 r5 r¼ Û s zCMySQLCursor.descriptionr< c C s | j dkr| jS | j S )z/Returns the number of rows produced or affectedrN )rS rR r? r4 r4 r5 Úrowcountà s
|
zCMySQLCursor.rowcountc C s$ | j s
|
dS | j ¡ d| _d| _ dS )z<Close the cursor
|
|
The result will be freed.
|
FNT)rX r r^ r? r4 r4 r5 Úcloseç s
|
zCMySQLCursor.closez Sequence[Any]z8Optional[Union[Dict[str, ToPythonOutputTypes], RowType]]©ÚprocnameÚargsr1 c
|
C sl |rt |tstdt |ttfs,tdd}g | _zäg }g }| d¡d }|rög }t|D ]n\}} |j||d d}
|
| |
|
¡ t | trº| d|
|
d | d d
|
¡ | | d ¡ q`| |
|
¡ | | ¡ q`d
|
d d |D ¡} | d| |¡ d| dd
|
|¡ d
|
} | j j | | j| jd} g }| j jr¸| j ¡ } t | ttfrRt}n(t | ttfrht}n| jrvt}nt}|| j ¡ }d| d
|
|_| | ¡ | |¡ | j ¡ q(|| _| ¡ |r| ¡ dd t |dd |D D }dd
|
|¡ }| |¡ | ¡ W S t W S t k
|
r4 Y n4 t!k
|
rf } zt"d| dW 5 d}~X Y nX dS )z1Calls a stored procedure with the given argumentszprocname must be a stringzargs must be a sequencez@_{name}_arg{index}Ú.rN r )Únamer2 z CAST(ú AS ú)r ú,c s s | ]}| d V qdS )z=%sNr4 ©Ú.0Úargr4 r4 r5 Ú <genexpr> s z(CMySQLCursor.callproc.<locals>.<genexpr>zSET zCALL ú()r r z (a result of c S s g | ]\}}| d | qS )rÈ r4 )rÌ rÇ Úaliasr4 r4 r5 Ú
|
<listcomp>; s ÿz)CMySQLCursor.callproc.<locals>.<listcomp>c S s g | ]}| d ¡qS )z@_)ÚlstriprË r4 r4 r5 rÑ > s zSELECT z Failed calling stored routine; N)#rU rx r½ r r Ú_stored_resultsr Ú enumerateÚformatr² r³ r§ rX rl rH rJ Úresult_set_availableÚfetch_eof_columnsÚCMySQLCursorDictÚCMySQLCursorBufferedDictÚCMySQLCursorNamedTupleÚ CMySQLCursorBufferedNamedTupleÚCMySQLCursorBufferedRawÚCMySQLCursorBufferedZget_selfrf r Ú next_resultr rb ÚzipÚfetchoner) rn r* )r3 rÄ rÅ ZargfmtÚargnamesÚargtypesZ procname_absZ argvaluesÚidxrÍ ÚargnameZ placeholdersÚcallrz ÚresultsZ cursor_classÚcurÚselectrp r4 r4 r5 Úcallprocô s
|
|
|
ÿ
|
|
þ
|
|
ÿþ
|
|
zCMySQLCursor.callproczOptional[bool]c C s` | j ¡ s| jdd dS | jdd | j jsL| j ¡ }| |¡ ttd| | j ¡ ¡ dS )z%Skip to the next available result setT©r[ NFrP ) rX rÞ rb rÖ Zfetch_eof_statusr r* r( r× )r3 Úeofr4 r4 r5 r L s
|
|
|
|
zCMySQLCursor.nextsetú List[RowType]c C s~ | ¡ | jjsg S | j ¡ }| jrD| jd rD|d d| jd ¡ |d sX| ¡ g S | jt|d 7 _| ¡ |d S )úReturn all rows of a query result set.
|
|
Returns:
|
list: A list of tuples with all rows of a query result set.
|
r ) rh rX rº rm rT Úinsertr rS r> ©r3 Úrowsr4 r4 r5 r» [ s
|
zCMySQLCursor.fetchallr ©Úsizer1 c C s¼ | ¡ | jr.| jd r.| jd g}|d8 }ng }|rT| jjrT| | j |¡d ¡ |r| jjr| j ¡ | _| jr| jd s| jjs| j ¡ nd| _|s¦| ¡ g S | j
|
t |7 _
|
|S )á< Return the next set of rows of a query result set.
|
|
When no more rows are available, it returns an empty list.
|
The number of rows returned can be specified using the size argument,
|
which defaults to one.
|
|
Returns:
|
list: The next set of rows of a query result set.
|
r r rO ) rh rT rX rº Úextendrm Úget_rowr r` r rS r> )r3 rò rð r4 r4 r5 Ú fetchmanyr s.
|
|
ÿþý zCMySQLCursor.fetchmanyúOptional[RowType]c C s| | ¡ | j}|s$| jjr$| j ¡ }|rZ|d rZ| j ¡ | _| jd sf| jjsf| j ¡ n | ¡ dS | jd7 _|d S )úyReturn next row of a query result set.
|
|
Returns:
|
tuple or None: A row from query result set.
|
r Nr ) rh rT rX rº rõ r r` r rS ©r3 Úrowr4 r4 r5 rà s
|
zCMySQLCursor.fetchonezIterator[RowType]c C s t | jdS )zIteration over the result set
|
|
Iteration over the result set which calls self.fetchone()
|
and returns the next row.
|
N)Úiterrà r? r4 r4 r5 Ú__iter__® s zCMySQLCursor.__iter__c c s | j D ]
|
}|V qg | _ dS )z÷Returns an iterator for stored results
|
|
This method returns an iterator over results which are stored when
|
callproc() is called. The iterator will provide MySQLCursorBuffered
|
instances.
|
|
Returns a iterator.
|
N)rÓ r~ r4 r4 r5 Ústored_results¶ s
|
zCMySQLCursor.stored_resultsr c C s6 z | ¡ }W n tk
|
r& tdY nX |s2td|S )zÈIteration over the result set
|
Used for iterating over the result set. Calls self.fetchone()
|
to get the next row.
|
|
Raises StopIteration when no more rows are available.
|
N)rà r* r
rù r4 r4 r5 Ú__next__Ã s zCMySQLCursor.__next__zTuple[str, ...]c C s | j s
|
dS tdd | j D S )ztReturns column names
|
|
This property returns the columns names as a tuple.
|
|
Returns a tuple.
|
r4 c s s | ]}|d V qdS )r Nr4 )rÌ Údr4 r4 r5 rÎ Ü s z,CMySQLCursor.column_names.<locals>.<genexpr>)r¼ r r? r4 r4 r5 Ú column_namesÒ s zCMySQLCursor.column_namesc C s6 z| j ¡ d¡W S tk
|
r0 | j ¡ Y S X dS )zÎReturns the executed statement
|
|
This property returns the executed statement. When multiple
|
statements were executed, the current statement in the iterator
|
will be returned.
|
Úutf8N)rf r ÚdecodeÚAttributeErrorr? r4 r4 r5 Ú statementÞ s zCMySQLCursor.statementc C s | j r
|
dS dS )zæReturns whether the cursor could have rows returned
|
|
This property returns True when column descriptions are available
|
and possibly also rows, which will need to be fetched.
|
|
Returns True or False.
|
TF)r¼ r? r4 r4 r5 r¹ ë s zCMySQLCursor.with_rowsc C sj d}| j rTz| j d¡}W n tk
|
r4 | j }Y nX t|dkrX|d d
d }nd}|j| jj|dS )Nz{class_name}: {stmt}zutf-8é( z..z(Nothing executed yet))Ú
|
class_namer¢ )rf r r r> rÕ re rA )r3 r¶ Zexecutedr4 r4 r5 Ú__str__ø s zCMySQLCursor.__str__)T)r4 F)r4 )r )%rA rB rC rD rH Ú__annotations__rI rJ r6 rb rh rq ry r r} r r r§ r¸ rÀ rE r¼ rÁ r ré r r» rö rà rü rý rþ r r r¹ r Ú __classcell__r4 r4 rd r5 rF z sN
|
|
$ üA;C ýX' rF c s e Zd ZdZdd fdd Zdddd Zd d dd fd d ZddddZddddZd dddddZ ddddZ
|
e d dd d Z Z S ) rÝ z*Cursor using C Extension buffering resultsrK ©rL c s t |¡ d| _d| _dS )rM Nr )ra r6 Ú_rowsÚ _next_rowrY rd r4 r5 r6 s z CMySQLCursorBuffered.__init__r/ r= c C s. | j ¡ d | _d| _t| j| _| ¡ dS )r r N)rX rm r r r> rS r r? r4 r4 r5 r} s z&CMySQLCursorBuffered._handle_resultsetTrG rZ c s d| _ d| _t j|d dS )zReset the cursor to defaultNr rê )r r ra rb rc rd r4 r5 rb s zCMySQLCursorBuffered.resetr÷ c C s> d}z| j | j }W n tk
|
r* Y dS X | jd7 _|S )úQReturns the next row in the result set
|
|
Returns a tuple or None.
|
Nr )r r r: rù r4 r4 r5 Ú
|
_fetch_row s z CMySQLCursorBuffered._fetch_rowrì c C s( | ¡ | j| jd
}t| j| _|S )rí N)rh r r r> ©r3 Úresr4 r4 r5 r» , s z CMySQLCursorBuffered.fetchallr r< rñ c C sF | ¡ g }|p| j}|dkrB|d8 }| ¡ }|rB| |¡ qqBq|S ©ró r r )rh Ú arraysizer r² ©r3 rò r Zcntrú r4 r4 r5 rö 7 s
|
|
z CMySQLCursorBuffered.fetchmanyc C s | ¡ | ¡ S )rø ©rh r r? r4 r4 r5 rà M s z CMySQLCursorBuffered.fetchonec C s
|
| j dk S )zÀReturns whether the cursor could have rows returned
|
|
This property returns True when rows are available,
|
which will need to be fetched.
|
|
Returns True or False.
|
N)r r? r4 r4 r5 r¹ V s z CMySQLCursorBuffered.with_rows)T)r )rA rB rC rD r6 r} rb r r» rö rà rE r¹ r r4 r4 rd r5 rÝ s rÝ c @ s e Zd ZU dZdZded< dS )ÚCMySQLCursorRawz+Cursor using C Extension return raw resultsTrG rH N©rA rB rC rD rH r r4 r4 r4 r5 r b s
|
r c @ s e Zd ZU dZdZded< dS )rÜ z.Cursor using C Extension buffering raw resultsTrG rH Nr r4 r4 r4 r5 rÜ h s
|
rÜ c s\ e Zd ZU dZdZded< dd fdd Zdd
|
d d fd d Zd d fdd Z Z S )rØ z7Cursor using C Extension returning rows as dictionariesFrG rH ú(Optional[Dict[str, ToPythonOutputTypes]]r= c s" t ¡ }|r tt| j|S dS )zyReturn next row of a query result set.
|
|
Returns:
|
dict or None: A dict from query result set.
|
N)ra rà r rß r rù rd r4 r5 rà s s
|
zCMySQLCursorDict.fetchoner r< ú$List[Dict[str, ToPythonOutputTypes]]rñ c s t j|d} fdd|D S )a Return the next set of rows of a query result set.
|
|
When no more rows are available, it returns an empty list.
|
The number of rows returned can be specified using the size argument,
|
which defaults to one.
|
|
Returns:
|
list: The next set of rows of a query result set represented
|
as a list of dictionaries where column names are used as keys.
|
©rò c s g | ]}t t j|qS r4 ©r rß r ©rÌ rú r? r4 r5 rÑ s z.CMySQLCursorDict.fetchmany.<locals>.<listcomp>©ra rö ©r3 rò r rd r? r5 rö | s zCMySQLCursorDict.fetchmanyc s t ¡ } fdd|D S )zÅReturn all rows of a query result set.
|
|
Returns:
|
list: A list of dictionaries with all rows of a query
|
result set where column names are used as keys.
|
c s g | ]}t t j|qS r4 r r r? r4 r5 rÑ s z-CMySQLCursorDict.fetchall.<locals>.<listcomp>©ra r» r rd r? r5 r» s
|
zCMySQLCursorDict.fetchall)r )
|
rA rB rC rD rH r rà rö r» r r4 r4 rd r5 rØ n s
|
|
rØ c s< e Zd ZdZdZdd fdd Zdd fdd Z ZS )
|
rÙ zECursor using C Extension buffering and returning rows as dictionariesFr r= c s" t ¡ }|r tt| j|S d S ©N)ra r r rß r rù rd r4 r5 r s
|
z#CMySQLCursorBufferedDict._fetch_rowr c s t ¡ } fdd|D S )rí c s g | ]}t t j|qS r4 r r r? r4 r5 rÑ § s z5CMySQLCursorBufferedDict.fetchall.<locals>.<listcomp>r r rd r? r5 r» s
|
z!CMySQLCursorBufferedDict.fetchall)rA rB rC rD rH r r» r r4 r4 rd r5 rÙ s rÙ c sn e Zd ZU dZdZded< dd fdd Zd d fd
|
d Zdd dd fdd Zdd fdd Z Z
|
S )rÚ z7Cursor using C Extension returning rows as named tuplesNr Ú named_tupler/ r= c sR t ¡ t| j}zt| | _W n* tk
|
rL td|| _| jt|< Y nX dS )r ÚRowN)ra r} r r r r ÚKeyErrorr )r3 r{ rd r4 r5 r} ¯ s
|
|
z(CMySQLCursorNamedTuple._handle_resultsetr÷ c s t ¡ }|r| j| S dS ©rø N)ra rà r rù rd r4 r5 rà ¹ s
|
|
z CMySQLCursorNamedTuple.fetchoner r< rì rñ c s( t j|d}|sg S fdd|D S )ró r c s g | ]} j | qS r4 ©r r r? r4 r5 rÑ Ñ s z4CMySQLCursorNamedTuple.fetchmany.<locals>.<listcomp>r r rd r? r5 rö Ä s
|
z CMySQLCursorNamedTuple.fetchmanyc s t ¡ } fdd|D S )rí c s g | ]} j | qS r4 r$ r r? r4 r5 rÑ Ú s z3CMySQLCursorNamedTuple.fetchall.<locals>.<listcomp>r r rd r? r5 r» Ó s
|
z CMySQLCursorNamedTuple.fetchall)r ) rA rB rC rD r r r} rà rö r» r r4 r4 rd r5 rÚ ª s
|
|
rÚ c sX e Zd ZU dZdZded< dd fdd Zd d fd
|
d Zd d fd d Z Z S )rÛ zECursor using C Extension buffering and returning rows as named tuplesNr r r/ r= c s t ¡ td| j| _d S )Nr! )ra r} r r r r? rd r4 r5 r} â s
|
z0CMySQLCursorBufferedNamedTuple._handle_resultsetr÷ c s t ¡ }|r| j| S d S r )ra r r rù rd r4 r5 r æ s
|
|
z)CMySQLCursorBufferedNamedTuple._fetch_rowrì c s t ¡ } fdd|D S )rí c s g | ]} j | qS r4 r$ r r? r4 r5 rÑ ó s z;CMySQLCursorBufferedNamedTuple.fetchall.<locals>.<listcomp>r r rd r? r5 r» ì s
|
z'CMySQLCursorBufferedNamedTuple.fetchall)
|
rA rB rC rD r r r} r r» r r4 r4 rd r5 rÛ Ý s
|
|
rÛ c sØ e Zd ZdZdd fdd Zdddd Zd/d d d ddZd0ddddddZdd fdd Zd1d dd fdd Z d2d d d dd d d Z
|
d!d"dd#d$d%Z d dd&d'Z d3d(d)d*d+d,Z d)dd-d.Z ZS )4ÚCMySQLCursorPreparedz&Cursor using MySQL Prepared StatementsrK r
|
c s. t |¡ d | _d| _d| _d| _d | _d S )Nr T)ra r6 r rS r Ú_binaryÚ_stmtrY rd r4 r5 r6 ù s z CMySQLCursorPrepared.__init__r/ r= c C s d| _ | ¡ dS )zHandle EOF packetrO N)rT ry r? r4 r4 r5 r s z CMySQLCursorPrepared._handle_eofFrG r÷ )r r1 c C sÈ | j r| j jsdS d}| jdkr@| jj| j| j|| j d\}}n
|
| j\}}|r®| jj| j| j|| j d| _| jd }|dk r|d | _| ¡ | j dkr d| _ n| j d7 _ |rÄ|d | _| ¡ |S )r NrO )Úbinaryr{ r Ú prep_stmtr r| rN )
|
r' Úhave_result_setrT rX rõ r& r¼ r] r rS )r3 r rú rë r4 r4 r5 r s:
|
ü
|
ü
|
|
|
|
z CMySQLCursorPrepared._fetch_rowNr r rà c C s
|
t dS )zRCalls a stored procedue
|
|
Not supported with CMySQLCursorPrepared.
|
N)r+ )r3 rÄ rÅ r4 r4 r5 ré . s z CMySQLCursorPrepared.callprocc s0 | j r"| ¡ | j | j ¡ d| _ t ¡ dS )zzClose the cursor
|
|
This method will try to deallocate the prepared statement and close
|
the cursor.
|
N)r' rb rX Úcmd_stmt_closera r r? rd r4 r5 r 5 s
|
zCMySQLCursorPrepared.closeTrZ c s& | j r| j | j ¡ t j|d dS )z Resets the prepared statement.rê N)r' rX Úcmd_stmt_resetra rb rc rd r4 r5 rb A s zCMySQLCursorPrepared.resetr z"Optional[ParamsSequenceOrDictType]r c
|
s |sdS z| j r| j ¡ r tW n2 ttfk
|
rR } ztdd|W 5 d}~X Y nX | j jdd | j j}|dkrvd}t|tsÀz| |¡}W n0 t k
|
r¾ } ztt||W 5 d}~X Y nX t t
|
r0t t |¡}zt fdd |D W n. tk
|
r } ztd
|
|W 5 d}~X Y nX t td |¡}|| jk rê| jrR| j | j¡ || _z| |¡}W n2 tk
|
r } ztt||W 5 d}~X Y nX d |kr²t td |¡}z| j |¡| _W n$ tk
|
rè d| _d| _ Y nX | j | j¡ | jjdkr sdS rdt tt fsFtddt j d dd| jjt krdtddd dkrrd | j j | jf }|r| !|¡ dS )a) Prepare and execute a MySQL Prepared Statement
|
|
This method will prepare the given operation and execute it using
|
the given parameters.
|
|
If the cursor instance already had a prepared statement, it is
|
first closed.
|
|
Note: argument "multi" is unused.
|
Nr r T)r£ Zutf8mb4r c 3 s | ]} | V qd S r r4 )rÌ r¤ ©r0 r4 r5 rÎ p s z/CMySQLCursorPrepared.execute.<locals>.<genexpr>z6Not all placeholders were found in the parameters dictú?s %só ?r iº z Incorrect type of argument: rÏ zP), it must be of type tuple or list the argument given to the prepared statement)rQ rj z:Incorrect number of arguments executing prepared statementr4 )"rX r r, r r ÚcharsetrU rx r r r r° Úfindallr% r r" r¡ r& rf r' r+ r r r! Zcmd_stmt_preparer) r, Z param_countr ÚtyperA r> Zcmd_stmt_executer )r3 r r0 r rp r0 Zreplacement_keysr r4 r- r5 r§ G s|
|
ÿþ
|
þþ
|
z CMySQLCursorPrepared.executerx z Sequence[ParamsSequenceType]r¨ c
|
C sx d}z2|D ](}| ||¡ | jr(| ¡ || j7 }q
|
W n6 ttfk
|
rl } ztd| |W 5 d}~X Y nX || _dS )a Prepare and execute a MySQL Prepared Statement many times
|
|
This method will prepare the given operation and execute with each
|
tuple found the list seq_params.
|
|
If the cursor instance already had a prepared statement, it is
|
first closed.
|
r r¯ N)r§ r¹ r» rS r½ r¾ r* )r3 r r© r¿ r0 rp r4 r4 r5 rÀ ¥ s "z CMySQLCursorPrepared.executemanyc C s | ¡ | ¡ pdS r# r r? r4 r4 r5 rà » s z CMySQLCursorPrepared.fetchonez Optional[int]rì rñ c C sJ | ¡ g }|p| j}|dkrF| jjrF|d8 }| ¡ }|r| |¡ q|S r )rh r r' r* r r² r r4 r4 r5 rö Ä s
|
|
z CMySQLCursorPrepared.fetchmanyc C s | ¡ | jjsg S | jj| jd}| jrJ| jd rJ|d d| jd ¡ |d s^| ¡ g S | jt |d 7 _| ¡ |d S )rí )r) r )
|
rh r' r* rX rm rT rî r rS r> rï r4 r4 r5 r» Ø s z CMySQLCursorPrepared.fetchall)F)N)T)NF)N)rA rB rC rD r6 r r ré r rb r§ rÀ rà rö r» r r4 r4 rd r5 r% ö s ( ü^ r% c @ s e Zd ZdZdS )ÚCMySQLCursorPreparedDictaÔ This class is a blend of features from CMySQLCursorDict and CMySQLCursorPrepared
|
|
Multiple inheritance in python is allowed but care must be taken
|
when assuming methods resolution. In the case of multiple
|
inheritance, a given attribute is first searched in the current
|
class if it's not found then it's searched in the parent classes.
|
The parent classes are searched in a left-right fashion and each
|
class is searched once.
|
Based on python's attribute resolution, in this case, attributes
|
are searched as follows:
|
1. CMySQLCursorPreparedDict (current class)
|
2. CMySQLCursorDict (left parent class)
|
3. CMySQLCursorPrepared (right parent class)
|
4. CMySQLCursor (base class)
|
N©rA rB rC rD r4 r4 r4 r5 r3 ï s r3 c @ s e Zd ZdZdS )Ú CMySQLCursorPreparedNamedTuplezVThis class is a blend of features from CMySQLCursorNamedTuple and CMySQLCursorPreparedNr4 r4 r4 r4 r5 r5 s r5 c @ s e Zd ZU dZdZded< dS )ÚCMySQLCursorPreparedRawzOThis class is a blend of features from CMySQLCursorRaw and CMySQLCursorPreparedTrG rH Nr r4 r4 r4 r5 r6 s
|
r6 )FrD Ú
|
__future__r r° rv rV Ú collectionsr Útypingr r r r r r r
|
r r r r r Z_mysql_connectorr r Útypesr r r r r r r r r Z abstractsr r r Úcursorr r r! r" r# r$ r% r& r' Ú errorcoder( Úerrorsr) r* r+ r, r- rg r. rF rÝ r rÜ rØ rÙ rÚ rÛ r% r3 r5 r6 r4 r4 r4 r5 Ú<module> sB 4 ,, ['3 z
|
