a cf+@s|dZzddlZddlmZWney2dZYn0dZzddlZddlZWneybdZ Yn0dZ ddl Z ddl Z ddl m Z ddlmZdd lmZdd lmZmZmZmZmZmZmZmZmZmZmZmZdd lmZm Z m!Z!m"Z"m#Z#dd l$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3dd l4m5Z5iZ6dZ7ddZ8ddZ9ddZ:e:Z;e jZ?gdZ@dS)z9 MySQL Connector/Python - MySQL driver written in Python N)CMySQLConnectionFT)version)MySQLConnection)DEFAULT_CONFIGURATION) ErrorWarningInterfaceError DatabaseErrorNotSupportedError DataErrorIntegrityErrorProgrammingErrorOperationalError InternalErrorcustom_error_exception PoolError) FieldFlag FieldType CharacterSet RefreshOption ClientFlag)DateTime TimestampBinary DateFromTicksTimestampFromTicks TimeFromTicksSTRINGBINARYNUMBERDATETIMEROWIDapilevel threadsafety paramstyle)read_option_filesz0MySQL Connector/Python C Extension not availablecKsddlm}m}m}z |d}Wn ty@|fi|}Yn0d|vr^|ds^ts^tt|`|tvr|fi|t|<n4t t||rt|j }d|vr|d|krt dWdn1s0Yzt| WSt ytd|Yn0dS) z Return a pooled MySQL connectionr)MySQLConnectionPoolgenerate_pool_nameCONNECTION_POOL_LOCK pool_nameuse_pure pool_sizez)Size can not be changed for active pools.Nz)Failed getting connection from pool '{0}')Zpoolingr(r)r*KeyError HAVE_CEXT ImportError ERROR_NO_CEXT_CONNECTION_POOLS isinstancer-rget_connectionAttributeErrorr format)kwargsr(r)r*r+Z check_sizer8U/home/httpd/docs/test/DocsMgr/lib/python3.9/site-packages/mysql/connector/__init__.py_get_pooled_connectionJs.     &r:c Ks$|}z |d}Wnty.tdYn0|d=tgd}d}|D]}t||}|rtdt|dkrxdndd |t|d r|d7}| d d |d <|d dks|d d krt d |d t |d t sJt d |d qJd|krt|krnnt d|jddddi}g}|D]D}|d |vrl|g||d <||d n||d |q<|D]} || } tt| D]t} t| d} td| } | | }|}|||d dztfi|WStyYn0qqt ddS)aReturn a MySQL connection and try to failover if needed An InterfaceError is raise when no MySQL is available. ValueError is raised when the failover server configuration contains an illegal connection argument. Supported arguments are user, password, host, port, unix_socket and database. ValueError is also raised when the failover argument was not provided. Returns MySQLConnection instance. failoverzfailover argument not provided) userpasswordhostport unix_socketZdatabaser+r-priorityrz4Unsupported connection argument {0} in failover: {1}rsz, rAdz;Priority value should be in the range of 0 to 100, got : {}zFPriority value should be an integer in the range of 0 to 100, got : {}z\You must either assign no priority to any of the routers or give a priority for every routercSs|dS)NrAr8xr8r8r9z*_get_failover_connection..T)keyreverseNz,Unable to connect to any of the target hosts)copyr. ValueErrorsetkeysr6lenjoinhasattrgetr r3intrsortappendrangerandomrandintpopupdateconnectr)r7configr;Zsupport_cnx_argsZpriority_countserverdiffZserver_directoryZserver_priority_listrAZ failover_list_lastindex new_configr8r8r9_get_failover_connectionnst          rcc sdvrdnd}t|ts(td|rts:tddvrJtddvrZtdd vrjtd d vr~td d <ztjd d }Wn(tj j ytd d Yn0g}|D](}| |j jdd|j|j|jdq|jddddd|Dd <dvr2dd<ddvrXtfi}tfi|Sd vrptfiSz8ddlm}tfdd|DrtfiWSWntyYn0dd}dvrd=|ststttr|st|iSt |iS)aCreate or get a MySQL connection object In its simpliest form, Connect() will open a connection to a MySQL server and return a MySQLConnection object. When any connection pooling arguments are given, for example pool_name or pool_size, a pool is created or a previously one is used to return a PooledMySQLConnection. Returns MySQLConnection or PooledMySQLConnection. dns_srvFz(The value of 'dns-srv' must be a booleanztMySQL host configuration requested DNS SRV. This requires the Python dnspython module. Please refer to documentationr@zZSRVz$Unable to locate any hosts for '{0}'T)Zomit_final_dot)r>r?rAweightcSs|d|d fS)NrArer8rEr8r8r9rGrHzconnect..)rIcSsg|]}|d|ddqS)r>r?)r>r?r8).0srvr8r8r9 szconnect..Zread_default_fileZ option_filesr) CNX_POOL_ARGScsg|] }|vqSr8r8)rfrIr7r8r9rhrHr,)!rYr3boolr HAVE_DNSPYTHONrdnsresolverquery exceptionZ DNSExceptionr6rUtargetZto_textr?rArerTr'r[rc constantsrianyr: NameErrorrRr/r0r1rr) argsr7rdZ srv_recordsr;rgrbrir,r8rjr9r[sl                 r[)%rConnectrrrrrrr/rrr r r r r rrrr[r$r%r&rrrrrrrrrr r!r"r#r)A__doc__Z_mysql_connectorZconnection_cextrr0r/Z dns.resolverrmZ dns.exceptionrlrWwarningsrCr connectionrrrrerrorsrrr r r r r rrrrrrrrrrZdbapirrrrrrrrr r!r"r#r$r%r&Z optionfilesr'r2r1r:rcr[rvVERSION__version_info__Z VERSION_TEXT __version____all__r8r8r8r9s<        8D $NV