"iw:dZddlZddlZddlZddlmZmZddlmZm Z m Z m Z m Z ddl mZmZddlmZdZ ddlZdd lmZmZmZmZmZmZmZmZmZdd lmZd Zn4#e$r,Z ed !e"e dZ [ wwxYwGd deZ#dS)z'Connection class using the C Extension N)errorsversion) CharacterSet FieldFlag ServerFlag ShutdownType ClientFlag)MySQLConnectionAbstractMySQLCursorAbstract) MySQLProtocolF) CMySQLCursorCMySQLCursorRawCMySQLCursorBufferedCMySQLCursorBufferedRawCMySQLCursorPreparedCMySQLCursorDictCMySQLCursorBufferedDictCMySQLCursorNamedTupleCMySQLCursorBufferedNamedTuple)MySQLInterfaceErrorTz6MySQL Connector/Python C Extension not available ({0})cHeZdZdZfdZdZdZedZdZ d;dZ ed Z e j d Z ed Z e j d Z ed ZdZdZeZdZdZddZdZdZdZdZd Zd?d!Zd"Z d#Z!d$Z"d%Z#d&Z$d@d'Z%e%Z& dAd(Z'ed)Z(ed*Z)ed+Z*ed,Z+ed-Z,d.Z-d/Z. dBd2Z/d3Z0d4Z1d5Z2d?d6Z3d7Z4d8Z5dCd9Z6dDd:Z7xZ8S)ECMySQLConnectionz5Class initiating a MySQL Connection using Connector/Cc \tstdd|_g|_tjtjtjtj ddd|_ tj dkrLtj|j s(tjdrdnd|_ d|_t!t"|jd i||r|jd i|dSdS) 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 convertersuperr__init__connect)selfkwargs __class__s W/srv/django_bis/venv311/lib/python3.11/site-packages/mysql/connector/connection_cext.pyr2zCMySQLConnection.__init__Fs) DBDD D  7<< GOOBGOO,<,EFF G G Xx   ?   ' '7>>$"233 w~~&?@@1--0 .%%.88888  # DL " "6 " " " " " # #c $tjd}|ddkrd}nd}|jd|ddtjdd Dtjd d S) z!Add default connection attributes rGPLv2zGPL-2.0 Commercialzmysql-connector-python.c,g|]}t|Sr )str).0xs r7 z.ls666AQ666r8)_connector_name_connector_license_connector_version _source_hostN) rLICENSEsplit _conn_attrsupdater'VERSIONsocket gethostname)r4license_chunksclient_licenses r7_add_default_conn_attrsz(CMySQLConnection._add_default_conn_attrs`s ..s33 !  ' '&NN)N 7"0"%((661!5666#8#8".00 !!     r8c (|j|j|jdddd|jd|_||jd|_dS)z . N & &u - - - - - . .r8cL|dd}|dkrdndS)z#Get whether autocommit is on or offzSELECT @@session.autocommitrrTF info_queryrns r7 autocommitzCMySQLConnection.autocommits- =>>qAzzttu,r8c |j|||_dS#t$r+}t j|j|j|jd}~wwxYw)zToggle autocommitmsgerrnosqlstateN) r#rs _autocommitrrget_mysql_exceptionrvrwrx)r4roexcs r7rszCMySQLConnection.autocommitsz D L # #E * * *$D   " D D D, 69lDDD D Ds!% A&AAc8|ddS)zGet the current databasezSELECT DATABASE()rrqrbs r7databasezCMySQLConnection.databases233A66r8c:|j|dS)zSet the current databaseN)r# select_dbrns r7r}zCMySQLConnection.databases  u%%%%%r8c*|jtjzS)z'MySQL session has started a transaction)rfrSTATUS_IN_TRANSrbs r7in_transactionzCMySQLConnection.in_transactions"Z%???r8c  tj|jd}tj|j|j||jpd|j|j |j |_ | tjsi|_id|jd|jd|jd|jd|jd|jd |jd |jd |jd |jd | tjddd|jd|jd|jd|jd|j}|j d}|+|!dd"|}|j dA|j dd}|j dd}nd}d}|d|vr|sd}|j#s|$|j d|j d|j d||||j dpd |j d!pd |j#d"  |j j%d$i||j&|j _'|j(r|j&|j(_)n8#tT$r+}tWj,|j-|j.|j/#d}~wwxYw|0dS)%Nr)bufferedraw charset_nameconnection_timeoutrlrX plugin_dirhostuserpassword password1 password2 password3r}port client_flags unix_socketcompress ssl_disabledT conn_attrs local_infileload_data_local_diroci_config_file fido_callback tls_versions)reverse,tls_ciphersuitesrzTLSv1.3TLS_AES_256_GCM_SHA384cacertkey verify_certFverify_identity) ssl_cassl_certssl_keyssl_cipher_suitesrtls_cipher_suitesssl_verify_certssl_verify_identityrrur )1rget_info _charset_idr*MySQL _buffered_raw_connection_timeoutrk _auth_pluginr,r#isset_client_flagr CONNECT_ARGSrJ_host_user _password _password1 _password2 _password3 _database_port _client_flags _unix_socketCOMPRESS_allow_local_infile_allow_local_infile_in_path_oci_config_file_fido_callback_sslgetsortr' _ssl_disabledrKr3_converter_str_fallbackconverter_str_fallbackr0 str_fallbackrrrzrvrwrxrc)r4r cnx_kwargsrssl_ciphersuitesrr{s r7_open_connectionz!CMySQLConnection._open_connections#,T-=>>qA '-^ % $ 8 =A))'))) %%j&=>> "!D  DJ DJ             DJ  D.  4,  ..z/BCC  D  $*  D4  "4#C t4! " T0# (y}}^44  #   d  + + +88L11L 9==+ , , 8#y}}-?@@C #y}}-?@@C  # #   # \(A(A)B7 !    )---- IMM&119==//%5 ,%5#'9==#?#?#H5IMM"344= $ 2      D DL . .: . . .262NDL /~ K.2.J+" D D D, 69lDDD D D s;;J77 K,&K''K,c|jrh ||jdS#t$r+}t j|j|j|jd}~wwxYwdS)z Disconnect from the MySQL serverruN) r# free_resultcloserrrzrvrwrx)r4r{s r7rzCMySQLConnection.closes < H H  """ ""$$$$$& H H H0SWCI:=,HHHH H  H Hs-8 A-&A((A-c6|j S)z8Return True if the connection to MySQL Server is closed.)r# connectedrbs r7 is_closedzCMySQLConnection.is_closed s<))++++r8cn|jr-||jSdS)z;Reports whether the connection to MySQL Server is availableF)r#handle_unread_resultpingrbs r7 is_connectedzCMySQLConnection.is_connecteds7 < '  % % ' ' '<$$&& &ur8Frrc| |j}|rdSn#t$rYnwxYw|r|||dSt jd)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)attemptsdelayz$Connection to MySQL is not available)rr#rAttributeError reconnectrInterfaceError)r4rrrrs r7rzCMySQLConnection.pings !!###  ))++I      D   P NNHEN : : : : :'(NOO Os4 AAc:|j|dS)zDSets the default character set name for current connection. N)r#set_character_set)r4rVs r7set_character_set_namez'CMySQLConnection.set_character_set_name4s  &&w/////r8cF|j|d}|jjr_|j}|jr-|jt jd|j|S)z%Send a query which only returns 1 rowr z'Query should not return more than 1 row)r#queryhave_result_set fetch_rowrrr)r4r first_rows r7rrzCMySQLConnection.info_query9s 5!!! < ' ? ..00I|%%'' ? ((***+=???   """r8cZ |jS#t$rYnwxYwdS)zMySQL connection IDN)r#r]rrbs r7 connection_idzCMySQLConnection.connection_idGsB <))++ +"    D ts  ((Nc |r|jn|j}|jr|stjd||j}g}||dkrt dd} |r|jn |jj} |jr|j d| } | r|jsk|jrdt| } t| D]6\} } |s/|j |j | | | | | <7t| } || |dz }|r||krn | } | | sN||d} |r|d|_n|nd} n#t&$rv}|r5|tjt+||tj|j|j|j d}~wwxYw|| fS) z8Get all or a subset of rows returned by the MySQL serverzNo result set availableNrz$count should be 1 or higher, or NoneTreofFru)r unread_resultr#r InternalErrorrrrr0rlist enumerate to_pythonr$tupleappendfetch_eof_columnsr_unread_resultrrr?rzrvrwrx)r4countbinarycolumnsr prep_stmtrrowscounterrrowi__eofr{s r7get_rowszCMySQLConnection.get_rowsQs6?$ 11#   B B&'@AA A ;)C  ! !GHH H( H'0, ##\+ ~ '   &&&)++C "y%T^%s))C )#FF1"F%)^%=%=dmA>N>A!f&F&FCF**C C   1 W--ikk " --i88?'))+++*/D''$$&&&&" H H H H%%'''+CHH555  """0SWCI:=,HHHH  HTzsD5F H A1HH c |d||||\}}|r |d|fSd|fS#t$rYdSwxYw)z.Get the next rows returned by the MySQL serverr)rrrrrrNNN)r IndexError)r4rrrrrrs r7get_rowzCMySQLConnection.get_rowsr  Afg*-&DDID# &Q~%#;    << s(// ==cx|jr2|j|jSdS)zReads the next resultN)r#consume_result next_resultrbs r7rzCMySQLConnection.next_results9 < . L ' ' ) ) )<++-- -tr8cJ|jr|jdSdS)zFrees the resultN)r#rrbs r7rzCMySQLConnection.free_results0 < ' L $ $ & & & & & ' 'r8cr|jr/||jdSdS)zCommit current transactionN)r#rcommitrbs r7rzCMySQLConnection.commitsB < "  % % ' ' ' L   ! ! ! ! ! " "r8c||jr4|j|jdSdS)zRollback current transactionN)r#rrollbackrbs r7rzCMySQLConnection.rollbacksD < $ L ' ' ) ) ) L ! ! # # # # # $ $r8c |j|dS#t$r+}tj|j|j|jd}~wwxYw)zChange the current databaseruN)r#rrrrzrvrwrx)r4r}r{s r7 cmd_init_dbzCMySQLConnection.cmd_init_dbsr D L " "8 , , , , ," D D D, 69lDDD D Ds A&AAc&|r|jn |jj}|stjd|r|n|j}g|_|D]}|j|dt|dddddt|dtj zt|dt|df |j |j d|jdS) z Fetch EOF and column information No result setN ) status_flag warning_count)rr) rr#rr fetch_fieldsr$rintrNOT_NULLrfst_warning_count)r4rrfieldscols r7rz"CMySQLConnection.fetch_eof_columnss+7@.)33-  9'88 8-6-'')))**,,    C M ACF SV y11CF CF  "     $2!%!>!>!@!@}    r8c|jri|j|j|j|j|jdSdS)z Fetch EOF and status information)r field_count insert_id affected_rowsrWN)r#rst_field_countrrrfrbs r7fetch_eof_statusz!CMySQLConnection.fetch_eof_statussl < !%!>!>!@!@#|::<<!\3355!%!;!;!=!=!%!4  tr8c|jstjd |j|}|j|_|S#t $r&}tjt|d}~wwxYw)zPrepares the SQL statementMySQL Connection not availableN) r#rOperationalError stmt_preparerrrrr?)r4 statementstmterrs r7cmd_stmt_preparez!CMySQLConnection.cmd_stmt_prepares| L)*JKK K 2<,,Y77D*.*FD 'K" 2 2 2'C11 1 2s'A A5!A00A5c  |j|n3#t$r&}tjt |d}~wwxYwg|_|jsd|_|Sd|_| |S)zExecutes the prepared statementNFT) stmt_executerrrr?r$rrrr)r4rargsr$s r7cmd_stmt_executez!CMySQLConnection.cmd_stmt_executes 2 "I "D ) ) )" 2 2 2'C11 1 2 ( +"'D ((** *"%%i000s =!8=cd|jrtjd|dS)zCloses the prepared statementUnread result foundN)rrr stmt_closer4rs r7cmd_stmt_closezCMySQLConnection.cmd_stmt_close7   >&'<== =r8cd|jrtjd|dS)zResets the prepared statementr+N)rrr stmt_resetr-s r7cmd_stmt_resetzCMySQLConnection.cmd_stmt_resetr/r8c`|||j} t|ts|d}|j|||||jn#t$r+}tj |j |j |j d}~wt$rG|jr|j}n|jdzt#|jz}tjd|dfwxYwg|_|jjs|S|S) z Send a query to the MySQL serverNzutf-8)rr raw_as_string query_attrs)rvrx:izConnection not available.)rwvalues)rr isinstancebytesencoder#r _query_attrsrrrzrwrvrxrrrr?rr r$rrr)r4rrrr4r{addrs r7 cmd_queryzCMySQLConnection.cmd_queryss !!### ;)C HeU++ . W-- L  u#&-:+/+<  > > > ># D D D,SYCG69lDDD D H H H  :(zC'#dj//9)D*E#FHHH H  H |+ +((** *%%'''sAA.. C28&BAC2c  |||stjd|4t |t stjd||S|p|j}|p|j}d |dur dz |dur dz |dur dz |dur d z |dur d z tttttttt t"d } | |S#t$$rBd t'd d fdt+dDzwxYw)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.CMySQLCursorrTrr r ) rrr@rCr r rrA)rr dictionary named_tuplepreparedz*Cursor not available with given criteria: z, c8g|]}d|zzdk|S)rrr )r@rr( cursor_types r7rBz+CMySQLConnection.cursor..us=(H(H(HA+6!q&+AQ+F+F)-Q+F+F+Fr8rB)rrrr  issubclassr ProgrammingErrorrrrrrrrrrrrKeyError ValueErrorr'range) r4rrrE cursor_classrCrDtypesr(rGs @@r7cursorzCMySQLConnection.cursor.s< !!(+++  "" M)*KLL L  #l,?@@ 4-3444!L$'' '-t~TY t   1 K $;; 1 K    1 K $   1 K t   2 K#&'%-$    J&E+&-- - J J JODI!YY(H(H(H(H(Hq(H(H(HIIIJJ J Js 1DA Ect|jjstjd|jS)z,Returns number of rows of current result setr )r#rrrnum_rowsrbs r7rQzCMySQLConnection.num_rowsxs6|+ 9'88 8|$$&&&r8cF|jsdS|jS)zReturns number of warningsr)r#rrbs r7rzCMySQLConnection.warning_counts'| 1|))+++r8c,|jsdS|jjS)z"Check if a result set is availableF)r#rrbs r7result_set_availablez%CMySQLConnection.result_set_availables| 5|++r8c|jS)z)Check if there are unread results or rows)rTrbs r7rzCMySQLConnection.unread_results ((r8c4|jS)zCheck if there are more results)r# more_resultsrbs r7rWzCMySQLConnection.more_resultss|((***r8cpt|ttfr'jrfd|D}njj|}nt|t ri}jrh|D]R\}}jj j |||<Snk|D](\}}j|d||<)n-tj 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 g|]L}jjj|MSr )r0quoteescapeto_mysql)r@ror4s r7rBz6CMySQLConnection.prepare_for_mysql..se  N((-- N33E::r8rzCould not process parameters: (z)), it must be of type list, tuple or dict)r8rrr0r#convert_to_mysqldictitemsrZr[r\rrItype__name__)r4paramsresultrros` r7prepare_for_mysqlz"CMySQLConnection.prepare_for_mysqls| ftUm , , ;~ @ $* 76?  % % ;F~ J"(,,..JC"&."6"6-- N33E::##F3KK#),,..JJJC"&,"?"?"F"Fq"IF3KKJ):f1F:::::;; ; r8c8|jdS)zlConsume the current result This method consume the result by reading (consuming) all rows. N)r#rrbs r7consume_resultsz CMySQLConnection.consume_resultss ##%%%%%r8-c  |j|||||||n8#t$r+} tj| j| j| jd} ~ wwxYw||_| dS)z!Change the current logged in userruN) r# change_userrrrzrvrwrxr_post_connection) r4usernamerr}rVrrrrr{s r7cmd_change_userz CMySQLConnection.cmd_change_users D L $ $ ! ! ! !# D D D, 69lDDD D D# s # A&AAcd|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_connectionrl)r4ress r7cmd_reset_connectionz%CMySQLConnection.cmd_reset_connections6l++--  $  ! ! # # # r8c ||j|n8#t$r+}t j|j|j|jd}~wwxYw| S)z,Send the Refresh command to the MySQL serverruN) rr#refreshrrrzrvrwrxr)r4optionsr{s r7 cmd_refreshzCMySQLConnection.cmd_refreshs D  % % ' ' ' L  ) ) ) )" D D D, 69lDDD D D$$&&&s.1 A&&A!!A&c.|dS)z,Close the current connection with the serverN)rrbs r7cmd_quitzCMySQLConnection.cmd_quits r8c~|jstjd|r+tj|stjd|}n tj} |j|n8#t$r+}tj |j |j |j d}~wwxYw| dS)zShut down the MySQL ServerrzInvalid shutdown typeruN)r#rr r rrSHUTDOWN_DEFAULTshutdownrrzrvrwrxr)r4 shutdown_typelevelr{s r7 cmd_shutdownzCMySQLConnection.cmd_shutdowns| L)*JKK K  2(77 E+,CDDD!EE 1E D L ! !% ( ( ( (" D D D, 69lDDD D D sA11 B&;&B!!B&c,| |j}t|dS#t t jf$r+}t j|j |j |j d}~wwxYw)z'Return statistics from the MySQL serverF) with_headerruN) rr#statr parse_statisticsrrrrzrvrwrx)r4rr{s r7cmd_statisticszCMySQLConnection.cmd_statistics s !!### D<$$&&D ??33De3LL L#V%:; D D D, 69lDDD D Ds;AB(&BBct|tstd|d|dS)zKill a MySQL processzMySQL PID must be intzKILL {0}N)r8rrKrrformat)r4 mysql_pids r7cmd_process_killz!CMySQLConnection.cmd_process_killsI)S)) 6455 5  )))4455555r8c|dur|jn|j}|jr|dS|rt jddS)z'Check whether there is an unread resultTr+N)rrcan_consume_resultsrgrr)r4rErs r7rz%CMySQLConnection.handle_unread_resultsg/74/?/?++#   # >  " " " " "  >&'<== = > >r8c |stjd|so ||j|j|j|j|j |j |j |j n)#tj $r|YnwxYw|s|r|}|rD|D]/\}}|d||f0|rD|D]/\}}|d||f0|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. r?zSET @`{0}` = %szSET SESSION `{0}` = %sN)rrr rrrnrrrrrrrrrIrrOr`executerr)r4user_variablessession_variablescurrros r7 reset_sessionzCMySQLConnection.reset_session%s   "" M)*KLL L((** ! !$$TZ%)^T5E%)_do%)_d6KMMMM* ! ! !      !  . ++--C I"0"6"6"8"8IIJCKK 1 8 8 = =xHHHH  P"3"9"9";";PPJCKK 8 ? ? D DuhOOOO IIKKKKK  sAB#B)(B))T)Frr)NFNNN)FNNN)N)NFF)NNNNNN)rhrhrhrirhrhrhN)Fr)9rb __module__ __qualname____doc__r2rQrcpropertyrfrirmrssetterr}rrr disconnectrrrrrrrrrrrrrr rrr%r)r.r2r=_execute_queryrOrQrrTrrWrergrnrrrvrxr~rrrr __classcell__)r6s@r7rrBs:??#####4    "//X/AAA . . . .--X- DDD77X7_&&_&@@X@DDDLHHHJ,,,PPPP:000   XDH::::x     ''' """ $$$ DDD    >    2 2 2111  ((((:NJN,0HJHJHJHJT''X',,X,,,X,))X)++X+$$$L&&&BDJL(,    *    ' ' '& D D D666 >>>>$$$$$$$$r8r)$rr%rMr-rhrr constantsrrrr r abstractsr r rSr r!r* cursor_cextrrrrrrrrrr ImportErrorr{rr?rr r8r7rs:  DCCCCCCC###### (((((((((((((((((((((( 544444KK    +@GG CHH      G G G G G .G G G G G s AB 'BB