o G)fЌ @sdZddlZddlZddlZddlZddlmZmZmZm Z m Z m Z m Z m Z mZmZddlmZddlmZmZddlmZmZmZmZddlmZdd lmZmZmZm Z m!Z!dd l"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+dd l,m-Z-d Z.z*ddl/Z/ddl/m0Z0ddl1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;myZ?z e>de?de?dZ?[?wwddl@mAZAddlBmCZCeArddlDmEZEmFZFGdddeZGdS)z'Connection class using the C Extension.N) AnyBinaryIODictListNoReturnOptionalSequenceTupleTypeUnion)version)CMySQLPrepStmtMySQLConnectionAbstract) ClientFlag FieldFlag ServerFlag ShutdownType)MySQLConverter)InterfaceError InternalErrorOperationalErrorProgrammingErrorget_mysql_exception) MySQLProtocol)CextEofPacketTypeCextResultTypeDescriptionTypeParamsSequenceOrDictTypeRowTypeStatsPacketType StrOrBytes) import_objectF)MySQLInterfaceError) CMySQLCursorCMySQLCursorBufferedCMySQLCursorBufferedDictCMySQLCursorBufferedNamedTupleCMySQLCursorBufferedRawCMySQLCursorDictCMySQLCursorNamedTupleCMySQLCursorPreparedCMySQLCursorPreparedDictCMySQLCursorPreparedNamedTupleCMySQLCursorPreparedRawCMySQLCursorRawTz2MySQL Connector/Python C Extension not available ()) OTEL_ENABLED)with_context_propagation)end_spanrecord_exception_eventcs*eZdZdZdeddffdd ZdddZdd d Zede fd d Z d e ddfddZ dde ddfddZede fddZejde ddfddZede fddZejde ddfddZede fddZdddZdddZeZde fd d!Zde fd"d#Zdd'e d(e d)e ddfd*d+Zd,e ddfd-d.Zd/edeefd0d1Zedee fd2d3Z  $   dd4ee d5e d6eee d7ee d8ee!de"eeee#ff d9d:Z$ $   dd5e d6eee d7ee d8ee!de"eeee#ff d;d<Z%dee fd=d>Z&dd?d@Z'ddAdBZ(ddCdDZ)dEe ddfdFdGZ* dd8ee!de+fdHdIZ,dee#fdJdKZ-dLe.de!fdMdNZ/e0dOe!dPedee1e#e+ffdQdRZ2dOe!ddfdSdTZ3dOe!ddfdUdVZ4e0  $ $dd/ed7ee dWe dXe dee1e#e+ff dYdZZ5e5Z6      ddWee d7ee d[ee d\ee7e8d]ee d^ee de8fd_d`Z9ede fdadbZ:ede fdcddZ;ede fdedfZdke?de1e@e.eAe e.fffdldmZBddndoZC p p p q p p p  ddre dse dEe d,e dte due dve dwee dxee ddfdydzZDde fd{d|ZEd}e dee#fd~dZFdddZGddee ddfddZHdeIfddZJde ddfddZKdeLfddZMdeLfddZNde deLfddZOdOe!de dePdeLfddZQdd[e ddfddZR  ddeeAe efdeeAe efddfddZSZTS)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)selfr6 __class__r=\/var/www/html/flask-app/venv/lib/python3.12/site-packages/mysql/connector/connection_cext.pyrOps6    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|qSr=)str).0xr=r=rV sz.)_connector_name_connector_license_connector_version _source_hostN) r LICENSEsplit _conn_attrsupdaterDVERSIONsocket gethostname)rSlicense_chunksclient_licenser=r=rV_add_default_conn_attrss  z(CMySQLConnection._add_default_conn_attrsc CsT|j|j|jdddd|jd|_||jd|_|j |jdS)z}z t|j|j |j d|d}~ww)z%Send a query which only returns 1 rowr=z'Query should not return more than 1 rowrN) r@rhave_result_set fetch_rowrrr#rrrr)rSr first_rowrr=r=rVrs$      zCMySQLConnection.info_querycCs"z|jWStyYdSw)zMySQL connection IDN)r@rxr#rr=r=rV connection_ids   zCMySQLConnection.connection_idcountbinarycolumnsr prep_stmtc Cs|r|jn|j}|jr |std|dur|j}g}|dur&|dkr&tdd}z||r.|jn|jj} |jr;|jd| } | r||jsg|jrgt | } t | D]\} } |sb|j |j | | | | | <qNt | } || |d7}|rw||krwn| } | s@| 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_resultr@rrrrrMrlist enumerate to_pythonrAtupleappendfetch_eof_columnsr_unread_resultr#rr[rrrr)rSrrrrrr rowscounterrrowi__eofrr=r=rVget_rowssl          zCMySQLConnection.get_rowscCsJz|jd||||d\}}|r|d|fWSd|fWSty$YdSw)z.Get the next rows returned by the MySQL serverr )rrrrrrNNN)r IndexError)rSrrrrrrr=r=rVget_rows   zCMySQLConnection.get_rowcCs|jr |j|jSdS)zReads the next resultN)r@consume_result next_resultrr=r=rVrs  zCMySQLConnection.next_resultcCs|jr |jdSdS)zFrees the resultN)r@rrr=r=rVr szCMySQLConnection.free_resultcCs |jr||jdSdS)zCommit current transactionN)r@rcommitrr=r=rVrszCMySQLConnection.commitcCs"|jr|j|jdSdS)zRollback current transactionN)r@rrollbackrr=r=rVrs zCMySQLConnection.rollbackrc Cr)zChange the current databaserNr)rSrrr=r=rV cmd_init_dbs 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)rr) rr@r fetch_fieldsrArintrNOT_NULLrst_warning_count)rSrrfieldscolr=r=rVr%s0   z"CMySQLConnection.fetch_eof_columnscCs4|jr|j|j|j|j|jdSdS)z Fetch EOF and status information)r& field_count insert_id affected_rowsrrN)r@r*st_field_countr.r/rrr=r=rVfetch_eof_statusHsz!CMySQLConnection.fetch_eof_status statementc CsT|jstdz|j|}|j|_t|WSty)}ztt||d}~ww)zPrepares the SQL statementMySQL Connection not availableN) r@r stmt_preparerrrr#rr[)rSr2stmtrr=r=rVcmd_stmt_prepareUs  z!CMySQLConnection.cmd_stmt_prepare statement_idargsc Gshz |j|d|jiWnty}ztt||d}~wwg|_|js,d|_|Sd|_| |S)zExecutes the prepared statement query_attrsNFT) stmt_executer9r#rr[rArrr1r)rSr7r8rr=r=rVcmd_stmt_executeas z!CMySQLConnection.cmd_stmt_executecC|jrtd|dS)zCloses the prepared statementUnread result foundN)rr stmt_closerSr7r=r=rVcmd_stmt_closet zCMySQLConnection.cmd_stmt_closecCr<)zResets the prepared statementr=N)rr stmt_resetr?r=r=rVcmd_stmt_reset}rAzCMySQLConnection.cmd_stmt_resetr raw_as_stringc Cs||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) z Send a query to the MySQL serverNzutf-8)rrrDr9)rr:izConnection not available.)rvalues)rrrbytesencoder@rr9r#rrrrrrrrrrArr1r)rSrrrrDraddrr=r=rV cmd_querysD     zCMySQLConnection.cmd_queryprepared cursor_class dictionary named_tuplec s |||s td|durt|tstd||S|p"|j}|p'|j}d|dur2dO|dur:dO|durBdO|durJd O|durRd Ottt t t t t tttttd }z||WStyd td dfddtdDdw)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 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.CMySQLCursorrTr r!r") rr rPr_r!r"r#rQ)rrrMrNrKz*Cursor not available with given criteria: z, cs$g|]}d|>@dkr|qS)r rr=)r\rr8 cursor_typer=rVr^s$z+CMySQLConnection.cursor..rR)rrr issubclassr$rrrr%r/r(r)r&r*r'r+r.r,r-KeyError ValueErrorrDrange)rSrrrKrLrMrNtypesr=rVrVcursors^ %    zCMySQLConnection.cursorcCs|jjstd|jS)z,Returns number of rows of current result setr )r@rrnum_rowsrr=r=rVr^s zCMySQLConnection.num_rowscCs|jsdS|jS)zReturns number of warningsr)r@r&rr=r=rVr&s zCMySQLConnection.warning_countcCs|jsdS|jjS)z"Check if a result set is availableF)r@rrr=r=rVresult_set_availablesz%CMySQLConnection.result_set_availablecCs|jS)z)Check if there are unread results or rows)r_rr=r=rVr szCMySQLConnection.unread_resultcCr)zCheck if there are more results)r@ more_resultsrr=r=rVr`#rzCMySQLConnection.more_resultsparamscsg}t|ttfrjrfdd|D}|Sjj|}|St|tr[i}jrF|D]\}}jj j |j ||<q-|S|D]\}}j|d||<qJ|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|jqSr=)rMquoteescapeto_mysql _sql_mode)r\rrr=rVr^5sz6CMySQLConnection.prepare_for_mysql..rzCould not process parameters: (z)), it must be of type list, tuple or dict)rr r rMr@convert_to_mysqldictitemsrbrcrdrertype__name__)rSraresultrrr=rrVprepare_for_mysql(s2     z"CMySQLConnection.prepare_for_mysqlcCs|jdS)zlConsume the current result This method consume the result by reading (consuming) all rows. N)r@rrr=r=rVconsume_resultsSsz CMySQLConnection.consume_results-usernamerrrrrrc Csfz|j|||||||| Wnty&} z t| j| j| jd| d} ~ ww||_||_| dS)z!Change the current logged in userrN) r@ change_userr#rrrrrr_post_connection) rSrqrrrqrrrrrrr=r=rVcmd_change_userZs,    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 )r@reset_connectionrs)rSresr=r=rVcmd_reset_connection|s z%CMySQLConnection.cmd_reset_connectionoptionsc CsNz||j|W|Sty&}z t|j|j|jd|d}~ww)z,Send the Refresh command to the MySQL serverrN) rr@refreshr#rrrrr1)rSrxrr=r=rV cmd_refreshs zCMySQLConnection.cmd_refreshcCs |dS)z,Close the current connection with the serverN)rRrr=r=rVcmd_quitrzCMySQLConnection.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. r3zInvalid shutdown typerN) r@rrrrSHUTDOWN_DEFAULTshutdownr#rrrrrR)rSr|levelrr=r=rV cmd_shutdowns$   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) rr@statrparse_statisticsr#rrrrr)rSrrr=r=rVcmd_statisticss  zCMySQLConnection.cmd_statistics mysql_pidcCs&t|ts td|d|dS)zKill a MySQL processzMySQL PID must be intzKILL N)rr(rZrJ)rSrr=r=rVcmd_process_kills z!CMySQLConnection.cmd_process_killcCt)zSend the DEBUG commandNotImplementedErrorrr=r=rV cmd_debugzCMySQLConnection.cmd_debugcCr)zSend the PING commandrrr=r=rVcmd_pingrzCMySQLConnection.cmd_ping statementscCr)z/Send one or more statements to the MySQL serverr)rSrr=r=rVcmd_query_iterrzCMySQLConnection.cmd_query_iterparam_iddatacCr)zSend data for a columnr)rSr7rrr=r=rVcmd_stmt_send_long_datasz(CMySQLConnection.cmd_stmt_send_long_datacCs6|dur|jn|j}|jr|dS|rtddS)z'Check whether there is an unread resultTr=N)rr can_consume_resultsrnr)rSrKr r=r=rVrs  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. rOzSET @`z` = %sz SET SESSION `N)rrrwrtrrrrrrrrrrrr]riexecuterR)rSrrcurrrr=r=rV reset_sessions8  zCMySQLConnection.reset_session)r7N)T)Fr r)NFNNN)FNNN)N)NFF)NNNNNN) rorororprororoNN)Fr)Urk __module__ __qualname____doc__rrOrmrpropertyr(rr[rrrrsetterrrrrR disconnectrrrrr!rrrrrrrr rrrrrrrrrrr1rGr6r2r r;r@rCrJ_execute_queryr r$r]r^r&r_r r`rrrrmrnrtrwrzr{rr rrrrrrrrrr __classcell__r=r=rTrVr5ms !       [   A       #        (  U +    "     r5)HrrBrJrirtypingrrrrrrrr r r ror abstractsrr constantsrrrr conversionrerrorsrrrrrrnrr\rrrrrr r!utilsr"r>rGr# cursor_cextr$r%r&r'r(r)r*r+r,r-r.r/ ImportErrorexcopentelemetry.constantsr1!opentelemetry.context_propagationr2opentelemetry.instrumentationr3r4r5r=r=r=rVsB0   $  8