U
|
£ý°dÓ ã
|
@ sx d Z ddlZddlZddlZddlmZmZmZmZm Z m
|
Z
|
m Z m Z ddl mZ ddlmZ ddlmZmZmZmZmZ ddlmZ dd lmZmZm Z m Z m Z dd
|
l m Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z( d Z)zXddl*Z*dd l*m+Z+m,Z, ddl-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9 dZ)W n6 e:k
|
rb Z; ze:de; de;W 5 dZ;[;X Y nX G dd deZ<dS )z'Connection class using the C Extension.é N)ÚAnyÚDictÚListÚOptionalÚSequenceÚTupleÚTypeÚUnioné )Úversion)ÚMySQLConnectionAbstract)Ú CharacterSetÚ
|
ClientFlagÚ FieldFlagÚ
|
ServerFlagÚ ShutdownType)ÚMySQLConverter)ÚInterfaceErrorÚ InternalErrorÚOperationalErrorÚProgrammingErrorÚget_mysql_exception)Ú MySQLProtocol)ÚCextEofPacketTypeÚCextResultTypeÚDescriptionTypeÚParamsSequenceOrDictTypeÚRowTypeÚStatsPacketTypeÚ
|
StrOrBytesF)ÚMySQLInterfaceErrorÚ MySQLPrepStmt) Ú CMySQLCursorÚCMySQLCursorBufferedÚCMySQLCursorBufferedDictÚ CMySQLCursorBufferedNamedTupleÚCMySQLCursorBufferedRawÚCMySQLCursorDictÚCMySQLCursorNamedTupleÚCMySQLCursorPreparedÚCMySQLCursorPreparedDictÚ CMySQLCursorPreparedNamedTupleÚCMySQLCursorPreparedRawÚCMySQLCursorRawTz2MySQL Connector/Python C Extension not available (ú)c s e Zd ZdZedd fdd ZddddZddd d
|
Zee dd d Z
|
e dd ddZ de ddddZee dddZeje ddddZee dddZeje ddddZee dddZddd d Zddd d ZeZe dd d!Ze dd"d#Zde e e dd'd(d)Ze dd*d+d,Zeee d-d.d/Z eee dd0d1Z dee e ee e ee ee! e"e e ee# f d2d3d4Z$de ee e ee ee! e"ee e#f d5d6d7Z%ee dd8d9Z&ddd:d;Z'ddd<d=Z(ddd>d?Z)e dd@dAdBZ*dee! e+dCdDdEZ,ee# ddFdGZ-e.e!dHdIdJZ/e!eee0e#e+f dKdLdMZ1e!ddNdOdPZ2e!ddNdQdRZ3deee e e ee0e#e+f dSdTdUZ4e4Z5dee ee ee ee6e7 ee ee e7dVdWdXZ8ee ddYdZZ9ee dd[d\Z:ee dd]d^Z;ee dd_d`Z<ee ddadbZ=e>e0e?e. e@e e.f f dcdddeZAdddfdgZBde e e e e e e ee ee ddj
|
dkdlZCe ddmdnZDe ee# dodpdqZEdddrdsZFdee ddtdudvZGeHddwdxZIe ddydzd{ZJedd|d}ZKedd~dZLeedddZMeeeeddd
ZNde ddddZOdee@e ef ee@e ef ddddZP ZQS )ÚCMySQLConnectionz6Class initiating a MySQL Connection using Connector/C.N)ÚkwargsÚreturnc s t s tdd| _g | _tj tj tj t j
|
¡¡ddd¡| _ t ¡ dkrntj | j ¡sntj d¡rhdnd| _ d| _t ¡ |r| jf | dS ) ZInitializationz0MySQL Connector/Python C Extension not availableNZmysqlÚvendorZpluginÚLinuxz/usr/lib64/mysql/pluginz/usr/lib/mysql/plugin)Ú HAVE_CMYSQLÚ RuntimeErrorÚ_cmysqlÚ_columnsÚosÚpathÚjoinÚdirnameÚabspathÚ_mysql_connectorÚ__file__Ú _plugin_dirÚplatformÚsystemÚexistsÚ converterÚsuperÚ__init__Úconnect)Úselfr0 ©Ú __class__© úVd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\mysql/connector/connection_cext.pyrE ] s* þü
|
ÿý
|
zCMySQLConnection.__init__)r1 c
|
C sZ t j d¡}|d dkr d}nd}| j d|d dd t jdd
|
D ¡t ¡ d ¡ d S ) z!Add default connection attributesú r ZGPLv2zGPL-2.0Z
|
Commercialzmysql-connector-pythonÚ.c S s g | ] }t |qS rJ )Ústr)Ú.0ÚxrJ rJ rK Ú
|
<listcomp> s z<CMySQLConnection._add_default_conn_attrs.<locals>.<listcomp>é )Z_connector_nameZ_connector_licenseZ_connector_versionZ _source_hostN) r ÚLICENSEÚsplitÚ _conn_attrsÚupdater: ÚVERSIONÚsocketÚ gethostname)rG Zlicense_chunksZclient_licenserJ rJ rK Ú_add_default_conn_attrsz s üÿz(CMySQLConnection._add_default_conn_attrsc C sR | j ¡ | j ¡ | j ¡ dddd| j ¡ d| _| | jd ¡| _t | j¡ dS )z<Gather information of the MySQL server before authenticationN)ÚprotocolÚserver_version_originalZserver_threadidÚcharsetÚ server_statusÚ auth_pluginZ auth_dataZ capabilitiesr\ )
|
r6 Zget_proto_infoZget_server_infoÚ thread_idZst_server_capabilitiesZ
|
_handshakeZ_check_server_versionZ_server_versionr Zset_mysql_version©rG rJ rJ rK Ú _do_handshake s ø ÿz CMySQLConnection._do_handshakec C s
|
| j ¡ S )z6Returns the server status attribute of MYSQL structure)r6 Zst_server_statusra rJ rJ rK Ú_server_status s z CMySQLConnection._server_status)r9 r1 c C s | j r| j |¡ dS )zJset local_infile_in_path
|
|
Set allow_local_infile_in_path.
|
N)r6 Z!set_load_data_local_infile_option)rG r9 rJ rJ rK Ú set_allow_local_infile_in_path¢ s z/CMySQLConnection.set_allow_local_infile_in_pathT)Úvaluer1 c C s. || _ | jr| j |¡ | jr*| j |¡ dS )zuToggle unicode mode
|
|
Set whether we return string fields as unicode or not.
|
Default is True.
|
N)Ú _use_unicoder6 Ú use_unicoderC Ú set_unicode©rG re rJ rJ rK rh « s
|
z CMySQLConnection.set_unicodec C s | d¡d }|dkS )z#Get whether autocommit is on or offzSELECT @@session.autocommitr r
|
©Ú
|
info_queryri rJ rJ rK Ú
|
autocommit· s zCMySQLConnection.autocommitc
|
C sT z| j |¡ || _W n8 tk
|
rN } zt|j|j|jd|W 5 d}~X Y nX dS )zToggle autocommit©ÚmsgÚerrnoÚsqlstateN)r6 rl Z _autocommitr r rn ro rp ©rG re ÚerrrJ rJ rK rl ½ s
|
ÿþc C s | d¡d S )zGet the current databasezSELECT DATABASE()r rj ra rJ rJ rK ÚdatabaseÈ s zCMySQLConnection.databasec
|
C sN z| j |¡ W n8 tk
|
rH } zt|j|j|jd|W 5 d}~X Y nX dS )zSet the current databaserm N©r6 Z select_dbr r rn ro rp rq rJ rJ rK rs Í s ÿþc C s | j tj@ S )z'MySQL session has started a transaction)rc r ZSTATUS_IN_TRANSra rJ rJ rK Úin_transaction× s z CMySQLConnection.in_transactionc C s t | j¡d }tj| j| j|| jp&d| j| j | j
|
d| _ | t j¡sLi | _| j| j| j| j| j| j| j| j| j| j| t j¡d| j| j| j | j | j | j d}| j !d¡}|d k rÈ|j"dd d #|¡}| j !d¡d k rú| j !d¡d }| j !d¡d }nd }d }|d k r d
|
|kr |s d }| j$s|| %| j !d ¡| j !d ¡| j !d¡|||| j !d¡p`d| j !d¡ppd| j$d ¡ t&j'dkr| j(dkrd|d< z.| j j)f | | j*| j _+| j,rÈ| j*| j,_-W n: t.k
|
r } zt/|j0|j1|j2d|W 5 d }~X Y nX | 3¡ d S )Nr )ÚbufferedÚrawÚ charset_nameZconnection_timeoutrg r_ Z
|
plugin_dirT)ÚhostÚuserÚpasswordÚ password1Ú password2Ú password3rs ÚportZ client_flagsZ unix_socketÚcompressÚ ssl_disabledZ
|
conn_attrsZ local_infileZload_data_local_dirÚoci_config_fileÚoci_config_profileZ fido_callbackÚ tls_versions)Úreverseú,Útls_ciphersuitesr
|
zTLSv1.3ZTLS_AES_256_GCM_SHA384ÚcaÚcertÚkeyZ verify_certFZverify_identity) Zssl_caZssl_certZssl_keyZssl_cipher_suitesr Ztls_cipher_suitesZssl_verify_certZssl_verify_identityr ÚntZMySQLKerberosAuthPluginZuse_kerberos_gssapirm )4r Úget_infoÚ _charset_idr= ZMySQLÚ _bufferedÚ_rawZ_connection_timeoutrf Z _auth_pluginr? r6 Zisset_client_flagr Z CONNECT_ARGSrU Ú_hostÚ_userÚ _passwordÚ
|
_password1Ú
|
_password2Ú
|
_password3Ú _databaseÚ_portZ _client_flagsÚ _unix_socketZCOMPRESSZ_allow_local_infileZ_allow_local_infile_in_pathÚ_oci_config_fileÚ_oci_config_profileZ_fido_callbackÚ_sslÚgetÚsortr: Z _ssl_disabledrV r8 ÚnameZ_auth_plugin_classrF Ú_converter_str_fallbackÚconverter_str_fallbackrC Z str_fallbackr r rn ro rp rb )rG rx Z
|
cnx_kwargsr Zssl_ciphersuitesr rr rJ rJ rK Ú_open_connectionÜ s ù
|
|
î
|
ÿþý
|
|
|
÷ÿ
|
ÿþz!CMySQLConnection._open_connectionc
|
C sZ | j rVz| ¡ | j ¡ W n8 tk
|
rT } zt|j|j|jd|W 5 d}~X Y nX dS )z Disconnect from the MySQL serverrm N)r6 Ú free_resultÚcloser r rn ro rp )rG rr rJ rJ rK r£ . s ÿþzCMySQLConnection.closec C s | j ¡ S )z8Return True if the connection to MySQL Server is closed.)r6 Ú connectedra rJ rJ rK Ú is_closed; s zCMySQLConnection.is_closedc C s | j r| ¡ | j ¡ S dS )z;Reports whether the connection to MySQL Server is availableF)r6 Úhandle_unread_resultÚpingra rJ rJ rK Ú is_connected? s
|
z CMySQLConnection.is_connectedFr
|
r )Ú reconnectÚattemptsÚdelayr1 c C sT | ¡ z| j ¡ }W n tk
|
r* Y n
|
X |r4dS |rH| j||d ntddS )aî Check availability of the MySQL server
|
|
When reconnect is set to True, one or more attempts are made to try
|
to reconnect to the MySQL server using the reconnect()-method.
|
|
delay is the number of seconds to wait between each retry.
|
|
When the connection is not available, an InterfaceError is raised. Use
|
the is_connected()-method if you just want to check the connection
|
without raising an error.
|
|
Raises InterfaceError on errors.
|
N)rª r« z$Connection to MySQL is not available)r¦ r6 r§ ÚAttributeErrorr© r )rG r© rª r« r¤ rJ rJ rK r§ G s zCMySQLConnection.ping)r] r1 c C s | j |¡ dS )z;Sets the default character set name for current connection.N)r6 Zset_character_set)rG r] rJ rJ rK Úset_character_set_named s z'CMySQLConnection.set_character_set_name)Úqueryr1 c
|
C s d}zH| j |¡ | j jr@| j ¡ }| j ¡ r@| j ¡ td| j ¡ W n8 tk
|
r } zt|j|j |j
|
d|W 5 d}~X Y nX |S )z%Send a query which only returns 1 rowrJ z'Query should not return more than 1 rowrm N) r6 r® Úhave_result_setÚ fetch_rowr¢ r r r rn ro rp )rG r® Z first_rowrr rJ rJ rK rk h s$
|
|
|
ÿþzCMySQLConnection.info_queryc C s& z | j ¡ W S tk
|
r Y nX dS )zMySQL connection IDN)r6 r` r ra rJ rJ rK Ú connection_idz s
|
z CMySQLConnection.connection_id)ÚcountÚbinaryÚcolumnsrw Ú prep_stmtr1 c
|
C s |r
|
|j n| j}| jr|s"td|dkr0| j}g }|dk rL|dkrLtdd}zà|r\|jn| jj} | jrv| j d¡ | }
|
|
|
rö| jsÎ| jrÎt |
|
}
|
t
|
|
|
D ](\} } |s| j | j | |
|
| ¡|
|
| < qt |
|
}
|
| |
|
¡ |d7 }|rî||krîqö| }
|
q||
|
s*| |¡d } |r | ¡ d| _n| ¡ nd} W n^ tk
|
r } z>|r`| ¡ tt||| ¡ t|j|j|jd |W 5 d}~X Y nX || fS )
|
z8Get all or a subset of rows returned by the MySQL serverzNo result set availableNr z$count should be 1 or higher, or NoneTr
|
ÚeofFrm )r¯ Ú unread_resultr6 r r r¬ r° rC rw ÚlistÚ enumerateZ to_pythonr7 ÚtupleÚappendÚfetch_eof_columnsr¢ Ú_unread_resultr r rN r rn ro rp )rG r² r³ r´ rw rµ r· ÚrowsÚcounterr° ÚrowÚiÚ_Ú_eofrr rJ rJ rK Úget_rows s`
|
|
ÿ
|
ÿþzCMySQLConnection.get_rows)r³ r´ rw rµ r1 c C sP z4| j d||||d\}}|r,|d |fW S d|fW S tk
|
rJ Y dS X dS )z.Get the next rows returned by the MySQL serverr
|
)r² r³ r´ rw rµ r N)NN)rÄ Ú
|
IndexError)rG r³ r´ rw rµ r¾ r¶ rJ rJ rK Úget_rowà s û
|
|
zCMySQLConnection.get_rowc C s | j r| j ¡ | j ¡ S dS )zReads the next resultN)r6 Úconsume_resultÚ next_resultra rJ rJ rK rÈ Ú s
|
|
z CMySQLConnection.next_resultc C s | j r| j ¡ dS )zFrees the resultN)r6 r¢ ra rJ rJ rK r¢ á s z CMySQLConnection.free_resultc C s | j r| ¡ | j ¡ dS )zCommit current transactionN)r6 r¦ Úcommitra rJ rJ rK rÉ æ s zCMySQLConnection.commitc C s | j r| j ¡ | j ¡ dS )z Rollback current transactionN)r6 rÇ Úrollbackra rJ rJ rK rÊ ì s
|
zCMySQLConnection.rollback)rs r1 c
|
C sN z| j |¡ W n8 tk
|
rH } zt|j|j|jd|W 5 d}~X Y nX dS )zChange the current databaserm Nrt )rG rs rr rJ rJ rK Ú cmd_init_dbò s ÿþz CMySQLConnection.cmd_init_db)rµ r1 c C s¨ |r
|
|j n| jj }|s td|r*| ¡ n| j ¡ }g | _|D ]N}| j |d t|d ddddt|d tj@ t|d t|d f ¡ q>| j | j
|
¡ d| jdS ) z Fetch EOF and column informationú No result seté é Né é )Z status_flagÚ warning_count)r¶ r´ ) r¯ r6 r Z fetch_fieldsr7 r» Úintr ZNOT_NULLrc Úst_warning_count)rG rµ r¯ ÚfieldsÚcolrJ rJ rK r¼ û s0 ÿ
|
|
|
÷ÿþûz"CMySQLConnection.fetch_eof_columnsc C s4 | j r0| j ¡ | j ¡ | j ¡ | j ¡ | jdS dS )z Fetch EOF and status information)rÑ Z field_countÚ insert_idÚ affected_rowsr^ N)r6 rÓ Zst_field_countrÖ r× rc ra rJ rJ rK Úfetch_eof_status s ûz!CMySQLConnection.fetch_eof_status)Ú statementr1 c
|
C s^ | j stdz| j |¡}| j|_|W S tk
|
rX } ztt||W 5 d}~X Y nX dS )zPrepares the SQL statementú MySQL Connection not availableN)r6 r Z stmt_preparer r r r rN )rG rÙ Zstmtrr rJ rJ rK Úcmd_stmt_prepare+ s z!CMySQLConnection.cmd_stmt_prepare)Ú statement_idÚargsr1 c
|
G sj z|j | W n0 tk
|
r> } ztt||W 5 d}~X Y nX g | _|jsZd| _| ¡ S d| _| |¡S )z Executes the prepared statementNFT) Z stmt_executer r rN r7 r¯ r½ rØ r¼ )rG rÜ rÝ rr rJ rJ rK Úcmd_stmt_execute7 s z!CMySQLConnection.cmd_stmt_execute)rÜ r1 c C s | j rtd| ¡ dS )z Closes the prepared statementúUnread result foundN)r½ r Z
|
stmt_close©rG rÜ rJ rJ rK Úcmd_stmt_closeI s z CMySQLConnection.cmd_stmt_closec C s | j rtd| ¡ dS )z Resets the prepared statementrß N)r½ r Z
|
stmt_resetrà rJ rJ rK Úcmd_stmt_resetO s z CMySQLConnection.cmd_stmt_reset)r® rw rv Ú raw_as_stringr1 c
|
C sî | ¡ |dkr| j}z0t|ts,| d¡}| jj||||| jd W n tk
|
r~ } zt |j
|
|j |j d|W 5 d}~X Y nR t k
|
rÎ } z4| jr| jn| j d| j }td|dfd|W 5 d}~X Y nX g | _| jjsæ| ¡ S | ¡ S ) z Send a query to the MySQL serverNzutf-8)rw rv rã Z query_attrs)rn rp ú:i zConnection not available.)ro Úvalues)r¦ r Ú
|
isinstanceÚbytesÚencoder6 r® Z _query_attrsr r ro rn rp r¬ r r r r r7 r¯ rØ r¼ )rG r® rw rv rã rr ÚaddrrJ rJ rK Ú cmd_queryU sD
|
|
û
|
ÿþ ÿ ÿþzCMySQLConnection.cmd_query)rv rw ÚpreparedÚ cursor_classÚ
|
dictionaryÚ named_tupler1 c s | |¡ | ¡ std|dk r<t|ts4td|| S |pD| j}|pN| j}d|dkrddO |dkrtdO |dkrdO |dkrd O |dkr¤d
|
O ttt t
|
t t t tttttd }z| | W S tk
|
r d td d fddtdD ¡ dY nX dS )aÅ Instantiates and returns a cursor using C Extension
|
|
By default, CMySQLCursor is returned. Depending on the options
|
while connecting, a buffered and/or raw cursor is instantiated
|
instead. Also depending upon the cursor options, rows can be
|
returned as dictionary or named tuple.
|
|
Dictionary and namedtuple based cursors are available with buffered
|
output but not raw.
|
|
It is possible to also give a custom cursor through the
|
cursor_class parameter, but it needs to be a subclass of
|
mysql.connector.cursor_cext.CMySQLCursor.
|
|
Raises ProgrammingError when cursor_class is not a subclass of
|
CursorBase. Raises ValueError when cursor is not available.
|
|
Returns instance of CMySQLCursor or subclass.
|
|
:param buffered: Return a buffering cursor
|
:param raw: Return a raw cursor
|
:param prepared: Return a cursor which uses prepared statements
|
:param cursor_class: Use a custom cursor class
|
:param dictionary: Rows are returned as dictionary
|
:param named_tuple: Rows are returned as named tuple
|
:return: Subclass of CMySQLCursor
|
:rtype: CMySQLCursor or subclass
|
ú MySQL Connection not available.Nz=Cursor class needs be to subclass of cursor_cext.CMySQLCursorr Tr
|
é rÍ rÎ é ) r r
|
rð rR rÍ é rÎ rÏ rñ é é é )rv rw rí rî rë z*Cursor not available with given criteria: z, c s$ g | ] }d |> @ dkr | qS )r
|
r rJ )rO rÁ ©rÝ Z cursor_typerJ rK rQ Ñ s z+CMySQLConnection.cursor.<locals>.<listcomp>rò )r¦ r¨ r Ú
|
issubclassr" r r r r# r- r& r' r$ r( r% r) r, r* r+ ÚKeyErrorÚ
|
ValueErrorr: Úrange)rG rv rw rë rì rí rî ÚtypesrJ rö rK Úcursor s\ %
|
|
ÿ
|
|
ô ÿÿýzCMySQLConnection.cursorc C s | j jstd| j ¡ S )z,Returns number of rows of current result setrÌ )r6 r¯ r Únum_rowsra rJ rJ rK rý Ô s zCMySQLConnection.num_rowsc C s | j s
|
dS | j ¡ S )zReturns number of warningsr )r6 rÑ ra rJ rJ rK rÑ Ü s z CMySQLConnection.warning_countc C s | j s
|
dS | j jS )z"Check if a result set is availableF)r6 r¯ ra rJ rJ rK Úresult_set_availableä s z%CMySQLConnection.result_set_availablec C s | j S )z)Check if there are unread results or rows)rþ ra rJ rJ rK r· ì s z CMySQLConnection.unread_resultc C s
|
| j ¡ S )z Check if there are more results)r6 Ú more_resultsra rJ rJ rK rÿ ñ s z CMySQLConnection.more_results)Úparamsr1 c sÎ g }t |ttfr: jr, fdd|D }qÊ jj| }nt |tr®i } jr| ¡ D ],\}} j j j
|
|¡ j ¡¡||< qVqÊ| ¡ D ] \}} j |¡d ||< qn t dt |j d| d|S )z¬Prepare parameters for statements
|
|
This method is use by cursors to prepared parameters found in the
|
list (or tuple) params.
|
|
Returns dict.
|
c s, g | ]$} j j j |¡ j¡¡qS rJ )rC ÚquoteÚescapeÚto_mysqlÚ _sql_mode)rO re ra rJ rK rQ s û
|
ÿÿz6CMySQLConnection.prepare_for_mysql.<locals>.<listcomp>r z Could not process parameters: ú(z)), it must be of type list, tuple or dict)ræ r¸ rº rC r6 Zconvert_to_mysqlÚdictÚitemsr r r r r ÚtypeÚ__name__)rG r Úresultr re rJ ra rK Úprepare_for_mysqlö s.
|
|
ú
|
|
ÿÿ ÿz"CMySQLConnection.prepare_for_mysqlc C s | j ¡ dS )zlConsume the current result
|
|
This method consume the result by reading (consuming) all rows.
|
N)r6 rÇ ra rJ rJ rK Úconsume_results! s z CMySQLConnection.consume_resultsÚ é- )
|
Úusernamer{ rs r] r| r} r~ r r r1 c
|
|
C sj z | j |||||||| ¡ W n8 tk
|
rV }
|
zt|
|
j|
|
j|
|
jd|
|
W 5 d}
|
~
|
X Y nX || _| ¡ dS )z!Change the current logged in userrm N) r6 Z change_userr r rn ro rp r Ú_post_connection) rG r r{ rs r] r| r} r~ r r rr rJ rJ rK Úcmd_change_user( s* ø ÿþz CMySQLConnection.cmd_change_userc C s | j ¡ }|r| ¡ |S )zÖResets the session state without re-authenticating
|
|
Reset command only works on MySQL server 5.7.3 or later.
|
The result is True for a successful reset otherwise False.
|
|
Returns bool
|
)r6 Zreset_connectionr )rG ÚresrJ rJ rK Úcmd_reset_connectionI s
|
z%CMySQLConnection.cmd_reset_connection)Úoptionsr1 c
|
C sZ z| ¡ | j |¡ W n8 tk
|
rP } zt|j|j|jd|W 5 d}~X Y nX | ¡ S )z,Send the Refresh command to the MySQL serverrm N) r¦ r6 Zrefreshr r rn ro rp rØ )rG r rr rJ rJ rK Ú cmd_refreshV s ÿþz CMySQLConnection.cmd_refreshc C s | ¡ dS )z,Close the current connection with the serverN)r£ ra rJ rJ rK Úcmd_quitb s zCMySQLConnection.cmd_quit)Ú shutdown_typer1 c
|
C s | j std|r*t |¡s$td|}ntj}z| j |¡ W n8 tk
|
rx } zt|j |j
|
|j d|W 5 d}~X Y nX | ¡ dS )zShut down the MySQL ServerrÚ zInvalid shutdown typerm N) r6 r r r r ZSHUTDOWN_DEFAULTÚshutdownr r rn ro rp r£ )rG r Úlevelrr rJ rJ rK Ú cmd_shutdownf s$
|
ÿþz CMySQLConnection.cmd_shutdownc
|
C sf | ¡ z | j ¡ }t j|ddW S ttfk
|
r` } zt|j|j |j
|
d|W 5 d}~X Y nX dS )z'Return statistics from the MySQL serverF)Z with_headerrm N) r¦ r6 Ústatr Zparse_statisticsr r r rn ro rp )rG r rr rJ rJ rK Úcmd_statisticsz s
|
ÿþz CMySQLConnection.cmd_statistics)Ú mysql_pidr1 c C s& t |tstd| d| ¡ dS )zKill a MySQL processzMySQL PID must be intzKILL N)ræ rÒ rù rk )rG r rJ rJ rK Úcmd_process_kill s
|
z!CMySQLConnection.cmd_process_killc C s t dS )zSend the DEBUG commandN©ÚNotImplementedErrorra rJ rJ rK Ú cmd_debug s zCMySQLConnection.cmd_debugc C s t dS )zSend the PING commandNr ra rJ rJ rK Úcmd_ping s zCMySQLConnection.cmd_ping)Ú
|
statementsr1 c C s t dS )z/Send one or more statements to the MySQL serverNr )rG r# rJ rJ rK Úcmd_query_iter s z CMySQLConnection.cmd_query_iter)rÜ Úparam_idÚdatar1 c C s t dS )zSend data for a columnNr )rG rÜ r% r& rJ rJ rK Úcmd_stmt_send_long_data s z(CMySQLConnection.cmd_stmt_send_long_data)rë r1 c C s4 |dkr| j n| j}| jr$| ¡ n |r0tddS )z'Check whether there is an unread resultTrß N)r½ r· Zcan_consume_resultsr r )rG rë r· rJ rJ rK r¦ s
|
|
z%CMySQLConnection.handle_unread_result)Úuser_variablesÚsession_variablesr1 c C sÚ | ¡ std| ¡ sfz0| | j| j| j| j| j| j | j
|
| j | j ¡ W n t k
|
rd | ¡ Y nX |sn|rÖ| ¡ }|r¢| ¡ D ] \}}| d| d|f¡ q|rÎ| ¡ D ] \}}| d| d|f¡ q®| ¡ dS )aÇ Clears the current active session
|
|
This method resets the session state, if the MySQL server is 5.7.3
|
or later active session will be reset without re-authenticating.
|
For other server versions session will be reset by re-authenticating.
|
|
It is possible to provide a sequence of variables and their values to
|
be set after clearing the session. This is possible for both user
|
defined variables and session variables.
|
This method takes two arguments user_variables and session_variables
|
which are dictionaries.
|
|
Raises OperationalError if not connected, InternalError if there are
|
unread results and InterfaceError on errors.
|
rï zSET @`z` = %sz SET SESSION `N)r¨ r r r r r r r r r r r r r r© rü r Úexecuter£ )rG r( r) Úcurr re rJ rJ rK Ú reset_session¦ s4 ÷ z CMySQLConnection.reset_session)T)Fr
|
r )NFNNN)FNNN)N)NFF)NNNNNN) r r r r r r r NN)N)F)NN)Rr Ú
|
__module__Ú __qualname__Ú__doc__r rE rZ rb ÚpropertyrÒ rc rN rd Úboolrh rl Úsetterrs ru r¡ r£ Z
|
disconnectr¥ r¨ r§ r r r r rk r± r r r! r r rÄ rÆ rÈ r¢ rÉ rÊ rË r r¼ rØ rç rÛ r rÞ rá râ rê Z_execute_queryr 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, Ú __classcell__rJ rJ rH rK r/ Z s2
|
R ú
|
ù A û
|
ú
|
ÿþ # þ ûú ( ù
|
ø Uþ + öõ ! þ
|
ýür/ )=r/ r8 r@ rX Útypingr r r r r r r r r r Z abstractsr Ú constantsr r r r r Ú
|
conversionr Úerrorsr r r r r r[ r rû r r r r r r r r4 r= r r! Z cursor_cextr" r# r$ r% r& r' r( r) r* r+ r, r- Ú ImportErrorÚexcr/ rJ rJ rJ rK Ú<module> s0 ( $
|
8
|
ÿþ
|
