vd@zdZ ddlZdZn #dZYnxYwddlZddlZddlmZddlmZddl m Z m Z m Z dd l mZdd lmZmZdd lmZmZmZdd lmZmZd ZdZGddeZdZGddeZGddeZGddeZ GddeZ!Gdde!Z"Gdde!Z#dS)z4Implementation of communication for MySQL X servers.NTFwraps)MySQL41AuthPlugin)InterfaceErrorOperationalErrorProgrammingErrorSchema)ProtocolMessageReaderWriter)Result RowResult DocResult) SqlStatement AddStatementzDROP DATABASE IF EXISTS `{0}`z#CREATE DATABASE IF NOT EXISTS `{0}`c6eZdZdZdZdZdZdZifdZdS) SocketStreamc"d|_d|_dS)NF)_socket_is_sslselfs M/var/www/html/t/fyr/venv311/lib/python3.11/site-packages/mysqlx/connection.py__init__zSocketStream.__init__2s  ct|tr tjn tj}tj|tj|_|j|dSN) isinstancetuplesocketAF_INETAF_UNIX SOCK_STREAMrconnect)rparamss_types rr%zSocketStream.connect6sP#-fe#<#<P&.}VV-?@@  V$$$$$rc |jtdg}|dkr\|j|}|dkrtd|||t |z}|dk\d|S)NMySQLx Connection not availablerrzUnexpected connection close)rrrecv RuntimeErrorappendlenjoin)rcountbufdatas rreadzSocketStream.read;s < "#DEE Eaii<$$U++Ds{{"#@AAA JJt    SYY E aii xx}}rcf|jtd|j|dS)Nr))rrsendallrr1s rr4zSocketStream.sendallGs5 < "#DEE E T"""""rcX|jsdS|jd|_dSr)rclosers rr7zSocketStream.closeLs0|  F  rcts#|tdtjtj}|d|vrk ||dtj|_ n=#ttj f$r$|tdwxYwd|vrk ||dtj |_n=#ttj f$r$|tdwxYwd|vro ||d|ddnd#ttj f$r$|tdwxYwd|vr#|td ||j|_d |_dS) Nz'Python installation has no SSL support.zssl-cazInvalid CA certificate.zssl-crlz Invalid CRL.zssl-certzssl-keyzInvalid Client Certificate/Key.z Client Certificate not provided.T) SSL_AVAILABLEr7r+ssl SSLContextPROTOCOL_SSLv23load_default_certsload_verify_locations CERT_REQUIRED verify_modeIOErrorSSLErrorrVERIFY_CRL_CHECK_CHAIN verify_flagsload_cert_chainget wrap_socketrr)rssl_optscontexts rset_sslzSocketStream.set_sslSs J JJLLLHII I.!455""$$$ x   @--hx.@AAA&)&7##S\* @ @ @ $%>??? @   5--hy.ABBB'*'A$$S\* 5 5 5 $^444 5  ! ! H''(<LLD113333S\* H H H $%FGGG H( " " JJLLL !CDD D**4<88  s$",B:C ,C>>:D80E11:F+N) __name__ __module__ __qualname__rr%r2r4r7rJrrrr1sx%%%   ###  "!!!!!!rrc<tfd}|S)Nc |g|Ri|S#tjtf$r$|t dwxYw)NzCannot connect to host.)r!errorr+ disconnectr)rargskwargsfuncs rwrapperz(catch_network_exception..wrapperxsi <4.t...v.. . l+ < < < OO    !:;; ; > %%f&6&6&8&8999]5577  ((  0 0 < < > > > ""$$$$$rc>|jd||dS)Nsql)resend_execute_statement)rrrSs rsend_sqlzConnection.send_sqls" ,,UC>>>>>rc|j|d}t|tr|j}t ||Sr)re send_insertrr_idsr)r statementidss rrzConnection.send_insertsF !!),,, i . . !.CdC   rc|j||jrt|nt |Sr)re send_find _doc_basedrrrrs rfindzConnection.finds6  ***"+"6KyIdOOKrcT|j|t|Sr)re send_deleterrs rdeletezConnection.delete$ !!),,,d||rcT|j|t|Sr)re send_updaterrs rupdatezConnection.updaterrTcX|j|||t|Sr)rerr)r namespacecmd raise_on_failrSs rexecute_nonqueryzConnection.execute_nonquerys( ,,YTBBBd||rc|jd||t|}||jdkrt d|ddS)Nrrz No data found)rerrrhr/r)rrrSresults rexecute_sql_scalarzConnection.execute_sql_scalarsb ,,UC>>>4 <1   11 1ay|rcX|jd||t|S)Nxplugin)rerr)rrrSs rget_row_resultzConnection.get_row_results( ,,YTBBBrc6|j|Sr)reread_rowrrs rrzConnection.read_rows}%%f---rc:|j|dSr)re close_resultrs rrzConnection.close_results ""6*****rc6|j|Sr)reget_column_metadatars rrzConnection.get_column_metadatas}00888rc|jjduSr)rcrrs ris_openzConnection.is_opens{"$..rcd|sdS|jdSr)rrcr7rs rrRzConnection.disconnects1||~~  F rc|sdS|j|j|j|j|jdSr)rrarhre send_closeread_okrcr7rs rr7zConnection.closesw||~~  F   *   ) ) + + +   """  rN)T)rKrLrMrriror%rqrrrWrrrrrrrrrrrrrRr7rNrrrYrYs''' %%%+++$%%%???!!!LLL...+++999/// rrYcReZdZfdZdZfdZfdZdZfdZfdZ xZ S) XConnectionctt||g|_|dg|_d|vrL|drD|j|d|dddd|_d|_| |j dddS) Nroutersrkrl)rkrlTc|dS)NpriorityrN)xs rz&XConnection.__init__..s :r)keyreverse) superrrdependent_connectionspop_routersr, _cur_router _can_failover_ensure_prioritiessortrrb __class__s rrzXConnection.__init__s k4  ))(333%'" Y33 X  (6"2  M  V,, VT22""    ! !!! 66EEEEErcd}d}|jD]@}|dd}| |dz }||d<n|dkrtdd|dz}Ad|cxkrt|jkrndStdddS) Nrdrrz(The priorities must be between 0 and 100iz\You must either assign no priority to any of the routers or give a priority for every routeri)rrFr r-)rpriority_countrrouterpris rrzXConnection._ensure_prioritiessm  F**Z..C{!#%-z""s&(!!! MHH ~ 2 2 2 2DM 2 2 2 2 2 2 2 2"$EFJLL L 3 2rc|js.d|_tt|S|jr |jdurd|_d|_|jD]}d|d<|xjdz c_|j|jd}|j|jd}|jdkrd|j|jdz d<|jt |jdz krd|_||fS) NFrT availablerrkrlr)rrrrrorr-)rrrkrlrs rrozXConnection._connection_params)s } A!&D d++>>@@ @! +T%5%;%;!D !%D - + +&*{## A}T-.v6}T-.v6  a  =BDM$*1, -k :  s4=11A5 5 5!&D d}rcDd}|jrM tt|S#tj$r }|}Yd}~nd}~wwxYw|jMt |jdkr"td |tdd)NrCannot connect to host: {0}z(Failed to connect to any of the routers.i) rrrr%r!rQr-rrformat)rrQerrrs rr%zXConnection.connect@s   [$//77999<       t}   " " !>!E!Ee!L!LMM MGNNNs&3AA  Ac:|j|dSr)rr,)r connections rbind_connectionzXConnection.bind_connectionMs "))*55555rc|jr2|j|j2tt|dSr)rrr7rrrrs rr7zXConnection.closePs^( 5  & * * , , 2 2 4 4 4( 5 k4  &&(((((rc|jr2|j|j2tt|dSr)rrrRrrrs rrRzXConnection.disconnectUs^( :  & * * , , 7 7 9 9 9( : k4  ++-----r) rKrLrMrrror%rr7rR __classcell__rs@rrrsFFFFF LLL$. O O O O O666))))) .........rrc(eZdZfdZfdZxZS)NodeConnectioncXtt||dSr)rrrrs rrzNodeConnection.__init__\s' nd##,,X66666rc tt|dS#tj$r'}t d|d}~wwxYw)Nr)rrr%r!rQrr)rrrs rr%zNodeConnection.connect_sm L .$ ' ' / / 1 1 1 1 1| L L L !>!E!Ec!J!JKK K Ls',A""AA")rKrLrMrr%rrs@rrr[sZ77777LLLLLLLLLrrcNeZdZdZdZdZdZdZdZdZ dZ d Z d Z d Z d S) BaseSessionaBase 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. c||_dSr) _settingsrfs rrzBaseSession.__init__ts !rc(|jjjduSr) _connectionrcrrs rrzBaseSession.is_openws&.d::rc"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 rrzs r get_schemazBaseSession.get_schemazsdD!!!rc|jjdr t||jjdSt d)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. r]zDefault schema not provided)rrbrFr r rs rget_default_schemazBaseSession.get_default_schemasK   $ ( ( 2 2 E$ 0 9( CDD D<===rcn|jdt|ddS)zDrops the schema with the specified name. Args: name (string): The name of the Schema object to be retrieved. rTN)rr_DROP_DATABASE_QUERYrrs r drop_schemazBaseSession.drop_schemas? )) '..t44d < < < <  > >dD!!!rc>|jddddS)z4Starts a transaction context on the server. rzSTART TRANSACTIONTNrrrs rstart_transactionzBaseSession.start_transactions& ))%1DdKKKKKrc>|jddddS)zXCommits all the operations executed after a call to startTransaction(). rCOMMITTNrrs rcommitzBaseSession.commits% ))%4@@@@@rc>|jddddS)zYDiscards all the operations executed after a call to startTransaction(). rROLLBACKTNrrs rrollbackzBaseSession.rollbacks% ))%TBBBBBrc8|jdSr)rr7rs rr7zBaseSession.closes      rN)rKrLrM__doc__rrrrrrrrrr7rNrrrrfs  """;;; " " " > > ><<< " " "LLL AAA CCC !!!!!rrc(eZdZdZfdZdZxZS)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. ctt||t|j|_|jdSr)rrrrrrr%rs rrzXSession.__init__sN h&&x000&t~66   """""rc|stdt|j}|j|j|S)Nz$XSession is not connected to a farm.)rr NodeSessionrrr)rnsesss rbind_to_default_shardzXSession.bind_to_default_shardsP||~~ K"#IJJ JDN++ (():;;; r)rKrLrMrrrrrs@rrrsQ  ##### rrc(eZdZdZfdZdZxZS)ratEnables 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. ctt||t|j|_|jdSr)rrrrrrr%rs rrzNodeSession.__init__sN k4  ))(333)$.99   """""rc,t|j|S)z}Creates a :class:`mysqlx.SqlStatement` object to allow running the SQL statement on the target MySQL Server. )rr)rrs rrzNodeSession.sqlsD,c222r)rKrLrMrrrrrs@rrrsQ  ##### 3333333rr)$rr:r9r|r! functoolsrauthenticationrerrorsrrr crudr rer r rrrrrrrrrobjectrrWrYrrrrrrNrrr sa0;:JJJMMMMM ------FFFFFFFFFF333333330000000000111111117>CCCCC6CCCLAAAAAAAAHR.R.R.R.R.*R.R.R.jLLLLLZLLLT!T!T!T!T!&T!T!T!n{633333+33333s