B [ @sdZddlZddlZddlZddlZddlmZddlmZddlm Z ddl Z ddl Z ddl Z y,ddl mZmZmZddlZddlmZWn@ek rddlmZmZmZddlmZddlmZYnXejddkrydd lmZWnek rd ZYnXd Zn0ydd lmZWnek r:d ZYnXd ZddlZdd 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<d!dfeXe[fd"dfeYfd#eOfeWfd$dfeWfd%dfeWfd&eUfeYfd'eLfeYfd(eKfd) Z\e ]d*Z^Gd+d,d,e_Z`Gd-d.d.e_ZaGd/d0d0e_ZbGd1d2d2ebZcGd3d4d4e_ZdGd5d6d6edZed7d8Zfd9d:Zgd;d<Zhd=d>ZierGd?d@d@ejjZkGdAdBdBeZlGdCdDdDe_ZmGdEdFdFe_ZnGdGdHdHenZoGdIdJdJenZpGdKdLdLe_ZqdS)Mz,Implementing communication with MySQL FabricN) b16decode)bisect)md5)Fault ServerProxy Transport) BadStatusLine)HTTPSConnectionFT)MySQLConnection)MySQLConverter)MySQLConnectionPool)ErrorInterfaceErrorNotSupportedErrorMySQLFabricError InternalError DatabaseError) MySQLCursorMySQLCursorBufferedMySQLCursorRawMySQLCursorBufferedRaw) errorcode)FabricMySQLServer FabricShard) FabricCache)WeightedRoundRobin)version)PY2 isunicode UNICODE_TYPESxmlrpci~i~)r"mysqlGLOBALLOCALZFAULTYzName 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) groupkeytablesmodeZshardmappingscopeattempts attempt_delayzmyconnpy-fabricc@sBeZdZdZddZddZddZdd d Zd d Zd dZ dS)MySQLRPCProtocolz0Class using MySQL protocol to query Fabric. cCs(t|_t||||||_|jdS)N)r converterFabricMySQLConnectionhandlerconnect)selffabrichostportconnect_attempts connect_delayr;C:\Users\HIRONO~1\AppData\Local\Temp\pip-install-ioykiiwb\mysql-connector-python-rf\mysql_connector_python_rf-2.2.2.data\purelib\mysql\connector\fabric\connection.py__init__s zMySQLRPCProtocol.__init__c Csy`g}xVt|D]F\}}|}|j|}|j|}|j|}|d|t|qWWn4t k r}zt j j d|Wdd}~XYnX|SdS)z,Process query parameters given as dictionaryz{0}={1}z)Failed processing pyformat-parameters; %sN)listitemsr1to_mysqlescapequoteappendformatstr Exceptionr# connectorerrorsProgrammingError)r5paramsresr)valueconverrr;r;r<_process_params_dicts   z%MySQLRPCProtocol._process_params_dictc syL|}fdd|D}fdd|D}fdd|D}dd|D}Wn4tk r}ztjjd|Wdd}~XYn Xt|SdS)zProcess query parameters.csg|]}j|qSr;)r1r@).0i)r5r;r< sz4MySQLRPCProtocol._process_params..csg|]}j|qSr;)r1rA)rPrQ)r5r;r<rRscsg|]}j|qSr;)r1rB)rPrQ)r5r;r<rRscSsg|] }t|qSr;)rE)rPrQr;r;r<rRsz'Failed processing format-parameters; %sN)rFr#rGrHrItuple)r5rJrKrNr;)r5r<_process_paramssz MySQLRPCProtocol._process_paramsNcCsH|sd}|jjjdd}g}x&|j||ddD]}||q.W|S)zYExecutes the given query Returns a list containing response from Fabric r;T) dictionary)Zmulti)r3 connectioncursorexecuterCZfetchall)r5ZstmtrJcurresultsrKr;r;r< _execute_cmdszMySQLRPCProtocol._execute_cmdcOsBg}|r||}|||r4||}||d|}|S)z6Process arguments to create query parameters. z, )rTextendrOjoin)r5argskwargsrJr;r;r< create_paramss     zMySQLRPCProtocol.create_paramsc Os|j||}d|||}d}y||}t|}WnFttjtfk rz} z dj||t| d} t| Wdd} ~ XYnX|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})Nz+Executing {group}.{command} failed: {error})r(commanderror) r`rDr[FabricMySQLSetrsocketrbrrE) r5r(rar^r_rJcmdfab_setdataexcmsgr;r;r<rXs   zMySQLRPCProtocol.execute)N) __name__ __module__ __qualname____doc__r=rOrTr[r`rXr;r;r;r<r0s r0c@s eZdZdZddZddZdS)XMLRPCProtocolz2Class using XML-RPC protocol to query Fabric. cCs t||||||_|jdS)N)FabricXMLRPCConnectionr3r4)r5r6r7r8r9r:r;r;r<r=s zXMLRPCProtocol.__init__c Osyt|jj|}t||}Wn:tk rV}ztdj||t|dWdd}~XYnXd}y|||} t| }WnFtt j t fk r}z dj||t|d} t | Wdd}~XYnX|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(rarNNz+Executing {group}.{command} failed: {error})r(rarb) getattrr3proxyAttributeError ValueErrorrDrE FabricSetrrdrbr) r5r(rar^r_grprerhrfrgrir;r;r<rXs$  zXMLRPCProtocol.executeN)rjrkrlrmr=rXr;r;r;r<rnsrnc@seZdZdZddZdS)FabricMySQLResponsezHClass used to parse a response got from Fabric with MySQL protocol. cCsN|dd}|d|d|d}}}|r4t|||_||_|d|_dS)Nr fabric_uuidttlmessager)rfabric_uuid_strrx coded_rows)r5rginforzrxrbr;r;r<r=s  zFabricMySQLResponse.__init__N)rjrkrlrmr=r;r;r;r<rvsrvcs8eZdZdZfddZddZddZdd ZZS) rcz^Iterator to navigate through the result set returned from Fabric with MySQL Protocol. cs<tt|||jd|_|j|_td|j|_ dS)z)Initialize the FabricSet object. r ResultSetN) superrcr=r{keysZ_FabricMySQLSet__names_FabricMySQLSet__rows collections namedtuple_FabricMySQLSet__result)r5rg) __class__r;r<r=(szFabricMySQLSet.__init__cCs t|jS)z.The number of rows in the result set. )lenr)r5r;r;r<rowcount0szFabricMySQLSet.rowcountccs"x|jD]}|jf|VqWdS)zUIterate over the rows of the result set. Each row is a named tuple. N)rr)r5rowr;r;r<rows5s zFabricMySQLSet.rowscCs|jf|j|S)zGIndexing method for a row. Each row is a named tuple. )rr)r5indexr;r;r<r=szFabricMySQLSet.row) rjrkrlrmr=rrr __classcell__r;r;)rr<rc$s  rcc@seZdZdZdZddZdS)FabricResponsez4Class used to parse a response got from Fabric. rcCsT|\}}}}}|rt||tjkr8tdjtj|d||_||_||_||_dS)z-Initialize the FabricResponse object zdSupported protocol has version {sversion}. Got a response from MySQL Fabric with version {gversion}.)ZsversionZgversionN)rrSUPPORTED_VERSIONrDformat_versionrzrxr{)r5rgrrzrxrbrr;r;r<r=Ks  zFabricResponse.__init__N)rjrkrlrmrr=r;r;r;r<rEsrcs8eZdZdZfddZddZddZdd ZZS) rtzEIterator to navigate through the result set returned from Fabric cstt|tjdks"tjddd_jdd_tfddjDsptjdksptt dj_ d S) z)Initialize the FabricSet object. rrr|namesrc3s |]}tjt|kVqdS)N)r_FabricSet__names)rPr)r5r;r< hsz%FabricSet.__init__..r}N) r~rtr=rr{AssertionErrorr_FabricSet__rowsallrr_FabricSet__result)r5rg)r)r5r<r=aszFabricSet.__init__cCs t|jS)z.The number of rows in the result set. )rr)r5r;r;r<rlszFabricSet.rowcountccs x|jD]}|j|VqWdS)zUIterate over the rows of the result set. Each row is a named tuple. N)rr)r5rr;r;r<rqs zFabricSet.rowscCs|j|j|S)zGIndexing method for a row. Each row is a named tuple. )rr)r5rr;r;r<rysz FabricSet.row) rjrkrlrmr=rrrrr;r;)rr<rt^s  rtcCsZ|sgat|ttfs|g}x8|D]0}t|tr@|dkr@|dksHtdt|q"WdS)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 isinstancer>rSintrrrC)Z error_codescoder;r;r<extra_failure_reports rcCsdj||dS)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})r7r8)rD)r7r8r;r;r<_fabric_xmlrpc_urisrcCsttjt||S)z!Create a UUID using host and port)uuiduuid3 NAMESPACE_URLr)r7r8r;r;r<_fabric_server_uuidsrcCsNts tdt|||grJ|s&td|s.|r>|r6|s>td|||dSdS)zvValidate the SSL argument. Raises AttributeError is required argument is not set. Returns dict or None. zPython does not support SSLzMissing ssl_ca argument.z;ssl_key and ssl_cert need to be both specified, or neither.)car)certN)HAVE_SSLranyrr)ssl_cassl_keyssl_certr;r;r<_validate_ssl_argssrcs2eZdZdZfddZddZd ddZZS) FabricHTTPSHandlerz Class handling HTTPS connectionscs&trtj|n t||_dS) InitializeN)rurllib2 HTTPSHandlerr=r~ _ssl_config)r5 ssl_config)rr;r<r=s zFabricHTTPSHandler.__init__cCs||j|S)zOpen HTTPS connection)do_openget_https_connection)r5reqr;r;r< https_openszFabricHTTPSHandler.https_open,cCst||jd|jddS)zReturns a HTTPSConnectionr)r)key_file cert_file)r r)r5r7timeoutr;r;r<rsz'FabricHTTPSHandler.get_https_connection)r)rjrkrlrmr=rrrr;r;)rr<rs rcs8eZdZdZdejZd fdd Zd dd Z Z S) FabricTransportz"Custom XMLRPC Transport for FabriczMySQL Connector Python/{0}rFNcstrtj|ddntjdd||_||_||_||_||_||_g|_|jrr|jrrt |_ t |j |_ n d|_ d|_ |r|j|d|_nd|_|j r|j|j dS)rF) use_datetimeNhttpshttp)rrr=r~ _username _password _use_datetimeverbose _handlersrHTTPPasswordMgrWithDefaultRealm_passmgrHTTPDigestAuthHandlerZ _auth_handlerrC_scheme)r5usernamepasswordrr https_handler)rr;r<r=s*   zFabricTransport.__init__c Cs8dj|j||d}|jr.|jd||j|j|jrDtd|t j |j }d|j d}t j |||d}y|||St jt jfk r} zry2d} | jd krd } | j} n| j} d j| | d } Wn.tk rd t| krd} nt| } YnXtd| Wdd} ~ XYntk r2tdYnXdS)zSend XMLRPC requestz{scheme}://{host}{handler})schemer7r3NzFabricTransport: {0}ztext/xml)z Content-Typez User-Agent)headersizPermission deniedz{reason} ({code}))reasonrZSSLz SSL errorzConnection with Fabric failed: z(Connection with Fabric failed: check SSL)rDrr add_passwordrrr_LOGGERdebugr build_openerr user_agentRequestparse_responseopenURLError HTTPErrorrrrrrErr) r5r7r3 request_bodyruriopenerrrrhrrrir;r;r<requests8     zFabricTransport.request)rFN)r) rjrkrlrmrDrZ VERSION_TEXTrr=rrr;r;)rr<rs rc @seZdZdZdddeedddddef ddZeddZ edd Z ed d Z d!d d Z d"ddZ ddZddZd#ddZd$ddZd%ddZd&ddZedfddZdd ZdS)'Fabricz%Class managing MySQL Fabric instancesNFc Cs| dkrt|_n| dkr t|_ntd| |s:t| }i|_d|_d|_d|_ ||_ ||_ t |_ i|_||_||_t|| | |_||_| |_| r|rtd| p||_||_dS)rr"r#z0Protocol not supported by MySQL Fabric, was '{}'N<z&can not specify both user and username)rn_protocol_classr0rrDMYSQL_FABRIC_PORT_fabric_instances _fabric_uuid_ttl_version_token_connect_attempts_connect_delayr_cache_group_balancers _init_host _init_portr_ssl_report_errors _protocolrsrr) r5r7rrr8r9r:Z report_errorsrrruserprotocolr;r;r<r=1s4 zFabric.__init__cCs|jS)z0Return username used to authenticate with Fabric)r)r5r;r;r<rWszFabric.usernamecCs|jS)z0Return password used to authenticate with Fabric)r)r5r;r;r<r\szFabric.passwordcCs|jS)zReturn the SSL configuration)r)r5r;r;r<raszFabric.ssl_configc Cs|p|j}|p|j}|j||||j|jd}||\}}}}|sJtd|j|krXdSt dj |d||_ ||_|dkr||_ xd|D]\}|j||d|d|j|jd} | j j} | |jkr| |j| <td j | j j| j jd qWdS) 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. )r9r:z%Failed getting list of Fabric serversNz.Loading Fabric configuration version {version})rrr7r8z%Added new Fabric server {host}:{port})r7r8)rrrrrget_fabric_serversrrrr|rDrrr3rrrr7r8) r5r7r8Zfabinstrwfabric_versionrxZfabricsr6instZ inst_uuidr;r;r<seedfs8          z Fabric.seedcCs<|r&tdj|d|j|ddntdt|_dS)zWReset cached information This method destroys all cached information. z#Resetting cache for group '{group}')r(F) use_cachezResetting cacheN)rrrDget_group_serversrr)r5r(r;r;r< reset_caches   zFabric.reset_cachecCsbd}d}|jst|dtr8|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?))rrrrr>r3 is_connectedr4)r5ZnxterrmsgZ instance_listrr;r;r< get_instances   zFabric.get_instancec Cs|js dSt|}t}|tks*|tkrtd|||}y| dd|||}t |Wn8t tj fk r}ztdt |Wdd}~XYnXdS)z{Report failure to Fabric This method sets the status of a MySQL server identified by server_uuid. NzReporting error %d of server %sZthreatreport_failurez&Failed reporting server to Fabric (%s))rrrdgetfqdn REPORT_ERRORSrrrrrXrrrbrE)r5 server_uuiderrnoZ current_hostrrgrhr;r;r<rs  zFabric.report_failurec Cs,|p |}g}d}y>|ddd|j}x$|D]}||j|jdq4WWnttj fk r}z(|j t ||j j|j jd}t |Wdd}~XYnLttfk r}z*|j d ||j j|j jd}t |Wdd}~XYnXyt|j} Wntk rt} YnXd } | | |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}dumpZ fabric_nodesz protocol.)r7r8)rNr7r8Nz No Fabric server available ({0})r)rrXrrrCr7r8rrdrbrDrEr3r TypeErrorrrrUUIDrzuuid4rx) r5Z fabric_cnxrresultZerr_msgfsetrrhrirwrr;r;r<rs.   zFabric.get_fabric_serversTc Cs|r|j|}|r|jS|}g}y|dd|j|}WnBttjfk r~}zdj t ||d}t |Wdd}~XYnXg} xb| D]V} | j |krt| j| j | j| j| j| j| j} || | jtkr| | j| jfqW|j||| r t| |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. rserversz:Looking up MySQL servers failed for group {group}: {error})rbr(N)rZ group_searchrrrXrrrdrbrDrErrgroup_idrrr7r8r+statusZweightrCSTATUS_SECONDARYrZ cache_grouprr) r5r(rentryrrrrhriweightsr mysqlserverr;r;r<rs2     zFabric.get_group_serversc Cs$|r|rtdd}|j|dd}|s6t|j|dd}g}x0|D](}|jtkr^||qD|jtkrD|}qDW|tt fks|tkr|s|j |dt|dj|rdnd ||p|d |S|s|r|S||j kr|j | d } x|D]} | | j kr| SqW|j |dt|j||d dS) 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}'T)r)r(Nz {query}={value}rr+)queryr(rLr)r(r+)rsrrrDrrrCSTATUS_PRIMARYMODE_WRITEONLYMODE_READWRITErrZget_nextr) r5r(r+rrrZprimaryZ secondaryserverZnext_secondaryrr;r;r<get_group_server$s>           zFabric.get_group_serverc Cs,t|ttfstdg}xf|D]^}t|ttfsD|sDtd|t|ttfrd|d}|d}n|}|}|d||q W|}y|dd|jd |}Wn@t t j fk r} zd jt | d } t| Wd d } ~ XYnXx>|D]2} |jt| j| j| j| j| j| j| j| jqWd 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. ztables should be a sequencez#No database specified for table {0}rrz{0}.{1}rZsharding_information,z0Looking up sharding information failed : {error})rbN)rr>rSrsrDrCrrXrr]rrdrbrErrrZsharding_cache_tablerZ schema_nameZ table_nameZ column_nameZ lower_boundZshard_idZ type_namer global_group) r5r*databasepatternstableZdbasetblrrrhrirr;r;r<get_sharding_information`s6    zFabric.get_sharding_informationc st|ttfstdgx|D]}y|d\}}Wn"tk r\td|YnX|j||}|s||f||j||}|st t j dj||dd|dkr|j |j |dS|jd kry t|} Wntk rtd YnX|j} | t| | d } |j| } nf|jd krt|tjtjfsDtd d} x |jD]} || krP| } PqPWy|j| } Wn$tk rtd|YnXn|jdkrt|stdd} x |jD]} || kr| } PqWy|j| } Wn$tk rtd|YnXnh|jdkrrtt|}|jd} x(|jD]} |t| krD| } PqDW|j| } ntd|j| dtfddDs"t dq"W|j d|dS)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. ztables should be a sequence.z5tables should be given as ., was {0}z"Unknown table '{database}.{table}')rr)rrir%)r+RANGEz Key must be an integer for RANGErZRANGE_DATETIMEzAKey must be datetime.date or datetime.datetime for RANGE_DATETIMENzKey invalid; was '{0}'Z RANGE_STRINGzKey must be a unicode valueHASHrzUnsupported sharding type {0}r(c3s|]}|dkVqdS)rNr;)rPr()groupsr;r<rsz*Fabric.get_shard_server..z'Tables are located in different shards.r)rr>rSrssplitrDrZsharding_searchrrrZER_BAD_TABLE_ERRORr r Z shard_typerrrZ partitioningdatetimedateZ keys_reversedKeyErrorr rrEdigestrrrCr)r5r*r)r-r+ZdbobjrrrZ range_keyZ partitionsr partitionZpartkeyZmd5keyr;)rr<get_shard_servers               zFabric.get_shard_servercOs|}|j||f||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. )rrX)r5r(rar^r_rr;r;r<rXs zFabric.execute)NN)N)N)T)NN)NN)rjrkrlrm_CNX_ATTEMPT_MAX_CNX_ATTEMPT_DELAYDEFAULT_FABRIC_PROTOCOLr=propertyrrrrrrrrrr r SCOPE_LOCALrrXr;r;r;r<r-s*    -  * - < 7Vrc@sdeZdZdZeeeefddZe ddZ e ddZ e dd Z d d Z e d d ZddZdS)FabricConnectionzIBase Class for a class holding a connection to a MySQL Fabric server cCs4t|tstd||_||_||_||_||_dS)rz'fabric must be instance of class FabricN)rrrs_fabric_host_portrr)r5r6r7r8r9r:r;r;r<r=s zFabricConnection.__init__cCs|jS)z6Returns server IP or name of current Fabric connection)r%)r5r;r;r<r7 szFabricConnection.hostcCs|jS)z0Returns TCP/IP port of current Fabric connection)r&)r5r;r;r<r8szFabricConnection.portcCst|j|jS)z7Returns UUID of the Fabric server we are connected with)rr%r&)r5r;r;r<rszFabricConnection.uuidcCsdS)zConnect with MySQL FabricNr;)r5r;r;r<r4szFabricConnection.connectcCsdS)zCheck 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;)r5r;r;r<rs zFabricConnection.is_connectedcCsdj|j|j|jdS)Nz"{class_}(host={host}, port={port}))class_r7r8)rDrr%r&)r5r;r;r<__repr__*szFabricConnection.__repr__N)rjrkrlrmrr rrr=r!r7r8rr4rr(r;r;r;r<r#s    r#cs`eZdZdZedeeffdd ZeddZ eddZ d d Z d d Z ed dZ ZS)rozCClass holding a connection to a MySQL Fabric server through XML-RPCr"cs"tt||||||d|_dS)rN)r~ror=_proxy)r5r6r7r8r9r:)rr;r<r=6s zFabricXMLRPCConnection.__init__cCs|jS)z5Returns the XMLRPC Proxy of current Fabric connection)r))r5r;r;r<rq?szFabricXMLRPCConnection.proxycCst|j|jS)z4Returns the XMLRPC URI for current Fabric connection)rr%r&)r5r;r;r<rDszFabricXMLRPCConnection.uric Cs|jr |jS|j}|j}d}d}x||kr |d7}yZ|jjrXtsJtdt|jj}nd}t |jj |jj d|d}t |j |dd}|Wnftk r|Stjk r}z4||krtd|tdj|j|j|d Wdd}~XYnX|dkr"t|q"WdS) 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. NrrzPython does not support SSL)rr) transportrz'Connection to MySQL Fabric failed ({0})z*Retrying {host}:{port}, attempts {counter})r7r8counter)rr)rrr$rrrrrrrrr_some_nonexisting_methodrrdrbrDrrr7r8timesleep)r5r.delayrqr+rr*rhr;r;r<_xmlrpc_get_proxyIs>   $z(FabricXMLRPCConnection._xmlrpc_get_proxycCs||_dS)zConnect with MySQL FabricN)r0r))r5r;r;r<r4vszFabricXMLRPCConnection.connectc CsBy|jWn*tk r"dSttfk r8dSXdSdS)zCheck whether connection with Fabric is valid Return True if we can still interact with the Fabric server; False if Not. Returns True or False. TFN)r)r,rrrr)r5r;r;r<rzs z#FabricXMLRPCConnection.is_connected)rjrkrlrmrrrr=r!rqrr0r4rrr;r;)rr<ro2s  -rocsTeZdZdZedeeffdd ZeddZ ddZ d d Z ed d Z Z S) r2zT Class holding a connection to a MySQL Fabric server through MySQL protocol r#cs$tt|j|||||dd|_dS)r)r8r9r:N)r~r2r= _connection)r5r6r7r8r9r:)rr;r<r=s  zFabricMySQLConnection.__init__cCs|jS)z*Returns the MySQL RPC Connection to Fabric)r1)r5r;r;r<rVsz FabricMySQLConnection.connectionc Cs|jr |jS|j}|j}d}x||kr|d7}yX|j|j|jj|jjd}|jj r~t s^t d|jj d|d<|jj d|d<t f|St k r}z4||krt d |td j|j|j|d Wd d }~XYnX|dkrt|qWd 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)r7r8rrzPython does not support SSLr)rrrz'Connection to MySQL Fabric failed ({0})z*Retrying {host}:{port}, attempts {counter})r7r8r+N)rr1rrr%r&r$rrrrrr rrrDrrr7r8r-r.)r5r.r/r+dbconfigrhr;r;r<_get_connections6    $z%FabricMySQLConnection._get_connectioncCs||_dS)zConnect with MySQL FabricN)r3r1)r5r;r;r<r4szFabricMySQLConnection.connectcCs$y |jStk rdSXdS)zCheck whether connection with Fabric is valid Return True if we can still interact with the Fabric server; False if Not. Returns True or False. FN)r1rrr)r5r;r;r<rs  z"FabricMySQLConnection.is_connected)rjrkrlrmrrrr=r!rVr3r4rrr;r;)rr<r2s +r2c@seZdZdZddZddZeddZedd Zd'd d Z d dZ ddZ ddZ ddZ ddZddZddZeZd(ddZddZdd Zd!d"Zd#d$Zd%d&Zd S))MySQLFabricConnectionz1Connection to a MySQL server through MySQL FabriccKsJd|_d|_d|_d|_i|_|d|kr6td|rF|jf|dS)rNr6z+Configuration parameters for Fabric missing) _mysql_cnxr$_fabric_mysql_server _mysql_config_cnx_propertiesreset_propertiesrs store_config)r5r_r;r;r<r=szMySQLFabricConnection.__init__cCs&|drtdj|dt|j|S)z7Return the return value of the MySQLConnection instanceZcmd_zHCalling {attr} is not supported for connections managed by MySQL Fabric.)attr) startswithrrDrpr5)r5r;r;r;r< __getattr__s   z!MySQLFabricConnection.__getattr__cCs|jr|jjSdS)z+Returns the Fabric UUID of the MySQL serverN)r6r)r5r;r;r<rwsz!MySQLFabricConnection.fabric_uuidcCs|jS)zReturns connection properties)r8)r5r;r;r< propertiessz MySQLFabricConnection.propertiesNcCs$|s|jr|jj}|jj|ddS)z'Reset cache for this connection's group)r(N)r6r(r$r)r5r(r;r;r<rs z!MySQLFabricConnection.reset_cachecCs |jdk S)z\Check whether we are connected with the MySQL server Returns True or False N)r5)r5r;r;r<r sz"MySQLFabricConnection.is_connectedcCs.i|_x"tD]\}}|d|j|<qWdS)zResets the connection properties This method can be called to reset the connection properties to their default values. r N)r8_CNX_PROPERTIESr?)r5r)r;r;r;r<r9sz&MySQLFabricConnection.reset_propertiescKsHy |Wntk r YnX|j}x|D] \}}|tkrVtd|nD|rt|t|dsdddt|dD}t dj||d|dkr|r|d s|d rtd n\|d kr|r|drtd n>|dkr|t t fkrtdn |dkr|t t fkrtd|dkr8t|d||<q4|||<q4WdS)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 cSsg|] }|jqSr;)rj)rPZatyper;r;r<rR6sz6MySQLFabricConnection.set_property..z({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'r-zInvalid value for 'scope'r+zInvalid value for 'mode'Nr )closerr8r?r?rsrDrr]rr" SCOPE_GLOBALr  MODE_READONLY)r5r>propsr@rLZvalid_types_strr;r;r< set_propertys<        z"MySQLFabricConnection.set_propertycCst|tr||_ndg}x$|D]}||krtdj|dqW|d}|dt}y|dt|}Wn"tk rt d|YnXt ||}yt ||_Wn>tk rt dtf||_|j|jt |<YnXdS) 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. r7z8Missing configuration parameter '{parameter}' for fabric)Z parameterrr8z{0} protocol is not availablezNew Fabric connectionN)rrr$rsrDgetr rrrrFABRICSrrr)r5configZ required_keysZ required_keyr7rr8rr;r;r<_configure_fabricPs.       z'MySQLFabricConnection._configure_fabricc Ks|}d|kr$||d|d=d|kr>tdd|d<|}d|krT|d=d|krb|d=d|krp|d=y"tttd}|jf|Wn0t k r}zt d |Wdd}~XYnX||_ 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. r6Z unix_socketz'MySQL Fabric does not use UNIX sockets.N pool_nameZ pool_sizeZpool_reset_session)rKz'Connection configuration not valid: {0}) copyrJrwarningr rErrZ set_configrrrDr7)r5r_rIZ test_configpoolrNr;r;r<r:qs*  z"MySQLFabricConnection.store_configc Cs|r dS|j}|d}|d}|j}d}x||kr|d7}yd}|dr|ddkrp|d sptd |jj|d|d |d|d d }n.|d r|d }|jj||d d}ntdWnttk r:}zTt d ||||krtd ||dkr(t d |t |w4Wdd}~XYnX|j|d<|j|d<ytjjf||_Wnptk r}zP||kr||j|j|j|jtd ||dkrt |w4Wdd}~XYq4X||_Pq4WdS)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. Nr.r/rrr*r-r&r)z*Scope 'LOCAL' needs key property to be setr+)r-r+r()r+z*Missing group or key and tables propertiesz-Trying to get MySQL server (attempt {0}; {1})zError getting connection: {0}z Waiting {0}r7r8z&Reported faulty server to Fabric ({0}))rr8r7rLrsr$rr rrrrDr-r.r7r8r#rGr4r5rrr(rrrr6) r5rEr.r/r2r+r(rrhr;r;r<_connectsf               zMySQLFabricConnection._connectcCsXzDy||jWn(tk r,Yntk r@YnXWdd|_d|_XdS)z Close connection to MySQL serverN)rollbackr5rBrrrr6)r5r;r;r< disconnects z MySQLFabricConnection.disconnectcCs||rtd|r td|jdkr2td|p:|j}|pD|j}d}|dkrZ|dO}|dkrj|dO}tttt f}|||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 ) rOrZ_unread_resultrZ _buffered_rawrrrr)r5ZbufferedrawpreparedZ cursor_classZ cursor_typetypesr;r;r<rWs*    zMySQLFabricConnection.cursorcCs6|jtkr.||tdjt|d|dS)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 transaction)rbN)rRESET_CACHE_ON_ERRORrrQrrDrE)r5rhr;r;r<handle_mysql_errors z(MySQLFabricConnection.handle_mysql_errorc Cs@y|jWn,tk r:}z||Wdd}~XYnXdS)zCommit current transaction Raises whatever MySQLConnection.commit() raises, but raises MySQLFabricError when MySQL returns error ER_OPTION_PREVENTS_STATEMENT. N)r5commitrrW)r5rhr;r;r<rX#szMySQLFabricConnection.commitc Cs@y|jWn,tk r:}z||Wdd}~XYnXdS)zRollback current transaction Raises whatever MySQLConnection.rollback() raises, but raises MySQLFabricError when MySQL returns error ER_OPTION_PREVENTS_STATEMENT. N)r5rPrrW)r5rhr;r;r<rP/szMySQLFabricConnection.rollbackc CsF|y |j|Stk r@}z||Wdd}~XYnXdS)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)rOr5 cmd_queryrrW)r5Z statementrhr;r;r<rY;s  zMySQLFabricConnection.cmd_queryc CsF|y |j|Stk r@}z||Wdd}~XYnXdS)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)rOr5cmd_query_iterrrW)r5Z statementsrhr;r;r<rZJs  z$MySQLFabricConnection.cmd_query_iter)N)NNNN)rjrkrlrmr=r=r!rwr>rrr9rFrJr:rOrQrBrWrWrXrPrYrZr;r;r;r<r4s(    3!'D  )  r4)rrmsysrr-rbase64rrhashlibrloggingrdr xmlrpclibrrrrhttplibr ImportError xmlrpc.clienturllib.requestr http.client version_infor rZmysql.connectorr#rVr conversionr Zpoolingr rHrrrrrrrWrrrrr'rrrZcachingrZ balancingrrZcatch23rr r!ZCR_SERVER_LOSTZER_OPTION_PREVENTS_STATEMENTrVZCR_SERVER_GONE_ERRORZCR_CONN_HOST_ERRORZCR_CONNECTION_ERRORZCR_IPSOCK_ERRORrrr rrHrrZ_GETCNX_ATTEMPT_DELAYZ_GETCNX_ATTEMPT_MAXrDrr Z STATUS_FAULTYZ STATUS_SPARErrrCr"Z_SERVER_STATUS_FAULTYrErSrrr>r? getLoggerrobjectr0rnrvrcrrtrrrrrrrrr#ror2r4r;r;r;r<s                      \#!# NR6[Q