a cfx @sdZddlZddlZddlZddlmZmZddlmZm Z m Z m Z m Z ddl mZmZddlmZdZzDddlZdd lmZmZmZmZmZmZmZmZmZdd lmZWn6eyZ zed !e"e WYdZ [ ndZ [ 00d ZGd ddeZ#dS)z'Connection class using the C Extension N)errorsversion) CharacterSet FieldFlag ServerFlag ShutdownType ClientFlag)MySQLConnectionAbstractMySQLCursorAbstract) MySQLProtocolF) CMySQLCursorCMySQLCursorRawCMySQLCursorBufferedCMySQLCursorBufferedRawCMySQLCursorPreparedCMySQLCursorDictCMySQLCursorBufferedDictCMySQLCursorNamedTupleCMySQLCursorBufferedNamedTuple)MySQLInterfaceErrorz6MySQL Connector/Python C Extension not available ({0})TcseZdZdZfddZddZddZedd Zd d Z dkd dZ eddZ e j ddZ eddZ e j ddZ eddZddZddZeZddZddZdld"d#Zd$d%Zd&d'Zed(d)Zdmd+d,Zdnd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zdod9d:Zd;d<Z d=d>Z!d?d@Z"dAdBZ#dCdDZ$dpdEdFZ%e%Z&dqdGdHZ'edIdJZ(edKdLZ)edMdNZ*edOdPZ+edQdRZ,dSdTZ-dUdVZ.drdYdZZ/d[d\Z0d]d^Z1d_d`Z2dsdadbZ3dcddZ4dedfZ5dtdgdhZ6dudidjZ7Z8S)vCMySQLConnectionz5Class initiating a MySQL Connection using Connector/Cc srts tdd|_g|_tjtjtjt j ddd|_ d|_ t t|jfi||rn|jfi|dS)ZInitializationz0MySQL Connector/Python C Extension not availableNmysqlvendorplugin) HAVE_CMYSQL RuntimeError_cmysql_columnsospathjoindirnameabspath_mysql_connector__file__ _plugin_dir convertersuperr__init__connect)selfkwargs __class__\/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/mysql/connector/connection_cext.pyr)FszCMySQLConnection.__init__c CsZtjd}|ddkrd}nd}|jd|ddd tjdd Dtd d S) z!Add default connection attributes rZGPLv2zGPL-2.0Z Commercialzmysql-connector-python.cSsg|] }t|qSr/)str).0xr/r/r0 cz.)Z_connector_nameZ_connector_licenseZ_connector_versionZ _source_hostN) rLICENSEsplit _conn_attrsupdater!VERSIONsocket gethostname)r+Zlicense_chunksZclient_licenser/r/r0_add_default_conn_attrsWs  z(CMySQLConnection._add_default_conn_attrsc CsF|j|j|jdddd|jd|_||jd|_dS)z@dkr|qS)rrr/)r4rrZ cursor_typer/r0r6isz+CMySQLConnection.cursor..r)rrrr issubclassr ProgrammingErrorrtrur rrrrrrrrKeyError ValueErrorr!range)r+r]r^rZ cursor_classrrtypesr/rr0cursor"sN      zCMySQLConnection.cursorcCs|jjstd|jS)z,Returns number of rows of current result setr)rrrrnum_rowsrHr/r/r0rls zCMySQLConnection.num_rowscCs|js dS|jS)zReturns number of warningsr)rrrHr/r/r0rtszCMySQLConnection.warning_countcCs|js dS|jjS)z"Check if a result set is availableF)rrrHr/r/r0result_set_available|sz%CMySQLConnection.result_set_availablecCs|jS)z)Check if there are unread results or rows)rrHr/r/r0rszCMySQLConnection.unread_resultcCs |jS)zCheck if there are more results)r more_resultsrHr/r/r0rszCMySQLConnection.more_resultscst|ttfr6jr(fdd|D}qĈjj|}nt|tri}jr~|D](\}}jj j |||<qRq|D]\}}j|d||<qnt dt |jd|d|S)zPrepare parameters for statements This method is use by cursors to prepared parameters found in the list (or tuple) params. Returns dict. c s(g|] }jjj|qSr/)r'quoteescapeto_mysql)r4rPrHr/r0r6s  z6CMySQLConnection.prepare_for_mysql..rzCould not process parameters: (z)), it must be of type list, tuple or dict)rrrr'rZconvert_to_mysqldictitemsrrrrrtype__name__)r+paramsresultrprPr/rHr0prepare_for_mysqls*    z"CMySQLConnection.prepare_for_mysqlcCs|jdS)zlConsume the current result This method consume the result by reading (consuming) all rows. N)rrrHr/r/r0consume_resultssz CMySQLConnection.consume_results-c Csjz|j|||||||Wn:tyV} z"tj| j| j| jdWYd} ~ n d} ~ 00||_| dS)z!Change the current logged in userrTN) rZ change_userrrrXrUrVrWrr_post_connection) r+usernamerbrZrCrcrdrerirYr/r/r0cmd_change_users   z CMySQLConnection.cmd_change_userc Csj|jdkrtdz|jWn:ty\}z"tj|j|j|j dWYd}~n d}~00| dS)zpResets the session state without re-authenticating Works only for MySQL server 5.7.3 or later. rr8zFMySQL version 5.7.2 and earlier does not support COM_RESET_CONNECTION.rTN) rGrNotSupportedErrorrZreset_connectionrrXrUrVrWrrr/r/r0cmd_reset_connections   z%CMySQLConnection.cmd_reset_connectionc CsTz|j|Wn:tyJ}z"tj|j|j|jdWYd}~n d}~00|S)z,Send the Refresh command to the MySQL serverrTN) rrefreshrrrXrUrVrWr)r+optionsrYr/r/r0 cmd_refreshs zCMySQLConnection.cmd_refreshcCs |dS)z,Close the current connection with the serverN)rrHr/r/r0cmd_quitszCMySQLConnection.cmd_quitc Cs|jstd|r.t|s(td|}ntj}z|j|Wn:ty~}z"tj |j |j |j dWYd}~n d}~00| dS)zShut down the MySQL ServerrzInvalid shutdown typerTN)rrrrrqrZSHUTDOWN_DEFAULTshutdownrrXrUrVrWr)r+Z shutdown_typelevelrYr/r/r0 cmd_shutdowns    zCMySQLConnection.cmd_shutdownc Csj|z|j}tj|ddWSttjfyd}z"tj|j |j |j dWYd}~n d}~00dS)z'Return statistics from the MySQL serverF)Z with_headerrTN) rrstatr Zparse_statisticsrrrrXrUrVrW)r+rrYr/r/r0cmd_statisticss  zCMySQLConnection.cmd_statisticscCs&t|tstd|d|dS)zKill a MySQL processzMySQL PID must be intzKILL {0}N)rrrrRformat)r+Z mysql_pidr/r/r0cmd_process_kill s z!CMySQLConnection.cmd_process_killcCs6|dur|jn|j}|jr$|n|r2tddS)z'Check whether there is an unread resultTrN)rrZcan_consume_resultsrrr)r+rrr/r/r0rs z%CMySQLConnection.handle_unread_resultc Cs|stdz |Wnhtjtfy|jrDtdn>|jdkrZtdn(||j |j |j |j |j |j|j|jYn0|s|r|}|r|D]\}}|d||fq|r|D]\}}|d||fq|dS)aClears 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. rzZReset session is not supported with compression for MySQL server version 5.7.2 or earlier.rzJReset session is not supported with MySQL server version 5.7.2 or earlier.zSET @`{0}` = %szSET SESSION `{0}` = %sN)rrrrrNotImplementedErrorZ _compressrGrrwrxr|rrryrzr{rrrexecuterr)r+Zuser_variablesZsession_variablescurrprPr/r/r0 reset_sessions6     zCMySQLConnection.reset_session)T)Frr)NFNNN)FNNN)N)NFF)NNNNNN)rrrrrrrN)N)F)NN)9r __module__ __qualname____doc__r)r@rIpropertyrJrKrNrSsetterrZr\rrZ disconnectrrrrrRrrrrrrrrrrrrrrrZ_execute_queryrrrrrrrrrrrrrrrrr  __classcell__r/r/r-r0rBs        E    <      J     &     r)$r rr> sysconfigrrr constantsrrrrr Z abstractsr r rAr rr$Z cursor_cextr rrrrrrrrr ImportErrorrYrr3rr/r/r/r0s( ,