Ytj@UdZddlmZddlmZmZmZmZmZddl m Z m Z ddl m Z mZddlmZer dd lmZmZmZeeeefZd ed <Gd d eZGddeZGddeZGddeZGddeZGddeZdS)zP Protocol objects to represent objects exposed by different pq implementations. ) annotations) TYPE_CHECKINGAnyProtocol TypeAliasUnion)CallableSequence)FormatTrace)Self)ConninfoOptionPGnotify PGresAttDescrBufferceZdZUded<ded<edxd Zedxd Zdyd ZdzdZe d{dZ dzdZ dzdZ dydZ ed|dZe d}dZe d}dZe d}dZe d}dZe d}dZe d}dZe d}dZe d}dZe dydZe dydZd~d!Ze d}d"Zddd&Ze dd'Ze dyd(Ze dyd)Ze dyd*Ze dyd+Z e dyd,Z!e dd.Z"e dd/Z#e dd0Z$e dd1Z%dd4Z&dd5Z'd6d6e(j)fdd=Z*d6d6e(j)fdd>Z+ ddd?Z,d6e(j)fdd@Z- dddAZ. dddDZ/ddEZ0ddFZ1ddGZ2ddHZ3ddIZ4ddJZ5ddKZ6ddLZ7ddNZ8dzdOZ9dydPZ:e dydQZ;e;j<ddSZ;dydTZ=dzdUZ>ddWZ?ddYZ@dd[ZAdd]ZBdd`ZCdddbZDddeZEddgZFddjZGdzdkZH dddoZIddpZJddrZKe dydsZLdzdtZMdzduZNdzdvZOdzdwZPd6S)PGconnz!Callable[[PGresult], None] | Nonenotice_handlerz!Callable[[PGnotify], None] | Nonenotify_handlerconninfobytesreturnrcdSNclsrs L/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/psycopg/pq/abc.pyconnectzPGconn.connects/2scdSrrrs r connect_startzPGconn.connect_starts58Sr"intcdSrrselfs r connect_pollzPGconn.connect_poll r"NonecdSrrr's r finishz PGconn.finish"r*r"list[ConninfoOption]cdSrrr's r infoz PGconn.info$,/Cr"cdSrrr's r resetz PGconn.reset'r*r"cdSrrr's r reset_startzPGconn.reset_start)r*r"cdSrrr's r reset_pollzPGconn.reset_poll+r*r"cdSrr)r(rs r pingz PGconn.ping-r1r"cdSrrr's r dbz PGconn.db0s3r"cdSrrr's r userz PGconn.user3 Sr"cdSrrr's r passwordzPGconn.password6!$r"cdSrrr's r hostz PGconn.host9r>r"cdSrrr's r hostaddrzPGconn.hostaddr<rAr"cdSrrr's r portz PGconn.port?r>r"cdSrrr's r ttyz PGconn.ttyBsCr"cdSrrr's r optionszPGconn.optionsE #r"cdSrrr's r statusz PGconn.statusHr>r"cdSrrr's r transaction_statuszPGconn.transaction_statusKs),r"name bytes | NonecdSrrr(rQs r parameter_statuszPGconn.parameter_statusNr*r"cdSrrr's r error_messagezPGconn.error_messageP&)cr".encodingstrcdSrrr(rYs r get_error_messagezPGconn.get_error_messageSr*r"cdSrrr's r _encodingzPGconn._encodingUrLr"cdSrrr's r protocol_versionzPGconn.protocol_versionXs'*sr"cdSrrr's r full_protocol_versionzPGconn.full_protocol_version[r1r"cdSrrr's r server_versionzPGconn.server_version^%(Sr"cdSrrr's r socketz PGconn.socketar>r"cdSrrr's r backend_pidzPGconn.backend_pidd"%#r"boolcdSrrr's r needs_passwordzPGconn.needs_passwordgrXr"cdSrrr's r used_passwordzPGconn.used_passwordjrfr"cdSrrr's r used_gssapizPGconn.used_gssapims#&3r"cdSrrr's r ssl_in_usezPGconn.ssl_in_useprkr"commandPGresultcdSrrr(rus r exec_z PGconn.exec_sr*r"cdSrrrxs r send_queryzPGconn.send_queryur*r"N param_valuesSequence[Buffer | None] | None param_typesSequence[int] | None param_formats result_formatcdSrrr(rur|r~rrs r exec_paramszPGconn.exec_paramsws 3r"cdSrrrs r send_query_paramszPGconn.send_query_paramss sr"cdSrrr(rQrur~s r send_preparezPGconn.send_prepares sr"cdSrrr(rQr|rrs r send_query_preparedzPGconn.send_query_prepareds sr"cdSrrrs r preparezPGconn.prepares 3r"rSequence[Buffer] | NonecdSrrrs r exec_preparedzPGconn.exec_prepareds 3r"cdSrrrTs r describe_preparedzPGconn.describe_preparedr*r"cdSrrrTs r send_describe_preparedzPGconn.send_describe_preparedr*r"cdSrrrTs r describe_portalzPGconn.describe_portalr*r"cdSrrrTs r send_describe_portalzPGconn.send_describe_portalr*r"cdSrrrTs r close_preparedzPGconn.close_preparedr*r"cdSrrrTs r send_close_preparedzPGconn.send_close_preparedr*r"cdSrrrTs r close_portalzPGconn.close_portalr*r"cdSrrrTs r send_close_portalzPGconn.send_close_portalr*r"PGresult | NonecdSrrr's r get_resultzPGconn.get_resultr*r"cdSrrr's r consume_inputzPGconn.consume_inputr*r"cdSrrr's r is_busyzPGconn.is_busyr*r"cdSrrr's r nonblockingzPGconn.nonblockingrkr"argcdSrr)r(rs r rzPGconn.nonblockings-0Sr"cdSrrr's r flushz PGconn.flushr*r"cdSrrr's r set_single_row_modezPGconn.set_single_row_moder*r"sizecdSrr)r(rs r set_chunked_rows_modezPGconn.set_chunked_rows_moder*r" PGcancelConncdSrrr's r cancel_connzPGconn.cancel_connr*r"PGcancelcdSrrr's r get_cancelzPGconn.get_cancelr*r"PGnotify | NonecdSrrr's r notifieszPGconn.notifiesr*r"bufferrcdSrr)r(rs r put_copy_datazPGconn.put_copy_datar*r"errorcdSrr)r(rs r put_copy_endzPGconn.put_copy_endr*r"async_tuple[int, memoryview]cdSrr)r(rs r get_copy_datazPGconn.get_copy_datar*r"filenocdSrr)r(rs r tracez PGconn.tracer*r"flagsr cdSrr)r(rs r set_trace_flagszPGconn.set_trace_flagsr*r"cdSrrr's r untracezPGconn.untracer*r"passwdr= algorithmcdSrr)r(rr=rs r encrypt_passwordzPGconn.encrypt_passwordsr"cdSrr)r(r=rs r change_passwordzPGconn.change_passwordr*r" exec_statuscdSrr)r(rs r make_empty_resultzPGconn.make_empty_resultr*r"cdSrrr's r pipeline_statuszPGconn.pipeline_statusrXr"cdSrrr's r enter_pipeline_modezPGconn.enter_pipeline_moder*r"cdSrrr's r exit_pipeline_modezPGconn.exit_pipeline_moder*r"cdSrrr's r pipeline_synczPGconn.pipeline_syncr*r"cdSrrr's r send_flush_requestzPGconn.send_flush_requestr*r")rrrrrr%rr+rr.)rrrr%rr)rQrrrR.rYrZrrZ)rrZ)rrl)rurrrv)rurrr+) rurr|r}r~rrrrr%rrv) rurr|r}r~rrrrr%rr+r)rQrrurr~rrr+) rQrr|r}rrrr%rr+)rQrrurr~rrrv)Nr) rQrr|rrrrr%rrv)rQrrrv)rQrrr+)rr)rr%rr+)rr%rr+)rr)rr)rr)rrrr%)rrRrr%)rr%rr)rr%rr+)rr rr+)rrr=rrrRrr)r=rrrrr+)rr%rrv)Q__name__ __module__ __qualname____annotations__ classmethodr!r$r)r-propertyr0r3r5r7r9r;r=r@rCrErGrIrKrNrPrUrWr]r_rarcrerhrjrnrprrrtryr{r TEXTrrrrrrrrrrrrrrrrrrsetterrrrrrrrrrrrrrrrrrrrrrr"r rrsU55555555222[2888[8&&&&!!!! ///X/    &&&&$$$$///[/ X    X  $$$X$    X  $$$X$    X  X ###X#    X  ,,,X,@@@@ )))X)@@@@@ ###X# ***X* ///X/ (((X(    X  %%%X% )))X) (((X( &&&X& %%%X%44445555 -1.2#[ -1.2#[ -1 /3#[ -1 /3 >===>>>>;;;;<<<<::::;;;;888899990000((((!!!! %%%X%0000....;;;;....))))....7777BBBBBGGGG----8888""""EIGFFFBBBB )))X)....----((((------r"rcPeZdZd'dZed(dZed)dZd*d+d Zd,dZed(dZ ed(dZ d-dZ d.dZ d.dZ d.dZd.dZd.dZd.dZed(dZd/dZed(dZd0dZed1dZed2d!Zed(d"Zd3d%Zd&S)4rvrr+cdSrrr's r clearzPGresult.clearr*r"r%cdSrrr's r rNzPGresult.statusr>r"rcdSrrr's r rWzPGresult.error_messagerXr".rYrZcdSrrr\s r r]zPGresult.get_error_messager*r" fieldcoderRcdSrr)r(rs r error_fieldzPGresult.error_fieldr*r"cdSrrr's r ntupleszPGresult.ntuples!cr"cdSrrr's r nfieldszPGresult.nfieldsrr" column_numbercdSrrr(rs r fnamezPGresult.fnamer*r"cdSrrrs r ftablezPGresult.ftabler*r"cdSrrrs r ftablecolzPGresult.ftablecolr*r"cdSrrrs r fformatzPGresult.fformatr*r"cdSrrrs r ftypezPGresult.ftype r*r"cdSrrrs r fmodz PGresult.fmod r*r"cdSrrrs r fsizezPGresult.fsizer*r"cdSrrr's r binary_tupleszPGresult.binary_tupless$'Cr" row_numbercdSrr)r(rrs r get_valuezPGresult.get_valuer*r"cdSrrr's r nparamszPGresult.nparamsrr" param_numbercdSrr)r(rs r param_typezPGresult.param_typer*r"cdSrrr's r command_statuszPGresult.command_statuss.1cr" int | NonecdSrrr's r command_tupleszPGresult.command_tuplesr1r"cdSrrr's r oid_valuezPGresult.oid_value rLr" descriptionslist[PGresAttDesc]cdSrr)r(rs r set_attributeszPGresult.set_attributes#r*r"Nrrrrr)rr%rrR)rr%rrR)rr%rr%)rr%rr%rrR)rr%rr%)rrR)rr)rr rr+)rrrrrrNrWr]rrrrrrrr r r rrrrrrrr"rr"r rvrvsu        X  )))X)@@@@@>>>> !!!X! !!!X!<<<<444477775555333322223333 '''X'QQQQ !!!X!7777 111X1 ///X/ ###X#KKKKKKr"rvceZdZddZddZddZeddZeddZedd Z dddZ ddZ ddZ dS)rrr+cdSrrr's r startzPGcancelConn.start'r*r"cdSrrr's r blockingzPGcancelConn.blocking)r*r"r%cdSrrr's r pollzPGcancelConn.poll+r*r"cdSrrr's r rNzPGcancelConn.status-r>r"cdSrrr's r rhzPGcancelConn.socket0r>r"rcdSrrr's r rWzPGcancelConn.error_message3rXr".rYrZcdSrrr\s r r]zPGcancelConn.get_error_message6r*r"cdSrrr's r r3zPGcancelConn.reset8r*r"cdSrrr's r r-zPGcancelConn.finish:r*r"Nrrrrr) rrrr%r'r)rrNrhrWr]r3r-rr"r rr&s    ####    X     X  )))X)@@@@@    !!!!!!r"rceZdZddZddZdS)rrr+cdSrrr's r freez PGcancel.free>r*r"cdSrrr's r cancelzPGcancel.cancel@r*r"Nr)rrrr2r4rr"r rr=s(!!!!!!r"rcVeZdZed dZed dZed d Zd S)Conninforr.cdSrr)rs r get_defaultszConninfo.get_defaultsDs363r"rrcdSrrrs r parsezConninfo.parseGs=@Sr"opts Sequence[Any]cdSrr)rr;s r _options_from_arrayzConninfo._options_from_arrayJsORsr"Nr)rrrr.)r;r<rr.)rrrrr8r:r>rr"r r6r6CsR666[6@@@[@RRR[RRRr"r6c@eZdZdddZdd Zdd Zdd Zdd Zdd ZdS)EscapingNconn PGconn | NonecdSrr)r(rAs r __init__zEscaping.__init__Or*r"datarrrcdSrrr(rEs r escape_literalzEscaping.escape_literalQr*r"cdSrrrGs r escape_identifierzEscaping.escape_identifierSr*r"cdSrrrGs r escape_stringzEscaping.escape_stringUr*r"cdSrrrGs r escape_byteazEscaping.escape_byteaWr*r"cdSrrrGs r unescape_byteazEscaping.unescape_byteaYr*r"r)rArB)rErrr) rrrrDrHrJrLrNrPrr"r r@r@Ns[777778888;;;;77776666888888r"r@N) __doc__ __future__rtypingrrrrrcollections.abcr r _enumsr r _compatrmiscrrrr bytearray memoryviewrrrrvrrr6r@rr"r rZs #"""""AAAAAAAAAAAAAA........!!!!!!!!=<<<<<<<<<<%J677777V.V.V.V.V.XV.V.V.r4L4L4L4L4Lx4L4L4Ln"""""8"""."""""x""" SSSSSxSSS 9 9 9 9 9x 9 9 9 9 9r"