U 4Je@sdZddlmZddlmZzLddlZdZejejej dZ e edrLej nej e d<e ed odejZWn ek rd Zd ZiZ YnXddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZdd lmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%zddl&Z'ddl(Z'Wnek r<d Z)YnXdZ)dd l*m*Z*m+Z+dd l,m-Z-ddl.m/Z/ddl0m1Z1m2Z2m3Z3ddl4m5Z5m6Z6m7Z7ddl8m9Z9m:Z:m;Z;mZ>m?Z?m@Z@ddlAmBZBddlCmDZDmEZEmFZFmGZGmHZHmIZIddlJmKZKmLZLmMZMddlNmNZNddlOmPZPddlQmRZRmSZSmTZTmUZUmVZVddlWmXZXmYZYmZZZm[Z[m\Z\ddl]m^Z^m_Z_m`Z`maZambZbmcZcmdZdmeZemfZfmgZgmhZhddlmiZimjZjmkZkmlZlejmndddlompZpmqZqmrZrmsZsddltmuZuddlvmwZwmxZxd d!d"d#Zyd$Zzd%Z{d&Z|d'Z}d(Z~d)Zd*Zed+Zd,Zd,Zd-Zd.Zd/Zd/Zd0Zd.Zeeeeeeeed1Zd2eiZed3Zed4ejZed5ejZed6Zd7d8d9d:d;dd?d@dAdBdCdDdEdFdGdHdIdJdKgZdLdMdNdOdPZdQdRdSdTdUZGdVdWdWZdXdXdYdZd[ZGd\d]d]eZGd^d_d_ZGd`dadaZGdbdcdceZGdddedeejZGdfdgdgZGdhdidiZGdjdkdkZdMdldmdndoZdMdpdqdrdsZdpdRdtdudvZddpdwdRdxdydzZdpdRdtd{d|ZdpdRdtd}d~ZdpdRdtddZdLdLdpdddZdLdLdidddZdddkdddZdS)z4Implementation of communication for MySQL X servers.) annotations) TracebackTypeNT)TLSv1TLSv1.1TLSv1.2 PROTOCOL_TLSTLSv1.3 HAS_TLSv1_3F) AnyCallableDictListMappingOptionalTupleTypeUnion)datetime timedeltawraps)JSONDecodeError) parse_qslunquoteurlparse)MySQL41AuthPluginPlainAuthPluginSha256MemoryAuthPlugin)COMPRESSION_ALGORITHMSDEPRECATED_TLS_VERSIONSOPENSSL_CS_NAMESSUPPORTED_TLS_VERSIONSTLS_CIPHER_SUITESAuth CompressionSSLModeSchema)InterfaceErrorNotSupportedErrorOperationalError PoolErrorProgrammingError TimeoutError)escapeget_item_or_attriani_to_openssl_cs_name)logger)Protobuf)HAVE_LZ4 HAVE_ZSTD MessageReader MessageWriterProtocol) BaseResult DocResultResult RowResult SqlResult) AddStatementDeleteStatement FindStatementInsertStatementModifyStatement ReadStatementRemoveStatementSelectStatement SqlStatementUpdateStatementquote_identifier) ColumnType MessageTypeResultBaseType StatementType..)DUPLICATED_IN_LIST_ERRORTLS_VER_NO_SUPPORTEDTLS_VERSION_DEPRECATED_ERRORTLS_VERSION_ERROR)linux_distribution)LICENSEVERSIONzThis session was closed because the connection has been idle for too long. Use 'mysqlx.getSession()' or 'mysqlx.getClient()' to create a new one.z.wrapperr)rrrxrrycatch_network_exceptions2rcsReZdZdZdddfdd Zddd d Zddd d Zd dddZZS)RouterzRepresents a set of connection parameters. Args: settings (dict): Dictionary with connection settings .. versionadded:: 8.0.20 r{r|)connection_paramsrpcs(t|||dd|d<dS)N availableT)superrrget)rr __class__rxryr9s  zRouter.__init__rrcCs|dS)zVerifies if the Router is available to open connections. Returns: bool: True if this Router is available else False. rrxrrxrxryr>szRouter.availablecCs d|d<dS)z1Sets this Router unavailable to open connections.FrNrxrrxrxryset_unavailableFszRouter.set_unavailablez%Union[str, Tuple[str, Optional[int]]]cCs d|kr|dS|d|dfS)zVerifies if the Router is available to open connections. Returns: tuple: host and port or socket information tuple. rerbrcrxrrxrxryget_connection_paramsJszRouter.get_connection_params) rrrrrrr r  __classcell__rxrxrryr1s rc@szeZdZdZddddddZddd d Zd dd d dZd dd ddZddddZddddZ ddddZ dS) RouterManagerzManages the connection parameters of all the routers. Args: Routers (list): A list of Router objects. settings (dict): Dictionary with connection settings. .. versionadded:: 8.0.20 z List[Router]Dict[str, Any]r|)rdsettingsrpcCs0||_||_d|_d|_i|_g|_|dS)NrT)_routers _settings_cur_priority_idx _can_failover_routers_directoryrouters_priority_list_ensure_priorities)rrdrrxrxryr^szRouterManager.__init__rcCsd}|jD]<}|dd}|dkr4|d7}d|d<q |dkr tddq d|krbt|jkrpnn tdd |jjd d d d |jD]H}|d}||jkrt|g|j|<|j|q|j|t|qdS)zuEnsure priorities. Raises: :class:`mysqlx.ProgrammingError`: If priorities are invalid. rpriorityNrdz(The priorities must be between 0 and 100\You must either assign no priority to any of the routers or give a priority for every routercSs|dS)Nrrxxrxrxryrz2RouterManager._ensure_priorities..T)rwr) rrr-rrrrrrs)rpriority_countrouterrrxrxryrhs(      z RouterManager._ensure_prioritiesr)rrpcCs|j|}dd|D}|S)zGet a list of the current available routers that shares the given priority. Returns: list: A list of the current available routers. cSsg|]}|r|qSrx)r).0r rxrxry sz8RouterManager._get_available_routers..r)rr router_listrxrxry_get_available_routerss z$RouterManager._get_available_routersrcCsF||}|sdSt|dkr&|dSt|d}td|}||S)z{Get a random router from the group with the given priority. Returns: Router: A random router. Nrr)r%rrandomrandint)rrr$lastindexrxrxry_get_random_connection_paramss    z+RouterManager._get_random_connection_paramsrcCs|jS)zReturns the next connection parameters. Returns: bool: True if there is more server to failover to else False. )rrrxrxry can_failoverszRouterManager.can_failovercCs|jsBd|_|j}|jdd|d<|jdd|d<t|S|j|j}t|j}d}|r| |}|dk s||j|kr|j|dkrt| |d krd|_q|jd7_|j|kr\|j|j}q\|S) zvReturns the next connection parameters. Returns: Router: with the connection parameters. Frbrrc$TNr) rrrcopyrrrrrr*r%)rZrouter_settings cur_priorityZrouters_priority_lensearchr rxrxryget_next_routers,      zRouterManager.get_next_routerzDict[int, List[Router]]cCs|jS)zReturns the directory containing all the routers managed. Returns: dict: Dictionary with priorities as connection settings. r#rrxrxryget_routers_directorysz#RouterManager.get_routers_directoryN) rrrrrrr%r*r+r1r2rxrxrxryr Us # #r c@sHeZdZdZdddddZdddd Zd dd d d ZddddZdddddZdjdddddddZ ddddZ ddddZ ddddZ ddd d!Z d"dd#d$d%Zdd&d'dd(d)d*Zdd&d'dd(d+d,Zed-d.d#d/d0Zed1d2d#d3d4Zed5d6d#d7d8Zed9d2d#d:d;ZedZedkddd?d@dAdBdCdDZed"dEdFdGdHZedddIdJdKdLZedIdMd dNdOZed2dd dPdQZed2dRd dSdTZdEddUdVZd?ddWdXZdYddZd[d\Zd?dd]d^Z d_dd`daZ!dddbdcZ"dddddeZ#dddfdgZ$dddhdiZ%dS)lrzkConnection to a MySQL Server. Args: settings (dict): Dictionary with connection settings. rr|rrpcCs||_t|_d|_d|_|d|_|d|_|d|_d|_ |dg|_ d|kr|dr|j |d|dddt |j ||_ |dt|_|jd krd|_d |_g|_d |_d |_d|_dS) Nr_r`rardrbrcrbrcrirTF)rrstreamprotocol keep_openr_user _passwordZ_schema_active_resultrrsr router_managerr_connect_timeout _stmt_counter_prepared_stmt_ids_prepared_stmt_supported_server_disconnected_server_disconnected_reason)rrrxrxryrs6     zConnection.__init__rcCs|jdk r|jd|_dS)zFetch active result.N)r: fetch_allrrxrxryfetch_active_results  zConnection.fetch_active_resultrK)rrpcCs ||_dS)aSet active result. Args: `Result`: It can be :class:`mysqlx.Result`, :class:`mysqlx.BufferingResult`, :class:`mysqlx.RowResult`, :class:`mysqlx.SqlResult` or :class:`mysqlx.DocResult`. N)r:rrrxrxryset_active_results zConnection.set_active_resultc Csd}|jr&z|j}|j||jt|j}t|j}t |||_ |j j }|rndd|Dni}| |d|jkr|jd}|j j|d|jdtj}|jd} |tjkrdn |||| } ||j | WdSttfk r"} z| }|W5d} ~ XYqXq|dk rrt|tjrrt|jdkr`td |jd td |jd t|jdkrt d |t dddS)a Attempt to connect to the MySQL server. Raises: :class:`mysqlx.InterfaceError`: If fails to connect to the MySQL server. :class:`mysqlx.TimeoutError`: If connect timeout was exceeded. NcSsi|]}t|d|qSr)r0lower)r!caprxrxry )s z&Connection.connect.. attributesZsession_connect_attrsrkrlrz9Connection attempt to the server was aborted. Timeout of z ms was exceededz8All server connection attempts were aborted. Timeout of z) ms was exceeded for each selected serverzCannot connect to host: ,Unable to connect to any of the target hostsi)!r;r+r1r5rr r<r6r7r8r6Zget_capabilitesZ capabilities_set_tls_capabilitiesrset_capabilitiesrr%Z PREFERREDDISABLED_set_compression_capabilities _authenticateZset_compressionrrr r~retimeoutrrr.r)) rerrorr readerwriterZ caps_datacaps conn_attrsrk algorithms algorithmrrxrxryrs^              zConnection.connect)rVrpc CsP|jdtjkrdS|jr:|jdr6tddSd|krR|t dd}t dkrt \}}}zd|ko| d d d k}Wntk rd}YnXtjd kr|s|td |jjdd|j|jdd|jdtj|jd|jd|jd|jd|jdd|jkrL|jd}|jj|ddS)aSet the TLS capabilities. Args: caps (dict): Dictionary with the server capabilities. Raises: :class:`mysqlx.OperationalError`: If SSL is not enabled at the server. :class:`mysqlx.RuntimeError`: If support for SSL is not available in Python. .. versionadded:: 8.0.21 rfNz(SSL not required when using Unix socket.tlszSSL not enabled at serverFLinuxz Oracle Linux.r7)r- z.arrayrwcSsg|]}|jjjdqS)ro)rmrnrjrprqrxrxryr"srYcSsg|]}|tkrt|qSrx)rr!itemrxrxryr"scsg|]}|kr|qSrxrxrsZserver_algorithmsrxryr"srzmThe connection compression is set as required, but none of the provided compression algorithms are supported.Z zstd_streamZ lz4_messageZdeflate_streamzFCompression requested but the compression algorithm negotiation failed)rk)rr%rr*r2r`r~rrjrkrlrrrwrr)r5r4r6rN) rrVrkrXZcompression_datarZcompression_dictrlrYZclient_algorithmsmatchedrxruryrPs\          z(Connection._set_compression_capabilitiesc Cs|jd}|rL|tjkr$|q|tjkr8|q|tjkr|nz|j r`|nfz |Wnt k rYnXdSz |Wn2t k r}zt d||W5d}~XYnXdS)z#Authenticate with the MySQL server.rgNzrAuthentication failed using MYSQL41 and SHA256_MEMORY, check username and password or try a secure connection err:) rrr$ZPLAIN_authenticate_plainZ SHA256_MEMORY_authenticate_sha256_memoryZMYSQL41_authenticate_mysql41r5rr))rrgrrxrxryrQs.           zConnection._authenticatecCsHt|j|j}|j||j}|j|||j dS)z=Authenticate with the MySQL server using `MySQL41AuthPlugin`.N) rr8r9r6send_auth_start auth_nameread_auth_continuesend_auth_continue auth_data read_auth_okrplugin extra_datarxrxryrys  z Connection._authenticate_mysql41cCsF|jstdt|j|j}|jj|| d|j dS)z;Authenticate with the MySQL server using `PlainAuthPlugin`.z>PLAIN authentication is not allowed via unencrypted connection)r~N) r5rr)rr8r9r6rzr{r~r)rrrxrxryrws zConnection._authenticate_plaincCsHt|j|j}|j||j}|j|||j dS)zBAuthenticate with the MySQL server using `Sha256MemoryAuthPlugin`.N) rr8r9r6rzr{r|r}r~rrrxrxryrx#s  z&Connection._authenticate_sha256_memoryrL) statementrpcCs,|jr(|j|j|j|jd|_dS)zrDeallocates statement. Args: statement (Statement): A `Statement` based type object. FN)preparedr6send_prepare_deallocatestmt_idr>remove)rrrxrxry_deallocate_statement+sz Connection._deallocate_statementrJzgUnion[FindStatement, DeleteStatement, ModifyStatement, ReadStatement, RemoveStatement, UpdateStatement])msg_typerrrpcCsRz||j|||Wntk r8d|_YdSX|j|jd|_dS)zPrepares a statement. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. statement (Statement): A `Statement` based type object. FNT) rCr6Zsend_prepare_preparer*r?r>rsrrrrrrrxrxry_prepare_statement6szConnection._prepare_statementcCs\|js|j|||dS|jrr|||||||jsR|j|||dS|j|||d|_|n|jr|j s|j|||n|j r|j s|||j|||d|_ |n|j s|j s|js|||||js|j|||dS|j|||n8|j rP|j rP|||j|||d|_ || dS)zExecutes the prepared statement pipeline. Args: msg_type (str): Message ID string. msg (mysqlx.protobuf.Message): MySQL X Protobuf Message. statement (Statement): A `Statement` based type object. NF) r?r6send_msg_without_psZdeallocate_prepare_executerrZsend_prepare_executeZreset_exec_counterrchangedZrepeatedZincrement_exec_counterrrxrxry_execute_prepared_pipelineSs@       z%Connection._execute_prepared_pipelinerFr=cCsT|j}|jdkrtdt|ts*td|jd|\}}|j|||t|S)zExecute a SQL statement. Args: sql (str): The SQL statement. Raises: :class:`mysqlx.ProgrammingError`: If the SQL statement is not a valid string. Nrz'The SQL statement is not a valid stringsql) rr6r+r~rnr-build_execute_statementrr=)rrrrrrxrxrysend_sqls   zConnection.send_sqlz$Union[AddStatement, InsertStatement]r;cCsN|jdkrtd|j|\}}|j||d}t|trD|j}t||S)a Send an insert statement. Args: statement (`Statement`): It can be :class:`mysqlx.InsertStatement` or :class:`mysqlx.AddStatement`. Returns: :class:`mysqlx.Result`: A result object. Nr)r6r+Z build_insertsend_msgr~r>idsr;)rrrrrrxrxry send_inserts  zConnection.send_insertz%Union[FindStatement, SelectStatement]zUnion[DocResult, RowResult]cCs6|j|\}}|||||r.t|St|S)aDSend an find statement. Args: statement (`Statement`): It can be :class:`mysqlx.SelectStatement` or :class:`mysqlx.FindStatement`. Returns: `Result`: It can be class:`mysqlx.DocResult` or :class:`mysqlx.RowResult`. )r6Z build_findrZ is_doc_basedr:r<rrrrrxrxry send_findszConnection.send_findz'Union[DeleteStatement, RemoveStatement]cCs&|j|\}}||||t|S)aSend an delete statement. Args: statement (`Statement`): It can be :class:`mysqlx.RemoveStatement` or :class:`mysqlx.DeleteStatement`. Returns: :class:`mysqlx.Result`: The result object. )r6 build_deleterr;rrxrxry send_deletes zConnection.send_deletez'Union[ModifyStatement, UpdateStatement]cCs&|j|\}}||||t|S)aSend an delete statement. Args: statement (`Statement`): It can be :class:`mysqlx.ModifyStatement` or :class:`mysqlx.UpdateStatement`. Returns: :class:`mysqlx.Result`: The result object. )r6Z build_updaterr;rrxrxry send_updates zConnection.send_updaterOptional[Dict[str, Any]]zOptional[Result]) namespacecmd raise_on_failfieldsrpcCsLz,|j|||\}}|j||t|WStk rF|rBYnXdS)aExecute a non query command. Args: namespace (str): The namespace. cmd (str): The command. raise_on_fail (bool): `True` to raise on fail. fields (Optional[dict]): The message fields. Raises: :class:`mysqlx.OperationalError`: On errors. Returns: :class:`mysqlx.Result`: The result object. N)r6rrr;r+)rrrrrrrrxrxryexecute_nonquerys zConnection.execute_nonqueryrrrpcCsN|jd|\}}|j||t|}||jdkrBtd|ddS)zExecute a SQL scalar. Args: sql (str): The SQL statement. Raises: :class:`mysqlx.InterfaceError`: If no data found. Returns: :class:`mysqlx.Result`: The result. rrz No data found)r6rrr<rBrr))rrrrrrxrxryexecute_sql_scalar s  zConnection.execute_sql_scalarr<)rrrpcCs*|jd||\}}|j||t|S)zReturns the row result. Args: cmd (str): The command. fields (dict): The message fields. Returns: :class:`mysqlx.RowResult`: The result object. mysqlx)r6rrr<)rrrrrrxrxryget_row_results zConnection.get_row_resultzOptional[MessageType]cCs |j|S)zdRead row. Args: result (:class:`mysqlx.RowResult`): The result object. )r6read_rowrDrxrxryr.szConnection.read_rowcCs|j|dS)zeClose result. Args: result (:class:`mysqlx.Result`): The result object. N)r6 close_resultrDrxrxryr7szConnection.close_resultzList[ColumnType]cCs |j|S)zlGet column metadata. Args: result (:class:`mysqlx.Result`): The result object. )r6rrDrxrxryr@szConnection.get_column_metadatacCs|jd7_|jS)z|Returns the next statement ID. Returns: int: A statement ID. .. versionadded:: 8.0.16 r)r=rrxrxryget_next_statement_idIsz Connection.get_next_statement_idcCs |jS)zgCheck if connection is open. Returns: bool: `True` if connection is open. )r5rrrxrxryrTszConnection.is_openzUnion[str, Tuple[str, int]])rrpcCsd|_||_dS)zSet the disconnection message from the server. Args: reason (str): disconnection reason from the server. TN)r@rA)rrrxrxryr\sz"Connection.set_server_disconnectedcCs|jS)zVerify if the session has been disconnect from the server. Returns: bool: `True` if the connection has been closed from the server otherwise `False`. )r@rrxrxryresz!Connection.is_server_disconnectedz%Optional[Union[str, Tuple[str, int]]]cCs|jS)zGet the disconnection message sent by the server. Returns: string: disconnection reason from the server. )rArrxrxryrnsz"Connection.get_disconnected_reasoncCs|s dS|jdS)zDisconnect from server.N)rr5rrrxrxryrvszConnection.disconnectc Cs|s dSz~zD||jr<|jD]}|j|q$d|_|j |j Wn4t t t fk r}ztd|W5d}~XYnXW5|jXdS)z*Close a sucessfully authenticated session.NrzGWarning: An error occurred while attempting to close the connection: %s)rr5rrCr?r>r6rr=Z send_closeread_okr)r+rr2r`)rrrrxrxry close_session|s   zConnection.close_sessionc Csl|s dS|jdk r |jz|j|j|_Wn2ttfk rf}zt d|W5d}~XYnXdS)z*Reset a sucessfully authenticated session.NzDWarning: An error occurred while attempting to reset the session: %s) rr:rBr6Z send_resetr7r)r+r2r`)rrrxrxry reset_sessions  zConnection.reset_sessioncCsB|s dS|jdk r |j|j|j|jdS)zAnnounce to the server that the client wants to close the connection. Discards any session state of the server. N)rr:rBr6Zsend_connection_closerr5rrrxrxryras    zConnection.close_connection)N)N)&rrrrrrCrErrMrPrQryrwrxrrrrrrrrrrrrrrrrrrrrrrrrarxrxrxryrs^" F:c  >    rcsteZdZdZdddfdd Zddfdd Zddd d Zddd d ZddddZdddddZ Z S)raClass to hold :class:`Connection` instances in a pool. PooledConnection is used by :class:`ConnectionPool` to facilitate the connection to return to the pool once is not required, more specifically once the close_session() method is invoked. It works like a normal Connection except for methods like close() and sql(). The close_session() method will add the connection back to the pool rather than disconnecting from the MySQL server. The sql() method is used to execute sql statements. Args: pool (ConnectionPool): The pool where this connection must return. .. versionadded:: 8.0.13 ConnectionPoolr|)rrpcsBt|tstdt|j||_|jd|_|jd|_dS)Nz&pool should be a ConnectionPool objectrbrc) r~rrrr cnx_configrrbrc)rrrrxryrs   zPooledConnection.__init__rcstdS)zGCloses the connection. This method closes the socket. N)rrrrrxryrasz!PooledConnection.close_connectioncCs|j|dS)aDo not close, but add connection back to pool. The close_session() method does not close the connection with the MySQL server. The connection is added back to the pool so it can be reused. When the pool is configured to reset the session, the session state will be cleared by re-authenticating the user once the connection is get from the pool. N)radd_connectionrrxrxryrs zPooledConnection.close_sessioncCs |jdk r|j|dS)zReconnect this connection.N)r:rBrQrrxrxry reconnects  zPooledConnection.reconnectcCs |dS)zQReset the connection. Resets the connection by re-authenticate. N)rrrxrxryresetszPooledConnection.resetrnrFrcCs t||SaCreates a :class:`mysqlx.SqlStatement` object to allow running the SQL statement on the target MySQL Server. Args: sql (string): The SQL statement to be executed. Returns: mysqlx.SqlStatement: SqlStatement object. )rFrrrxrxryrs zPooledConnection.sql) rrrrrrarrrrr rxrxrryrs rc@seZdZdZddddddZdddd d Zed d d dZd.dddddZdd ddZ d/dddddZ dddddZ dddddZ dd ddZ d d d!d"Zd0d dd$d%d&Zdd d'd(Zd)d d*d+Zdd d,d-ZdS)1raThis class represents a pool of connections. Initializes the Pool with the given name and settings. Args: name (str): The name of the pool, used to track a single pool per combination of host and user. **kwargs: max_size (int): The maximun number of connections to hold in the pool. reset_session (bool): If the connection should be reseted when is taken from the pool. max_idle_time (int): The maximum number of milliseconds to allow a connection to be idle in the queue before being closed. Zero value means infinite. queue_timeout (int): The maximum number of milliseconds a request will wait for a connection to become available. A zero value means infinite. priority (int): The router priority, to choose this pool over other with lower priority. Raises: :class:`mysqlx.PoolError` on errors. .. versionadded:: 8.0.13 rnr r|)rrorpcKs||d|_g|_d|_d|_t|_|dd|_ t j ||j |dd|_ |dd|_||_|dd|_|dd|_||_|d |_|d |_dS) NrTmax_sizer max_idle_time queue_timeoutrrbrc)_set_pool_nameZ_open_sessions_connections_openned _available_timeoutrnow_timeout_stampr pool_max_sizequeueQueuerrrrrrrrbrc)rrrorxrxryrs    zConnectionPool.__init__) pool_namerpcCs@t|rtd|dt|tkr6td|d||_dS)aSet the name of the pool. This method checks the validity and sets the name of the pool. Args: pool_name (str): The pool name. Raises: AttributeError: If the pool_name contains illegal characters ([^a-zA-Z0-9._\-*$#]) or is longer than connection._CNX_POOL_MAX_NAME_SIZE. z Pool name 'z' contains illegal charactersz ' is too longN)_CNX_POOL_NAME_REGEXr0rr_CNX_POOL_MAX_NAME_SIZEr)rrrxrxryr,s  zConnectionPool._set_pool_namerrcCs t|jS)zDReturns the number of open connections that can return to this pool.)rrrrxrxryopen_connections?szConnectionPool.open_connectionsNzOptional[PooledConnection]cnxrpcCs|j|dS)zwRemoves a connection from this pool. Args: cnx (PooledConnection): The connection object. N)rrrrrxrxryremove_connectionDsz ConnectionPool.remove_connectionc Csx|dkrtz|jd|jd}Wntjk r6YqXz,z |Wnttt fk r`YnXW5||XqdS)z*Removes all the connections from the pool.rTblockrRN) qsizerrrEmptyrrarrr)rrxrxryrLs   z!ConnectionPool.remove_connectionscCs|jstd|rtd|st|}|tdd}tdd| dd dDdkr|d |j |j |n*t |tstd |r||||d S) a=Adds a connection to this pool. This method instantiates a Connection using the configuration passed when initializing the ConnectionPool instance or using the set_config() method. If cnx is a Connection instance, it will be added to the queue. Args: cnx (PooledConnection): The connection object. Raises: PoolError: If no configuration is set, if no more connection can be added (maximum reached) or if the connection can not be instantiated. z&Connection configuration not available'Failed adding connection; queue is fullrcss|]}t|VqdSrrr!nrxrxry usz0ConnectionPool.add_connection..-r\r set mysqlx_wait_timeout = z1Connection instance not subclass of PooledSessionN)rr,fullrr_SELECT_VERSION_QUERYexecuterBtuplerdrrrsr~rrrqueue_connection)rrverrxrxryr[s & zConnectionPool.add_connectionrc Csft|tstd|jr |z|j|ddWn.tjk r`}ztd|W5d}~XYnXdS)aGPut connection back in the queue: This method is putting a connection back in the queue. It will not acquire a lock as the methods using _queue_connection() will have it set. Args: PooledConnection: The connection object. Raises: PoolError: On errors. z2Connection instance not subclass of PooledSession.F)rrN)r~rr,rputrFull)rrrrxrxryrs zConnectionPool.queue_connection) connectionrpcCs|j|dS)zETracks connection in order of close it when client.close() is invoke.N)rrs)rrrxrxrytrack_connectionszConnectionPool.track_connectioncCs|jSrrFrrxrxry__str__szConnectionPool.__str__rcCs|jS)zReturns if this pool is available for pool connections from it. Returns: bool: True if this pool is available else False. .. versionadded:: 8.0.20 )rrrxrxryrszConnectionPool.available)time_outrpcCs.|jr*td||d|_t|_||_dS)zhSets this pool unavailable for a period of time (in seconds). .. versionadded:: 8.0.20 z4ConnectionPool.set_unavailable pool: %s time_out: %sFN)rr2r`rrrr)rrrxrxryr s zConnectionPool.set_unavailablecCsd|_t|_dS)zaSets this pool available for pool connections from it. .. versionadded:: 8.0.20 TN)rrrrrrxrxry set_availableszConnectionPool.set_availablezTuple[int, datetime]cCs |j|jfS)zReturns the penalized time (timeout) and the time at the penalty. Returns: tuple: penalty seconds (int), timestamp at penalty (datetime object) .. versionadded:: 8.0.20 )rrrrxrxryget_timeout_stampsz ConnectionPool.get_timeout_stampcCs|jD] }|qdS)zEmpty this ConnectionPool.N)rrarrxrxryrs zConnectionPool.close)N)N)r)rrrrrrpropertyrrrrrrrrr rrrrxrxrxryrs *  rc@seZdZUdZdZded<iZded<ddddZd d d d d d ZdddddZ e dddddZ dddddZ e dddddZ e dddddd d!Zdddd"d#d$Ze d5dd%dd"d&d'Zd6dd(dd)d*d+Zdd,dd-d.Zdddd/d0Ze dd1dd2d3d4ZdS)7rzManages a pool of connections for a host or hosts in routers. This class handles all the pools of Connections. .. versionadded:: 8.0.13 N_PoolsManager__instancer_PoolsManager__poolsrcCs"tjdkrt|t_it_tjSr)rrobject__new__r)clsrxrxryrs  zPoolsManager.__new__rnr)rqrrpcCs,|j|g}|D]}|j|krdSqdS)zVerifies if a pool exists with the given name. Args: client_id (str): The client id. pool_name (str): The name of the pool. Returns: bool: Returns `True` if the pool exists otherwise `False`. TF)rrr)rrqrpoolsrrxrxry _pool_existss  zPoolsManager._pool_existsr r3cCs^g}g}||}|D]\}}||q|j|ddgD]}|j|kr@||q@|S)zRetrieves a list of pools that shares the given settings. Args: settings (dict): the configuration of the pool. Returns: list: A list of pools that shares the given settings. rqNo id)_get_connections_settingsrsrrr)rrZavailable_poolsZ pool_namesconnections_settings router_namerrrrxrxry _get_poolss      zPoolsManager._get_poolsz List[Tuple[str, Dict[str, Any]]]cCs|}|dg}g}d|kr*|dd|krVd|krV|dd|d|dd|jddd |D]T}|}|d|d<|d|d<|d |d <|d d|d <|tf||fqj|S) aHGenerates a list of separated connection settings for each host. Gets a list of connection settings for each host or router found in the given settings. Args: settings (dict): The configuration for the connections. Returns: list: A list of connections settings rdrbrcrr)rweightrbrccSs|d|dd fS)Nrrr)rrrxrxryr)rz8PoolsManager._get_connections_settings..)rwrr)r.rpoprsrrz)rZ pool_settingsrdrr Zconnection_settingsrxrxryr s4      z&PoolsManager._get_connections_settingsr|) cnx_settingsrpcCs~||}|dd|jkr.g|j|dd<|D]F\}}||dd|rPq2|j|ddg}|t|f|q2dS)a#Creates a `ConnectionPool` instance to hold the connections. Creates a `ConnectionPool` instance to hold the connections only if no other pool exists with the same configuration. Args: cnx_settings (dict): The configuration for the connections. rqrN)rrrrrsr)rrrrrrrxrxry create_pool8s  zPoolsManager.create_poolzList[ConnectionPool]r) pool_listrpcCs<|sdSt|dkr|dSt|d}td|}||S)zGet a random router from the group with the given priority. Returns: Router: a random router. .. versionadded:: 8.0.20 Nrr)rr&r')rr(r)rxrxry_get_random_poolNs    zPoolsManager._get_random_poolr)rr)r/rpcCsZg}d}|t|krV||j}||krB||rB|||n ||krLqV|d7}q|S)Nr)rrrrs)rr)r/ZsublistZ next_priorityrxrxry _get_sublist`s   zPoolsManager._get_sublist)rr/rpcCsbd}|D]"}|r"||jkr"q,|d7}qg}|sX|t|krX||||}|d7}q0||S)Nrr)rrrrr)rrr/r)rZsubpoolrxrxry_get_next_poolos  zPoolsManager._get_next_pool Optional[int]cCs@|dkr|r|djS|D]}|r|j}|Sq|djS)Nr)rr)rr/Zt_poolrxrxry_get_next_priority}s   zPoolsManager._get_next_priorityzOptional[bool])rreviverpcCsT||}|D]@}|rq|\}}|r0|}t|t|dkr|qdS)N)seconds)rrrrrrr)rrrrrrRZ timeout_stamprxrxry_check_unavailable_poolss  z%PoolsManager._check_unavailable_poolsrc s dddfdd }||}|dd}g}|||||}|dkrTtd||d<|||t}dk rzd kr|zjd j d }Wn t j k rtd dYnXz,| r܈ |js|||Wnvtttfk rlz.z |Wntttfk r8YnXW5|Xd krzjd j d }Wnt j k rYn>Xz.z |Wntttfk rYnXW5|XqJzHz&t}||||Wntttfk r YnXW5d krfz&jd j d }||Wntttfk r`YnXqXYnX|W5QRWSQRXnjjkrt}|||||WS|^z4jd j d }||||WW5QRWSt j k rtd dYnXW5QRXWqptttfk r}z|dd|t|trpdn |||||||dkr|||}||d<|||dkrd|} td| d|WYqpW5d}~XYqpXqptddS)aGet a connection from the pool. This method returns an `PooledConnection` instance which has a reference to the pool that created it, and can be used as a normal Connection. When the MySQL connection is not connected, a reconnect is attempted. Raises: :class:`PoolError`: On errors. Returns: PooledConnection: A pooled connection object. rr|rcsZ|tdd}tdd|dddDdkrV|djdS)Nrcss|]}t|VqdSrrrrxrxryrszOPoolsManager.get_connection..set_mysqlx_wait_timeout..rr\rr)rrrrBrrdr)rrrrxryset_mysqlx_wait_timeouts&z.set_mysqlx_wait_timeoutr/NzBUnable to connect to any of the target hosts. No pool is availablerTrz)Failed getting connection; pool exhaustedzpool max size has been reachedzpool: z error: r-z z2Unable to connect to any of the target hosts: [ z ]rL) rrrrr,r threadingRLockrrrrrrr7rrrr)rrarrrrrr.rsr~r rru) rrrrr/Z error_listlockrrrrxrryget_connections                           zPoolsManager.get_connectioncCsX||}|D]@}||dddk r|j|d}||kr||qt|S)zjCloses the connections in the pools Returns: int: The number of closed pools rqN)rrrrrr)rrrrZ client_poolsrxrxry close_pool+s  zPoolsManager.close_poolz#Union[InterfaceError, TimeoutError])rrrpc Csvd}z|j}t|}Wnttfk r.YnX|sX|j}tD]\}}||krB|}qB|rh||n |ddS)a\Sets a pool as unavailable. The time a pool is set unavailable depends on the given error message or the error number. Args: pool (ConnectionPool): The pool to set unavailable. err (Exception): The raised exception raised by a connection belonging to the pool. Ni)errnorrrtr_TIMEOUT_PENALTIESitemsr )rrZpenaltyZerr_noerr_msgrwrjrxrxryr;s  z!PoolsManager.set_pool_unavailable)N)N)rrrrr__annotations__rrrr staticmethodrrrrrrrrrrrxrxrxryrs0   ,  rc@sheZdZdZdddddZdddd Zd d d dd ddZddddZeddddZ e j dddddZ ddddZ dddddZ dddd Z d!dd"d#Zdd$d%d&d'Zd(dd)d*Zddd%d+d,Zdd$d%d-d.Zddd/d0Zddd1d2Zddd3d4ZdAd6dd%d7d8Zddd%d9d:Zddd%d;d<Zddd=d>Zddd?d@Zd5S)BSessiona*Enables interaction with a X Protocol enabled MySQL Product. The functionality includes: - Accessing available schemas. - Schema management operations. - Retrieval of connection information. Args: settings (dict): Connection data used to connect to the database. rr|r3c Cs|dtj|_||_|dr|drts6tdztj|dd}Wn<tj j k r}ztd|dd|W5d}~XYnXg|jd<|D].}|jd |j j d d |j|j|jd qd |jks|jd d k ri|jd<|d|kr6|dr6t|t||_|jdkrLtdnt|j|_|j|jd}|rz|dt|WnPtk r}z0|jdkr|jn d|d}t||j|W5d}~XYnXdS)NrhrbrmztMySQL host configuration requested DNS SRV. This requires the Python dnspython module. Please refer to documentationZSRVz Unable to locate any hosts for ''rdT)Zomit_final_dot)rbrcrrrjFrJpoolingz+Connection could not be retrieved from poolrazUSE iDefault schema '' does not exists)rr3use_purerHAVE_DNSPYTHONr)dnsresolverquery exceptionZ DNSExceptionrstargetZto_textrcrr_init_attributesrrr _connectionr,rrrrHrr+rr)rrZ srv_recordsrZsrvraerrmsgrxrxryrhs^              zSession.__init__rcCs|Srrxrrxrxry __enter__szSession.__enter__Type[BaseException] BaseExceptionrexc_type exc_value tracebackrpcCs |dSrrrrrrrxrxry__exit__szSession.__exit__c CstjdkrRdtdkr d}ndtdkr6d}nt}dtd}n.)Z_pid _platform_osZ _source_hostZ _client_nameZ_client_versionZ_client_licenserJrjAttribute name '' must be a string type "' exceeds 32 characters limit sizerrzHKey names in 'session-connect-attributes' cannot start with '_', found: z ' value 'z' must be a string type ' value: '$' exceeds 1024 characters limit sizeN)rrrb architecture win32_vermachinercmac_verrurRrSrdrngetpidre gethostnamerTrrr~r)r startswith)rZ platform_archZos_verZlicense_chunksZclient_licenseZdefault_attributes attr_name attr_valuerxrxryrs`           zSession._init_attributesrcCstjS)z8bool: `True` to use pure Python Protobuf implementation.)r3rrrxrxryrszSession.use_pure)rjrpcCs t|tstdt|dS)Nz)'use_pure' option should be True or False)r~rr-r3Z set_use_pure)rrjrxrxryr s cCs |jjS)zzReturns `True` if the session is open. Returns: bool: Returns `True` if the session is open. )rr5rrrxrxryr szSession.is_openrnrFrcCs t|j|Sr)rFrrrxrxryr s z Session.sqlrcCs|jS)z~Returns the underlying connection. Returns: mysqlx.connection.Connection: The connection object. )rrrxrxryr szSession.get_connectionrcCs |d}dd|DS)zReturns the list of schemas in the current session. Returns: `list`: The list of schemas in the current session. .. versionadded:: 8.0.12 zSHOW DATABASEScSsg|] }|dqS)rrx)r!rowrxrxryr"+ sz'Session.get_schemas..)rrrBrDrxrxry get_schemas" szSession.get_schemasr()rrpcCs t||S)zRetrieves a Schema object from the current session by it's name. Args: name (string): The name of the Schema object to be retrieved. Returns: mysqlx.Schema: The Schema object with the given name. r'rrrxrxry get_schema- s zSession.get_schemazOptional[Schema]cCsz|jjd}|rv|tt|}z |dd|krLt ||WSWn&t k rtt d|ddYnXdS)aRetrieves a Schema object from the current session by the schema name configured in the connection settings. Returns: mysqlx.Schema: The Schema object with the given name at connect time. None: In case the default schema was not provided with the initialization data. Raises: :class:`mysqlx.ProgrammingError`: If the provided default schema does not exists. rarr rN) rrrr_SELECT_SCHEMA_NAME_QUERYformatr/rrBr(rer-)rraresrxrxryget_default_schema8 s zSession.get_default_schemacCs|jdtt|ddS)zDrops the schema with the specified name. Args: name (string): The name of the Schema object to be retrieved. rTN)rr_DROP_DATABASE_QUERYr>rHr;rxrxry drop_schemaV s  zSession.drop_schemacCs$|jdtt|dt||S)zCreates a schema on the database and returns the corresponding object. Args: name (string): A string value indicating the schema name. rT)rr_CREATE_DATABASE_QUERYr>rHr(r;rxrxry create_schema` s  zSession.create_schemacCs|jddddS)z+Starts a transaction context on the server.rzSTART TRANSACTIONTNrrrrxrxrystart_transactionl szSession.start_transactioncCs|jddddS)zXCommits all the operations executed after a call to startTransaction(). rZCOMMITTNrErrxrxrycommitp szSession.commitcCs|jddddS)zYDiscards all the operations executed after a call to startTransaction(). rZROLLBACKTNrErrxrxryrollbackv szSession.rollbackNricCsT|dkrt}n"t|tr.t|dkr6td|jddt |d|S)aCreates a transaction savepoint. If a name is not provided, one will be generated using the uuid.uuid1() function. Args: name (Optional[string]): The savepoint name. Returns: string: The savepoint name. NrInvalid SAVEPOINT namerz SAVEPOINT T) uuidZuuid1r~rnrstripr-rrrHr;rxrxry set_savepoint| s   zSession.set_savepointcCs@t|trt|dkr"td|jddt|ddS)zRollback to a transaction savepoint with the given name. Args: name (string): The savepoint name. rrIrzROLLBACK TO SAVEPOINT TNr~rnrrKr-rrrHr;rxrxry rollback_to s zSession.rollback_tocCs@t|trt|dkr"td|jddt|ddS)z{Release a transaction savepoint with the given name. Args: name (string): The savepoint name. rrIrzRELEASE SAVEPOINT TNrMr;rxrxryrelease_savepoint s zSession.release_savepointcCs|jt|j|_dS)zCloses the session.N)rrrrrrxrxryr s z Session.closecCs|jdS)z8Closes all underliying connections as pooled connectionsN)rrarrxrxryclose_connections szSession.close_connections)N)rrrrrrr!rrrsetterrrrr:r<r@rBrDrFrGrHrLrNrOrrPrxrxrxryr [s2 ;M     r c@seZdZdZd%ddddddZdd d d Zd d dddddZdddddZdddddZdddddZ dddddZ d d d!d"Z dd d#d$Z dS)&Clienta(Class defining a client, it stores a connection configuration. Args: connection_dict (dict): The connection information to connect to a MySQL server. options_dict (dict): The options to configure this client. .. versionadded:: 8.0.13 Nrrr|)connection_dict options_dictrpcCs||_|dkri}g|_t|_||dd||dd||dd| |dd|j |jd<|j |jd<|j|jd <dS) NrrrrrenabledTr rq) rsessionsrJZuuid4rq_set_pool_sizer_set_max_idle_time_set_queue_timeout_set_pool_enabledpooling_enabledr)rrSrTrxrxryr s   zClient.__init__rcCs|Srrxrrxrxryr szClient.__enter__rrrrcCs |dSrrr rxrxryr! szClient.__exit__r) pool_sizerpcCsBt|tst|tr|dks,td|d|dkr8tn||_dS)aSet the size of the pool. This method sets the size of the pool but it will not resize the pool. Args: pool_size (int): An integer equal or greater than 0 indicating the pool size. Raises: :class:`AttributeError`: If the pool_size value is not an integer greater or equal to 0. rzGPool max_size value must be an integer greater than 0, the given value is not validN)r~rrr_CNX_POOL_MAXSIZEr)rr\rxrxryrW s zClient._set_pool_size)rrpcCsTt|tst|tr|dks,td|d||_|dkr>tn t|d|jd<dS)a}Set the max idle time. This method sets the max idle time. Args: max_idle_time (int): An integer equal or greater than 0 indicating the max idle time. Raises: :class:`AttributeError`: If the max_idle_time value is not an integer greater or equal to 0. rzYConnection max_idle_time value must be an integer greater or equal to 0, the given value r]rrrN)r~rrrr_CNX_POOL_MAX_IDLE_TIMEr)rrrxrxryrX s zClient._set_max_idle_timer)rUrpcCst|tstd||_dS)aSet if the pool is enabled. This method sets if the pool is enabled. Args: enabled (bool): True if to enabling the pool. Raises: :class:`AttributeError`: If the value of enabled is not a bool type. z*The enabled value should be True or False.N)r~rrr[)rrUrxrxryrZ s zClient._set_pool_enabled)rrpcCsjt|tst|tr|dks,td|d||_|dkr>tn t|d|jd<d|jkrf|j|jd<dS) a}Set the queue timeout. This method sets the queue timeout. Args: queue_timeout (int): An integer equal or greater than 0 indicating the queue timeout. Raises: :class:`AttributeError`: If the queue_timeout value is not an integer greater or equal to 0. rzYConnection queue_timeout value must be an integer greater or equal to 0, the given value r]rrrriN)r~rrrr_CNX_POOL_QUEUE_TIMEOUTr)rrrxrxryrY' s  zClient._set_queue_timeoutr cCst|j}|j||S)z~Creates a Session instance using the provided connection data. Returns: Session: Session object. )r rrVrsrsessionrxrxry get_sessionG s  zClient.get_sessioncCs&t|j|jD] }|qdS)z*Closes the sessions opened by this client.N)rrrrVrPrarxrxryrQ s z Client.close)N) rrrrrrr!rWrXrZrYrcrrxrxrxryrR s   rRz"Union[Dict[str, List[Dict]], Dict])pathrpc Cs|dd}d|ko.|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 st d|z|j|j |jdWn6tk r6}ztd|d|W5d}~XYnX||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%,rr[]rrr-rrz//zInvalid address: r4z Invalid URI: iNrrrd)replacerr6endswith _SPLIT_RErd _PRIORITY_REmatchgroupr _ROUTER_RErrr)rrcrr-rsr) rdrrrdZ address_listraddressr rmrrxrxry_parse_address_listX sD &     $  rqr)urirpcCsddi}t|}|r|nd|f\}}|dkrBtd|d|dkrRd|d <|d d d d \}}|d d d d \}}|d}||d ddkr|dkr|dd\}|d<|d}|r|rd|krtd|d| dd\} } t | t | |d<|d<| dr,t ||d<n$| drBtdn| t |d} t|dD]\} } | dd}|| krtd | d|tkrt | d||<n8| }|d!krd||<n|d"krd#||<n|||<q^|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. rarer)r mysqlx+srvzScheme 'z' is not validrsTrm@Nr-?/)rrrz()rzMalformed URI 'r r_r`)rvrMr\rez\.zWindows Pipe is not supported)r_r`rmrrrzInvalid option: ')1true)0falseF)_URI_SCHEME_RErmgroupsr) partitionrfindfindrsplitrKrdrr6rrqrrirG _SSL_OPTS)rrrrmschemeuserinfotmprbZ query_strposr_r`Zinvalid_optionsrwvaloptZval_strrxrxry_parse_connection_uri sH             rr3c Cst|t}|r0d|}td|dd|krR|dD]}t|dq@nd|krbt|d|kr|d}z&tt|t r| n||d<Wn<t t fk r}ztd|dd|W5d }~XYnXd |kr|dtjtjfkrtd d |krd |krtd d|kr2d|kr2tdd |kr`|dtjtjtjfkr`tdd|kr|d}z(tt|t r| n||d<Wn>t t fk r}ztd|dd|W5d }~XYnXd|krT|d}z(tt|t r| n||d<Wn>t t fk rR}ztd|dd|W5d }~XYnXd|krt|dt r|d d}|r|d|d<nd |d<nt|dttfstd|dtjkrd |d<d|krt|d|krZzFt|dt rt|d|d<t|dtr2|ddkr6t Wn t k rXtdd YnXd|krt|dts|td |d!rtd"|d#rtd$|drtd%nd|kr|d#sd|d#<d&|krt|d'|krt|d S)(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. z', 'zInvalid option(s): 'r rdr,rbrfzInvalid SSL Mode 'NrZzCannot verify Server without CAr\zCA Certificate not providedr[rYzClient Certificate not providedz$Must verify Server if CA is providedrgzInvalid Auth 'rkzpThe connection property 'compression' acceptable values are: 'preferred', 'required', or 'disabled'. The value 'z' is not acceptablerlz[]rfz@Invalid type of the connection property 'compression-algorithms'rjrirzEThe connection timeout value must be a positive integer (including 0)rmz(The value of 'dns-srv' must be a booleanrezt|t r|D]}| |qntdd t d|d|s,td g}g}g}|D]:}|t krT| ||tkrj| |n | |q<|r|dgkrtstt|t |||d<n.|rtt|t n|rtt|t dS)zValidate tls-versions. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-versions name is not valid. r]Nrgrhz%tls-versions must be a list, found: 'r rrrfre tls_versionsrrjzKAt least one TLS protocol version must be specified in 'tls-versions' list.z>tls-versions should be a list with one or more of versions in rz . found: 'r)r~rnr6rjr)rdrKrNr>rsrrrur"r rr*rOrrPrQ) rrZtls_versions_settingsZtls_verstls_verrZuse_tls_versionsZdeprecated_tls_versionsZnot_tls_versionsrxrxryr s            rc Csg}d|krdS|d}t|tr|dr6|dsFtd|d|ddd }|sdtd |D]}|}|rh||qhn.t|t t frd d |D}ntd |d| dddkrt ddn|ddd}|j dd|d}g}i}g} t dt |dD]"} |t| | t| q|D]p} d| krf| | krf|| nJ| |kr|| } | |krttjd| d|| ntd| dqB|std ||d<dS)zValidate tls-ciphersuites. Args: settings (dict): Settings dictionary. Raises: :class:`mysqlx.InterfaceError`: If tls-ciphersuites name is not valid. r^Nrgrhz)tls-ciphersuites must be a list, found: 'r rrrfz:No valid cipher suite found in the 'tls-ciphersuites' listcSsg|] }|r|qSrxrx)r!tls_csrxrxryr"d sz._validate_tls_ciphersuites..zItls-ciphersuites should be a list with one or more ciphersuites. Found: 'r]Trrrtls_ciphersuitesrz The value 'z.' in cipher suites is not a valid cipher suite)r~rnr6rjr)rdrKupperrsrrrr"rr)rr#rr!rrNr>) rrZtls_ciphersuites_settingsZtls_cssrrZ newer_tls_verZtranslated_namesZiani_cipher_suites_namesZossl_cipher_suites_namesrrZtranslated_namerxrxryrB sz            r)rrorpcOsi}|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. rrrrzSettings not provided)r~rnrrrrir)r)rrorrwrrxrxry_get_connection_settings srcOst||}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 )rrorrxrxryrc s rczUnion[str, Dict[str, Any]])connection_stringoptions_stringrpc Csdt|ttfstdt|}t|ttfs4tdt|tr|zt|}Wqtk rx}ztd|W5d}~XYqXn&i}|D]\}}||| dd<qt|tstdi}d|krZ| d}t|tstd| d d |d <| d d |d <| d d|d <| dd|d<t |dkr:td|t |dkrZtd| 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 dictNrrrr z<'pooling' options must be given in the form document or dictrUTrrrrrzUnrecognized pooling options: z!Unrecognized connection options: )r~rnrr)rjsonloadsrrrirrrrR) rrZ settings_dictrTrrwrjZpooling_options_dictZpooling_optionsrxrxry get_client sN5      r)N)r __future__rtypesrrrPROTOCOL_TLSv1PROTOCOL_TLSv1_1PROTOCOL_TLSv1_2rhasattrrPROTOCOL_SSLv23r r ImportErrorrrrbrr&rererfrrJrtypingr r r r rrrrrZ dns.exceptionrZ dns.resolverrrr functoolsrZ json.decoderr urllib.parserrrZauthenticationrrr constantsrr r!r"r#r$r%r&Zcrudr(errorsr)r*r+r,r-r.Zhelpersr/r0r1r2Zprotobufr3r6r4r5r6r7r8rr9r:r;r<r=rr>r?r@rArBrCrDrErFrGrHrIrJrKrLrdrsZmysql.connector.abstractsrNrOrPrQZmysql.connector.utilsrRZmysql.connector.versionrSrTrrrArCr=rr^rcompilerr_r`Z_PENALTY_SERVER_OFFLINEZ_PENALTY_MAXED_OUTZ_PENALTY_NO_ADD_INFOZ_PENALTY_CONN_TIMEOUTZ_PENALTY_WRONG_PASSWZ_PENALTY_RESTARTINGrrrkVERBOSErlror|rrrzrrrrrr rrrrrr rRrqrrrrrrrrcrrxrxrxrys0   ,    (    4        u>$_IX _!7?$p[Y$