vd dZddlZddlZddlZddlZddlmZddlmZddlm Z ddl Z ddl Z ddl Z ddl mZmZmZddlZddlmZn!#e$rddlmZmZmZddlmZddlmZYnwxYwejddkr dd lmZd Zn$#e$rd ZYnwxYw dd lmZd Zn #e$rd ZYnwxYwddlZdd lmZdd l m!Z!ddl"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*ddl+m,Z,m-Z-m.Z.m/Z/ddl0m1Z1ddl0m2Z2m3Z3ddl4m5Z5ddl6m7Z7ddl0m8Z8ddl9m:Z:m;Z;mfZ?e1j=e1j@e1jAe1jBe1jCfZDgaEdZFdddZGiZHdZIdZJdZKdZLdZMdZNdZOdZPdZQdZRdZSdZTdZUdZVeWfd dfeXeYeWejejZge[e<zd!dfeXe[fd"dfeYfd#eOfeWfd$dfeWfd%dfeWfd&eUfeYfd'eLfeYfd(eKfd) Z\e j]d*Z^Gd+d,e_Z`Gd-d.e_ZaGd/d0e_ZbGd1d2ebZcGd3d4e_ZdGd5d6edZed7Zfd8Zgd9Zhd:ZierGd;deZlGd?d@e_ZmGdAdBe_ZnGdCdDenZoGdEdFenZpGdGdHe_ZqdS)Iz,Implementing communication with MySQL FabricN) b16decode)bisect)md5)Fault ServerProxy Transport) BadStatusLine)HTTPSConnectionTF)MySQLConnection)MySQLConverter)MySQLConnectionPool)ErrorInterfaceErrorNotSupportedErrorMySQLFabricError InternalError DatabaseError) MySQLCursorMySQLCursorBufferedMySQLCursorRawMySQLCursorBufferedRaw) errorcode)FabricMySQLServer FabricShard) FabricCache)WeightedRoundRobinversion)PY2 isunicode UNICODE_TYPESxmlrpci~i~)r$mysqlGLOBALLOCALFAULTYzName of group of serversz Sharding keyzList of tables in queryz#Read-Only, Write-Only or Read-Writez+Identity of the shard for direct connectionz+GLOBAL for accessing Global Group, or LOCALzAttempts for getting connectionz$Seconds to wait between each attempt) groupkeytablesmodeshardmappingscopeattempts attempt_delayzmyconnpy-fabricc8eZdZdZdZdZdZd dZdZdZ dS) MySQLRPCProtocolz0Class using MySQL protocol to query Fabric. ct|_t||||||_|jdSN)r converterFabricMySQLConnectionhandlerconnectselffabrichostportconnect_attempts connect_delays ]/var/www/html/t/fyr/venv311/lib/python3.11/site-packages/mysql/connector/fabric/connection.py__init__zMySQLRPCProtocol.__init__sH')),VT4-=-:<<  c  g}t|D]\}}|}|j|}|j|}|j|}|d|t| |S#t$r,}tj j d|zd}~wwxYw)z,Process query parameters given as dictionaryz{0}={1}z)Failed processing pyformat-parameters; %sN)listitemsr8to_mysqlescapequoteappendformatstr Exceptionr% connectorerrorsProgrammingError)r=paramsresr,valueconverrs rC_process_params_dictz%MySQLRPCProtocol._process_params_dicts C"6<<>>22 = = U~..t44~,,T22~++D11 9++CT;;<<<<  =J  C C C/(99;cACC C CsB/B44 C*>'C%%C*c |}fd|D}fd|D}fd|D}d|D}t|S#t$r,}tjjd|zd}~wwxYw)zProcess query parameters.cDg|]}j|S)r8rI.0ir=s rC z4MySQLRPCProtocol._process_params..s);;;!4>**1--;;;rEcDg|]}j|Sr[)r8rJr\s rCr_z4MySQLRPCProtocol._process_params..s)9994>((++999rEcDg|]}j|Sr[)r8rKr\s rCr_z4MySQLRPCProtocol._process_params..s)888q4>''**888rEc,g|]}t|Sr[)rN)r]r^s rCr_z4MySQLRPCProtocol._process_params..s'''a3q66'''rEz'Failed processing format-parameters; %sN)tuplerOr%rPrQrR)r=rSrTrWs` rC_process_paramsz MySQLRPCProtocol._process_paramss C;;;;s;;;C9999S999C8888C888C''3'''C ::   A A A/(999C?AA A As8A B'A;;BNc|sd}|jjd}g}|||dD])}||*|S)zYExecutes the given query Returns a list containing response from Fabric r[T) dictionary)multi)r: connectioncursorexecuterLfetchall)r=stmtrScurresultsrTs rC _execute_cmdzMySQLRPCProtocol._execute_cmdst  Fl%,,,==;;tV4;88 + +C NN3<<>> * * * *rEcg}|r*||}|||r*||}||d|}|S)z6Process arguments to create query parameters. z, )rdextendrXjoin)r=argskwargsrSs rC create_paramszMySQLRPCProtocol.create_paramssy  ''--D MM$     "..v66F MM& ! ! !6"" rEcN|j|i|}d|||}d} ||}t|}nX#tt jtf$r9} d||t| } t| d} ~ wwxYw|S)zExecutes the given command with MySQL protocol Executes the given command with the given parameters. Returns an iterator to navigate to navigate through the result set returned by Fabric zCALL {0}.{1}({2})N+Executing {group}.{command} failed: {error}r+commanderror) rurMroFabricMySQLSetrsocketrzrrN) r=r+ryrsrtrScmdfab_setdataexcmsgs rCrjzMySQLRPCProtocol.executes$#T4V44!((@@ &$$S))D$T**GGv|^4 & & &?FFWCHHG>>C %% % & s$A B")4BB"r7) __name__ __module__ __qualname____doc__rDrXrdrorurjr[rErCr5r5s}          rEr5ceZdZdZdZdZdS)XMLRPCProtocolz2Class using XML-RPC protocol to query Fabric. cht||||||_|jdSr7)FabricXMLRPCConnectionr:r;r<s rCrDzXMLRPCProtocol.__init__s:-fdD.> OO  rEc  t|jj|}t||}nD#t$r7}t d||t |d}~wwxYwd} ||i|} t| }nX#ttj tf$r9}d||t |} t| d}~wwxYw|S)zExecutes the given command with XML-RPC protocol Executes the given command with the given parameters Returns an iterator to navigate to navigate through the result set returned by Fabric z'{group}.{command} not available ({err}))r+ryrWNrwrx) getattrr:proxyAttributeError ValueErrorrMrN FabricSetrr|rzr) r=r+ryrsrtgrpr}rr~rrs rCrjzXMLRPCProtocol.executes =$,,e44C#w''CC = = =FMMW#c((N<<== = = &3'''DooGGv|^4 & & &?FFWCHHG>>C %% % & s,*- A.2A))A.4B C!(4CC!N)rrrrrDrjr[rErCrrs< rErceZdZdZdZdS)FabricMySQLResponsezHClass used to parse a response got from Fabric with MySQL protocol. c|dd}|d|d|d}}}|rt|||_||_|d|_dS)Nr fabric_uuidttlmessager)rfabric_uuid_strr coded_rows)r=rinforrrzs rCrDzFabricMySQLResponse.__init__saAwqz)-m)D>->-  -.rEN)rrrrrrDr[rErCrrEs5rErc4eZdZdZfdZdZdZdZxZS)rzEIterator to navigate through the result set returned from Fabric ctt|tjdksJjddd_jdd_tfdjDstjdksJtj dj_ dS) rrrrnamesrc3bK|])}tjt|kV*dSr7)r_FabricSet__names)r]rr=s rC z%FabricSet.__init__..hs8HHS3t|$$C0HHHHHHrErN) rrrDrrr_FabricSet__rowsallrr_FabricSet__resultrs` rCrDzFabricSet.__init__as i''---4?##q((((q)&1': oa(0 HHHHDKHHHHH %4;1$$$$#.{DLII rEc*t|jSr)rrrs rCrzFabricSet.rowcountlrrEc#6K|jD]}|j|VdS)rN)rrrs rCrzFabricSet.rowsqs; ; & &C$-% % % % % & &rEc,|j|j|S)r)rrrs rCrz FabricSet.rowys t}dk%011rErrs@rCrr^st J J J J J   &&&2222222rErc|sgat|ttfs|g}|D]L}t|tr |dkr|dkst dt|MdS)axAdd MySQL error to be reported to Fabric This function adds error_codes to the error list to be reported to Fabric. To reset the custom error reporting list, pass None or empty list. The error_codes argument can be either a MySQL error code defined in the errorcode module, or list of error codes. Raises AttributeError when code is not an int. ii zUnknown or invalid error code.N)REPORT_ERRORS_EXTRA isinstancerGrcintrrL) error_codescodes rCextra_failure_reportrs !  kD%= 1 1$"m ))$$$ CTT\\dTkk !ABB B""4(((())rEc0d||S)zCreate an XMLRPC URI for connecting to Fabric This method will create a URI using the host and TCP/IP port suitable for connecting to a MySQL Fabric instance. Returns a URI. zhttp://{host}:{port}r?r@)rMrs rC_fabric_xmlrpc_urirs " ( (d ( > >>rEc\tjtjt||S)z!Create a UUID using host and port)uuiduuid3 NAMESPACE_URLrrs rC_fabric_server_uuidrs" :d(*|jr7tj |_ tj |j |_ nd|_ d|_ |r"|j|d|_nd|_|j r!|j|j dSdS)rF) use_datetimeNhttpshttp)r!rrDr _username _password _use_datetimeverbose _handlersrHTTPPasswordMgrWithDefaultRealm_passmgrHTTPDigestAuthHandler _auth_handlerrL_scheme)r=usernamepasswordrr https_handlerrs rCrDzFabricTransport.__init__s  1  t% 8 8 8 8 8 GG  %  0 0 0!!) !! > !dn !#CEEDM!(!>t}!M!MD  !%D  DM  " N ! !- 0 0 0"DLL!DL   6 N ! !$"4 5 5 5 5 5 6 6rEc(d|j||}|jr'|jd||j|j|jr-td|tj |j }d|j d}tj |||} |||S#tjtjf$r} d} | jd kr d } | j} n| j} d | | } n3#t($r&d t+| vrd} nt+| } YnwxYwt-d| zd} ~ wt.$rt-dwxYw)zSend XMLRPC requestz{scheme}://{host}{handler})schemer?r:NzFabricTransport: {0}ztext/xml)z Content-Typez User-Agent)headersizPermission deniedz{reason} ({code}))reasonrSSLz SSL errorzConnection with Fabric failed: z(Connection with Fabric failed: check SSL)rMrr add_passwordrrr_LOGGERdebugr build_openerr user_agentRequestparse_responseopenURLError HTTPErrorrrrrNrr ) r=r?r: request_bodyruriopenerr rrrrrs rCrequestzFabricTransport.requests*117;W2NN = 7 M & &tS$.'+~ 7 7 7 < > MM077<< = = =%t~6'/  oc<AAA M&&v{{3'7'788 8 '"34 J J J #8s??0F8DD ZF)00T0JJ! # # #CHH$$%CCc((C  # !!BS!HII I M M M !KLL L Ms65'CF95D/.E4/-EE4EE44F)rFN)r) rrrrrMr VERSION_TEXTrrDrrrs@rCrrs|,,-44W5IJJJ?C666666@%M%M%M%M%M%M%M%MrErc eZdZdZdddeedddddef dZedZ edZ edZ ddZ dd Z d Zd Zdd ZddZddZddZedfdZdZdS)Fabricz%Class managing MySQL Fabric instancesNFc | dkr t|_n5| dkr t|_n"td| |s t | }i|_d|_d|_d|_ ||_ ||_ t|_ i|_||_||_t#|| | |_||_| |_| r|rt+d| p||_||_dS)rr$r%z0Protocol not supported by MySQL Fabric, was '{}'N<z&can not specify both user and username)r_protocol_classr5rrMMYSQL_FABRIC_PORT_fabric_instances _fabric_uuid_ttl_version_token_connect_attempts_connect_delayr_cache_group_balancers _init_host _init_portr_ssl_report_errors _protocolrrr) r=r?rr r@rArB report_errorsrrruserprotocols rCrDzFabric.__init__1s x  #1D  #3D  "F8,,.. . /$X.D!#  "!1+!mm "&vwAA +!  GH GEFF F)!rEc|jS)z0Return username used to authenticate with Fabric)rrs rCrzFabric.usernameW ~rEc|jS)z0Return password used to authenticate with Fabric)rrs rCr zFabric.password\r7rEc|jS)zReturn the SSL configuration)r0rs rCrzFabric.ssl_configas yrEc|p|j}|p|j}|||||j|j}||\}}}}|st d|j|krdSt d |||_ ||_|dkr||_ |D]}|||d|d|j|j} | j j} | |jvrM| |j| <td | j j| j j dS) zGet MySQL Fabric Instances This method uses host and port to connect to a MySQL Fabric server and get all the instances managing the same metadata. Raises InterfaceError on errors. )rArBz%Failed getting list of Fabric serversNz.Loading Fabric configuration version {version}rrr?r@z%Added new Fabric server {host}:{port}r)r.r/r$r*r+get_fabric_serversrr)rrrMr'r(r:rr&rr?r@) r=r?r@fabinstrfabric_versionrfabricsr>inst inst_uuids rCseedz Fabric.seedfs&t&t&&tT48<8N595H'JJ594K4K 551 ^S' J !HII I  . 0 0 F < C C& D ( ( ) ) )(, 77DI I IF''fVnfVn9=9O6:6I(KKD )I 66648&y1 ;BB!\.T\5FCHHIII I IrEc|rGtd|||ddStdt |_dS)zWReset cached information This method destroys all cached information. z#Resetting cache for group '{group}'r+F use_cachezResetting cacheN)rrrMget_group_serversrr,r=r+s rC reset_cachezFabric.reset_caches  ( MM?FFG     " "5E " : : : : : MM+ , , ,%--DKKKrEc<d}d}|jst|dztr-|j}|j||}n%|jt |j|}|jjs|j|S)zGet a MySQL Fabric Instance This method will get the next available MySQL Fabric Instance. Raises InterfaceError when no instance is available or connected. rz"No MySQL Fabric instance availablez (not seeded?))r&rr!rrGr: is_connectedr;)r=nxterrmsg instance_listr?s rC get_instancezFabric.get_instances5% < *:!:;; ;  M 27799M)-*<=DD)$t/E*F*Fs*KLD|( # L " " " rEc|jsdSt|}tj}|tvs |t vrt d|||} | dd|||}t|dS#ttj f$r3}t dt|Yd}~dSd}~wwxYwdS)z{Report failure to Fabric This method sets the status of a MySQL server identified by server_uuid. NzReporting error %d of server %sthreatreport_failurez&Failed reporting server to Fabric (%s))r1rr|getfqdn REPORT_ERRORSrrrrNrjrrrzrN)r= server_uuiderrno current_hostr?rrs rCrQzFabric.report_failures "  FE ~'' M ! !U.A%A%A MM;U% ' ' '$$&&D (||H.>$/uFFt$$$$$6<( ( ( ( F!#hh((((((((( (&B%As/(BC"/(CC"c|p|}g}d} |ddd|jz}|D]$}||j|jd%n#ttj f$rM}| t||j j|j j}t|d}~wttf$rS}| d ||j j|j j}t|d}~wwxYw t!j|j} n##t$rt!j} YnwxYwd } | | |j|fS) aGet all MySQL Fabric instances This method looks up the other MySQL Fabric instances which uses the same metadata. The returned list contains dictionaries with connection information such ass host and port. For example: [ {'host': 'fabric_prod_1.example.com', 'port': 32274 }, {'host': 'fabric_prod_2.example.com', 'port': 32274 }, ] Returns a list of dictionaries z;Looking up Fabric servers failed using {host}:{port}: {err}dump fabric_nodesz protocol.r)rWr?r@Nz No Fabric server available ({0})r)rNrjr2rrLr?r@rr|rzrMrNr:r TypeErrorrrUUIDruuid4r) r= fabric_cnxr?resulterr_msgfsetrrrrr=s rCr;zFabric.get_fabric_serverss0T..00O &<< +dn <>>Dyy{{ D D sxBBCCCC Dv|$ & & &..SXXDL4E&*l&7!99C %% %>* & & &..6==cBB\&T\->!@@C!%% %  &  ')D$899KK ' ' '*,,KKK 'NDHf<EE87E8Tc |r#|j|}|r|jS|}g} |dd|j|}nQ#t tjf$r8}d t||}t|d}~wwxYwg} | D]} | j |kr~t| j| j | j| j| j| j| j} || | jt,kr!| | j| jf|j||| rt3| |j|<|S)a?Get all MySQL servers in a group This method returns information about all MySQL part of the given high-availability group. When use_cache is set to True, the cached information will be used. Raises InterfaceError on errors. Returns list of FabricMySQLServer objects. rXserversz:Looking up MySQL servers failed for group {group}: {error})rzr+N)r, group_searchrbrNrjr)rr|rzrMrNrrgroup_idrrTr?r@r.statusweightrLSTATUS_SECONDARYr cache_grouprr-) r=r+rEentryr?r^r`rrweightsr mysqlservers rCrFzFabric.get_group_serverss  %K,,U33E %}$  "" &<< 43FNNDDv|$ & & &&'-vCHHEv'J'J  %% % & 99;; K KC|u$$/OS\38SXHcj#*  k***%)999NNK$4k6H#IJJJ v...  H+=w+GD !% ( sAB)13B$$B)c|r|rtdd}||d}|s#t||d}g}|D]:}|jt kr||(|jtkr|};|ttfvs |tkrH|sD| |t|dz|rdnd ||p| |S|s|r|S||j vr9|j | d } |D]} | | j kr| cS| |t||| ) aGet a MySQL server from a group The method uses MySQL Fabric to get the correct MySQL server for the specified group. You can specify mode or status, but not both. The mode argument will decide whether the primary or a secondary server is returned. When no secondary server is available, the primary is returned. Status is used to force getting either a primary or a secondary. The returned tuple contains host, port and uuid. Raises InterfaceError on errors; ValueError when both mode and status are given. Returns a FabricMySQLServer object. z-Either mode or status must be given, not bothz-No MySQL server available for group '{group}'TrDrCNz {query}={value}rer.)queryr+rUr)r+r.)rrFrrMrergrLSTATUS_PRIMARYMODE_WRITEONLYMODE_READWRITErHr-get_nextr) r=r+r.rerLrbprimary secondaryservernext_secondaryrks rCget_group_serverzFabric.get_group_server$s(  AF A?AA AA(($(?? = U!;!;<< <  ! !F} 000  ((((.00  NN3 3 3v7O7O +  u ---$f/A&A%I%I&,8((& .D&J&*&*+++N 'W 'N d+ + +!259BBDDQGN( ' ' ![%555&&&&6 u%%%V]]T]BBCCCrEc t|ttfstdg}|D]}t|ttfs$|s"td|t|ttfr|d}|d}n|}|}|d|||} |dd|jd |}nP#ttj f$r7} d t|  } t| d } ~ wwxYw|D]X} |jt%| j| j| j| j| j| j| j| jYd S) aGet and cache the sharding information for given tables This method is fetching sharding information from MySQL Fabric and caches the result. The tables argument must be sequence of sequences contain the name of the database and table. If no database is given, the value for the database argument will be used. Examples: tables = [('salary',), ('employees',)] get_sharding_information(tables, database='employees') tables = [('salary', 'employees'), ('employees', employees)] get_sharding_information(tables) Raises InterfaceError on errors; ValueError when something is wrong with the tables argument. tables should be a sequencez#No database specified for table {0}rrz{0}.{1}rXsharding_information,z0Looking up sharding information failed : {error}rzN)rrGrcrrMrLrNrjr)rrrr|rzrNrrr,sharding_cache_tabler schema_name table_name column_name lower_boundshard_id type_namerd global_group) r=r-databasepatternstabledbasetblr?r`rrrs rCget_sharding_informationzFabric.get_sharding_information`s&&4-00 <:;; ; : :EedE]33 H  !F!M!M""%$// aAh  OOI,,UC88 9 9 9 9  "" &<<.0C""DDv|$ & & &DKK#hhL  C %% % & 99;;  C K , ,COS^S_OS\3=L#*:<<      s"0DE )2EE c>t|ttfstdg|D]O} |d\}}n0#t$r#td|wxYw|j||}|sd||f||j||}|s0ttj d|||dkr| |j |cS|jd kr] t|} n#t$rtd wxYw|j} | t#| | d z } |j| } n|jd krt|t&jt&jfstd d} |jD] } || kr| } n |j| } nJ#t,$r#td|wxYw|jdkrst/|stdd} |jD] } || kr| } n |j| } n#t,$r#td|wxYw|jdkrjt1t3|}|jd} |jD]+} |t7| kr| } n,|j| } n't9d|j| dt=fdDstdQ| d|S)a"Get MySQL server information for a particular shard Raises DatabaseError when the table is unknown or when tables are not on the same shard. ValueError is raised when there is a problem with the methods arguments. InterfaceError is raised for other errors. rx.z5tables should be given as ., was {0}z"Unknown table '{database}.{table}')rr)rUrr'r.RANGEz Key must be an integer for RANGErRANGE_DATETIMEzAKey must be datetime.date or datetime.datetime for RANGE_DATETIMENzKey invalid; was '{0}' RANGE_STRINGzKey must be a unicode valueHASHrzUnsupported sharding type {0}r+c30K|]}|dkVdS)rNr[)r]r+groupss rCrz*Fabric.get_shard_server..s,>>euq )>>>>>>rEz'Tables are located in different shards.r)rrGrcrsplitrMr,sharding_searchrrrER_BAD_TABLE_ERRORrvr shard_typerrr partitioningdatetimedate keys_reversedKeyErrorr"rrNdigestrrrLr)r=r-r,r1r.dbobjrrri range_key partitionsr partitionpartkeymd5keyrs @rCget_shard_serverzFabric.get_shard_serversb&4-00 <:;; ;F ?F ?E -"'++c"2"2%% - - - $fUmm--- - K//%@@E =--uhAAA 33HeDD='':@GG%-UH<<====   ,,U-?d,KKKKK7**I #CII!III$%GHHHI"Z "6*i#@#@1#DE!.u5 !%555!# x7H'IJJ*$)***$2Gg~~ '&K % 25 9IIKKK$%=%D%DS%I%IJJJK!^33 ~~D$%BCCC$2Gg~~ '&K % 25 9IIKKK$%=%D%DS%I%IJJJK!V++SXX+B/$2G}})G*<*<<< '=".u5 $3::5;KLLNNN MM)G, - - ->>>>v>>>>> ?#=??? ?$$VAYT$:::s/A-A;/D??E" G11-H! I//-JcN|}|j||g|Ri|S)aiExecute a Fabric command from given group This method will execute the given Fabric command from the given group using the given arguments. It returns an instance of FabricSet. Raises ValueError when group.command is not valid and raises InterfaceError when an error occurs while executing. Returns FabricSet. )rNrj)r=r+ryrsrtr?s rCrjzFabric.executes9  ""t|E7DT;T;T;T;l = = = = =rEr!ceZdZdZeeeefdZe dZ e dZ e dZ dZ e dZdZd S) FabricConnectionzIBase Class for a class holding a connection to a MySQL Fabric server ct|tstd||_||_||_||_||_dS)rz'fabric must be instance of class FabricN)rr!r_fabric_host_portr*r+r<s rCrDzFabricConnection.__init__sQ &&)) HFGG G   !1+rEc|jS)z6Returns server IP or name of current Fabric connection)rrs rCr?zFabricConnection.host  zrEc|jS)z0Returns TCP/IP port of current Fabric connection)rrs rCr@zFabricConnection.portrrEc6t|j|jS)z7Returns UUID of the Fabric server we are connected with)rrrrs rCrzFabricConnection.uuids#4:tz:::rEcdSzConnect with MySQL FabricNr[rs rCr;zFabricConnection.connects rEcdS)Check whether connection with Fabric is valid Return True if we can still interact with the Fabric server; False if Not. Returns True or False. Nr[rs rCrJzFabricConnection.is_connecteds  rEcPd|j|j|jS)Nz"{class_}(host={host}, port={port}))class_r?r@)rMrrrrs rC__repr__zFabricConnection.__repr__*s.3::>;   rEN)rrrrr%rrrrDrr?r@rr;rJrr[rErCrrs((?@"21 , , , ,XX;;X;     X      rErceZdZdZedeeffd ZedZ edZ dZ dZ edZ xZS) rzCClass holding a connection to a MySQL Fabric server through XML-RPCr$cntt||||||d|_dSr)rrrD_proxyr=r>r?r@rArBrs rCrDzFabricXMLRPCConnection.__init__6sA $d++44 D$ 0-    rEc|jS)z5Returns the XMLRPC Proxy of current Fabric connection)rrs rCrzFabricXMLRPCConnection.proxy?s {rEc6t|j|jS)z4Returns the XMLRPC URI for current Fabric connection)rrrrs rCrzFabricXMLRPCConnection.uriDs"$*dj999rEc|jr|jS|j}|j}d}d}||krE|dz } |jjr0t stdt|jj}nd}t|jj |jj d|}t|j |d}|n#t$r|cYSt j$rl}||kr"td|t&d|j|j| Yd}~nd}~wwxYw|dkrt/j|||kCdSdS) zReturn the XMLRPC server proxy instance to MySQL Fabric This method tries to get a valid connection to a MySQL Fabric server. Returns a XMLRPC ServerProxy instance. Nrrr)rr ) transportr'Connection to MySQL Fabric failed ({0})*Retrying {host}:{port}, attempts {counter}r?r@counter)rJrr*r+rrrrrrrr rr_some_nonexisting_methodrr|rzrMrrr?r@timesleep)r=r2delayrrr rrs rC_xmlrpc_get_proxyz(FabricXMLRPCConnection._xmlrpc_get_proxyIs   ; )#!! qLG J<*)#L,-JKKK$6t|7N$O$OMM$(M+DL,A,0L,A45:GIII $DH 1MMM..0000    < J J Jh&&(AHHMMOOO @GG!YTYHIIJJJJJJJJ  Jqyy 5!!!7!!!!!!sBB?? E EA"EEc8||_dSr)rrrs rCr;zFabricXMLRPCConnection.connectvs,,.. rEc |jdS#t$rYdSttf$rYdSwxYw)rFT)rrrrZrrs rCrJz#FabricXMLRPCConnection.is_connectedzsd  K 0 0 2 2 2 5    44>*   55 s >>>)rrrrr%rrrDrrrrr;rJrrs@rCrr2sMM*;H*E"21X::X:+"+"+"Z///XrErcneZdZdZedeeffd ZedZ dZ dZ edZ xZ S)r9zT Class holding a connection to a MySQL Fabric server through MySQL protocol r%cptt||||||d|_dS)r)r@rArBN)rr9rD _connectionrs rCrDzFabricMySQLConnection.__init__sI #T**33 Dt-] 4    rEc|jS)z*Returns the MySQL RPC Connection to Fabric)rrs rCrhz FabricMySQLConnection.connections rEc|jr|jS|j}|j}d}||kr|dz } |j|j|jj|jjd}|jj r@tstd|jj d|d<|jj d|d<td i|S#t$rl}||kr"td |td |j|j| Yd }~nd }~wwxYw|dkrt'j|||kd Sd S)zReturn the connection instance to MySQL Fabric through MySQL RPC This method tries to get a valid connection to a MySQL Fabric server. Returns a MySQLConnection instance. rr)r?r@r4r rr,rrrrrrNr[)rJrr*r+rrrrr rrrr rrMrrr?r@rr)r=r2rrdbconfigrs rC_get_connectionz%FabricMySQLConnection._get_connections   $# #)#!! qLG J J J L1 $ 5  <*K#L,-JKKK*.,*A%*HHY'+/<+B6+JHZ(&22222! J J Jh&&(AHHMMOOO @GG!YTYHIIJJJJJJJJ  Jqyy 5!!!3!!!!!!sA #0022 2   55 s  )))rrrrr%rrrDrrhrr;rJrrs@rCr9r9s+z+Configuration parameters for Fabric missingr[) _mysql_cnxr_fabric_mysql_server _mysql_config_cnx_propertiesreset_propertiesr store_config)r=rts rCrDzMySQLFabricConnection.__init__s $(!!!  6 ! !JKK K  ( D  ' ' ' ' ' ' ' ( (rEc|dr#td|t|j|S)z7Return the return value of the MySQLConnection instancecmd_zHCalling {attr} is not supported for connections managed by MySQL Fabric.)attr) startswithrrMrr)r=rs rC __getattr__z!MySQLFabricConnection.__getattr__sP ??6 " " 3# &D 1 133 3t---rEc,|jr |jjSdS)z+Returns the Fabric UUID of the MySQL serverN)rrrs rCrz!MySQLFabricConnection.fabric_uuids   $ 2,1 1trEc|jS)zReturns connection properties)rrs rC propertiesz MySQLFabricConnection.propertiess ##rENcf|s|jr |jj}|j|dS)z'Reset cache for this connection's grouprCN)rr+rrHrGs rCrHz!MySQLFabricConnection.reset_caches> 42 4-3E   u -----rEc|jduS)z\Check whether we are connected with the MySQL server Returns True or False N)rrs rCrJz"MySQLFabricConnection.is_connected s d**rEcri|_tD]\}}|d|j|<dS)zResets the connection properties This method can be called to reset the connection properties to their default values. r N)r_CNX_PROPERTIESrH)r=r,rs rCrz&MySQLFabricConnection.reset_propertiessI "(..00 0 0IC(,QD  % % 0 0rEc 6 |n#t$rYnwxYw|j}|D]U\}}|tvr"t d||rut|t|dsTddt|dD}td|||dkr!|r|ds|d rt d |d vr|r|drt d |d kr|ttfvrt d|dkr|ttfvrt d|t|d||<P|||<WdS)atSet one or more connection properties Arguments to the set_property() method will be used as properties. They are validated against the _CNX_PROPERTIES constant. Raise ValueError in case an invalid property is being set. TypeError is raised when the type of the value is not correct. To unset a property, set it to None. zInvalid property connection {0}rz or cg|] }|j Sr[)r)r]atypes rCr_z6MySQLFabricConnection.set_property..6sJJJU^JJJrEz({name} is not valid, excepted {typename})nametypenamer+r,r-z>'group' property can not be set when 'key' or 'tables' are set)r,r-z@'key' and 'tables' property can not be set together with 'group'r1zInvalid value for 'scope'r.zInvalid value for 'mode'Nr )closerrrHrrrMrrrrZr SCOPE_GLOBALrp MODE_READONLY)r=rpropsrrUvalid_types_strs rC set_propertyz"MySQLFabricConnection.set_propertys   JJLLLL    D $%++-- $ $KD%?** 5<z%1Fq1IJJ >"(++JJ1Fq1IJJJ#L#L>EE!OF==>>>E5\ %*8_  '(((***u*w* 0111U; 2M%M%M !<===E"M23%3%3 !;<<<}-d3A6d #d = $ $s  $$ct|tr ||_dSdg}|D])}||vr#td|*|d}|dt } |dt|}n0#t$r#td|wxYwt||} t||_dS#t$rWt dtd i||_|j|jt|<YdSwxYw) zConfigure the Fabric connection The config argument can be either a dictionary containing the necessary information to setup the connection. Or config can be an instance of Fabric. r?z8Missing configuration parameter '{parameter}' for fabric) parameterr5r@z{0} protocol is not availablezNew Fabric connectionNr[)rr!rrrMgetrr%rrrFABRICSrrrA)r=config required_keys required_keyr?r5r@rTs rC_configure_fabricz'MySQLFabricConnection._configure_fabricPs ff % % 4!DLLL#HM - E E v--$%%+VlV%C%CEEE.&>Dzz*.EFFH Fzz&*;H*EFF F F F$3::8DDFFF F.dD99K 4&{3  4 4 4 5666%////  !!###'+| $$$$  4s2!B-CC))AE  E c |}d|vr||d|d=d|vrtdd|d<|}d|vr|d=d|vr|d=d|vr|d= t t t j}|jd i|n4#t$r'}td |d}~wwxYw||_ dS) aStore configuration of MySQL connections to use with Fabric The configuration found in the dictionary kwargs is used when instanciating a MySQLConnection object. The host and port entries are used to connect to MySQL Fabric. Raises ValueError when the Fabric configuration parameter is not correct or missing; AttributeError is raised when when a paramater is not valid. r> unix_socketz'MySQL Fabric does not use UNIX sockets.N pool_name pool_sizepool_reset_session)rz'Connection configuration not valid: {0}r[) copyrrwarningrrNrr\ set_configrrMr)r=rtr test_configpoolrWs rCrz"MySQLFabricConnection.store_configqsH v    " "6(#3 4 4 4x F " " OOE F F F$(F= !kkmm + % %K( + % %K( ; . .01 G&TZ\\1B1BCCCD DO * *k * * * * G G G 9@@EEGG G G$s;C C1 "C,,C1c |rdS|j}|d}|d}|j}d}||kr4|dz } d}|drZ|ddkr|d st d |j|d|d |d|d  }nB|d r+|d }|j||d }nt dn#t$r}t d ||||kr"td ||dkrAt d |tj |Yd}~ad}~wwxYw|j|d<|j|d< t!jjdi||_||_dS#t*$r}||kra||j|j|j|jtd ||dkrtj |Yd}~3d}~wwxYwdS)aGet a MySQL server based on properties and connect This method gets a MySQL server from MySQL Fabric using already properties set using the set_property() method. You can specify how many times and the delay between trying using attempts and attempt_delay. Raises ValueError when there are problems with arguments or properties; InterfaceError on connectivity errors. Nr2r3rrr-r1r(r,z*Scope 'LOCAL' needs key property to be setr.)r1r.r+rz*Missing group or key and tables propertiesz-Trying to get MySQL server (attempt {0}; {1})zError getting connection: {0}z Waiting {0}r?r@z&Reported faulty server to Fabric ({0})r[)rJrrrrrrrvrrrrMrrr?r@r%rPr;rrrrHr+rQrrU) r=rr2r3rrr+rkrs rC_connectzMySQLFabricConnection._connects        F$$o. %**,,!! qLG ?FW~00u0(HJJJ"&,"?"?hu#Gn"6]#@#,#,KK7^F!'NE"&,"?"?E&M#@#3#3KK%DFFF!    CJJ&&'''h&&()H)O)O** 1$$MM-"6"6}"E"EFFFJ}---  +/HV */HV  "'/"9"E"EH"E"E-8)   h&&$$[%6777L// 0@#)LLL(@GGLLNNN 1$$J}--- I"!s3B&C== F/BF**F/G++ J5BI<<Jc ||jn#t$rYnt$rwxYwd|_d|_dS#d|_d|_wxYw)z Close connection to MySQL serverN)rollbackrrrrrrs rC disconnectz MySQLFabricConnection.disconnects - MMOOO O ! ! # # # #    D     #DO(,D % % %#DO(,D % , , , ,s$-0A AA AAA*c@||rtd|rtd|jdurtd|p|j}|p|j}d}|dur|dz}|dur|dz}t tttf}|||S)aiInstantiates and returns a cursor This method is similar to MySQLConnection.cursor() except that it checks whether the connection is available and raises an InterfaceError when not. cursor_class argument is not supported and will raise a NotSupportedError exception. Returns a MySQLCursor or subclass. z.Custom cursors not supported with MySQL Fabricz7Prepared Statements are not supported with MySQL FabricTzUnread result found.rrr ) r r_unread_resultr _buffered_rawrrrr)r=bufferedrawprepared cursor_class cursor_typetypess rCrizMySQLFabricConnection.cursors   B#@BB B  K#IKK K  $ & & 677 7-t~TY t   1 K $;; 1 K    "   #k"D)))rEc|jtvrX||t dt ||)zHandles MySQL errors This method takes a mysql.connector.errors.Error exception and checks the error code. Based on the value, it takes certain actions such as clearing the cache. z,Temporary error ({error}); retry transactionr{)rURESET_CACHE_ON_ERRORrHr rrMrNr=rs rChandle_mysql_errorz(MySQLFabricConnection.handle_mysql_errorsg 9, , ,       OO   "$$*FSF$:$:<< < rEc |jdS#t$r }||Yd}~dSd}~wwxYw)zCommit current transaction Raises whatever MySQLConnection.commit() raises, but raises MySQLFabricError when MySQL returns error ER_OPTION_PREVENTS_STATEMENT. N)rcommitrrrs rCrzMySQLFabricConnection.commit#sf ) O " " $ $ $ $ $ ) ) )  # #C ( ( ( ( ( ( ( ( ( ) AAAc |jdS#t$r }||Yd}~dSd}~wwxYw)zRollback current transaction Raises whatever MySQLConnection.rollback() raises, but raises MySQLFabricError when MySQL returns error ER_OPTION_PREVENTS_STATEMENT. N)rr rrrs rCr zMySQLFabricConnection.rollback/sf ) O $ $ & & & & & ) ) )  # #C ( ( ( ( ( ( ( ( ( )rc| |j|S#t$r }||Yd}~dSd}~wwxYw)zSend a statement to the MySQL server Raises whatever MySQLConnection.cmd_query() raises, but raises MySQLFabricError when MySQL returns error ER_OPTION_PREVENTS_STATEMENT. Returns a dictionary. N)r r cmd_queryrr)r= statementrs rCr!zMySQLFabricConnection.cmd_query;sq  )?,,Y77 7 ) ) )  # #C ( ( ( ( ( ( ( ( ( )0 AAAc| |j|S#t$r }||Yd}~dSd}~wwxYw)zSend one or more statements to the MySQL server Raises whatever MySQLConnection.cmd_query_iter() raises, but raises MySQLFabricError when MySQL returns error ER_OPTION_PREVENTS_STATEMENT. Returns a dictionary. N)r rcmd_query_iterrr)r= statementsrs rCr%z$MySQLFabricConnection.cmd_query_iterJsq  )?11*== = ) ) )  # #C ( ( ( ( ( ( ( ( ( )r#r7)NNNN)rrrrrDrrrrrHrJrrrrr r rrirrr r!r%r[rErCrrsY;;((( ...X $$X$.... +++0001$1$1$f444B%$%$%$NBBBH - - - E'*'*'*'*R ) ) ) ) ) ) ) ) ) ) ) ) ) )rEr)rrsysrrrbase64rrhashlibrloggingr|r xmlrpclibrrrrhttplibr ImportError xmlrpc.clienturllib.requestr http.client version_infor rmysql.connectorr%rhr conversionr poolingrrQrrrrrrrirrrrr*rrrcachingr balancingrr catch23r!r"r#CR_SERVER_LOSTER_OPTION_PREVENTS_STATEMENTrCR_SERVER_GONE_ERRORCR_CONN_HOST_ERRORCR_CONNECTION_ERRORCR_IPSOCK_ERRORrSrrr%rrr_GETCNX_ATTEMPT_DELAY_GETCNX_ATTEMPT_MAXrrorp STATUS_FAULTY STATUS_SPARErgrnrr_SERVER_STATUS_FAULTYrNrcrrrGr getLoggerrobjectr5rrr{rrrrrrrrrr!rrr9rr[rErCrEsb032   *7777777777NNN%%%%%%%***;;;;;;;;;;$$$$$$)))))))) * A!++++++  //////  (((((('''''')))))),,,,,,,, ))))))3333333333 * "   !   "        f0$ 7 E3X.="$(D$7$78 9 9 D "t}7>V:N KfCT JD!fC:$&fD+-$ ' - . .YYYYYvYYYx     V   F " " " " "& " " "33333(333BV2 2 2 2 2 2 2 2 2F)))4???JJJ 4 W12KMKMKMKMKMiKMKMKM\L=L=L=L=L=VL=L=L=^3 3 3 3 3 v3 3 3 lXXXXX-XXXvNNNNN,NNNby)y)y)y)y)Fy)y)y)y)y)s5AA%$A%:BB  B BB$#B$