U æãf }ã/@sÐdZddlZddlZddlZddlZddlmZmZmZzddl m Z Wne k r`e Z YnXddl mZmZddlmZmZmZmZmZmZddlmZmZmZmZdd 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 lCmDZCe Ed¡ZFe EdejG¡ZHe EdejG¡ZIe Ed¡ZJddddddgZKeKddddddddd d!d"d#d$d%d&gZLe MeN¡ Oe P¡¡d'ZQd(ZRd)ZSd*ZTd+d,gZd-d.gZUd/ZVeWed0ƒrejXrd1ZVd2d3„ZYd4d5„ZZd6d7„Z[dsd8d9„Z\d:d;„Z]dd?„Z_d@dA„Z`dBdC„ZadDdE„ZbdFdGdEdCdHdIdJdKdLdMdNdOdPdQdRdSdTdUdVdWdXdYdZd[d\d]d^d_d`dadbdcdddedfdgdhdidjdkdldmdndodpdqdrg/ZcdS)tz$MySQL X DevAPI Python implementationéN)Ú parse_qslÚunquoteÚurlparse)ÚJSONDecodeErroré)ÚClientÚSession)ÚAuthÚLockContentionÚOPENSSL_CS_NAMESÚSSLModeÚ TLS_VERSIONSÚTLS_CIPHER_SUITES)ÚSchemaÚ CollectionÚTableÚView)ÚDbDoc) ÚErrorÚInterfaceErrorÚ DatabaseErrorÚNotSupportedErrorÚ DataErrorÚIntegrityErrorÚProgrammingErrorÚOperationalErrorÚ InternalErrorÚ PoolErrorÚ TimeoutError)ÚColumnÚRowÚResultÚBufferingResultÚ RowResultÚ SqlResultÚ DocResultÚ ColumnType)Ú StatementÚFilterableStatementÚ SqlStatementÚ FindStatementÚ AddStatementÚRemoveStatementÚModifyStatementÚSelectStatementÚInsertStatementÚDeleteStatementÚUpdateStatementÚCreateCollectionIndexStatementÚExprÚ ReadStatementÚWriteStatement)Ú ExprParserz,(?![^\(\)]*\))z!^\(address=(.+),priority=(\d+)\)$z^\(address=(.+)[,]*\)$z"^([a-zA-Z][a-zA-Z0-9+\-.]+)://(.*)ússl-certússl-caússl-keyússl-crlú tls-versionsútls-ciphersuitesÚuserÚpasswordÚschemaÚhostÚportÚroutersÚsocketússl-modeÚauthzuse-pureúconnect-timeoutúconnection-attributesÚ compressionúcompression-algorithmsúdns-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 {}).zHThe given tls_version: '{}' are no longer allowed (should be one of {}).zINo supported TLS protocol version found in the 'tls-versions' list '{}'. zTLSv1.2úTLSv1.3ÚTLSv1zTLSv1.1FÚ HAS_TLSv1_3Tc Cs‚| dd¡}d|ko.| d¡dko.| d¡dk oD| d¡oD| d¡}g}t |r^|dd…n|¡}d }|D]Ô}i}t |¡}|r¨| d¡}t | d ¡ƒ|d <|d7}n t  |¡}|rÈ| d¡}d |d <t d   |¡ƒ}|j sêtd  |¡ƒ‚z|j|j |jdWn4tk r4}ztd  |¡dƒ‚W5d}~XYnX| |¡qld |kr^t|ƒkrlnn tddƒ‚|rzd|iS|d S)zÛParses 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ú[ú]éÿÿÿÿréÚpriorityédz//{0}zInvalid address: {0})r@rAzInvalid URI: {0}i¢Nz\You must either assign no priority to any of the routers or give a priority for every routeri rB)ÚreplaceÚcountÚ startswithÚendswithÚ _SPLIT_REÚsplitÚ _PRIORITY_REÚmatchÚgroupÚintÚ _ROUTER_RErÚformatÚhostnamerÚupdaterAÚ ValueErrorrÚappendÚlen) ÚpathÚarrayrBZ address_listZpriority_countÚaddressÚrouterr_Úerr©rnú3/tmp/pip-unpacked-wheel-mzf9r1ws/mysqlx/__init__.pyÚ_parse_address_listbsF  ÿÿþ     "  þrpcCsèddi}t |¡}|r| ¡nd|f\}}|dkr@td |¡ƒ‚|dkrPd|d<| d ¡d d d …\}}| d ¡d d d …\}}| d ¡}||d … d¡dkr¼|dkr¼| d d¡\}|d<|  d¡}|rÖ|rÖd|krätd |¡ƒ‚|  dd¡\} } t | ƒt | ƒ|d<|d<|  d¡r(t |ƒ|d<n$|  d¡r>tdƒ‚n|  t|ƒ¡d} t|dƒD]ˆ\} } |  dd¡ ¡}|| krŠtd | ¡ƒ‚|tkr¨t |   d¡ƒ||<n8|  ¡}|dkrÄd||<n|d krØd!||<n|||<qZ|S)"aqParses 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 invalid option. r?rOÚmysqlx)rqú mysqlx+srvzScheme '{0}' is not validrrTrJú@NrUú?ú/ú)rTrrz()rQzMalformed URI '{0}'r=r>)ruz..Ú.rCz\.zWindows Pipe is not supported)r=r>rJÚ_ú-zInvalid option: '{0}')Ú1Útrue)Ú0ÚfalseF)Ú_URI_SCHEME_REr_ÚgroupsrrcÚ partitionÚrfindÚfindÚrsplitÚstripr]rrZrerprrXÚlowerÚ _SSL_OPTS)ÚuriÚsettingsr_ÚschemeÚuserinfoÚtmpr@Z query_strÚposr=r>Zinvalid_optionsÚkeyÚvalÚoptZval_strrnrnroÚ_parse_connection_uri•sH             rc Cszt| ¡ƒ t¡}|r*td d |¡¡ƒ‚d|krL|dD]}t|dƒq:nd|kr\t|ƒd|kr²z"|d ¡|d<t   |d¡Wn*t t fk r°td |d¡ƒ‚YnXd|krÊd |krÊtd ƒ‚d |krâd |krâtd ƒ‚d |kr |  d¡t jt jfkr tdƒ‚d |kr:|  d¡t jt jt jfkr:tdƒ‚d|kr”z"|d ¡|d<t  |d¡Wn,t t fk r’td |d¡ƒ‚YnXd|krÒ|d ¡ ¡}|dkrÊtd |d¡ƒ‚||d<d|krRt|dtƒr|d ¡ d¡}|r| d¡|d<nd|d<nt|dttfƒs:tdƒ‚|  d¡dkrRd|d<d|krdt|ƒd|krÔzFt|dtƒrt|dƒ|d<t|dtƒr®|ddkr²t ‚Wnt k rÒtdƒ‚YnXd|kr4t|dtƒsötd ƒ‚|  d!¡r td"ƒ‚|  d#¡rtd$ƒ‚|  d¡rRtd%ƒ‚nd|krR|  d#¡sRd|d#<d&|krdt|ƒd'|krvt|ƒdS)(anValidates the settings to be passed to a Session object the port values are converted to int if specified or set to 33060 otherwise. The priority values for each router is converted to int if specified. Args: settings: dict containing connection settings. Raises: :class:`mysqlx.InterfaceError`: On any configuration issue. zInvalid option(s): '{0}'z', 'rBi$r@rDzInvalid SSL Mode '{0}'r:r8zCA Certificate not providedr9r7zClient Certificate not providedzCannot verify Server without CAz$Must verify Server if CA is providedrEzInvalid Auth '{0}'rH)Ú preferredÚrequiredÚdisabledz†The connection property 'compression' acceptable values are: 'preferred', 'required', or 'disabled'. The value '{0}' is not acceptablerIz[]rPNz@Invalid type of the connection property 'compression-algorithms'r“rGrFrzEThe connection timeout value must be a positive integer (including 0)rJz(The value of 'dns-srv' must be a booleanrCz>sÿz._validate_tls_ciphersuites..zLtls-ciphersuites should be a list with one or more ciphersuites. Found: '{}'r;T)ÚreverserryÚtls_ciphersuitesr´z;The value '{}' in cipher suites is not a valid cipher suite)rržrZr[rrcr]r„ÚupperrgrŸr”rœr rºršrerÚextendr r›r¶) rˆrÂZtls_ciphersuites_settingsZtls_cssr¿r³Z newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namesr½ÚnameZtranslated_namernrnror¥ sz   ÿÿ   þ ÿÿ    ÿÿ ÿÿr¥cOs˜i}|rZt|dtƒr$t|dƒ}q€t|dtƒr€|d ¡D]\}}||| dd¡<q>n&|r€| ¡D]\}}||| dd¡<qf|sŒtdƒ‚t|ƒ|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. rrxryzSettings not provided)rržrr­ÚitemsrXrr¦)ÚargsÚkwargsrˆrrŽrnrnroÚ_get_connection_settingsssrÉcOst||Ž}t|ƒS)a°Creates 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. )rÉr)rÇrÈrˆrnrnroÚ get_session—s rÊcCsTt|ttfƒstdƒ‚t|ƒ}t|ttfƒs4tdƒ‚t|tƒrlzt |¡}Wq’tk rhtdƒ‚Yq’Xn&i}| ¡D]\}}|||  dd¡<qxt|tƒs¤tdƒ‚i}d|krJ|  d¡}t|tƒsÎtdƒ‚|  dd ¡|d<|  d d ¡|d <|  d d ¡|d <|  dd ¡|d<t |ƒd kr*td  |¡ƒ‚t |ƒd krJtd  |  ¡¡ƒ‚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 dictryrxZpoolingz<'pooling' options must be given in the form document or dictZenabledTÚmax_sizeéZ max_idle_timerZ queue_timeoutz Unrecognized pooling options: {}z#Unrecognized connection options: {})rržr­rrÉÚjsonÚloadsrrÆrXÚpoprhrcr•r)Zconnection_stringZoptions_stringZ settings_dictZ options_dictrrµZpooling_options_dictZpooling_optionsrnrnroÚ get_client¨sF2      ÿ ÿÿÿrÐrrÚexprr r r rrrrrrrrrrrrrrrrr r!r"r#r$r%r&rr'r(r)r*r+r,r-r.r/r0r1r4r5r2r3)N)dÚ__doc__ÚrerÍÚloggingÚsslÚ urllib.parserrrZ json.decoderrÚ ImportErrorrfÚ connectionrrÚ constantsr r r r r rZcrudrrrrZdbdocrÚerrorsrrrrrrrrrrrÚresultrr r!r"r#r$r%r&Z statementr'r(r)r*r+r,r-r.r/r0r1r2r3r4r5rÑr6Úcompiler\ÚVERBOSEr^rbr~r†r—Ú getLoggerÚ__name__Ú addHandlerÚ NullHandlerr¶r¼r»r¹r·r¸ÚhasattrrMrprr¦r™r¡r¤r¥rÉrÊrÐÚ__all__rnrnrnroÚsÒ   4(D    ÿ ýÿ3?n mRS$dè