a cfc~@sRdZddlZddlZddlZddlZddlmZmZmZzddl m Z Wne y^e Z Yn0ddl 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 lCmDZCeEdZFeEdejGZHeEdejGZIeEdZJgdZKeKgdZLeMeNOePdZQdZRdZSdZTddgZddgZUdZVeWedrejXrdZVdd ZYd!d"ZZd#d$Z[d4d%d&Z\d'd(Z]d)d*Z^d+d,Z_d-d.Z`d/d0Zad1d2Zbgd3ZcdS)5z$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 {}).zHThe given tls_version: '{}' are no longer allowed (should be one of {}).zINo supported TLS protocol version found in the 'tls-versions' list '{}'. zTLSv1.2TLSv1.3TLSv1zTLSv1.1F HAS_TLSv1_3Tc Cs|dd}d|vo.|ddko.|ddk oD|doD|d}g}t|r^|ddn|}d }|D]}i}t|}|r|d}t |d |d <|d7}n t |}|r|d}d |d <t d |}|j std |z|j|j |jdWn6ty6}ztd |dWYd}~n d}~00||qld |kr`t|krnnn tdd|r|d|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_errrnL/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/mysqlx/__init__.py_parse_address_listbsF       &  rpcCsddi}t|}|r|nd|f\}}|dvr@td||dkrPd|d<|d d d d \}}|d d d d \}}|d }||d ddkr|dkr|d d\}|d<| d}|r|rd|vrtd|| dd\} } t | t | |d<|d<| dr(t ||d<n$| dr>tdn| t|d} t|dD]\} } | dd}|| vrtd| ||vrtd| |tvrt | d||<n8| }|d vrd||<n|d!vrd"||<n|||<qZ|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}|r*tdd|dvrLdD]}t|dq:ndvr\tdvrz"dd<t dWn(t t fytddYn0dt j krtfdd tDrtd d vrd vrtd dvrdvrtdd vr:dt jt jfvr:tdd vrddt jt jfvrdtddvrz"dd<t dWn*t t fytddYn0dvrd}|dvrtdd|d<dvrztdtrFdd}|r<|dd<ndd<ntdttfsbtdddkrzdd<dvrtdvrzFtdtrtdd<tdtrֈdd krt Wnt ytd!Yn0d"vrZtd"tstd#d$r0td%d&rDtd'drxtd(ndvrxd&sxdd&<d)vrtd*vrtdS)+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|]}|vVqdS)Nrn).0rrrnro z%_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 booleanrCzDsz._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 rrrerextendr rr) rrZtls_ciphersuites_settingsZtls_cssrrZ newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namesrnameZtranslated_namernrnror&sx            rcOsi}|rZt|dtr$t|d}qt|dtr|dD]\}}|||dd<q>n&|r|D]\}}|||dd<qf|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. rrxryzSettings not provided)rrrritemsrXrr)argskwargsrrrrnrnro_get_connection_settingsysrcOst|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 rcCsRt|ttfstdt|}t|ttfs4tdt|trjzt|}WqtyftdYq0n&i}|D]\}}||| dd<qvt|tstdi}d|vrH| d}t|tstd| dd |d<| d d |d <| d d |d <| dd |d<t |d kr(td |t |d krHtd | 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_clientsF2        r)/rrrrexprr r r rrrrrrrrrrrrrrrrr r!r"r#r$r%r&rr'r(r)r*r+r,r-r.r/r0r1r4r5r2r3)N)d__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 NullHandlerrrrrrrhasattrrMrprrrrrrrrr__all__rnrnrnrosZ    4(D    3Bq mRS$b