o h>@sdZddlZddlZddlmZddlmZmZmZm Z m Z m Z ddl m Z mZddlmZmZmZddlmZmZmZmZdd lmZdd lmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$dd l%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-dd l.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;mm?Z>e@dZAe@dejBZCgdZDeDgdZEddZFddZGddZHddZIddZJddZKddZLgd ZMdS)!z$MySQL X DevAPI Python implementationN) constants) INT_TYPES STRING_TYPESJSONDecodeErrorurlparseunquote parse_qsl)ClientSession)AuthLockContentionSSLMode)Schema CollectionTableView)DbDoc) ErrorInterfaceError DatabaseErrorNotSupportedError DataErrorIntegrityErrorProgrammingErrorOperationalError InternalError PoolError TimeoutError)ColumnRowResultBufferingResult RowResult SqlResult DocResult ColumnType) StatementFilterableStatement SqlStatement FindStatement AddStatementRemoveStatementModifyStatementSelectStatementInsertStatementDeleteStatementUpdateStatementCreateCollectionIndexStatementExpr ReadStatementWriteStatement) ExprParserz,(?![^\(\)]*\))z!^\(address=(.+),priority=(\d+)\)$)ssl-certssl-cassl-keyssl-crl) userpasswordschemahostportrouterssocketssl-modeauthzuse-pureconnect-timeoutcCs|dd}d|vo|ddko|ddk o"|do"|d}g}t|r/|ddn|}|D]8}i}t|}|rM|d}t |d |d <t d |}|j s^t d ||j|j |jd ||q4|rsd|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[]priorityz//{0}zInvalid address: {0})r>r?r@r)replacecount startswithendswith_SPLITsplit _PRIORITYmatchgroupintrformathostnamerupdater?append)patharrayr@ address_listaddressrouterrUraA/var/www/html/env/lib/python3.10/site-packages/mysqlx/__init__.py_parse_address_list?s,     rccCsddi}d|dr dnd|}|dd\}}|dddd \}}|d ddd \}}|d }||dd d krO|dkrO|d d\}|d<|d}|r\|r\d|vrctd||dd\}} t |t | |d<|d<|drt ||d<n|drtd| t |t |dD]?\} } | dd} | |vrtd| | tvrt | d|| <q| } | dvrd|| <q| dvrd|| <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. r=rFz{0}{1}z mysqlx://z://r@NrL?/)rKrz()rHzMalformed URI '{0}'r;r<)rfz...rAz\.zWindows Pipe is not supported.T_-zDuplicate option '{0}'.)1true)0falseF)rXrPrS partitionrfindfindrsplitstriprrrZrcr rNlower _SSL_OPTS)urisettingsritempuserinfor> query_strposr;r<keyvaloptval_strrararb_parse_connection_uribsB        rc stt}|rtdd|dvr%dD]}t|qndvr-tdvrkzdd<t dWnt t fyTt ddwdt jkrktfddtDrkt d d vrwd vrwt d d vrdvrt dd vrdt jt jfvrt dd vrdt jt jfvrt ddvrzdd<t dWdSt t fyt ddwdS)aValidates 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. zInvalid options: {0}.z, r@r>rBzInvalid SSL Mode '{0}'.c3s|]}|vVqdS)Nra).0r|rwrarb sz%_validate_settings..z*SSL options used with ssl-mode 'disabled'.r:r8zCA Certificate not provided.r9r7z Client Certificate not provided.z Cannot verify Server without CA.z%Must verify Server if CA is provided.rCzInvalid Auth '{0}'N)setkeys difference _SESS_OPTSrrXjoin_validate_hostsrtrindexAttributeError ValueErrorrDISABLEDanyrugetVERIFY_IDENTITY VERIFY_CAr )rw invalid_optsr`rarrb_validate_settingssX       rcCsd|vr|drz t|d|d<Wn tytdwd|vr=|dr=z t|d|d<WdSty<tdwd|vrGd|d<dSdS)zValidate hosts. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If priority or port are invalid. rMzInvalid priorityr?z Invalid portr>i$N)rW NameErrorrrrararbrs    rcOsi}|r-t|dtrt|d}n6t|dtr,|dD] \}}|||dd<qn|rH|||D]}d|vrG||||dd<q6|sNtdd|vr~z t|dtrbt |d|d<t|dt ro|ddkrqt Wn t y}t dwt ||S)aParses 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. rrirjzSettings not providedrDzEThe connection timeout value must be a positive integer (including 0)) isinstancerrdictitemsrNrZpoprrWrr TypeErrorr)argskwargsrwr|r}rararb_get_connection_settingss:   rcOst|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 )rrrwrararb 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 dictrjripoolingz<'pooling' options must be given in the form document or dictenabledTmax_size max_idle_timer queue_timeoutz Unrecognized pooling options: {}z#Unrecognized connection options: {})rrrrrjsonloadsrrrNrlenrXrr )connection_stringoptions_string settings_dict options_dictr|valuepooling_options_dictpooling_optionsrararb get_client"sH2           r)-r r rrexprr r rrrrrrrrrrrrrrrrrr r!r"r#r$r%r&rr'r(r)r*r+r,r-r.r/r0r1r2r3)N__doc__rerrFrcompatrrrrrr connectionr r r r rcrudrrrrdbdocrerrorsrrrrrrrrrrrresultrr r!r"r#r$r%r& statementr'r(r)r*r+r,r-r.r/r0r1r2r3r4r5rr6compilerRVERBOSErTrurrcrrrrrr__all__rarararbs2   4(D   #430 b