vd#>dZddlZddlmZddlmZmZmZmZddl m Z m Z ddl m Z mZmZmZddlmZdd lmZmZmZmZmZmZmZmZmZmZdd lmZm Z m!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.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m9Z9d Z:d Z;dZdZ?gdZ@dS)z$MySQL X DevAPI Python implementationN) constants) STRING_TYPESurlparseunquote parse_qsl)XSession NodeSession)Schema CollectionTableView)DbDoc) ErrorWarningInterfaceError DatabaseErrorNotSupportedError DataErrorIntegrityErrorProgrammingErrorOperationalError InternalError)ColumnMetaDataRowResultBufferingResult RowResult SqlResult ColumnType) StatementFilterableStatement SqlStatement FindStatement AddStatementRemoveStatementModifyStatementSelectStatementInsertStatementDeleteStatementUpdateStatementCreateCollectionIndexStatementDropCollectionIndexStatementCreateViewStatementAlterViewStatement ColumnDefGeneratedColumnDef ForeignKeyDefExprcttjd}tjd}tjd}g}||r+|d}||}n1t d|}|j|jdS|ri}| d}||}|rL| d}t| d |d <t d|}|js"td ||j|d <|j|d <| ||d |iS)zParses a list of host, port pairs Args: address_list: String containing a list of routers or just router Returns: Returns a dict with parsed values of host, port and priority if specified. z^\[(?![^,]*\]).*]$z,(?![^\(\)]*\))zJ^\(address\s*=\s*(?P
.+)\s*,\s*priority\s*=\s*(?P\d+)\)$z[]z//{0})hostportraddresspriorityzInvalid address: {0}r5r6routers)recompilematchstripsplitrformathostnamer6popgroupintrappend) address_listis_listhst_listpri_addrr9r<routerr7s K/var/www/html/t/fyr/venv311/lib/python3.11/site-packages/mysqlx/__init__.py_parse_address_listrK1sz/00Gz,--HzghhHG}}\"" #))$// ~~l33  5566NJ   ""1%%++--w''  >kk),,2244G!$U[[%<%!>w!G!GHH Hvvv   !!cddi}d|drdnd|}|dd\}}|dddd \}}|d ddd \}}|d }||dd d ur"|dkr|d d\}|d<|d}|r|rd|vr"td||dd\|d<|d<|drt||d<nF|drtd| t|tt|dD],\}} t| dpd||<-|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. schemaz{0}{1}z mysqlx://z://r@N?/)rz():zMalformed URI '{0}'userpassword)rSz...socketz\.zWindows Pipe is not supported.T)r? startswithr> partitionrfindfindrsplitr=rrupdaterKdictritems) urisettingsschemetempuserinfor5 query_strposoptvals rJ_parse_connection_urirl\s"~H //{ ; ;+""*C 1 1C99UA&&LFD^^C((1-NHdnnS))##A#.OD) **S//C CDDzsr!!cAgg#';;sA#6#6 hx ::d  D @x@3h#6#6299#>>???-5^^C-C-C*HVhz* '((3$T]]   3=>>>+D112229d3344::<<99S $008D OrLc*d|vr?|dr7 t|d|d<n#t$rtdwxYwd|vr@|dr8 t|d|d<dS#t$rtdwxYwd|vrd|d<dSdS)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. r8zInvalid priorityr6z Invalid portr5i$N)rC NameErrorr)rds rJ_validate_settingsrosX(:"6 5#&x ';#<#(888HHQRRR x  rL).r r rxrzrr r r rrrrrrrrrrrrrrrrrr rr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3)A__doc__r:rOrcompatrrrr connectionr r crudr r r rdbdocrerrorsrrrrrrrrrrresultrrrrrrr statementr!r"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3rKrlrorurxrz__all__rLrJrs0+* >>>>>>>>>>>>--------111111111111HHHHHHHHHHHHHHHHHHHHHHHH,,,,,,,,,,,,,,,,,,AAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAAA)")")"V$$$L!!!.   D"!!!(   rL