3 (hg}-@sdZddlZddlZddlZddlZddlmZddlmZm Z m Z m Z m Z m Z ddlmZmZddlmZmZmZmZmZmZddlmZmZmZmZdd lmZdd lmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)dd l*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2dd l3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@mAZAmBZBdd lCmDZCejEdZFejEdejGZHejEdejGZIejEdZJddddddgZKeKddddddddd d!d"d#d$d%d&gZLejMeNjOejPd'ZQd(ZRd)ZSd*d+d,d-gZd.ZTeUed/rejVrd0ZTd1d2ZWd3d4ZXd5d6ZYdpd7d8ZZd9d:Z[d;d<Z\d=d>Z]d?d@Z^dAdBZ_dCdDZ`dEdFdDdBdGdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndog-ZadS)qz$MySQL X DevAPI Python implementationN) constants) INT_TYPES STRING_TYPESJSONDecodeErrorurlparseunquote parse_qsl)ClientSession)AuthLockContentionOPENSSL_CS_NAMESSSLMode TLS_VERSIONSTLS_CIPHER_SUITES)Schema CollectionTableView)DbDoc) ErrorInterfaceError DatabaseErrorNotSupportedError DataErrorIntegrityErrorProgrammingErrorOperationalError InternalError PoolError TimeoutError)ColumnRowResultBufferingResult RowResult SqlResult DocResult ColumnType) StatementFilterableStatement SqlStatement FindStatement AddStatementRemoveStatementModifyStatementSelectStatementInsertStatementDeleteStatementUpdateStatementCreateCollectionIndexStatementExpr ReadStatementWriteStatement) ExprParserz,(?![^\(\)]*\))z!^\(address=(.+),priority=(\d+)\)$z^\(address=(.+)[,]*\)$z"^([a-zA-Z][a-zA-Z0-9+\-.]+)://(.*)zssl-certzssl-cazssl-keyzssl-crlz tls-versionsztls-ciphersuitesuserpasswordschemahostportrouterssocketzssl-modeauthzuse-purezconnect-timeoutzconnection-attributes compressionzcompression-algorithmszdns-srvzVThe '{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 {}).zINo supported TLS protocol version found in the 'tls-versions' list '{}'. ZTLSv1zTLSv1.1zTLSv1.2zTLSv1.3F HAS_TLSv1_3Tc Cs|jdd}d|ko.|jddko.|jddk oD|jdoD|jd}g}tj|r^|ddn|}d}x|D]}i}tj|}|r|jd}t |jd |d <|d7}n t j|}|r|jd}d |d <t d j |}|j std j |y|j|j |jdWn4tk r6}ztdj |dWYdd}~XnX|j|qnWd|ko^t|knrptdd|r~d|iS|dS)zParses a list of host, port pairs Args: path: String containing a list of routers or just router Returns: Returns a dict with parsed values of host, port and priority if specified.  ,:r[]rprioritydz//{0}zInvalid address: {0})r=r>zInvalid URI: {0}iNz\You must either assign no priority to any of the routers or give a priority for every routerir?)replacecount startswithendswith _SPLIT_REsplit _PRIORITY_REmatchgroupint _ROUTER_RErformathostnamerupdater> ValueErrorrappendlen) patharrayr?Z address_listZpriority_countaddressrouterrUerrrdC/tmp/pip-install-q3hcpn_q/mysql-connector-python/mysqlx/__init__.py_parse_address_listYs<        " rfcCsddi}tj|}|r|jnd|f\}}|d#kr@tdj||dkrPd|d<|jdd d d \}}|jd d d d \}}|jd }||d jd d$kr|dkr|jd d\}|d<|j d}| s| sd|krtdj||j dd\} } t | t | |d<|d<|j d%r,t ||d<n$|j drBtdn|j t|d&} xt|dD]\} } | jddj}|| krtdj| ||krtdj| |tkrt | j d||<n8| j}|d'krd||<n|d(krd"||<n|||<q`W|S))aParses the connection string and returns a dictionary with the connection settings. Args: uri: mysqlx URI scheme to connect to a MySQL server/farm. Returns: Returns a dict with parsed values of credentials and address of the MySQL server/farm. Raises: :class:`mysqlx.InterfaceError`: If contains a duplicate option or URI scheme is not valid. r<rEmysqlx mysqlx+srvzScheme '{0}' is not validTdns-srv@NrJ?/)rrz()rGzMalformed URI '{0}'r:r;...r@z\.zWindows Pipe is not supported_-zInvalid option: '{0}'zDuplicate option: '{0}'1true0falseF)rgrhrM)rlrnro)r:r;ri)rrrs)rtru)_URI_SCHEME_RErUgroupsrrY partitionrfindfindrsplitstriprSrrPr[rfr rNlower _SSL_OPTS)urisettingsrUschemeuserinfotmpr=Z query_strposr:r;Zinvalid_optionskeyvaloptZval_strrdrdre_parse_connection_urisL             rcstjjt}|r*tdjdj|dkrPx,dD]}t|dqsz%_validate_settings..z)SSL options used with ssl-mode 'disabled'zssl-crlzssl-cazCA Certificate not providedzssl-keyzssl-certzClient Certificate not providedzCannot verify Server without CAz$Must verify Server if CA is providedrAzInvalid Auth '{0}'rB preferredrequireddisabledzThe connection property 'compression' acceptable values are: 'preferred', 'required', or 'disabled'. The value '{0}' is not acceptablezcompression-algorithmsz[]rFNz@Invalid type of the connection property 'compression-algorithms'zconnection-attributeszconnect-timeoutrzEThe connection timeout value must be a positive integer (including 0)zdns-srvz(The value of 'dns-srv' must be a booleanr@zz;Specifying a port number with DNS SRV lookup is not allowedzASpecifying multiple hostnames with DNS SRV look up is not allowedz tls-versionsztls-ciphersuites)rrr)!setkeys difference _SESS_OPTSrrYjoin_validate_hostsr}rindexAttributeErrorr\ZDISABLEDanyr~getZVERIFY_IDENTITYZ VERIFY_CAr r| isinstancerrSlisttuple_validate_connection_attributesrWr TypeErrorbool_validate_tls_versions_validate_tls_ciphersuites)rZ invalid_optsrbrBZcompression_algorithmsrd)rre_validate_settingss                rcCsd|kr|dry6t|d|d<|ddks:|ddkrDtddWnDtk rdtddYn(tk rtdj|ddYnXd|kr|dryt|d|d<Wqtk rtd YqXnd |kr|r||d<d S) zValidate hosts. Args: settings (dict): Settings dictionary. default_port (int): Default connection port. Raises: :class:`mysqlx.InterfaceError`: If priority or port are invalid. rKrrLz1Invalid priority value, must be between 0 and 100izInvalid priorityzInvalid priority: {}r>z Invalid portr=N)rWr NameErrorr\rYr)r default_portrdrdrer?s$   rc Csi}d|krdS|d}t|tr|dkr8i|d<dS|jdoJ|jd rf|dkrftd j|n|dkr|dkrd |d<ni|d<dS|d djd }xb|D]Z}|dkrq|jd}|d}t|d kr|d nd}||krtdj|q|||<qWn.t|trHx2|D]*}||}t|ts8t |}|||<qWnt|t s^|dkrz|rni|d<nd |d<dSt|t rx|D]}d||<qWnt|t rx|D]b}|dkrĐq|jd}|d}t|d kr|d nd}||kr tdj|n|||<qWnt|t s4tdj||rx|D]}||}t|tsftdj|t|dkrtdj||jdrtdj|t|tstdj||t|dkr@tdj||q@W||d<dS)zValidate connection-attributes. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If attribute name or value exceeds size. zconnection-attributesNrErHrIFalseruTruersz`The value of 'connection-attributes' must be a boolean or a list of key-value pairs, found: '{}'FrrF=rz0Duplicate key '{}' used in connection-attributeszOconnection-attributes must be Boolean or a list of key-value pairs, found: '{}'z(Attribute name '{}' must be a stringtype z4Attribute name '{}' exceeds 32 characters limit sizerpzEKey names in connection-attributes cannot start with '_', found: '{}'z0Attribute '{}' value: '{}' must be a string typeiz=Attribute '{}' value: '{}' exceeds 1024 characters limit size)rrurrs)rrurrs)rrurM)rr) rrrPrQrrYrSr^dictreprrrr) r attributesZ conn_attrsZconn_attributesattrZ attr_name_val attr_nameZattr_val attr_valuerdrdrer^s                          rcCsg}d|krdS|d}t|tr|jdo4|jdsFtdj|np|ddjd}x\|D]T}|j}|dkrtq^|tkrtt j|tq^||krtt jd |d |j |q^Wnt|t r"|std x|D]F}|tkrtt j|tq||krtt jd |d q|j |qWnZt|t rfxL|D],}|tkrTtt j|tn |j |q4Wntd jd jt||std |dgkrt rttj|t||d<dS)zValidate tls-versions. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-versions name is not valid. z tls-versionsNrHrIz(tls-versions must be a list, found: '{}'rrFrE tls_versions)rvaluezKAt least one TLS protocol version must be specified in 'tls-versions' list.zMtls-versions should be a list with one or more of versions in {}. found: '{}'z, zTLSv1.3rM)rrrPrQrrYrSr|rTLS_VERSION_ERRORDUPLICATED_IN_LIST_ERRORr]rrrTLS_V1_3_SUPPORTEDTLS_VER_NO_SUPPORTED)rrZtls_versions_settingsZtls_verstls_verZ tls_versionrdrdrers`                 rc Csg}d|krdS|d}t|tr|jdo4|jdsFtdj|q|ddjd}|sdtdxx|D]}|jj}|rj|j |qjWnPt|t rd d |D}n6t|t rx*|D]}|r|j |qWntd j||j d ddkrt ddn|d dd}|jd d|d}g}i}g} x2sz._validate_tls_ciphersuites..zLtls-ciphersuites should be a list with one or more ciphersuites. Found: '{}'z tls-versionsT)reverserrqtls_ciphersuites)rrz;The value '{}' in cipher suites is not a valid cipher suiterM)rrrPrQrrYrSr|upperr]rrrrsortrr[rextendrrr) rrZtls_ciphersuites_settingsZtls_cssrrZ newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namesrnameZtranslated_namerdrdrersd           $      rcOsi}|r^t|dtr$t|d}qt|dtrxT|djD]\}}|||jdd<q@Wn*|rx$|jD]\}}|||jdd<qlW|stdt||S)aZParses the connection string and returns a dictionary with the connection settings. Args: *args: Variable length argument list with the connection data used to connect to the database. It can be a dictionary or a connection string. **kwargs: Arbitrary keyword arguments with connection data used to connect to the database. Returns: mysqlx.Session: Session object. Raises: TypeError: If connection timeout is not a positive integer. :class:`mysqlx.InterfaceError`: If settings not provided. rrprqzSettings not provided)rrrritemsrNrr)argskwargsrrrrdrdre_get_connection_settingsgsrcOst||}t|S)aCreates a Session instance using the provided connection data. Args: *args: Variable length argument list with the connection data used to connect to a MySQL server. It can be a dictionary or a connection string. **kwargs: Arbitrary keyword arguments with connection data used to connect to the database. Returns: mysqlx.Session: Session object. )rr )rrrrdrdre get_sessions rc CsXt|ttfstdt|}t|ttfs4tdt|trlytj|}Wqtk rhtdYqXn*i}x$|jD]\}}|||j dd<qzWt|tstdi}d|krN|j d}t|tstd|j dd |d<|j d d |d <|j d d |d <|j dd |d<t |d kr.tdj |t |d krNtdj |j t||S)a8Creates a Client instance with the provided connection data and settings. Args: connection_string: A string or a dict type object to indicate the connection data used to connect to a MySQL server. The string must have the following uri format:: cnx_str = 'mysqlx://{user}:{pwd}@{host}:{port}' cnx_str = ('mysqlx://{user}:{pwd}@[' ' (address={host}:{port}, priority=n),' ' (address={host}:{port}, priority=n), ...]' ' ?[option=value]') And the dictionary:: cnx_dict = { 'host': 'The host where the MySQL product is running', 'port': '(int) the port number configured for X protocol', 'user': 'The user name account', 'password': 'The password for the given user account', 'ssl-mode': 'The flags for ssl mode in mysqlx.SSLMode.FLAG', 'ssl-ca': 'The path to the ca.cert' "connect-timeout": '(int) milliseconds to wait on timeout' } options_string: A string in the form of a document or a dictionary type with configuration for the client. Current options include:: options = { 'pooling': { 'enabled': (bool), # [True | False], True by default 'max_size': (int), # Maximum connections per pool "max_idle_time": (int), # milliseconds that a # connection will remain active while not in use. # By default 0, means infinite. "queue_timeout": (int), # milliseconds a request will # wait for a connection to become available. # By default 0, means infinite. } } Returns: mysqlx.Client: Client object. .. versionadded:: 8.0.13 z(connection_data must be a string or dictz+connection_options must be a string or dictzA'pooling' options must be given in the form of a document or dictrqrpZpoolingz<'pooling' options must be given in the form document or dictZenabledTmax_sizeZ max_idle_timerZ queue_timeoutz Unrecognized pooling options: {}z#Unrecognized connection options: {})rrrrrjsonloadsrrrNpopr^rYrr )Zconnection_stringZoptions_stringZ settings_dictZ options_dictrrZpooling_options_dictZpooling_optionsrdrdre get_clients>2      rr r exprr r rrrrrrrrrrrrrrr r!r"r#r$r%r&r'r(r)rr*r+r,r-r.r/r0r1r2r3r4r5r6)N)b__doc__rerloggingsslrErcompatrrrrrr connectionr r r r rrrrZcrudrrrrZdbdocrerrorsrrrrrrrrrr r!resultr"r#r$r%r&r'r(r)Z statementr*r+r,r-r.r/r0r1r2r3r4r5r6r7r8rr9compilerRVERBOSErTrXrvr~r getLogger__name__ addHandler NullHandlerrrrrhasattrrCrfrrrrrrrrr__all__rdrdrdresl    4(D        3Bq mIS$d