B Roa`,@sdZddlZddlmZmZddlmZmZmZm Z m Z m Z m Z m Z mZmZddddd d Zed Zd d ZGdddejZdS)a This module implements connections for MySQLdb. Presently there is only one class: Connection. Others are unlikely. However, you might want to make your own subclasses. In most cases, you will probably override Connection.default_cursor with a non-standard Cursor class. N)cursors_mysql) WarningErrorInterfaceError DataError DatabaseErrorOperationalErrorIntegrityError InternalErrorNotSupportedErrorProgrammingErrorutf8cp1252koi8_rkoi8_u)Zutf8mb4Zutf8mb3latin1Zkoi8rZkoi8uz^(\d+)cCs t|}|rt|dSdS)zReturns the leading numeric part of a string. >>> numeric_part("20-alpha") 20 >>> numeric_part("foo") >>> numeric_part("16b") 16 rN)re_numeric_partmatchintgroup)smrX/var/www/pobierzsterownik/drivers_env/lib/python3.7/site-packages/MySQLdb/connections.py numeric_part#s rcseZdZdZejZfddZddZddZ dd Z dd d Z d dZ ddZ ddZddZddZfddZddZddZeZeZeZeZeZeZeZeZeZeZZS) Connectionz MySQL Database Connection Objectcsdddlm}m}ddlm}m}ddlm}|}d|krJ| d|d<d|kr`| d|d<d |krr|d } n|} i} xB| D]6\} } t | t rt | t r| d d | | <q| | | <qW| |d <| d |j} |d d }| dd}| dd }| dd|_|dd}||jO}| dd}|r8||jO}||d<| dd}tj||| |_dd| D|_tdd|dd dD|_d|_|s|}|||r|||rx4|j|j |j!|j"|j#|j$|j%fD]}||j&|<qWt'|j&|j(<||dfdd }||jt'<|j)|j*@|_+|j+rZ|d k rZ|,|g|_-d S) a Create a connection to the database. It is strongly recommended that you only use keyword parameters. Consult the MySQL C API documentation for more information. :param str host: host to connect :param str user: user to connect as :param str password: password to use :param str passwd: alias of password (deprecated) :param str database: database to use :param str db: alias of database (deprecated) :param int port: TCP/IP port to connect to :param str unix_socket: location of unix_socket to use :param dict conv: conversion dictionary, see MySQLdb.converters :param int connect_timeout: number of seconds to wait before the connection attempt fails. :param bool compress: if set, compression is enabled :param str named_pipe: if set, a named pipe is used to connect (Windows only) :param str init_command: command which is run once the connection is created :param str read_default_file: file from which default client values are read :param str read_default_group: configuration group to use from the default file :param type cursorclass: class object, used to create cursors (keyword only) :param bool use_unicode: If True, text-like columns are returned as unicode objects using the connection's character set. Otherwise, text-like columns are returned as bytes. Unicode objects will always be encoded to the connection's character set regardless of this setting. Default to True. :param str charset: If supplied, the connection character set will be changed to this character set. :param str auth_plugin: If supplied, the connection default authentication plugin will be changed to this value. Example values: `mysql_native_password` or `caching_sha2_password` :param str sql_mode: If supplied, the session SQL mode will be changed to this setting. For more details and legal values, see the MySQL documentation. :param int client_flag: flags to use or 0 (see MySQL docs or constants/CLIENTS.py) :param bool multi_statements: If True, enable multi statements for clients >= 4.1. Defaults to True. :param str ssl_mode: specify the security settings for connection to the server; see the MySQL documentation for more details (mysql_option(), MYSQL_OPT_SSL_MODE). Only one of 'DISABLED', 'PREFERRED', 'REQUIRED', 'VERIFY_CA', 'VERIFY_IDENTITY' can be specified. :param dict ssl: dictionary or mapping contains SSL connection parameters; see the MySQL documentation for more details (mysql_ssl_set()). If this is set, and the client does not support SSL, NotSupportedError will be raised. :param bool local_infile: enables LOAD LOCAL INFILE; zero disables :param bool autocommit: If False (default), autocommit is disabled. If True, autocommit is enabled. If None, autocommit isn't set and server default is used. :param bool binary_prefix: If set, the '_binary' prefix will be used for raw byte query arguments (e.g. Binary). This is disabled by default. There are a number of undocumented, non-standard methods. See the documentation for the MySQL C API for some hints on what they do. r)CLIENT FIELD_TYPE) conversions _bytes_or_str)proxydbZdatabasepasswdpasswordconvN cursorclasscharset use_unicodeTsql_modeZ binary_prefixF client_flagmulti_statements autocommitcSs"i|]\}}t|tk r||qSr)typer).0kvrrr sz'Connection.__init__..cSsg|] }t|qSr)r)r0nrrr sz'Connection.__init__...asciics|jS)N)string_literalencodeencoding)udummy)r#rrunicode_literalsz,Connection.__init__..unicode_literal)N).ZMySQLdb.constantsrrZMySQLdb.convertersr r!weakrefr"copypopitems isinstancerlistdefault_cursorget_binary_prefixZ MULTI_RESULTSZMULTI_STATEMENTSsuper__init__r'encoderstupleZget_server_infosplit_server_versionr;Zcharacter_set_nameset_character_set set_sql_modeSTRINGZ VAR_STRINGZVARCHARZ TINY_BLOBZ MEDIUM_BLOBZ LONG_BLOBZBLOB converterstrZJSONZserver_capabilitiesZ TRANSACTIONSZ_transactionalr.messages)selfargskwargsrrr r!r"Zkwargs2r&Zconv2r1r2r'r(r*r+r,r-r.tr>) __class__)r#rrI8svY           $       zConnection.__init__cCs|S)Nr)rTrrr __enter__szConnection.__enter__cCs |dS)N)close)rTexc_type exc_value tracebackrrr__exit__szConnection.__exit__cCs&t|}||kr"tj||dS)N)boolZget_autocommitr connectionr.)rTonrrrr.s zConnection.autocommitNcCs|p|j|S)z Create a cursor on which queries may be performed. The optional cursorclass parameter is used to create the Cursor. By default, self.cursorclass=cursors.Cursor is used. )r')rTr'rrrcursorszConnection.cursorcCs$t|trt|}tj||dS)N)rC bytearraybytesrr`query)rTrerrrres zConnection.querycCs.t|ttfst||}|jr*d|S|S)Ns_binary)rCrdrcAssertionErrorr9rG)rTbsxrrr_bytes_literals  zConnection._bytes_literalcCsddt|j|S)Ns(%s),)joinmapliteral)rTrWrrr_tuple_literalszConnection._tuple_literalcCst|tr|||j}njt|tr4||}nTt|trJ||}n>t|tt frd| |}n$| ||j }t|tr||j}t|tst |S)aIf o is a single object, returns an SQL literal as a string. If o is a non-string sequence, the items of the sequence are converted and returned as a sequence. Non-standard. For internal use; do not use this in your applications. )rCrRr9r:r;rcrirdrKrDrnescaperJrf)rTorrrrrm s        zConnection.literalcCs|ddS)ziExplicitly begin a connection. This method is not used when autocommit=False (default). sBEGINN)re)rTrrrbegin!szConnection.begincst|t|||_dS)z,Set the connection character set to charset.N)rHrN_charset_to_encodingrFr;)rTr()rXrrrN(s zConnection.set_character_setcCs,|jdkrtd|d||dS)zNSet the connection sql_mode. See MySQL documentation for legal values.)rz!server is too old to set sql_modezSET SESSION sql_mode='%s'N)rMr re store_result)rTr+rrrrO-s zConnection.set_sql_modecCs.|jdkrdS|d|}|d}|S)zReturn detailed information about warnings as a sequence of tuples of (Level, Code, Message). This is only supported in MySQL-4.1 and up. If your server is an earlier version, an empty sequence is returned.)rsrrz SHOW WARNINGSr)rMrertZ fetch_row)rTrwarningsrrr show_warnings5s    zConnection.show_warnings)N)__name__ __module__ __qualname____doc__rZCursorrErIrYr^r.rbrerirnrmrqrNrOrwrrrr rr r r rr __classcell__rr)rXrr3s4 /   r)r{rer)rr _exceptionsrrrrr r r r r rrrcompilerrr`rrrrrs0