U e~ @sUdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z m Z ddlmZddlmZddl mZdd lmZdd lmZmZmZmZmZmZmZmZmZmZm Z m!Z!d Z"z ddl#Z#e$e#d re#j%rd Z"Wne&k rYnXddl'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/ddl0m1Z1m2Z2ddl3m4Z4m5Z5m6Z6m7Z7m8Z8ddl9m:Z:ddlm;Z;mZ>m?Z?m@Z@mAZAeBZCdeDd<dZEdZFdZGdZHdZIeeJe e eKeLeMe e f ZNGdddeZOGdddeZPdS)z+Module gathering all abstract base classes.) annotationsN)ABCabstractmethod)datedatetimetime timedelta)Decimal) signature)sleep) TracebackType) AnyBinaryIOCallableDict GeneratorListMappingOptionalSequenceTupleTypeUnionF HAS_TLSv1_3T) CONN_ATTRS_DNDEFAULT_CONFIGURATIONDEPRECATED_TLS_VERSIONSOPENSSL_CS_NAMESTLS_CIPHER_SUITES TLS_VERSIONS CharacterSet ClientFlag)MySQLConverterMySQLConverterBase)ErrorInterfaceErrorNotSupportedErrorOperationalErrorProgrammingError)read_option_files) ConnAttrsTypeDescriptionType HandShakeType QueryAttrType StrOrBytes!SupportedMysqlBinaryProtocolTypes WarningTypez%weakref.WeakValueDictionary[Any, Any]NAMED_TUPLE_CACHEzVThe '{list}' list must not contain repeated values, the value '{value}' is duplicated.zdThe given tls_version: '{}' is not recognized as a valid TLS protocol version (should be one of {}).zHThe given tls_version: '{}' are no longer allowed (should be one of {}).zINo supported TLS protocol version found in the 'tls-versions' list '{}'. aOption "krb_service_principal" {error}, must be a string in the form "primary/instance@realm" e.g "ldap/ldapauth@MYSQL.COM" where "@realm" is optional and if it is not given will be assumed to belong to the default realm, as configured in the krb5.conf file.c @s eZdZUdZddddZddddZdd d dd d d ZddddZeddddZ eddddZ eddddZ dddddZ ddddZ ddddZddd d!Zed"dd#d$Zed"dd%d&Zed'dd(d)Zed*dd+d,Zeed"dd-d.Zejd"ddd/d.Zeddd0d1Zejdddd2d1Zed3dd4d5Zejd3ddd6d5Zd3dd7d8d9Zd3dd:d;Zedd?d@Zd=ddAdBZd*ddCdDZeed3ddEdFZdGd'dHdIdJZ d'ddKdLdMZ!ed"ddNdOZ"e"jd"dddPdOZ"ed"ddQdRZ#e#jdSdddTdRZ#ed3d3dUdVdWZ$dd*d*ddYdZd[Z%ddddd]d^Z&eddd_d`Z'e'jddddad`Z'edddbdcZ(e(jddddddcZ(edddedfZ)e)jddddgdfZ)edddhdiZ*e*jddddjdiZ*ed"ddkdlZ+ed"ddmdnZ,ddod*ddpdqdrZ-ed"ddsdtZ.ed3ddudvZ/ed3ddwdxZ0dddydzZ1ed3dd{d|Z2e2Z3d}e4d~<d3dd7ddZ5dd'd'ddddZ6ed3dddZ7eddd'd'd3dddZ8ed3dddZ9edddddddddddZ:ed3d3dUddZ;ed3dddZdddddZ?edddddd3ddddZ@d"ddddZAdd3dddddddZBd3ddddZCd'ddddZDd3dddZEddddddZFddddZGed3dddZHd'dddd„ZIddddĄZJddddƄZKdd"d"d"d'd"d"d"d"ddɜ dd˄ZLd3dd̜dd΄ZMdd3ddd'd3dќddӄZNd3d3dԜddքZOd3d'dd3d؜ddڄZPd3d3dԜdd܄ZQd3dddބZRdXS)MySQLConnectionAbstractz7Abstract class for classes connecting to a MySQL serverNonereturncCs8t|_d|_d|_d|_d|_d|_d|_i|_ d|_ d|_ d|_ d|_ d|_d|_d|_d|_d|_d|_d|_i|_td|_d|_d|_d|_d|_d |_d|_d|_td |_d|_ d|_!d|_"d|_#d|_$td |_%td |_&d|_'g|_(d|_)d|_*d|_+d|_,d|_-d|_.d|_/d|_0d|_1d|_2dS) Z Initialize-NFz 127.0.0.1i r ssl_disabledTconnect_timeoutallow_local_infileallow_local_infile_in_path)3r" get_default _client_flags _charset_id _sql_mode _time_zone _autocommit_server_version _handshake _conn_attrs_user _passwordZ _password1Z _password2Z _password3 _database_host_port _unix_socketZ _client_hostZ _client_port_sslr _ssl_disabledZ _force_ipv6Z_oci_config_file_fido_callback_krb_service_principal _use_unicode _get_warnings_raise_on_warningsZ_connection_timeoutZ _buffered_unread_result_have_next_result_rawZ_in_transaction_allow_local_infile_allow_local_infile_in_pathZ_prepared_statements _query_attrs _ssl_active _auth_plugin_auth_plugin_class_pool_config_version converter_converter_class_converter_str_fallback _compress_consume_results _init_commandselfreZ/var/www/html/assets/scripts/venv/lib/python3.8/site-packages/mysql/connector/abstracts.py__init__sh   z MySQLConnectionAbstract.__init__cCs|SNrercrererf __enter__sz!MySQLConnectionAbstract.__enter__Type[BaseException] BaseExceptionr exc_type exc_value tracebackr6cCs |dSrhcloserdrmrnrorererf__exit__sz MySQLConnectionAbstract.__exit__cCs|S)zReturn self for weakref.proxy This method is used when the original object is needed when using weakref.proxy. rercrererfget_selfsz MySQLConnectionAbstract.get_selfboolcCs|jp|jdk otjdkS)z&Return True if is a secure connection.Nposix)rYrKosnamercrererf is_securesz!MySQLConnectionAbstract.is_securecCs|jS)zReturn if have next result.)rTrcrererfhave_next_resultsz(MySQLConnectionAbstract.have_next_resultr.cCs|jS)zReturn query attributes list.rXrcrererf query_attrssz#MySQLConnectionAbstract.query_attrsz-Tuple[str, SupportedMysqlBinaryProtocolTypes])valuer6cCs|j|dS)z)Add element to the query attributes list.N)rXappendrdr}rererfquery_attrs_appendsz*MySQLConnectionAbstract.query_attrs_appendcCs|jdd=dS)zClear query attributes list.Nr{rcrererfquery_attrs_clearsz)MySQLConnectionAbstract.query_attrs_clearc Cs@g}|jd}t|tr|dr,|dsszFMySQLConnectionAbstract._validate_tls_ciphersuites..zItls_ciphersuites should be a list with one or more ciphersuites. Found: ' tls_versionsNT)reverser-TLSv1.3listr}z The value 'z1' in tls_ciphersuites is not a valid cipher suitez:No valid cipher suite found in the 'tls_ciphersuites' list:)rL isinstancestr startswithendswithAttributeErrorsplitstripupperr~rsetgetr sortindexupdaterextendrDUPLICATED_IN_LIST_ERRORformatjoin) rdrrZtls_cssZ_tls_csrZ newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namestls_verrxZtranslated_namerererf_validate_tls_ciphersuitessx           z2MySQLConnectionAbstract._validate_tls_ciphersuitescCsg}|jd}t|tr|dr,|dstls_versions should be a list with one or more of versions in z, z . found: 'zdAt least one TLS protocol version must be specified in 'tls_versions' list when this option is givenN)rLrrrrrrrrrr~TLS_V1_3_SUPPORTEDTLS_VER_NO_SUPPORTEDr rrrrr'rTLS_VERSION_DEPRECATED_ERRORTLS_VERSION_ERROR)rdrZ tls_versionZtls_versrZuse_tls_versionsZdeprecated_tls_versionsZinvalid_tls_versionsrererf_validate_tls_versionsLs             z.MySQLConnectionAbstract._validate_tls_versionsrcCs|jS)z#User used while connecting to MySQL)rFrcrererfuserszMySQLConnectionAbstract.usercCs|jS)zMySQL server IP address or name)rIrcrererf server_hostsz#MySQLConnectionAbstract.server_hostintcCs|jS)zMySQL server TCP/IP port)rJrcrererf server_portsz#MySQLConnectionAbstract.server_portz Optional[str]cCs|jS)zMySQL Unix socket file location)rKrcrererf unix_socketsz#MySQLConnectionAbstract.unix_socketcCsdS)zGet the current databaseNrercrererfdatabasesz MySQLConnectionAbstract.databasecCs|d|dS)zSet the current databasezUSE N) cmd_queryrrererfrscCs|jS)z"Returns whether to consume results)rarcrererfcan_consume_resultssz+MySQLConnectionAbstract.can_consume_resultscCst|tst||_dS)zSet if can consume results.N)rruAssertionErrorrarrererfrsr cCs|jS)z%Return the pool configuration versionr\rcrererfpool_config_versionsz+MySQLConnectionAbstract.pool_config_versioncCs ||_dS)z"Set the pool configuration versionNrrrererfrs)kwargsr6c Ks\ |}d|krtdtf|}z|d|_|d=Wntk rJYnXz|d|_|d=Wntk rtYnXz$t}||dp||d=Wntk rYnXz |drd|_ |tj gWntk rYnX| dt d|_ | d t d |_d }|jr\tj|j}|rFtj|rFtj|rTtj|r\td |j sl|jr||tjgn|tj gz|d sd |_nd|_Wntk rd |_YnXz|d|_|d=Wntk rd|_YnXd|ks d|krzz|d}|d=Wntk r8d }YnXz|d}|d=Wntk rfd }YnXt||d|_z||dWnBtk rYn.tk r}ztd|W5d }~XYnXdddddg}|D]B\} } z | |kr|| || <|| =Wntk r YnXqd|ks:d|krz|d} |d=Wntk rh|j} YnXz|d} |d=Wntk r|j} YnX| | | d|kr|dr|d|_!zt"|d|_#|d=WnBtk rYn.t$k r}zt%d|W5d }~XYnXd|kr6|&d|_'d |krP|d |_(|d =d } |)D]\}}z t |Wn(tk rtd!|d"d YnX|*d#rd} |j+,|-d#d|inb|*d$rd} |j+,||in@d%|}zt.|||/Wn"tk r$t.|||YnXq\|j0rDtj1d&krDd|_'|j'r`|jd'kr`t%d(| r~d)|j+krt d*|j+d)<d+|j+krt d,|j+d+<d-|j+ks|j+d-d krd|j+d-<t2d.|j+kt2d/|j+kkrtd0t3d1t3|j+ksd |j+d.<d |j+d/<n&|j+d.d k|j+d/d kkr6td2d3|j+krZ|j+d3d k rZ|4d4|j+kr~|j+d4d k r~|5|j6d kri|_6nt7|j6t8st%d5n|j6)D]\}}|t9krʐqt7|t:st%d6|d7|j6d"t;|d8kr t%d9|d:|*d%r t%d;t7|t:sBt%d<|d=|d>t;|d?krt%d<|d=|d@q|jdA|kr|dAd k rt7|dAt:st%dB|dA?}|dCkrtj1dDkrt%dEdF|_@n|dGkrdH|_@nt%dIdJ|krt|dJd k rt|dJ|_At7|jAt:sZ CONNECT_ARGS_add_default_conn_attrslowerr[rOKRB_SERVICE_PINCIPAL_ERRORrrNrsplitr) importlib import_modulegetattrModuleNotFoundErrorcallabler parameters)rdrconfigdefaultZinfile_in_pathrrerrZ compat_mapcompat translaterrZ set_ssl_flagrr} attribute attr_nameZ attr_valuermodulecallbackparamsrererfrs                                                                  zMySQLConnectionAbstract.configcCsdS)z&Add the default connection attributes.Nrercrererfrsz/MySQLConnectionAbstract._add_default_conn_attrsr/zTuple[int, ...])server_versionr6cCspt|ttfr|}td}||}|s6tdtdd| ddD}|dkrltd|d |S) a7Check the MySQL version This method will check the MySQL version and raise an InterfaceError when it is not supported or invalid. It will return the version as a tuple with major, minor and patch. Raises InterfaceError if invalid server version. Returns tuple z$^(\d{1,2})\.(\d{1,2})\.(\d{1,3})(.*)zFailed parsing MySQL versioncss|]}t|VqdSrh)r)rvrererf 'sz@MySQLConnectionAbstract._check_server_version..r)rzMySQL Version 'z' is not supported) r bytearraybytesdecoderecompilematchr&tuplegroups)rZ regex_verrversionrererf_check_server_versions   z-MySQLConnectionAbstract._check_server_versioncCs|jS)zGet the MySQL version This method returns the MySQL server version as a tuple. If not previously connected, it will return None. Returns a tuple or None. )rCrcrererfget_server_version-sz*MySQLConnectionAbstract.get_server_versionc Cs,z |jdWSttfk r&YdSXdS)zGet the original MySQL version information This method returns the original MySQL server as text. If not previously connected, it will return None. Returns a string or None. Zserver_version_originalN)rDrrrcrererfget_server_info7s z'MySQLConnectionAbstract.get_server_infocCsdS)z'MySQL session has started a transactionNrercrererfin_transactionDsz&MySQLConnectionAbstract.in_transactionzUnion[int, Sequence[int]])flagsr6cCsnt|tr|dkr||_nNt|ttfr`|D]0}|dkrN|jt|M_q,|j|O_q,ntd|jS)aSet the client flags The flags-argument can be either an int or a list (or tuple) of ClientFlag-values. If it is an integer, it will set client_flags to flags as is. If flags is a list (or tuple), each flag will be set or unset when it's negative. set_client_flags([ClientFlag.FOUND_ROWS,-ClientFlag.LONG_FLAG]) Raises ProgrammingError when the flags argument is not a set or an integer bigger than 0. Returns self.client_flags rz+set_client_flags expect integer (>0) or set)rrr>rrabsr))rdrflagrererfrIsz(MySQLConnectionAbstract.set_client_flags)rr6cCs|j|@dkrdSdS)zCheck if a client flag is setrTF)r>)rdrrererfisset_client_flagesz)MySQLConnectionAbstract.isset_client_flagcCs|ddS)zGet the current time zonezSELECT @@session.time_zoner info_queryrcrererf time_zoneksz!MySQLConnectionAbstract.time_zonecCs|d|d||_dS)zSet the time zonezSET @@session.time_zone = 'rN)rrArrererfr pscCs|ddS)zGet the SQL modezSELECT @@session.sql_moderr rcrererfsql_modevsz MySQLConnectionAbstract.sql_modezUnion[str, Sequence[int]]cCs4t|ttfrd|}|d|d||_dS)aSet the SQL mode This method sets the SQL Mode for the current connection. The value argument can be either a string with comma separate mode names, or a sequence of mode names. It is good practice to use the constants class SQLMode: from mysql.connector.constants import SQLMode cnx.sql_mode = [SQLMode.NO_ZERO_DATE, SQLMode.REAL_AS_FLOAT] rzSET @@session.sql_mode = 'rN)rrrrrr@rrererfr {s  )queryr6cCsdS)z%Send a query which only returns 1 rowNrerdr rererfr sz"MySQLConnectionAbstract.info_queryN)rrr6cCs4|dk r||_nd|_|dk r*||_nd|_dS)zSet login information for MySQL Set the username and/or password for the user connecting to the MySQL Server. Nr8)rrFrG)rdrrrererfrs  z!MySQLConnectionAbstract.set_loginTcCs||_|jr|j|dS)zuToggle unicode mode Set whether we return string fields as unicode or not. Default is True. N)rPr] set_unicoderrererfrsz#MySQLConnectionAbstract.set_unicodecCs|dd}|dkS)z#Get whether autocommit is on or offzSELECT @@session.autocommitrrr rrererf autocommitsz"MySQLConnectionAbstract.autocommitcCs&|rdnd}|d|||_dS)zToggle autocommitONZOFFzSET @@session.autocommit = N)rrB)rdr}switchrererfrs cCs|jS)zGet whether this connection retrieves warnings automatically This method returns whether this connection retrieves warnings automatically. Returns True, or False when warnings are not retrieved. )rQrcrererfrs z$MySQLConnectionAbstract.get_warningscCst|tstd||_dS)zSet whether warnings should be automatically retrieved The toggle-argument must be a boolean. When True, cursors for this connection will retrieve information about warnings (if any). Raises ValueError on error. Expected a boolean typeN)rrurrQrrererfrs cCs|jS)zGet whether this connection raises an error on warnings This method returns whether this connection will raise errors when MySQL reports warnings. Returns True or False. )rRrcrererfrs z)MySQLConnectionAbstract.raise_on_warningscCs&t|tstd||_|r"||_dS)aSet whether warnings raise an error The toggle-argument must be a boolean. When True, cursors for this connection will raise an error when MySQL reports warnings. Raising on warnings implies retrieving warnings automatically. In other words: warnings will be set to True. If set to False, warnings will be also set to False. Raises ValueError on error. rN)rrurrRrQrrererfrs cCs|jS)zGet whether there is an unread result This method is used by cursors to check whether another cursor still needs to retrieve its result set. Returns True, or False when there is no unread result. )rSrcrererf unread_results z%MySQLConnectionAbstract.unread_resultcCst|tstd||_dS)zSet whether there is an unread result This method is used by cursors to let other cursors know there is still a result set that needs to be retrieved. Raises ValueError on errors. rN)rrurrSrrererfrs cCst|jdS)a+Returns the character set for current connection This property returns the character set name of the current connection. The server is queried when the connection is active. If not connected, the configured character set name is returned. Returns a string. rr!get_infor?rcrererfrs zMySQLConnectionAbstract.charsetcCs t|jd}|dkrdS|S)ayReturns the Python character set for current connection This property returns the character set name of the current connection. Note that, unlike property charset, this checks if the previously set character set is supported by Python and if not, it returns the equivalent character set that Python supports. Returns a string. r)Zutf8mb4Zutf8mb3binaryutf8r)rdencodingrererfpython_charsets z&MySQLConnectionAbstract.python_charsetzOptional[Union[int, str]])rrr6cCs"d}t|ttfs(|dk r(t|dt|tsB|dk rBtd|rt|trdt|\|_}}qt|trt||\|_}}qt|dn8|rtj|d\|_}}ntd}tj|dd\|_}}| d|d|dz| |Wnt k rYnX|j r|j |dS) aVSets the character set and collation for the current connection This method sets the character set and collation to be used for the current connection. The charset argument can be either the name of a character set as a string, or the numerical equivalent as defined in constants.CharacterSet. When the collation is not given, the default will be looked up and used. For example, the following will set the collation for the latin1 character set to latin1_general_ci: set_charset('latin1','latin1_general_ci') z+{} should be either integer, string or NoneNrz)collation should be either string or None)rz SET NAMES 'z ' COLLATE 'r)rrrrrr!rr?r_execute_queryZset_character_set_namerr] set_charset)rdrrerr_msg charset_nameZcollation_namerererfset_charset_collation#sR     z-MySQLConnectionAbstract.set_charset_collationcCst|jdS)aReturns the collation for current connection This property returns the collation name of the current connection. The server is queried when the connection is active. If not connected, the configured collation name is returned. Returns a string. )r!rr?rcrererfres z!MySQLConnectionAbstract.collationcCsdS)zr"ZCAN_HANDLE_EXPIRED_PASSWORDSr#)rdrrererfconnects   zMySQLConnectionAbstract.connectrr)attemptsdelayr6c Csd}||kr|d}z |||r2WqWnHttfk r|}z&||krld|d|}t||W5d}~XYnX|dkrt|qdS)aAttempt to reconnect to the MySQL server The argument attempts should be the number of times a reconnect is tried. The delay argument is the number of seconds to wait between each retry. You may want to set the number of attempts higher and use delay when you expect the MySQL server to be down for maintenance or when you expect the network to be temporary unavailable. Raises InterfaceError on errors. rrz!Can not reconnect to MySQL after z attempt(s): N)r$r% is_connectedr%IOErrorr&r )rdr&r'counterrmsgrererf reconnects z!MySQLConnectionAbstract.reconnectcCsdS)z;Reports whether the connection to MySQL Server is availableNrercrererfr(sz$MySQLConnectionAbstract.is_connectedF)r,r&r'r6cCsdS)z&Check availability of the MySQL serverNre)rdr,r&r'rererfpingszMySQLConnectionAbstract.pingcCsdS)zCommit current transactionNrercrererfcommitszMySQLConnectionAbstract.commitzOptional[bool]zOptional[type]z'MySQLCursorAbstract')bufferedrawprepared cursor_class dictionary named_tupler6cCsdS)z!Instantiates and returns a cursorNre)rdr/r0r1r2r3r4rererfcursors zMySQLConnectionAbstract.cursorcCsdS)zExecute a queryNrerrererfrsz&MySQLConnectionAbstract._execute_querycCsdS)zRollback current transactionNrercrererfrollbacksz MySQLConnectionAbstract.rollback)consistent_snapshotisolation_levelreadonlyr6cCs|jrtd|rZ|dd}ddddg}||krJtd|d |d ||d k r|jd kr~td |jd|rd}nd}|d|d}|r|d7}||d S)aStart a transaction This method explicitly starts a transaction sending the START TRANSACTION statement to the MySQL server. You can optionally set whether there should be a consistent snapshot, which isolation level you need or which access mode i.e. READ ONLY or READ WRITE. For example, to start a transaction with isolation level SERIALIZABLE, you would do the following: >>> cnx = mysql.connector.connect(..) >>> cnx.start_transaction(isolation_level='SERIALIZABLE') Raises ProgrammingError when a transaction is already in progress and when ValueError when isolation_level specifies an Unknown level. zTransaction already in progressr zREAD UNCOMMITTEDzREAD COMMITTEDzREPEATABLE READZ SERIALIZABLEzUnknown isolation level ""z SET TRANSACTION ISOLATION LEVEL N)r<zMySQL server version z does not support this featurez READ ONLYz READ WRITEzSET TRANSACTION zSTART TRANSACTIONz WITH CONSISTENT SNAPSHOT) rr)rrrrrrCr)rdr7r8r9levelZlevelsZ access_moder rererfstart_transactions2  z)MySQLConnectionAbstract.start_transactionzOptional[Dict[str, Any]])user_variablessession_variablesr6c Cs|stdz |Wn@ttfk r\|jr@tdd||j|j|j |j YnX|sf|r| }|r| D]\}}| d|d|qz|r| D]\}}| d|d|q|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. zMySQL Connection not availablezYReset session is not supported with compression for MySQL server version 5.7.2 or earlierNzSET @`z` = z SET SESSION `)r(r(cmd_reset_connectionr'NotImplementedErrorr`cmd_change_userrFrGrHr?r5rexecuterq)rdr@rAcurrr}rererf reset_sessions4  z%MySQLConnectionAbstract.reset_sessionzOptional[Type[MySQLConverter]]) convclassr6cCsJ|r>t|tr>t|jd}||_|||j|_|j|j_ nt ddS)z Set the converter class to be used. This should be a class overloading methods and members of conversion.MySQLConverter. rzFConverter class should be a subclass of conversion.MySQLConverterBase.N) issubclassr$r!rr?r^rPr]r_Z str_fallbackr)rdrHrrererfrIs z+MySQLConnectionAbstract.set_converter_class Optional[int]Optional[List[DescriptionType]]z-Tuple[List[Any], Optional[Mapping[str, Any]]])countrcolumnsr0 prep_stmtr6cCsdS)z)Get all rows returned by the MySQL serverNre)rdrLrrMr0rNrererfget_rowsXs z MySQLConnectionAbstract.get_rowszOptional[Mapping[str, Any]])rr6cCstdS)zChange the current databaseNrC)rdrrererf cmd_init_dbcsz#MySQLConnectionAbstract.cmd_init_db)r r0r/ raw_as_stringr6cCstdS)z Send a query to the MySQL serverNrP)rdr r0r/rRrererfrgsz!MySQLConnectionAbstract.cmd_queryz(Generator[Mapping[str, Any], None, None]) statementsr6cCstdS)z/Send one or more statements to the MySQL serverNrP)rdrSrererfcmd_query_iterqsz&MySQLConnectionAbstract.cmd_query_iter)optionsr6cCstdS)z,Send the Refresh command to the MySQL serverNrP)rdrUrererf cmd_refreshwsz#MySQLConnectionAbstract.cmd_refreshcCstdS)z,Close the current connection with the serverNrPrcrererfcmd_quit{sz MySQLConnectionAbstract.cmd_quit) shutdown_typer6cCstdS)zShut down the MySQL ServerNrP)rdrXrererf cmd_shutdownsz$MySQLConnectionAbstract.cmd_shutdowncCstdS)z/Send the statistics command to the MySQL ServerNrPrcrererfcmd_statisticssz&MySQLConnectionAbstract.cmd_statisticscCs tddS)akGet the process list of the MySQL Server This method is a placeholder to notify that the PROCESS_INFO command is not supported by raising the NotSupportedError. The command "SHOW PROCESSLIST" should be send using the cmd_query()-method or using the INFORMATION_SCHEMA database. Raises NotSupportedError exception z;Not implemented. Use SHOW PROCESSLIST or INFORMATION_SCHEMAN)r'rerererfcmd_process_infos z(MySQLConnectionAbstract.cmd_process_info) mysql_pidr6cCstdS)zKill a MySQL processNrP)rdr\rererfcmd_process_killsz(MySQLConnectionAbstract.cmd_process_killcCstdS)zSend the DEBUG commandNrPrcrererf cmd_debugsz!MySQLConnectionAbstract.cmd_debugcCstdS)zSend the PING commandNrPrcrererfcmd_pingsz MySQLConnectionAbstract.cmd_pingr8r7) rrrr password1 password2 password3oci_config_filer6c CstdS)z!Change the current logged in userNrP) rdrrrrr`rarbrcrererfrDs z'MySQLConnectionAbstract.cmd_change_user) statementr6cCstdS)zPrepare a MySQL statementNrP)rdrdrererfcmd_stmt_preparesz(MySQLConnectionAbstract.cmd_stmt_preparere Sequence[Any]) statement_iddatarrr6cCstdS)z"Execute a prepared MySQL statementNrP)rdrgrhrrrererfcmd_stmt_executesz(MySQLConnectionAbstract.cmd_stmt_execute)rgr6cCstdS)z%Deallocate a prepared MySQL statementNrPrdrgrererfcmd_stmt_closesz&MySQLConnectionAbstract.cmd_stmt_closer)rgparam_idrhr6cCstdS)zSend data for a columnNrP)rdrgrlrhrererfcmd_stmt_send_long_datasz/MySQLConnectionAbstract.cmd_stmt_send_long_datacCstdS)z3Reset data for prepared statement sent as long dataNrPrjrererfcmd_stmt_resetsz&MySQLConnectionAbstract.cmd_stmt_resetcCstdS)z2Resets the session state without re-authenticatingNrPrcrererfrBsz,MySQLConnectionAbstract.cmd_reset_connection)NN)T)NN)rr)Frr)NNNNNN)FNN)NN)NFNNN)FFF)N)r8r8r8r7r8r8r8r8)rerer)S__name__ __module__ __qualname____doc__rgrirsrtpropertyryrzr|rrrrrrrrrrsetterrrrr staticmethodrrrrrrr r r rrrrrrrrrrr!r"r#r$rq__annotations__r%r,r(r-r.r5rr6r?rGrrOrQrrTrVrWrYrZr[r]r^r_rDrerirkrmrnrBrerererfr3sJ <SRA         B   <0    r3c@seZdZdZddddZddddZdd d dd d d ZedPddddddZeddddZ edQdddddddZ edddddd Z ed!dd"d#Z edRd%d&d'd(d)Z eddd*d+Zddd,d-Zddd.d/d0ZdSdddd2d3d4ZdTddd6d7d8Zeed9dd:d;Zeed%dddd?d@ZedAddBdCZed%ddDdEZdAddFdGZdHddIdJZddddKdLdMZdddNdOZd1S)UMySQLCursorAbstractzAbstract cursor class Abstract class defining cursor class with method and members required by the Python Database API Specification v2.0. r4r5cCs:d|_d|_d|_d|_d|_d|_g|_g|_d|_dS)ZInitializationNrrr) _description _rowcount_last_insert_id _warnings_warning_countZ _executedZ_executed_listZ_stored_resultsZ arraysizercrererfrgszMySQLCursorAbstract.__init__cCs|SrhrercrererfriszMySQLCursorAbstract.__enter__rjrkr rlcCs |dSrhrprrrererfrsszMySQLCursorAbstract.__exit__rerrfr )procnameargsr6cCsdS)aCalls a stored procedure with the given arguments The arguments will be set during this session, meaning they will be called like ___arg where is an enumeration (+1) of the arguments. Coding Example: 1) Defining the Stored Routine in MySQL: CREATE PROCEDURE multiply(IN pFac1 INT, IN pFac2 INT, OUT pProd INT) BEGIN SET pProd := pFac1 * pFac2; END 2) Executing in Python: args = (5,5,0) # 0 is to hold pprod cursor.callproc('multiply', args) print(cursor.fetchone()) Does not return a value, but a result set will be available when the CALL-statement execute successfully. Raises exceptions when something is wrong. Nre)rdr}r~rererfcallprocszMySQLCursorAbstract.callproccCsdS)zClose the cursor.Nrercrererfrq szMySQLCursorAbstract.closeFz$Union[Sequence[Any], Dict[str, Any]]ru) operationrmultir6cCsdS)aExecutes the given operation Executes the given operation substituting any markers with the given parameters. For example, getting all rows where id is 5: cursor.execute("SELECT * FROM t1 WHERE id = %s", (5,)) The multi argument should be set to True when executing multiple statements in one operation. If not set and multiple results are found, an InterfaceError will be raised. If warnings where generated, and connection.get_warnings is True, then self._warnings will be a list containing these warnings. Returns an iterator when multi is True, otherwise None. Nre)rdrrrrererfrEszMySQLCursorAbstract.executez.Sequence[Union[Sequence[Any], Dict[str, Any]]])r seq_paramsr6cCsdS)aExecute the given operation multiple times The executemany() method will execute the operation iterating over the list of parameters in seq_params. Example: Inserting 3 new employees and their phone number data = [ ('Jane','555-001'), ('Joe', '555-001'), ('John', '555-003') ] stmt = "INSERT INTO employees (name, phone) VALUES ('%s','%s')" cursor.executemany(stmt, data) INSERT statements are optimized by batching the data, that is using the MySQL multiple rows syntax. Results are discarded. If they are needed, consider looping over data using the execute() method. Nre)rdrrrererf executemany'szMySQLCursorAbstract.executemanyzOptional[Sequence[Any]]cCsdS)zQReturns next row of a query result set Returns a tuple or None. NrercrererffetchoneAszMySQLCursorAbstract.fetchonerrzList[Sequence[Any]])sizer6cCsdS)a Returns the next set of rows of a query result, returning a list of tuples. When no more rows are available, it returns an empty list. The number of rows returned can be specified using the size argument, which defaults to one Nre)rdrrererf fetchmanyHszMySQLCursorAbstract.fetchmanycCsdS)zRReturns all rows of a query result set Returns a list of tuples. NrercrererffetchallRszMySQLCursorAbstract.fetchallcCsdSzNot Implemented.NrercrererfnextsetYszMySQLCursorAbstract.nextset)sizesr6cCsdSrre)rdrrererf setinputsizes\sz!MySQLCursorAbstract.setinputsizesN)rcolumnr6cCsdSrre)rdrrrererf setoutputsize_sz!MySQLCursorAbstract.setoutputsizeT)freer6cCsdS)zReset the cursor to defaultNre)rdrrererfresetbszMySQLCursorAbstract.resetrKcCs|jS)aReturns description of columns in a result This property returns a list of tuples describing the columns in in a result set. A tuple is described as follows:: (column_name, type, None, None, None, None, null_ok, column_flags) # Addition to PEP-249 specs Returns a list of tuples. )rxrcrererf descriptioneszMySQLCursorAbstract.descriptioncCs|jS)aReturns the number of rows produced or affected This property returns the number of rows produced by queries such as a SELECT, or affected rows when executing DML statements like INSERT or UPDATE. Note that for non-buffered cursors it is impossible to know the number of rows produced before having fetched them all. For those, the number of rows will be -1 right after execution, and incremented when fetching rows. Returns an integer. )ryrcrererfrowcount|szMySQLCursorAbstract.rowcountrJcCs|jS)aReturns the value generated for an AUTO_INCREMENT column Returns the value generated for an AUTO_INCREMENT column by the previous INSERT or UPDATE statement or None when there is no such value available. Returns a long value or None. )rzrcrererf lastrowids zMySQLCursorAbstract.lastrowidzOptional[List[WarningType]]cCs|jS)zReturn warnings.r{rcrererfwarningsszMySQLCursorAbstract.warningscCs|jS)zReturns the number of warnings This property returns the number of warnings generated by the previously executed operation. Returns an integer value. )r|rcrererf warning_counts z!MySQLCursorAbstract.warning_countcCs|jS)zReturns Warnings.rrcrererf fetchwarningssz!MySQLCursorAbstract.fetchwarningszOptional[List[Tuple[Any, Any]]]cCs(t|dr|jjSt|dr$|jjSdS)z&Get the added query attributes so far._cnx _connectionN)hasattrrr|rrcrererfget_attributess   z"MySQLCursorAbstract.get_attributes)rxr}r6cCsnt|tstd|dk r4t|ts4td|dt|drP|j||fnt|drj|j||fdS)z$Add a query attribute and his value.z&Parameter `name` must be a string typeNzObject z$ cannot be converted to a MySQL typerr)rrr)MYSQL_PY_TYPESrrrr)rdrxr}rererf add_attributes    z!MySQLCursorAbstract.add_attributecCs.t|dr|jnt|dr*|jdS)z Remove all the query attributes.rrN)rrrrrcrererfclear_attributess   z$MySQLCursorAbstract.clear_attributes)re)reF)r)N)T)rorprqrrrgrirsrrrqrErrrrrrrrrsrrrrrrrrrrerererfrwsP     rw)Qrr __future__rrrwrweakrefabcrrrrrrdecimalr inspectr r typesr typingr rrrrrrrrrrrrsslrr ImportError constantsrrrrrr r!r" conversionr#r$errorsr%r&r'r(r)Z optionfilesr*r+r,r-r.r/r0r1WeakValueDictionaryr2rvrrrrrrfloatrrrr3rwrerererfsr     8(  $  Q