B Ñš[¥@ã@s&dZyddlZdZWndZYnXddlZddlZddlmZddlmZddl m Z m Z m Z dd l mZdd lmZmZdd lmZmZmZdd lmZmZd ZdZGdd„deƒZdd„ZGdd„deƒZGdd„deƒZGdd„deƒZ Gdd„deƒZ!Gdd„de!ƒZ"Gdd„de!ƒZ#dS)z4Implementation of communication for MySQL X servers.éNTF)Úwrapsé)ÚMySQL41AuthPlugin)ÚInterfaceErrorÚOperationalErrorÚProgrammingError)ÚSchema)ÚProtocolÚMessageReaderWriter)ÚResultÚ RowResultÚ DocResult)Ú SqlStatementÚ AddStatementzDROP DATABASE IF EXISTS `{0}`z#CREATE DATABASE IF NOT EXISTS `{0}`c@s@eZdZdd„Zdd„Zdd„Zdd„Zd d „Zifd d „Zd S)Ú SocketStreamcCsd|_d|_dS)NF)Ú_socketÚ_is_ssl)Úself©rú•C:\Users\HIRONO~1\AppData\Local\Temp\pip-install-ioykiiwb\mysql-connector-python-rf\mysql_connector_python_rf-2.2.2.data\purelib\mysqlx\connection.pyÚ__init__2szSocketStream.__init__cCs6t|tƒrtjntj}t |tj¡|_|j |¡dS)N)Ú isinstanceÚtupleÚsocketÚAF_INETÚAF_UNIXÚ SOCK_STREAMrÚconnect)rÚparamsZs_typerrrr6szSocketStream.connectcCs`|jdkrtdƒ‚g}x>|dkrT|j |¡}|dkr      zSocketStream.set_sslN) Ú__name__Ú __module__Ú __qualname__rrr(r)r*r;rrrrr1s  rcstˆƒ‡fdd„ƒ}|S)Nc s@yˆ|f|ž|ŽStjtfk r:| ¡tdƒ‚YnXdS)NzCannot connect to host.)rÚerrorr!Ú disconnectr)rÚargsÚkwargs)ÚfuncrrÚwrapperxs z(catch_network_exception..wrapper)r)rCrDr)rCrÚcatch_network_exceptionwsrEc@sÚeZdZdd„Zdd„Zdd„Zdd„Zd d „Zd d „Ze d d„ƒZ e dd„ƒZ e dd„ƒZ e dd„ƒZ e dd„ƒZe d+dd„ƒZe dd„ƒZe dd„ƒZe dd„ƒZe d d!„ƒZe d"d#„ƒZd$d%„Zd&d'„Zd(d)„Zd*S),Ú ConnectioncCsH| d¡|_| d¡|_| d¡|_d|_||_tƒ|_d|_d|_ dS)NÚuserÚpasswordÚschema) r8Ú_userÚ _passwordZ_schemaÚ_active_resultÚsettingsrÚstreamÚ reader_writerÚprotocol)rrMrrrrƒs   zConnection.__init__cCs|jdk r|j ¡d|_dS)N)rLÚ fetch_all)rrrrÚfetch_active_results  zConnection.fetch_active_resultcCs:d|jkr"|jd|j dd¡fSd|jkr6|jdSdS)NÚhostÚporti$r)Ú localhosti$)rMr8)rrrrÚ_connection_params’s    zConnection._connection_paramscCs<|j | ¡¡t|jƒ|_t|jƒ|_| ¡| ¡dS)N) rNrrVr rOr rPÚ_handle_capabilitiesÚ _authenticate)rrrrr™s   zConnection.connectcCs–|j ¡j}|r$|dj ¡dksJndsJ|j dd¡rF| ¡tdƒ‚dSt j dkrv|j dd¡rr| ¡t dƒ‚dS|jj dd |j  |j¡dS) NrÚtlsFz ssl-enablezSSL not enabled at server.)ééé z=The support for SSL is not available for this Python version.T)rY)rPZget_capabilitesZ capabilitiesÚnameÚlowerrMr8r*rÚsysÚ version_infor!Zset_capabilitiesrNr;)rr'rrrrW s  zConnection._handle_capabilitiescCsHt|j|jƒ}|j | ¡¡|j ¡}|j | |¡¡|j  ¡dS)N) rrJrKrPZsend_auth_startZ auth_nameZread_auth_continueZsend_auth_continueZbuild_authentication_responseZ read_auth_ok)rZpluginÚ extra_datarrrrX²s   zConnection._authenticatecGs|j d||¡dS)NÚsql)rPÚsend_execute_statement)rrbrArrrÚsend_sqlºszConnection.send_sqlcCs*|j |¡d}t|tƒr |j}t||ƒS)N)rPÚ send_insertrrZ_idsr )rÚ statementÚidsrrrre¾s   zConnection.send_insertcCs"|j |¡|jrt|ƒSt|ƒS)N)rPZ send_findZ _doc_basedr r )rrfrrrÚfindÆs zConnection.findcCs|j |¡t|ƒS)N)rPZ send_deleter )rrfrrrÚdeleteËs zConnection.deletecCs|j |¡t|ƒS)N)rPZ send_updater )rrfrrrÚupdateÐs zConnection.updateTcGs|j |||¡t|ƒS)N)rPrcr )rÚ namespaceÚcmdZ raise_on_failrArrrÚexecute_nonqueryÕszConnection.execute_nonquerycGs>|j d||¡t|ƒ}| ¡|jdkr2tdƒ‚|ddS)Nrbrz No data found)rPrcr rQr%r)rrbrAÚresultrrrÚexecute_sql_scalarÚs  zConnection.execute_sql_scalarcGs|j d||¡t|ƒS)NZxplugin)rPrcr )rrlrArrrÚget_row_resultãszConnection.get_row_resultcCs |j |¡S)N)rPÚread_row)rrnrrrrqèszConnection.read_rowcCs|j |¡dS)N)rPÚ close_result)rrnrrrrrìszConnection.close_resultcCs |j |¡S)N)rPÚget_column_metadata)rrnrrrrsðszConnection.get_column_metadatacCs |jjdk S)N)rNr)rrrrÚis_openôszConnection.is_opencCs| ¡s dS|j ¡dS)N)rtrNr*)rrrrr@÷szConnection.disconnectcCsB| ¡s dS|jdk r |j ¡|j ¡|j ¡|j ¡dS)N)rtrLrQrPZ send_closeÚread_okrNr*)rrrrr*üs    zConnection.closeN)T)r<r=r>rrRrVrrWrXrErdrerhrirjrmrorprqrrrsrtr@r*rrrrrF‚s*           rFcs\eZdZ‡fdd„Zdd„Z‡fdd„Z‡fdd„Zd d „Z‡fd d „Z‡fd d„Z ‡Z S)Ú XConnectioncs€tt|ƒ |¡g|_| dg¡|_d|krT|drT|j | d¡| dd¡dœ¡d|_d|_|  ¡|jj dd„dd dS) NZroutersrSrT)rSrTéÿÿÿÿTcSs|dS)NÚpriorityr)ÚxrrrÚsz&XConnection.__init__..)ÚkeyÚreverse) ÚsuperrvrÚdependent_connectionsÚpopÚ_routersr"Ú _cur_routerÚ _can_failoverÚ_ensure_prioritiesÚsort)rrM)Ú __class__rrrszXConnection.__init__cCs„d}d}xN|jD]D}| dd¡}|dkr:|d7}||d<n|dkrLtddƒ‚|d8}qWd|krrt|jƒkr€nn tddƒ‚dS) Nrédrxrz(The priorities must be between 0 and 100i§z\You must either assign no priority to any of the routers or give a priority for every routeri )r€r8rr#)rZpriority_countrxÚrouterÚprirrrrƒs    zXConnection._ensure_prioritiescs¼|jsd|_tt|ƒ ¡S|jr*|jdkrNd|_d|_x|jD] }d|d<q>W|jd7_|j|jd}|j|jd}|jdkršd|j|jdd<|jt|jƒdkr´d|_||fS) NFrwTÚ availablerrSrTr)r€r‚r}rvrVrr#)rr‡rSrT)r…rrrV)s    zXConnection._connection_paramsc srd}xB|jrFytt|ƒ ¡Stjk rB}z|}Wdd}~XYqXqWt|jƒdkrdtd  |¡ƒ‚tddƒ‚dS)NrzCannot connect to host: {0}z(Failed to connect to any of the routers.i¡) r‚r}rvrrr?r#r€rÚformat)rr?Úerr)r…rrr@szXConnection.connectcCs|j |¡dS)N)r~r")rÚ connectionrrrÚbind_connectionMszXConnection.bind_connectioncs,x|jr|j ¡ ¡qWtt|ƒ ¡dS)N)r~rr*r}rv)r)r…rrr*PszXConnection.closecs,x|jr|j ¡ ¡qWtt|ƒ ¡dS)N)r~rr@r}rv)r)r…rrr@UszXConnection.disconnect) r<r=r>rrƒrVrrr*r@Ú __classcell__rr)r…rrvs    rvcs(eZdZ‡fdd„Z‡fdd„Z‡ZS)ÚNodeConnectioncstt|ƒ |¡dS)N)r}rr)rrM)r…rrr\szNodeConnection.__init__c sJytt|ƒ ¡Wn2tjk rD}ztd |¡ƒ‚Wdd}~XYnXdS)NzCannot connect to host: {0})r}rrrr?rrŠ)rr‹)r…rrr_szNodeConnection.connect)r<r=r>rrrŽrr)r…rr[s rc@s`eZdZdZdd„Zdd„Zdd„Zdd „Zd d „Zd d „Z dd„Z dd„Z dd„Z dd„Z dS)Ú BaseSessionaÜBase functionality for Session classes through the X Protocol. This class encloses the core functionality to be made available on both the XSession and NodeSession classes, such functionality includes: - Accessing available schemas. - Schema management operations. - Enabling/disabling warning generation. - Retrieval of connection information. Args: settings (dict): Connection data used to connect to the database. cCs ||_dS)N)Ú _settings)rrMrrrrtszBaseSession.__init__cCs|jjjdk S)N)Ú _connectionrNr)rrrrrtwszBaseSession.is_opencCs t||ƒS)zöRetrieves 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)rr]rrrÚ get_schemazs zBaseSession.get_schemacCs,|jj d¡r t||jjdƒStdƒ‚dS)aKRetrieves 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. Raises: ProgrammingError: If default schema not provided. rIzDefault schema not providedN)r’rMr8rr)rrrrÚget_default_schema…s zBaseSession.get_default_schemacCs|j dt |¡d¡dS)z‹Drops the schema with the specified name. Args: name (string): The name of the Schema object to be retrieved. rbTN)r’rmÚ_DROP_DATABASE_QUERYrŠ)rr]rrrÚ drop_schema”szBaseSession.drop_schemacCs |j dt |¡d¡t||ƒS)z¬Creates a schema on the database and returns the corresponding object. Args: name (string): A string value indicating the schema name. rbT)r’rmÚ_CREATE_DATABASE_QUERYrŠr)rr]rrrÚ create_schemaszBaseSession.create_schemacCs|j ddd¡dS)z4Starts a transaction context on the server. rbzSTART TRANSACTIONTN)r’rm)rrrrÚstart_transaction¨szBaseSession.start_transactioncCs|j ddd¡dS)zXCommits all the operations executed after a call to startTransaction(). rbZCOMMITTN)r’rm)rrrrÚcommit­szBaseSession.commitcCs|j ddd¡dS)zYDiscards all the operations executed after a call to startTransaction(). rbZROLLBACKTN)r’rm)rrrrÚrollback³szBaseSession.rollbackcCs|j ¡dS)N)r’r*)rrrrr*¹szBaseSession.closeN)r<r=r>Ú__doc__rrtr“r”r–r˜r™ršr›r*rrrrrfs    rcs(eZdZdZ‡fdd„Zdd„Z‡ZS)ÚXSessionaWEnables interaction with a X Protocol enabled MySQL Product. The functionality includes: - Accessing available schemas. - Schema management operations. - Enabling/disabling warning generation. - Retrieval of connection information. Args: settings (dict): Connection data used to connect to the database. cs*tt|ƒ |¡t|jƒ|_|j ¡dS)N)r}rrrvr‘r’r)rrM)r…rrrÊs zXSession.__init__cCs,| ¡stdƒ‚t|jƒ}|j |j¡|S)Nz$XSession is not connected to a farm.)rtrÚ NodeSessionr‘r’r)rZnsessrrrÚbind_to_default_shardÏs  zXSession.bind_to_default_shard)r<r=r>rœrrŸrŽrr)r…rr½s  rcs(eZdZdZ‡fdd„Zdd„Z‡ZS)ržatEnables interaction with a X Protocol enabled MySQL Server. The functionality includes: - Accessing available schemas. - Schema management operations. - Enabling/disabling warning generation. - Retrieval of connection information. - Includes SQL Execution. Args: settings (dict): Connection data used to connect to the database. cs*tt|ƒ |¡t|jƒ|_|j ¡dS)N)r}ržrrr‘r’r)rrM)r…rrræs zNodeSession.__init__cCs t|j|ƒS)z}Creates a :class:`mysqlx.SqlStatement` object to allow running the SQL statement on the target MySQL Server. )rr’)rrbrrrrbëszNodeSession.sql)r<r=r>rœrrbrŽrr)r…rržØs  rž)$rœr,r+r_rÚ functoolsrZauthenticationrÚerrorsrrrZcrudrrPr r rnr r r rfrrr•r—ÚobjectrrErFrvrrrržrrrrÚs2    F U W