o g @sdZddlZddlZddlZddlZddlZddlmZmZm Z m Z m Z m Z m Z mZmZmZddlmZddlmZddlmZmZddlmZmZmZmZmZmZdd lm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&dd l'm(Z(dd l)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0dd l1m2Z2m3Z3m4Z4dZ5z*ddl6Z6ddl6m7Z7ddl8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBmCZCmDZDdZ5WneEyZFz eEdeFdeFdZF[FwwddlGmHZHddlImJZJeHrddlKmLZLmMZMGdddeZNdS)z'Connection class using the C Extension.N) AnyBinaryIODictListNoReturnOptionalSequenceTupleTypeUnion)version)cmd_refresh_verify_options)CMySQLPrepStmtMySQLConnectionAbstract) ClientFlag FieldFlag FieldType ServerFlag ShutdownType-raise_warning_against_deprecated_cursor_class)MySQLConverter)InterfaceError InternalErrorOperationalErrorProgrammingErrorget_mysql_exception) MySQLProtocol)CextEofPacketTypeCextResultTypeDescriptionTypeParamsSequenceOrDictTypeRowTypeStatsPacketType StrOrBytes) import_objectwarn_ciphersuites_deprecatedwarn_tls_version_deprecatedF)MySQLInterfaceError) CMySQLCursorCMySQLCursorBufferedCMySQLCursorBufferedDictCMySQLCursorBufferedNamedTupleCMySQLCursorBufferedRawCMySQLCursorDictCMySQLCursorNamedTupleCMySQLCursorPreparedCMySQLCursorPreparedDictCMySQLCursorPreparedNamedTupleCMySQLCursorPreparedRawCMySQLCursorRawTz2MySQL Connector/Python C Extension not available ()) OTEL_ENABLED)with_context_propagation)end_spanrecord_exception_eventcseZdZdZdeddffdd ZdddZdd d Zede fd d Z d e ddfddZ dde ddfddZede fddZejde ddfddZedee fddZejde ddfddZedee fddZejde ddfddZede fddZejde ddfd dZede fd!d"Zdd#d$Zdd%d&ZeZde fd'd(Zde fd)d*Zdd.e d/e d0e ddfd1d2Zd3e ddfd4d5Zd6edeefd7d8Zedee fd9d:Z  +   dd;ee dee d?ee#dede$e!eee%ffd@dAZ& +   ddee d?ee#dede$eeee%ff dBdCZ'dee fdDdEZ(ddFdGZ)ddHdIZ*ddJdKZ+dLe ddfdMdNZ, dd?ee#de-fdOdPZ.dee%fdQdRZ/dSe0dede#fdTdUZ1e2dVe#dWededee3e%e-ffdXdYZ4dVe#deddfdZd[Z5dVe#deddfd\d]Z6e2  + +dd6ed>ee d^e d_e dedee3e%e-ff d`daZ7e7Z8        dd^ee d>ee dbee dcee9e:ddee deee dfee dgee de:fdhdiZ;ede fdjdkZede fdpdqZ?ede fdrdsZ@dteAde3eBe0eCe0e0fffdudvZDddwdxZE y y y  y y y   ddze d{e dLe d3ee d|e d}e d~e dee dee dee ddfddZFde fddZGeHde dee%fddZIdddZJddee ddfddZKdeLfddZMde ddfddZNdeOfddZPdeOfddZQde dedeOfddZRdVe#de deSdedeOf ddZTddbe ddfddZU  ddeeCe efdeeCe efddfddZVZWS)CMySQLConnectionz6Class initiating a MySQL Connection using Connector/C.kwargsreturnNc ststdd|_g|_tjtjtjt j ddd|_ t dkr7tj|j s7tjdr4dnd|_ d|_t|rYz |jd i|WdStyX|wdS) Initializationz0MySQL Connector/Python C Extension not availableNmysqlvendorpluginLinuxz/usr/lib64/mysql/pluginz/usr/lib/mysql/plugin) HAVE_CMYSQL RuntimeError_cmysql_columnsospathjoindirnameabspath_mysql_connector__file__ _plugin_dirplatformsystemexists convertersuper__init__connect Exceptionclose)selfr; __class__rBY/var/www/html/api-tag/env/lib/python3.10/site-packages/mysql/connector/connection_cext.pyrT}s6    zCMySQLConnection.__init__c CsZtjd}|ddkrd}nd}|jd|ddd tjdd Dtd d S) z!Add default connection attributes rGPLv2zGPL-2.0 Commercialzmysql-connector-python.cSsg|]}t|qSrB)str).0xrBrBr[ sz.)_connector_name_connector_license_connector_version _source_hostN) r LICENSEsplit _conn_attrsupdaterIVERSIONsocket gethostname)rXlicense_chunksclient_licenserBrBr[_add_default_conn_attrss  z(CMySQLConnection._add_default_conn_attrsc CsT|j|j|jdddd|jd|_||jd|_|j |jdS)z|t?||q]dSdSdSdS)*Nr)bufferedraw charset_nameconnection_timeoutrrx plugin_dirhostuserpassword password1 password2 password3rport client_flags unix_socketcompress ssl_disabledT conn_attrs local_infileload_data_local_diroci_config_fileoci_config_profile)webauthn_callbackopenid_token_filerr tls_versions)reverse,tls_ciphersuitesr zTLSv1.3TLS_AES_256_GCM_SHA384cacertkey verify_certFverify_identity) ssl_cassl_certssl_keyssl_cipher_suitesrtls_cipher_suitesssl_verify_certssl_verify_identityrntMySQLKerberosAuthPluginuse_kerberos_gssapirget_ssl_cipherrB)@rget_info _charset_idrLMySQL _buffered_raw_connection_timeoutr _auth_pluginrNrEisset_client_flagr CONNECT_ARGSrk_host_user _password _password1 _password2 _password3 _database_port _client_flags _unix_socket _compress_allow_local_infile_allow_local_infile_in_path_oci_config_file_oci_config_profile isinstance_webauthn_callbackr`r%_openid_token_filerr_sslgetsortrI _ssl_disabledrlrGname_auth_plugin_classrU_converter_str_fallbackconverter_str_fallbackrR str_fallbackr(rrrrrhasattrcallablersetr'r&) rXr cnx_kwargsrssl_ciphersuitesrrcipher tls_versionrBrBr[_open_connections                       z!CMySQLConnection._open_connectionc Cs|jr|jrt|jtd|jsdSz7z ||jWntyB}zt r3t|j|t |j |j |j d|d}~wwWt rMt|jdSdSt rWt|jww)z Disconnect from the MySQL serverr Nr)_span is_recordingr9sysexc_inforE free_resultrWr(r6rrrrr8)rXrrBrBr[rWs.   zCMySQLConnection.closecCs |j S)z8Return True if the connection to MySQL Server is closed.)rE connectedrrBrBr[ is_closed zCMySQLConnection.is_closedcCs|jr ||jSdS)z;Reports whether the connection to MySQL Server is availableF)rEhandle_unread_resultpingrrBrBr[ is_connecteds zCMySQLConnection.is_connectedFr r reconnectattemptsdelaycCsP|z|j}Wn tyYnw|rdS|r$|j||ddStd)aCheck 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)rrz$Connection to MySQL is not available)rrErAttributeErrorrr)rXrrrr rBrBr[rs zCMySQLConnection.pingrvcCs|j|dS)z;Sets the default character set name for current connection.N)rEset_character_set)rXrvrBrBr[set_character_set_namesz'CMySQLConnection.set_character_set_namequeryc Cs~d}z%|j||jjr |j}|jr |jtd|jW|Sty>}z t|j|j |j d|d}~ww)z%Send a query which only returns 1 rowrBz'Query should not return more than 1 rowrN) rErhave_result_set fetch_rowr rr(rrrr)rXr first_rowrrBrBr[rs$      zCMySQLConnection.info_querycCs"z|jWStyYdSw)zMySQL connection IDN)rEr}r(rrBrBr[ connection_ids   zCMySQLConnection.connection_idcountbinarycolumnsr prep_stmtc Ks|r|jn|j}|jr |std|dur|j}g}|dur&|dkr&tdd} z|r.|jn|jj} |js7|r=|jd| } | rt | } |jsg|sgt |j D]\} } | dt j krft| | | | <qR|js|jrt | D]\} }|s|j|j | | | | | <qq|t| | d7} |r| |krn| } | sB| s||d}|r|d|_n|nd}W||fSW||fSW||fSty}z|r|tt|||t|j|j|jd |d}~ww) z8Get all or a subset of rows returned by the MySQL serverzNo result set availableNrz$count should be 1 or higher, or NoneTr eofFr)r unread_resultrErrrrrRrlist enumeraterFrVECTORr_vector_to_python to_pythonappendtuplefetch_eof_columnsr _unread_resultr(rr`rrrr)rXrrrrrr;r!rowscounterrrowidsc__eofrrBrBr[get_rowsst          zCMySQLConnection.get_rowscKsJz|jd||||d\}}|r|d|fWSd|fWSty$YdSw)z.Get the next rows returned by the MySQL serverr )rrrrrrNNN)r2 IndexError)rXrrrrr;r+r rBrBr[get_row9s    zCMySQLConnection.get_rowcCs|jr |j|jSdS)zReads the next resultN)rEconsume_result next_resultrrBrBr[r7Qs  zCMySQLConnection.next_resultcCs|jr |jdSdS)zFrees the resultN)rEr rrBrBr[r XszCMySQLConnection.free_resultcCs |jr||jdSdS)zCommit current transactionN)rErcommitrrBrBr[r8]szCMySQLConnection.commitcCs"|jr|j|jdSdS)zRollback current transactionN)rEr6rollbackrrBrBr[r9cs zCMySQLConnection.rollbackrc Cr)zChange the current databaserNr)rXrrrBrBr[ cmd_init_dbis zCMySQLConnection.cmd_init_dbcCs|r|jn|jj}|std|r|n|j}g|_|D]'}|j|dt|dddddt|dtj@t|dt|df q|j |j d|jdS) z Fetch EOF and column information No result setN ) status_flag warning_count)r r) rrEr fetch_fieldsrFr'intrNOT_NULLrst_warning_count)rXrrfieldscolrBrBr[r)rs0   z"CMySQLConnection.fetch_eof_columnscCs4|jr|j|j|j|j|jdSdS)z Fetch EOF and status information)rA field_count insert_id affected_rowsrwN)rErEst_field_countrIrJrrrBrBr[fetch_eof_statussz!CMySQLConnection.fetch_eof_status statementc KsT|jstdz|j|}|j|_t|WSty)}ztt||d}~ww)zPrepares the SQL statementMySQL Connection not availableN) rEr stmt_preparerrrr(rr`)rXrMr;stmtrrBrBr[cmd_stmt_prepares  z!CMySQLConnection.cmd_stmt_prepare statement_idargsc Oshz |j|d|jiWnty}ztt||d}~wwg|_|js,d|_|Sd|_| |S)zExecutes the prepared statement query_attrsNFT) stmt_executerTr(rr`rFrr*rLr))rXrRrSr;rrBrBr[cmd_stmt_executes z!CMySQLConnection.cmd_stmt_executec KsL|jrtdz|WdSty%}z t|j|j|jd|d}~ww)zCloses the prepared statementUnread result foundrrN)r*r stmt_closer(rrrrrXrRr;rrBrBr[cmd_stmt_closes zCMySQLConnection.cmd_stmt_closec KsD|jrtdz|WdSty!}ztt||d}~ww)zResets the prepared statementrWN)r*r stmt_resetr(rr`rZrBrBr[cmd_stmt_resetszCMySQLConnection.cmd_stmt_resetr raw_as_stringc Ks||dur |j}zt|ts|d}|jj|||||jdWn:ty:}z t |j |j |j d|d}~wt y]}z|jrG|jn|jd|j}td|dfd|d}~wwg|_|jjsi|S|S)Nzutf-8)rrr^rTrX:izConnection not available.)rvalues)rrrbytesencoderErrTr(rrrrrrrrrrFrrLr))rXrrrr^r;raddrrBrBr[ cmd_querysD     zCMySQLConnection.cmd_queryprepared cursor_class dictionary named_tuplerrc s2|||s td|s|rtjdtd|dur)t|ts%td||S|p-|j }|p2|j }d|dur=dO|durEd O|durMd O|durUd O|dur]d Ott t t ttttttttd } zt| jd| |WStydtddfddtdDdw)aInstantiates 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 CMySQLCursor. 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.zsThe use of read_timeout after the connection has been established is unsupported in the C-Extension)categoryNz=Cursor class needs be to subclass of cursor_cext.CMySQLCursorrTr r<r=) rr rkrdr<r=r>rl) cursor_name)rrrgrhrez*Cursor not available with given criteria: z, cs$g|]}d|>@dkr|qS)r rrB)rar.rS cursor_typerBr[rcls$z+CMySQLConnection.cursor..rm)rrrwarningswarnWarning issubclassr)rrrr*r4r-r.r+r/r,r0r3r1r2r__name__KeyError ValueErrorrIrange) rXrrrerfrgrhrrtypesrBrrr[cursorsn '    zCMySQLConnection.cursorcCs|jjstd|jS)z,Returns number of rows of current result setr;)rErrnum_rowsrrBrBr[r~os zCMySQLConnection.num_rowscCs|jsdS|jS)zReturns number of warningsr)rErArrBrBr[rAws zCMySQLConnection.warning_countcCs|jsdS|jjS)z"Check if a result set is availableF)rErrrBrBr[result_set_availablesz%CMySQLConnection.result_set_availablecCr)z)Check if there are unread results or rows)rrrBrBr[r!szCMySQLConnection.unread_resultcCr)zCheck if there are more results)rE more_resultsrrBrBr[rrzCMySQLConnection.more_resultsparamscsg}t|ttfrjrfdd|D}|Sjj|}|St|tr_i}jrH|D]\}}jj j |j || <q-|S|D]\}}j|d|| <qL|St dt|jd|d)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|jqSrB)rRquoteescapeto_mysql _sql_mode)rarrrBr[rcsz6CMySQLConnection.prepare_for_mysql..rzCould not process parameters: (z)), it must be of type list, tuple or dict)rr"r(rRrEconvert_to_mysqldictitemsrrrrrbrtyperx)rXrresultrrrBrr[prepare_for_mysqls2    z"CMySQLConnection.prepare_for_mysqlcCs|jdS)zlConsume the current result This method consume the result by reading (consuming) all rows. N)rEr6rrBrBr[consume_resultssz CMySQLConnection.consume_resultsusernamerrrrrrrc Csz|j|||||||| | Wnty'} z t| j| j| jd| d} ~ ww|dur@t|ts5t d|dkr=t d||_ ||_ | dS)z!Change the current logged in userrNzcharset must be an integerrz2charset should be either zero or a postive integer) rE change_userr(rrrrrrCrzrr_post_connection) rXrrrrvrrrrrrrrBrBr[cmd_change_users8    z CMySQLConnection.cmd_change_usercCs|j}|r ||S)zResets 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 )rEreset_connectionr)rXresrBrBr[cmd_reset_connections z%CMySQLConnection.cmd_reset_connectionoptionsc CsNz||j|W|Sty&}z t|j|j|jd|d}~ww)Nr) rrErefreshr(rrrrrL)rXrrrBrBr[ cmd_refreshs zCMySQLConnection.cmd_refreshcCs |dS)z,Close the current connection with the serverN)rWrrBrBr[cmd_quitr zCMySQLConnection.cmd_quit shutdown_typec Cs||jstd|rt|std|}ntj}z|j|Wnty7}z t|j |j |j d|d}~ww| dS)zShut down the MySQL Server This method sends the SHUTDOWN command to the MySQL server. The `shutdown_type` is not used, and it's kept for backward compatibility. rNzInvalid shutdown typerN) rErrrrSHUTDOWN_DEFAULTshutdownr(rrrrrW)rXrlevelrrBrBr[ cmd_shutdown s$   zCMySQLConnection.cmd_shutdownc CsX|z|j}tj|ddWSttfy+}z t|j|j |j d|d}~ww)z'Return statistics from the MySQL serverF) with_headerrN) rrEstatrparse_statisticsr(rrrrr)rXrrrBrBr[cmd_statistics#s  zCMySQLConnection.cmd_statistics mysql_pidcCs&t|ts td|d|dS)zKill a MySQL processzMySQL PID must be intzKILL N)rrCrzrd)rXrrBrBr[cmd_process_kill/s z!CMySQLConnection.cmd_process_killcCt)zSend the DEBUG commandNotImplementedErrorrrBrBr[ cmd_debug5zCMySQLConnection.cmd_debugcCr)zSend the PING commandrrrBrBr[cmd_ping9rzCMySQLConnection.cmd_ping statementscKr)z/Send one or more statements to the MySQL serverr)rXrr;rBrBr[cmd_query_iter=rzCMySQLConnection.cmd_query_iterparam_iddatacKr)zSend data for a columnr)rXrRrrr;rBrBr[cmd_stmt_send_long_dataAsz(CMySQLConnection.cmd_stmt_send_long_datacCs6|dur|jn|j}|jr|dS|rtddS)z'Check whether there is an unread resultTrWN)r*r!can_consume_resultsrr)rXrer!rBrBr[rKs  z%CMySQLConnection.handle_unread_resultuser_variablessession_variablesc Cs|std|s2z||j|j|j|j|j|j |j |j |j Wn t y1|Ynw|s6|rl|}|rP|D]\}}|d|d|fq@|rf|D]\}}|d|d|fqV|dSdS)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. rizSET @`z` = %sz SET SESSION `N)rrrrrrrrrrrrrrrr}rexecuterW)rXrrcurrrrBrBr[ reset_sessionSs8  zCMySQLConnection.reset_session)r<N)T)Fr r)NFNNN)FNNNr)NFF)NNNNNNNN) rrrNrrrNNN)Fr3)Xrx __module__ __qualname____doc__rrTrrrpropertyrCrr`rrrrsetterrrrrrrrW disconnectr rrrr$r"rrrr rr rr2r5r7r r8r9r:rr)rLrarQr7r rVr[r]rd_execute_queryr r)r}r~rArr!rr!rrrrrrrrrrr#rrrrrrrrrr __classcell__rBrBrYr[r:zs !       l   T       #       (   ` +     +      r:)OrrGrOrnrrttypingrrrrrrrr r r rr _decoratingr abstractsrr constantsrrrrrr conversionrerrorsrrrrrrsrr|rrr r!r"r#r$utilsr%r&r'rCrLr( cursor_cextr)r*r+r,r-r.r/r0r1r2r3r4 ImportErrorexcopentelemetry.constantsr6!opentelemetry.context_propagationr7opentelemetry.instrumentationr8r9r:rBrBrBr[sF0    $  8