o b1}@sBdZddlZddlZddlZddlZddlmZmZmZzddl m Z Wn e y/e Z Ynwddl 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 lCmDZCeEdZFeEdejGZHeEdejGZIeEdZJgdZKeKgdZLeMeNOePdZQdZRdZSgdZdZTeUedrejVrdZTddZWddZXdd ZYd0d!d"ZZd#d$Z[d%d&Z\d'd(Z]d)d*Z^d+d,Z_d-d.Z`gd/ZadS)1z$MySQL X DevAPI Python implementationN) parse_qslunquoteurlparse)JSONDecodeError)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+\-.]+)://(.*))ssl-certssl-cassl-keyssl-crl tls-versionstls-ciphersuites)userpasswordschemahostportrouterssocketssl-modeauthzuse-pureconnect-timeoutconnection-attributes compressioncompression-algorithmsdns-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 '{}'. )TLSv1zTLSv1.1zTLSv1.2TLSv1.3F HAS_TLSv1_3Tc Csp|dd}d|vo|ddko|ddk o"|do"|d}g}t|r/|ddn|}d }|D]d}i}t|}|rT|d}t |d |d <|d7}nt |}|rd|d}d |d <t d |}|j sutd |z |j|j |jdWnty}ztd |dd}~ww||q6d |krt|krnntdd|rd|iS|d S)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@rAzInvalid URI: {0}iNz\You must either assign no priority to any of the routers or give a priority for every routerirB)replacecount startswithendswith _SPLIT_REsplit _PRIORITY_REmatchgroupint _ROUTER_RErformathostnamerupdaterA ValueErrorrappendlen) patharrayrBZ address_listZpriority_countaddressrouterr_errrnN/var/www/secure340b-portal/env/lib/python3.10/site-packages/mysqlx/__init__.py_parse_address_list]sJ        rpcCsddi}t|}|r|nd|f\}}|dvr td||dkr(d|d<|d d d d \}}|d d d d \}}|d }||d ddkr^|dkr^|d d\}|d<| d}|rk|rkd|vrrtd|| dd\} } t | t | |d<|d<| drt ||d<n| drtd| t|d} t|dD]J\} } | dd}|| vrtd| ||vrtd| |tvrt | d||<q| }|d vrd||<q|d!vrd"||<q|||<q|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?rOmysqlx)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}'zDuplicate option: '{0}')1true)0falseF)_URI_SCHEME_REr_groupsrrc partitionrfindfindrsplitstripr]rrZrerprrXlower _SSL_OPTS)urisettingsr_schemeuserinfotmpr@Z query_strposr=r>Zinvalid_optionskeyvaloptZval_strrnrnro_parse_connection_urisL        rc stt}|rtdd|dvr&dD]}t|dqndvr.tdvrlzdd<t dWnt t fyUtddwdt j krltfdd tDrltd d vrxd vrxtd dvrdvrtdd vrdt jt jfvrtdd vrdt jt jfvrtddvrzdd<t dWnt t fytddwdvrd}|dvrtdd|d<dvr/tdtrdd}|r|dd<ndd<ntdttfs#tdddkr/dd<dvr8tdvrmz#tdtrNtdd<tdtr]dd kr_t Wn t yltd!wd"vrtd"ts~td#d$rtd%d&rtd'drtd(ndvrd&sdd&<d)vrtd*vrtdSdS)+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}'c3s|]}|vVqdSNrn).0rrrnro sz%_validate_settings..z)SSL options used with ssl-mode 'disabled'r:r8zCA Certificate not providedr9r7zClient Certificate not providedzCannot verify Server without CAz$Must verify Server if CA is providedrEzInvalid Auth '{0}'rH) preferredrequireddisabledzThe 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'rrGrFrzEThe connection timeout value must be a positive integer (including 0)rJz(The value of 'dns-srv' must be a booleanrCzd |d<dSi|d<dS|d d d }|D]+}|dkrVqO|d }|d}t|d kri|d nd}||vrvtd||||<qOnt|tr|D]}||}t|tst |}|||<qnft|t s|dvr|ri|d<dSd |d<dSt|t r|D]}d||<qn@t|t r|D]+}|dkrq|d }|d}t|d kr|d nd}||vrtd||||<qn t|t std||rP|D]L}||}t|tstd|t|dkr$td||dr1td|t|ts?td||t|dkrNtd||q||d<dS)zValidate connection-attributes. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If attribute name or value exceeds size. rGNrOrRrS)Falser}Truer{z`The value of 'connection-attributes' must be a boolean or a list of key-value pairs, found: '{}')rr}FrrTrP=rz0Duplicate key '{}' used in connection-attributes)rrzOconnection-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 sizerxzEKey names in connection-attributes cannot start with '_', found: '{}'z0Attribute '{}' value: '{}' must be a string typeiz=Attribute '{}' value: '{}' exceeds 1024 characters limit size) rrrZr[rrcr]rhdictreprrrr) r attributesZ conn_attrsZconn_attributesattrZ attr_name_val attr_nameZattr_val attr_valuernrnrorbs                 rcCsg}d|vrdS|d}t|trX|dr|ds"td||ddd}|D])}|}|d kr8q-|tvrDtt |t||vrQtt jd |d | |q-nVt|t r|sctd |D] }|tvrstt |t||vrtt jd |d | |qen't|t r|D]}|tvrtt |t| |qn td dt||std |dgkrtstt|t||d<dS)zValidate tls-versions. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-versions name is not valid. r;NrRrSz(tls-versions must be a list, found: '{}'rrTrPrO tls_versionsrvaluezKAt 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, rL)rrrZr[rrcr]rr TLS_VERSION_ERRORDUPLICATED_IN_LIST_ERRORrgrrrTLS_V1_3_SUPPORTEDTLS_VER_NO_SUPPORTED)rrZtls_versions_settingsZtls_verstls_verZ tls_versionrnrnrors|          rc Csg}d|vrdS|d}t|trD|dr|ds"td||ddd}|s1td |D]}|}|rB| |q3n&t|t rQd d |D}nt|t rc|D] }|ra| |qXntd || d ddurxt ddn|d dd}|jdd|d}g}i}g} t dt |dD]} |t| | t| q|D]1} d| vr| | vr| | q| |vr|| } | |vrttjd| d| | qtd| |std ||d<dS)zValidate tls-ciphersuites. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-ciphersuites name is not valid. r<NrRrSz,tls-ciphersuites must be a list, found: '{}'rrTrPz;No valid cipher suite found in the 'tls-ciphersuites' list.cSsg|]}|r|qSrnrn)rtls_csrnrnro 6s z._validate_tls_ciphersuites..zLtls-ciphersuites should be a list with one or more ciphersuites. Found: '{}'r;T)reverserrytls_ciphersuitesrz;The value '{}' in cipher suites is not a valid cipher suite)rrrZr[rrcr]rupperrgrrrr sortrrerextendr rr) rrZtls_ciphersuites_settingsZtls_cssrrZ newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namesrnameZtranslated_namernrnrors~             rcOsi}|r-t|dtrt|d}n.t|dtr,|dD] \}}|||dd<qn|r@|D] \}}|||dd<q3|sFtdt||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)rrrritemsrXrr)argskwargsrrrrnrnro_get_connection_settingsksrcOst|i|}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)rrrrnrnro get_sessions rcCsFt|ttfs tdt|}t|ttfstdt|tr2zt|}Wnty1tdwi}|D] \}}||| dd<q8t|tsNtdi}d|vr| d}t|tsbtd| dd |d<| d d |d <| d d |d <| dd |d<t |d krtd |t |d krtd | 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 dictenabledTmax_sizeZ max_idle_timerZ queue_timeoutz Unrecognized pooling options: {}z#Unrecognized connection options: {})rrrrrjsonloadsrrrXpoprhrcrr)Zconnection_stringZoptions_stringZ settings_dictZ options_dictrrZpooling_options_dictZpooling_optionsrnrnro get_clientsH2           r)/rrrrexprr r r rrrrrrrrrrrrrrrrr r!r"r#r$r%r&rr'r(r)r*r+r,r-r.r/r0r1r4r5r2r3r)b__doc__rerloggingssl urllib.parserrrZ json.decoderr ImportErrorrf connectionrr constantsr r r r r rZcrudrrrrZdbdocrerrorsrrrrrrrrrrrresultrr r!r"r#r$r%r&Z statementr'r(r)r*r+r,r-r.r/r0r1r2r3r4r5rr6compiler\VERBOSEr^rbr~rr getLogger__name__ addHandler NullHandlerrrrrhasattrrMrprrrrrrrrr__all__rnrnrnrosZ   4(D    3B qmIS$ b