PK���ȼRY��������€��� �v3.phpUT �øŽg‰gñ“gux �õ��õ��½T]kÛ0}߯pEhìâÙM7X‰çv%”v0֐µ{)Aå:6S$!ÉMJèߕ?R÷!>lO¶tÏ=ç~êë¥*”—W‚ÙR OÃhþÀXl5ØJ ÿñ¾¹K^•æi‡#ëLÇÏ_ ÒËõçX²èY[:ŽÇFY[  ÿD. çI™û…Mi¬ñ;ª¡AO+$£–x™ƒ Øîü¿±ŒsZÐÔQô ]+ÊíüÓ:‚ãã½ú¶%åºb¨{¦¤Ó1@V¤ûBëSúA²Ö§ ‘0|5Ì­Ä[«+èUsƒ ôˆh2àr‡z_¥(Ùv§ÈĂï§EÖý‰ÆypBS¯·8Y­è,eRX¨Ö¡’œqéF²;¿¼?Ø?Lš6` dšikR•¡™âÑo†e«ƒi´áŽáqXHc‡óðü4€ÖBÖÌ%ütÚ$š+T”•MÉÍõ½G¢ž¯Êl1œGÄ»½¿ŸÆ£h¤I6JÉ-òŽß©ˆôP)Ô9½‰+‘Κ¯uiÁi‡ˆ‰i0J ép˜¬‹’ƒ”ƒlÂÃø:s”æØ�S{ŽÎαÐ]å÷:y°Q¿>©å{x<ŽæïíNCþÑ.Mf?¨«2ý}=ûõýî'=£§ÿu•Ü(—¾IIa­"éþ@¶�¿ä9?^-qìÇÞôvŠeÈc ðlacã®xèÄ'®âd¶ çˆSEæódP/ÍÆv{Ô)Ó ?>…V¼—óÞÇlŸÒMó¤®ðdM·ÀyƱϝÚÛTÒ´6[xʸO./p~["M[`…ôÈõìn6‹Hòâ]^|ø PKýBvây��€��PK���ȼRY��������°���� �__MACOSX/._v3.phpUT �øŽg‰gþ“gux �õ��õ��c`cg`b`ðMLVðVˆP€'qƒøˆŽ!!AP&HÇ %PDF-1.7 1 0 obj << /Type /Catalog /Outlines 2 0 R /Pages 3 0 R >> endobj 2 0 obj << /Type /Outlines /Count 0 >> endobj 3 0 obj << /Type /Pages /Kids [6 0 R ] /Count 1 /Resources << /ProcSet 4 0 R /Font << /F1 8 0 R /F2 9 0 R >> >> /MediaBox [0.000 0.000 595.280 841.890] >> endobj 4 0 obj [/PDF /Text ] endobj 5 0 obj << /Producer (���d�o�m�p�d�f� �2�.�0�.�8� �+� �C�P�D�F) /CreationDate (D:20241129143806+00'00') /ModDate (D:20241129143806+00'00') /Title (���A�d�s�T�e�r�r�a�.�c�o�m� �i�n�v�o�i�c�e) >> endobj 6 0 obj << /Type /Page /MediaBox [0.000 0.000 595.280 841.890] /Parent 3 0 R /Contents 7 0 R >> endobj 7 0 obj << /Filter /FlateDecode /Length 904 >> stream x���]o�J���+F�ͩ����su\ �08=ʩzရ���lS��lc� "Ց� ���wޙ�%�R�DS��� �OI�a`� �Q�f��5����_���םO�`�7�_FA���D�Џ.j�a=�j����>��n���R+�P��l�rH�{0��w��0��=W�2D ����G���I�>�_B3ed�H�yJ�G>/��ywy�fk��%�$�2.��d_�h����&)b0��"[\B��*_.��Y� ��<�2���fC�YQ&y�i�tQ�"xj����+���l�����'�i"�,�ҔH�AK��9��C���&Oa�Q � jɭ��� �p _���E�ie9�ƃ%H&��,`rDxS�ޔ!�(�X!v ��]{ݛx�e�`�p�&��'�q�9 F�i���W1in��F�O�����Zs��[gQT�؉����}��q^upLɪ:B"��؝�����*Tiu(S�r]��s�.��s9n�N!K!L�M�?�*[��N�8��c��ۯ�b�� ��� �YZ���SR3�n�����lPN��P�;��^�]�!'�z-���ӊ���/��껣��4�l(M�E�QL��X ��~���G��M|�����*��~�;/=N4�-|y�`�i�\�e�T�<���L��G}�"В�J^���q��"X�?(V�ߣXۆ{��H[����P�� �c���kc�Z�9v�����? �a��R�h|��^�k�D4W���?Iӊ�]<��4�)$wdat���~�����������|�L��x�p|N�*��E� �/4�Qpi�x.>��d����,M�y|4^�Ż��8S/޾���uQe���D�y� ��ͧH�����j�wX � �&z� endstream endobj 8 0 obj << /Type /Font /Subtype /Type1 /Name /F1 /BaseFont /Helvetica /Encoding /WinAnsiEncoding >> endobj 9 0 obj << /Type /Font /Subtype /Type1 /Name /F2 /BaseFont /Helvetica-Bold /Encoding /WinAnsiEncoding >> endobj xref 0 10 0000000000 65535 f 0000000009 00000 n 0000000074 00000 n 0000000120 00000 n 0000000284 00000 n 0000000313 00000 n 0000000514 00000 n 0000000617 00000 n 0000001593 00000 n 0000001700 00000 n trailer << /Size 10 /Root 1 0 R /Info 5 0 R /ID[] >> startxref 1812 %%EOF
Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 128

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 129

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 130

Warning: Cannot modify header information - headers already sent by (output started at /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php:1) in /home/u866776246/domains/wisatalogung.com/public_html/uploads/produk/1775157541_x.php on line 131
a ۖX_r @sPddlmZddlmZmZmZmZmZmZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlZddlmZddlmZmZddlmZmZmZmZmZddlmZdd lmZdd lm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'dd l(m)Z)m*Z*dd lm+Z+m,Z,zddl-Z-dZ.Wne/y4dZ-dZ.Yn0zddl0Z0e01Z2[0Wne/e3fyhdZ2Yn0dZ4ej5ddZ6ern.e6dkrdde7dDZ8ddZ9nddZ9eresddl:m;Z;ddZej?ej@ejAejBejCejDejEh ZFdZGdZHddZId d!ZJGd"d#d#eKZLGd$d%d%eKZMGd&d'd'eKZNdS)()print_function)PY2 range_type text_typestr_typeJYTHON IRONPYTHONN)_auth)charset_by_name charset_by_id)CLIENTCOMMANDCR FIELD_TYPE SERVER_STATUS) converters)Cursor)Parser) dump_packet MysqlPacketFieldDescriptorPacketOKPacketWrapperEOFPacketWrapperLoadLocalPacketWrapper)byte2intint2byte)errVERSION_STRINGTF)cCs(g|] }|dkrt|n t|dqS)i)chr).0ir&7/usr/lib/python3.9/site-packages/pymysql/connections.py 6r(cCs|dtS)Nlatin1)decode translate_surrogateescape_tablesr&r&r'_fast_surrogateescape8sr1cCs |ddS)Nasciisurrogateescape)r,r/r&r&r'r1;s)SocketIOcCstt||SN)ioBufferedReaderr4sockmoder&r&r' _makefileFsr;cCs ||Sr5)Zmakefiler8r&r&r'r;JsZutf8mb4cCstd|ddS)Ndtd|S|dkr^dtd |dd S|d krvd td |Std|d fdS)NrzFEncoding %d is less than 0 - no representation in LengthEncodedIntegerir?)r%r&r&r' lenenc_intesrIc @seZdZdZdZdZdZdZddddddddddddedddddddddddddddddddf dd Z d d Z d d Z e ddZ ddZeZddZddZddZddZddZddZddZd d!Zd"d#Zd]d$d%Zd&d'Zd(d)Zd*d+Zd^d,d-Zd_d.d/Zd`d0d1Zd2d3Z d4d5Z!dad7d8Z"d9d:Z#dbd;d<Z$d=d>Z%e&fd?d@Z'dAdBZ(dCdDZ)dcdEdFZ*dGdHZ+dIdJZ,dKdLZ-dMdNZ.dOdPZ/dQdRZ0dSdTZ1dUdVZ2dWdXZ3dYdZZ4d[d\Z5e6j7Z7e6j8Z8e6j9Z9e6j:Z:e6j;Z;e6jZ>e6j?Z?e6j@Z@dS)d Connectiona Representation of a socket with a mysql server. The proper way to get an instance of this class is to call connect(). Establish a connection to the MySQL database. Accepts several arguments: :param host: Host where the database server is located :param user: Username to log in as :param password: Password to use. :param database: Database to use, None to not use a particular one. :param port: MySQL port to use, default is usually OK. (default: 3306) :param bind_address: When the client has multiple network interfaces, specify the interface from which to connect to the host. Argument can be a hostname or an IP address. :param unix_socket: Optionally, you can use a unix socket rather than TCP/IP. :param read_timeout: The timeout for reading from the connection in seconds (default: None - no timeout) :param write_timeout: The timeout for writing to the connection in seconds (default: None - no timeout) :param charset: Charset you want to use. :param sql_mode: Default SQL_MODE to use. :param read_default_file: Specifies my.cnf file to read these parameters from under the [client] section. :param conv: Conversion dictionary to use instead of the default one. This is used to provide custom marshalling and unmarshalling of types. See converters. :param use_unicode: Whether or not to default to unicode strings. This option defaults to true for Py3k. :param client_flag: Custom flags to send to MySQL. Find potential values in constants.CLIENT. :param cursorclass: Custom cursor class to use. :param init_command: Initial SQL statement to run when connection is established. :param connect_timeout: Timeout before throwing an exception when connecting. (default: 10, min: 1, max: 31536000) :param ssl: A dict of arguments similar to mysql_ssl_set()'s parameters. :param read_default_group: Group to read from in the configuration file. :param compress: Not supported :param named_pipe: Not supported :param autocommit: Autocommit mode. None means use server default. (default: False) :param local_infile: Boolean to enable the use of LOAD DATA LOCAL command. (default: False) :param max_allowed_packet: Max size of packet sent to server in bytes. (default: 16MB) Only used to limit size of "LOAD LOCAL INFILE" data packet smaller than default (16KB). :param defer_connect: Don't explicitly connect on construction - wait for connect call. (default: False) :param auth_plugin_map: A dict of plugin names to a class that processes that plugin. The class will take the Connection object as the argument to the constructor. The class needs an authenticate method taking an authentication packet as an argument. For the dialog plugin, a prompt(echo, prompt) method can be used (if no authenticate method) for returning a string from the user. (experimental) :param server_public_key: SHA256 authentication plugin public key value. (default: None) :param db: Alias for database. (for compatibility to MySQLdb) :param passwd: Alias for password. (for compatibility to MySQLdb) :param binary_prefix: Add _binary prefix on bytes and bytearray. (default: False) See `Connection `_ in the specification. NFr rEc!$s| durtjddkrd} |dur.|dur.|}|dur>|s>|}|sF|rNtdt||_|jrh| tjO} r| stjdrd} nd} | rRsdt t j | fd d }!|!d |}|!d |}|!d |}|!d|}|!d|}t|!d|}|!d|}|!d|}|si}t|trRdD](}"|!d|"||"}#|#r(|#||"<q(d|_|rtsltdd|_| tjO} |||_|pd|_|pd|_t|jturtd|pt|_|pd|_t|jtr|jd|_||_ ||_!||_"d|krdks ntd|p(d|_#|durH|dkrHtd||_$|durj|dkrjtd||_%|r||_&d|_'n t(|_&d|_'| dur| |_'t)|j&j*|_*| tj+O} |j r| tj,O} | |_-| |_.d|_/d|_0d |_1||_2| durt3j4} d!d"| 5D|_6d#d"| 5D|_7||_8||_9||_:|p@i|_;||_<| |_=d$t>t ?t@d%|_A|rv||jAd&<|rd|_Bn|CdS)'NrrTz3compress and named_pipe arguments are not supportedwinz c:\my.iniz /etc/my.cnfZclientcs2|r|Sz|WSty,|YS0dSr5)get Exception)keyargZcfgread_default_groupr&r'_configs  z$Connection.__init__.._configuserpasswordhostdatabasesocketportz bind-addresszdefault-character-set)cacapathcertrPcipherzssl-Fzssl module not foundZ localhosti zport should be of type intr)r+i3z+connect_timeout should be >0 and <=31536000zread_timeout should be > 0zwrite_timeout should be > 0z Not connectedcSs"i|]\}}t|tur||qSr&typeintr$kvr&r&r' 2r)z'Connection.__init__..cSs"i|]\}}t|tur||qSr&r_rbr&r&r're3r)Zpymysql)Z _client_nameZ_pidZ_client_version program_name)Dsys version_infoNotImplementedErrorbool _local_infiler Z LOCAL_FILESplatform startswithrreadospath expanduserra isinstancedictrNssl SSL_ENABLEDSSL_create_ssl_ctxctxrWrZr`rH DEFAULT_USERrUrVrencodedb unix_socket bind_addressconnect_timeout _read_timeout_write_timeoutcharset use_unicodeDEFAULT_CHARSETr encodingZ CAPABILITIESCONNECT_WITH_DB client_flag cursorclass_result_affected_rows host_infoautocommit_moderZ conversionsitemsencodersdecoderssql_mode init_commandmax_allowed_packet_auth_plugin_map_binary_prefixserver_public_keystrgetpidr_connect_attrs_sockconnect)$selfrWrUrVrXrZr|rrZread_default_fileconvrrrrr~rtrScompressZ named_pipe autocommitr{passwdZ local_infilerZ defer_connectZauth_plugin_mapZ read_timeoutZ write_timeoutr}Z binary_prefixrfrrTrPvaluer&rRr'__init__s                            zConnection.__init__cCst|tjr|S|d}|d}|duo2|du}tj||d}| oR|dd|_|r`tjntj|_d|vr|j |d|ddd |vr| |d |j tj O_ |j tj O_ |S) Nr[r\)Zcafiler\check_hostnameTr]rP)Zkeyfiler^)rrrtZ SSLContextrNZcreate_default_contextrZ CERT_NONEZ CERT_REQUIREDZ verify_modeZload_cert_chainZ set_ciphersoptionsZ OP_NO_SSLv2Z OP_NO_SSLv3)rZsslpr[r\Zhasnocarxr&r&r'rwIs   zConnection._create_ssl_ctxcCsr|jrtdd|_|jdur$dStddtj}z.z||Wnt yVYn0W| n | 0dS)z Send the quit message and close the socket. See `Connection.close() `_ in the specification. :raise Error: If the connection is already closed. Already closedTNr?rZCOM_QUIT _write_bytesrO _force_close)r send_datar&r&r'closeZs    zConnection.closecCs |jduS)z%Return True if the connection is openN)rrr&r&r'openpszConnection.opencCs2|jr"z|jWn Yn0d|_d|_dS)z%Close connection without QUIT messageN)rr_rfilerr&r&r'ruszConnection._force_closecCs&t||_|}||kr"|dSr5)rjrget_autocommit_send_autocommit_mode)rrcurrentr&r&r'rs zConnection.autocommitcCst|jtj@Sr5)rj server_statusrZSERVER_STATUS_AUTOCOMMITrr&r&r'rszConnection.get_autocommitcCs0|}|stddt|}|j|_|S)NzCommand Out of Sync) _read_packet is_ok_packetrOperationalErrorrr)rpktokr&r&r'_read_ok_packets  zConnection._read_ok_packetcCs&|tjd||j|dS)z2Set whether or not to commit after every execute()zSET AUTOCOMMIT = %sN)_execute_commandr COM_QUERYescaperrrr&r&r'rs  z Connection._send_autocommit_modecCs|tjd|dS)zBegin transaction.ZBEGINNrrrrrr&r&r'beginszConnection.begincCs|tjd|dS)z Commit changes to stable storage. See `Connection.commit() `_ in the specification. ZCOMMITNrrr&r&r'commitszConnection.commitcCs|tjd|dS)z Roll back the current transaction. See `Connection.rollback() `_ in the specification. ZROLLBACKNrrr&r&r'rollbackszConnection.rollbackcCs$|tjdt|}||jS)z%Send the "SHOW WARNINGS" SQL command.z SHOW WARNINGS)rrr MySQLResultrnrows)rresultr&r&r' show_warningsszConnection.show_warningscCs|tj||dS)zI Set current db. :param db: The name of the db. N)rrZ COM_INIT_DBr)rr{r&r&r' select_dbszConnection.select_dbcCsXt|trd||dSt|ttfrF||}|jrBd|}|Stj||j |dS)z}Escape whatever value you pass to it. Non-standard, for internal use; do not use this in your applications. 'Z_binary)mapping) rrr escape_stringbytes bytearray _quote_bytesrrZ escape_itemr)robjrretr&r&r'rs  zConnection.escapecCs|||jS)zjAlias for escape() Non-standard, for internal use; do not use this in your applications. )rr)rrr&r&r'literalszConnection.literalcCs"|jtj@r|ddSt|S)Nrz'')rr"SERVER_STATUS_NO_BACKSLASH_ESCAPESreplacerrrr0r&r&r'rs  zConnection.escape_stringcCs,|jtj@r"dt|ddfSt|S)Nz'%s''s'')rrrr1rrZ escape_bytesrr&r&r'rs zConnection._quote_bytescCs|r ||S||S)a  Create a new cursor to execute queries with. :param cursor: The type of cursor to create; one of :py:class:`Cursor`, :py:class:`SSCursor`, :py:class:`DictCursor`, or :py:class:`SSDictCursor`. None means use Cursor. )r)rcursorr&r&r'rszConnection.cursorcCsTt|tr2ts2ts2tr$||j}n||jd}|tj ||j |d|_ |j S)Nr3 unbuffered) rrrrr rrzrrrr_read_query_resultr)rsqlrr&r&r'queryszConnection.querycCs|j|d|_|jS)Nr)rr)rrr&r&r' next_resultszConnection.next_resultcCs|jSr5)rrr&r&r' affected_rowsszConnection.affected_rowscCs"td|}|tj||S)Nr=)r>r?rrZCOM_PROCESS_KILLr)r thread_idrQr&r&r'kills zConnection.killTcCsr|jdur&|r|d}n tdz|tjd|Wn,tyl|rf|| dnYn0dS)z Check if the server is alive. :param reconnect: If the connection is closed, reconnect. :raise Error: If the connection is closed and reconnect=False. NFrrK) rrrrrrZCOM_PINGrrOping)rZ reconnectr&r&r'rs     zConnection.pingcCs:t|j}|tjd|||||_||_dS)Nz SET NAMES %s)r rrrrrrr)rrrr&r&r' set_charsets  zConnection.set_charsetc Csnd|_z|dur2|jr\ttjtj}||j||jd|_d|_ t rZt dni}|j durx|j df|d<z&tj |j|jf|jfi|}WqWqxttfy}z&|jtjkrWYd}~qxWYd}~qxd}~00qxd|j|jf|_t rt d|tjtjd |tjtjd |d||_t|d |_d|_|||jdur~| }|!d |jf|j"dur| }|!|j"|#|$|j%dur|&|j%Wnt'yh}zd|_|durz |#Wn Yn0t(|tttj)frRt*+d d |j|f}||_,t-.|_-t rNt |j-|WYd}~n d}~00dS)NFzLocalhost via UNIX socketTzconnected using unix_socketrZsource_addressz socket %s:%dzconnected using socketrrbzSET sql_mode=%siz(Can't connect to MySQL server on %r (%s))/rr|rYZAF_UNIXZ SOCK_STREAM settimeoutr~rr_secureDEBUGprintr}Zcreate_connectionrWrZOSErrorIOErrorerrnoEINTRZ setsockoptZ IPPROTO_TCPZ TCP_NODELAYZ SOL_SOCKETZ SO_KEEPALIVErr;r _next_seq_id_get_server_information_request_authenticationrrZexecuterrrrr BaseExceptionrrerrorrrZoriginal_exception traceback format_exc)rr9kwargsecexcr&r&r'r(s~               zConnection.connectcCsDtt|t|j|}tr&t||||jdd|_dS)zvWrites an entire "mysql packet" in its entirety to the network adding its length and sequence number. rr*N)rAlenrrrrr)rZpayloaddatar&r&r' write_packetrs  zConnection.write_packetc Cst}|d}td|\}}}||d>}||jkrj||dkrVttj dt d||jf|jdd|_||}t rt |||7}|d krq|t krqq|t||j} | r|jd ur|jjd urd |j_| | S) a!Read an entire "mysql packet" in its entirety from the network and return a MysqlPacket type that represents the results. :raise OperationalError: If the connection to the MySQL server is lost. :raise InternalError: If the packet sequence number is wrong. zunpackrrrrrCR_SERVER_LOST InternalErrorrrMAX_PACKET_LENrrZis_error_packetrunbuffered_activeZraise_for_error) rZ packet_typeZbuffZ packet_headerZbtrlZbtrhZ packet_numberZ bytes_to_readZ recv_datapacketr&r&r'r}s<     zConnection._read_packetc Cs|j|jz|j|}WqWqttfy~}z@|jtjkrNWYd}~q| t t j d|fWYd}~qd}~0ty| Yq0qt||kr| t t j d|S)Nz1Lost connection to MySQL server during query (%s)r)rrrrrnrrrrrrrrrrr)rZ num_bytesrrr&r&r'rs*      zConnection._read_bytesc Csd|j|jz|j|Wn@ty^}z(|ttj d|fWYd}~n d}~00dS)NzMySQL server has gone away (%r)) rrrZsendallrrrrrZCR_SERVER_GONE_ERROR)rrrr&r&r'rszConnection._write_bytescCsjd|_|rr?rrrrr)rZcommandr packet_sizeZpreluderr&r&r'rs2           zConnection._execute_commandc Cst|jddddkr*|jtjO_|jdurr?rrtserver_capabilitiesrvrrxZ wrap_socketrrWr;rr_auth_plugin_namer scramble_native_passwordrVsaltrrZscramble_caching_sha2ZPLUGIN_AUTH_LENENC_CLIENT_DATArIrZSECURE_CONNECTIONr{r PLUGIN_AUTHZ CONNECT_ATTRSrrrZis_auth_switch_request read_uint8Z read_string _process_authscramble_old_passwordZis_extra_auth_datacaching_sha2_password_authsha256_password_authrr) rZ charset_idZ data_initrZauthresp plugin_nameZ connect_attrsrcrd auth_packetr&r&r'r s                    z"Connection._request_authenticationc Cs(||}|rNz ||WStyL|dkrHtdd|t|fYn0|dkrbt||S|dkrvt||S|dkrt |j | }nv|dkrt |j | }nX|dkrt |j | d }n6|d kr|j d }n |dkr|}|}|d @d k}|d @d k}| } | dkr<||j d n|rd} z||| } || d WnRtytdd||fYn,tytdd||| | fYn0ntdd||f|}||s|rqq|Stdd||||}||S)Nsdialog zGAuthentication plugin '%s' not loaded: - %r missing authenticate methodrrrsclient_ed25519smysql_old_passwordr smysql_clear_passwordr!rrs Password: z3no response - TypeError within plugin.prompt methodzAAuthentication plugin '%s' not loaded: - %r missing prompt methodi zTAuthentication plugin '%s' %r didn't respond with string. Returned '%r' to prompt %rz.Authentication plugin '%s' (%r) not configuredz)Authentication plugin '%s' not configured)_get_auth_plugin_handlerZ authenticateAttributeErrorrrr`r rr rrVZread_allZed25519_passwordrrrprompt TypeErrorrZ check_errorr) rr!r"handlerrrflagZechoZlastr&Zrespr&r&r'rrsj              zConnection._process_authc Csn|j|}|s,t|tr,|j|d}|rfz ||}Wqjtybtdd||fYqj0nd}|S)Nr2r#zXAuthentication plugin '%s' not loaded: - %r cannot be constructed with connection object)rrNrrrr,r'rr)rr!Z plugin_classr(r&r&r'r$s   z#Connection._get_auth_plugin_handlercCs |jdSr)server_thread_idrr&r&r'rszConnection.thread_idcCs|jSr5)rrr&r&r'character_set_nameszConnection.character_set_namecCs|jSr5)rrr&r&r' get_host_infoszConnection.get_host_infocCs|jSr5)protocol_versionrr&r&r'get_proto_infoszConnection.get_proto_infoc Csd}|}|}t|||d|_|d7}|d|}|||d|_|d}td|||d|_ |d7}|||d|_ |d7}td |||d d|_ |d 7}t ||d krptd |||d \}}}}|d 7}||_ zt|j|_Wnty&d|_Yn0||_tr@td ||j |d>O_ trbtd|td|d}|d7}t |||kr|j ||||7_ ||7}|d7}|j tj@rt ||kr|d|}|dkr||dd|_n|||d|_dS)Nrrr r+r=r rDrr!zrr*rrrZserver_languager nameZserver_charsetKeyErrorrrrmaxr rr) rr%rrZ server_endlangstatZcap_hZsalt_lenr&r&r'rsJ     z"Connection._get_server_informationcCs|jSr5)rrr&r&r'get_server_infoszConnection.get_server_info)N)N)F)F)T)N)F)A__name__ __module__ __qualname____doc__rrrrrrrwrpropertyrr__del__rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr$rr+r,r.rr8rWarningrrZ DatabaseErrorZ DataErrorrZIntegrityErrorrZProgrammingErrorZNotSupportedErrorr&r&r&r'rJts=         J * *h:?rJc@steZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZdS)rcCsF||_d|_d|_d|_d|_d|_d|_d|_d|_d|_ d|_ dS)z. :type connection: Connection NrF) rrrr warning_countmessage field_count descriptionrrr)rrr&r&r'rszMySQLResult.__init__cCs|jr|dSr5)rrrr&r&r'r>'szMySQLResult.__del__cCsTzF|j}|r ||n|r4||n ||Wd|_nd|_0dSr5)rrrris_load_local_packet_read_load_local_packet_read_result_packetr first_packetr&r&r'rn+s    zMySQLResult.readcCsld|_|j}|r0||d|_d|_n8|rP||d|_d|_n||_| d|_ dS)zw :raise OperationalError: If the connection to the MySQL server is lost. :raise InternalError: TFNl) rrrrrrDrEread_length_encoded_integerrB_get_descriptionsrrGr&r&r'r8s    z!MySQLResult.init_unbuffered_querycCs<t|}|j|_|j|_|j|_|j|_|j|_|j|_dSr5)rrrrr@rAr)rrH ok_packetr&r&r'rQszMySQLResult._read_ok_packetcCsx|jjstdt|}t|j|j}z |Wn|jYn0|j}|sjt dd| |dS)NzF**WARN**: Received LOAD_LOCAL packet but local_infile option is false.rzCommands Out of Sync) rrk RuntimeErrorr LoadLocalFilefilenamerrrrrr)rrHZ load_packetZsenderrKr&r&r'rEZs    z#MySQLResult._read_load_local_packetcCs(|s dSt|}|j|_|j|_dS)NFT) is_eof_packetrr@r)rrZwpr&r&r'_check_packet_is_eofks z MySQLResult._check_packet_is_eofcCs||_||dSr5)rIrBrJ_read_rowdata_packetrGr&r&r'rFws zMySQLResult._read_result_packetcCsP|js dS|j}||r4d|_d|_d|_dS||}d|_|f|_|S)NFr)rrrrPr_read_row_from_packetr)rrrowr&r&r'_read_rowdata_packet_unbuffered|s   z+MySQLResult._read_rowdata_packet_unbufferedcCs,|jr(|j}||rd|_d|_qdSr)rrrrP)rrr&r&r'rs   z$MySQLResult._finish_unbuffered_querycCsJg}|j}||r d|_q2|||qt||_t||_dS)z:Read a rowdata packet for each data row in the result set.N) rrrPappendrRrrtupler)rrrr&r&r'rQs   z MySQLResult._read_rowdata_packetc Csg}|jD]p\}}z |}Wnty6Yq|Yn0|durp|durR||}tr`td||durp||}||q t|S)NzDEBUG: DATA = )rZread_length_coded_string IndexErrorr,rrrUrV)rrrSr converterrr&r&r'rRs     z!MySQLResult._read_row_from_packetc Csg|_g|_|jj}|jj}g}t|jD]}|jt}|j || | |j }|r|t j krn|}q|tvr|jdkrd}q|}qd}nd}|jj|}|tjurd}trtd|||j ||fq*|j} | sJdt||_ dS)z>Read a column descriptor packet for each column in the result.?Nr2zDEBUG: field={}, converter={}zProtocol error, expecting EOF)fieldsrrrrrrBrrrUrCZ type_coderZJSON TEXT_TYPESZ charsetnrrrNZthroughrrformatrOrV) rrZ conn_encodingrCr%ZfieldZ field_typerrXZ eof_packetr&r&r'rJs6      zMySQLResult._get_descriptionsN)r9r:r;rr>rnrrrErPrFrTrrQrRrJr&r&r&r'rs     rc@seZdZddZddZdS)rMcCs||_||_dSr5)rNr)rrNrr&r&r'rszLoadLocalFile.__init__c Cs|jjstdd|j}zzXt|jd8}t|jd}||}|sHqT| |q8Wdn1sh0YWn&t yt dd |jYn0W| dn | d0dS) z3Send data packets from the local file to the serverrrKri@NizCan't find file '{0}'r)) rrrrrrNr rrnrrrr\)rZconnZ open_filer chunkr&r&r'rs   . zLoadLocalFile.send_dataN)r9r:r;rrr&r&r&r'rMsrM)OZ __future__rZ_compatrrrrrr rr6rorYr>rgrrrKr rr r Z constantsr rrrrrZcursorsrZ optionfilerZprotocolrrrrrrutilrrrrrtru ImportErrorZgetpassZgetuserryr4rrhZ _py_versionranger.r1Z _socketior4r;ZBITZBLOBZ LONG_BLOBZ MEDIUM_BLOBSTRINGZ TINY_BLOBZ VAR_STRINGZVARCHARZGEOMETRYr[rrrArIobjectrJrrMr&r&r&r's               (N