joUdZddlmZddlmZddlmZmZmZmZm Z ddl m Z m Z ddl mZmZer dd lmZmZmZeeeefZd ed <Gd d eZGddeZGddeZGddeZGddeZGddeZy)zP Protocol objects to represent objects exposed by different pq implementations. ) annotations)Union) TYPE_CHECKINGAnyCallableProtocolSequence)FormatTrace)Self TypeAlias)ConninfoOptionPGnotify PGresAttDescrBuffercfeZdZUded<ded<edNdZedNdZdOdZdPdZe dQd Z dPd Z dPd Z dOd Z edRd Ze dSdZe dSdZe dSdZe dSdZe dSdZe dSdZe dSdZe dSdZe dOdZe dOdZdTdZe dSdZdUdVdZe dWdZe dOdZe dOdZe dOdZe dOdZ e dXd Z!e dXd!Z"e dXd"Z#e dXd#Z$dYd$Z%dZd%Z&d&d&e'jPf d[d'Z)d&d&e'jPf d\d(Z* d] d^d)Z+d&e'jPf d_d*Z, d] d`d+Z- da dbd,Z.dcd-Z/ddd.Z0dcd/Z1ddd0Z2dcd1Z3ddd2Z4dcd3Z5ddd4Z6ded5Z7dPd6Z8dOd7Z9e dOd8Z:e:jvdfd9Z:dOd:Zdhd=Z?did>Z@djd?ZAdkd@ZBd]dldAZCdmdBZDdndCZEdodDZFdPdEZG d] dpdFZHdqdGZIdrdHZJe dOdIZKdPdJZLdPdKZMdPdLZNdPdMZOy&)sPGconnz!Callable[[PGresult], None] | Nonenotice_handlerz!Callable[[PGnotify], None] | Nonenotify_handlercyNclsconninfos U/var/www/html/kelly/kelly-backend/venv/lib/python3.12/site-packages/psycopg/pq/abc.pyconnectzPGconn.connects/2cyrrrs r connect_startzPGconn.connect_starts58r cyrrselfs r connect_pollzPGconn.connect_poll 3r cyrrr$s rfinishz PGconn.finish"cr cyrrr$s rinfoz PGconn.info$,/r cyrrr$s rresetz PGconn.reset'Sr cyrrr$s r reset_startzPGconn.reset_start)r'r cyrrr$s r reset_pollzPGconn.reset_poll+sr cyrr)r%rs rpingz PGconn.ping-r-r cyrrr$s rdbz PGconn.db0sr cyrrr$s ruserz PGconn.user3 r cyrrr$s rpasswordzPGconn.password6!$r cyrrr$s rhostz PGconn.host9r;r cyrrr$s rhostaddrzPGconn.hostaddr<r>r cyrrr$s rportz PGconn.port?r;r cyrrr$s rttyz PGconn.ttyBsr cyrrr$s roptionszPGconn.optionsE #r cyrrr$s rstatusz PGconn.statusHr;r cyrrr$s rtransaction_statuszPGconn.transaction_statusKs),r cyrrr%names rparameter_statuszPGconn.parameter_statusNSr cyrrr$s r error_messagezPGconn.error_messageP&)r cyrrr%encodings rget_error_messagezPGconn.get_error_messageSrRr cyrrr$s r _encodingzPGconn._encodingUrIr cyrrr$s rprotocol_versionzPGconn.protocol_versionXs'*r cyrrr$s rserver_versionzPGconn.server_version[%(r cyrrr$s rsocketz PGconn.socket^r;r cyrrr$s r backend_pidzPGconn.backend_pida"%r cyrrr$s rneeds_passwordzPGconn.needs_passworddrUr cyrrr$s r used_passwordzPGconn.used_passwordgr`r cyrrr$s r used_gssapizPGconn.used_gssapijs#&r cyrrr$s r ssl_in_usezPGconn.ssl_in_usemrer cyrrr%commands rexec_z PGconn.exec_pr cyrrros r send_queryzPGconn.send_queryr#r Ncyrrr%rp param_values param_types param_formats result_formats r exec_paramszPGconn.exec_paramstsr cyrrrws rsend_query_paramszPGconn.send_query_params}sr cyrrr%rPrprys r send_preparezPGconn.send_prepares r cyrrr%rPrxrzr{s rsend_query_preparedzPGconn.send_query_prepareds r cyrrrs rpreparezPGconn.prepares r cyrrrs r exec_preparedzPGconn.exec_prepareds r cyrrrOs rdescribe_preparedzPGconn.describe_prepareds#r cyrrrOs rsend_describe_preparedzPGconn.send_describe_prepared3r cyrrrOs rdescribe_portalzPGconn.describe_portalr cyrrrOs rsend_describe_portalzPGconn.send_describe_portalr cyrrrOs rclose_preparedzPGconn.close_preparedssr cyrrrOs rsend_close_preparedzPGconn.send_close_preparedrr cyrrrOs r close_portalzPGconn.close_portalSr cyrrrOs rsend_close_portalzPGconn.send_close_portalscr cyrrr$s r get_resultzPGconn.get_resultsSr cyrrr$s r consume_inputzPGconn.consume_inputSr cyrrr$s ris_busyzPGconn.is_busyr*r cyrrr$s r nonblockingzPGconn.nonblockingrer cyrr)r%args rrzPGconn.nonblockings-0r cyrrr$s rflushz PGconn.flushCr cyrrr$s rset_single_row_modezPGconn.set_single_row_mode3r cyrr)r%sizes rset_chunked_rows_modezPGconn.set_chunked_rows_moderr cyrrr$s r cancel_connzPGconn.cancel_connrr cyrrr$s r get_cancelzPGconn.get_cancelscr cyrrr$s rnotifieszPGconn.notifiesrr cyrr)r%buffers r put_copy_datazPGconn.put_copy_dataCr cyrr)r%errors r put_copy_endzPGconn.put_copy_endsr cyrr)r%async_s r get_copy_datazPGconn.get_copy_datasCr cyrr)r%filenos rtracez PGconn.trace#r cyrr)r%flagss rset_trace_flagszPGconn.set_trace_flagsrr cyrrr$s runtracezPGconn.untracessr cyrr)r%passwdr: algorithms rencrypt_passwordzPGconn.encrypt_passwordsr cyrr)r%r:rs rchange_passwordzPGconn.change_passwords3r cyrr)r% exec_statuss rmake_empty_resultzPGconn.make_empty_resultrr cyrrr$s rpipeline_statuszPGconn.pipeline_statusrUr cyrrr$s renter_pipeline_modezPGconn.enter_pipeline_moderr cyrrr$s rexit_pipeline_modezPGconn.exit_pipeline_moderr cyrrr$s r pipeline_synczPGconn.pipeline_syncrr cyrrr$s rsend_flush_requestzPGconn.send_flush_requestrr )rbytesreturnrrintrNonerlist[ConninfoOption])rrrrrr)rPrr bytes | None.rXstrrr)rr)rbool)rprrPGresult)rprrr) rprrxSequence[Buffer | None] | NonerySequence[int] | Nonerzrr{rrr) rprrxrryrrzrr{rrrr)rPrrprryrrr) rPrrxrrzrr{rrr)rPrrprryrrr)Nr) rPrrxzSequence[Buffer] | Nonerzrr{rrr)rPrrr)rPrrr)rzPGresult | None)rrrr)rrrr)r PGcancelConn)rPGcancel)rzPGnotify | None)rrrr)rrrr)rrrztuple[int, memoryview])rrrr)rr rr)rrr:rrrrr)r:rrrrr)rrrr)P__name__ __module__ __qualname____annotations__ classmethodrr"r&r)propertyr,r/r2r4r6r8r:r=r@rBrDrFrHrKrMrQrTrYr[r]r_rbrdrgrirkrmrqrtr TEXTr|r~rrrrrrrrrrrrrrrrsetterrrrrrrrrrrrrrrrrrrrrrr rrrs55552288&! // &$//     $$    $$     ##    ,,@ ))@ ## ** ((    %% )) (( && %%45 -1.2#[[ 5*  ,    -1.2#[[ 5*  ,    -1 *   /3#[[ 5,     -1 *   /3 .,     >>;<:;890(! %%00.;.).7BG-8"EI#(5A GB )).-(-r rceZdZddZeddZeddZdddZddZeddZ eddZ ddZ dd Z dd Z dd Zdd Zdd ZddZeddZd dZeddZd!dZed"dZed#dZeddZd$dZy)%rcyrrr$s rclearzPGresult.clearr0r cyrrr$s rrKzPGresult.statusr;r cyrrr$s rrTzPGresult.error_messagerUr cyrrrWs rrYzPGresult.get_error_messagerRr cyrr)r% fieldcodes r error_fieldzPGresult.error_fieldrr cyrrr$s rntupleszPGresult.ntuples!r cyrrr$s rnfieldszPGresult.nfieldsrr cyrrr% column_numbers rfnamezPGresult.fnamerr cyrrrs rftablezPGresult.ftablerrr cyrrrs r ftablecolzPGresult.ftablecolrr cyrrrs rfformatzPGresult.fformatrur cyrrrs rftypezPGresult.ftyper cyrrrs rfmodz PGresult.fmod ssr cyrrrs rfsizezPGresult.fsize rr cyrrr$s r binary_tupleszPGresult.binary_tuples s$'r cyrr)r% row_numberr s r get_valuezPGresult.get_valuescr cyrrr$s rnparamszPGresult.nparamsrr cyrr)r% param_numbers r param_typezPGresult.param_typerr cyrrr$s rcommand_statuszPGresult.command_statuss.1r cyrrr$s rcommand_tupleszPGresult.command_tuplesr-r cyrrr$s r oid_valuezPGresult.oid_valuerIr cyrr)r% descriptionss rset_attributeszPGresult.set_attributes sr Nrrrrr)rrrr)r rrr)r rrr)rrr rrr)r rrr)rr)rz int | None)r)zlist[PGresAttDesc]rr)rrrrrrKrTrYrrrr r rrrrrrrrr!r#r%r'r*rr rrrs     ))@> !! !!<475323 ''Q !!7 11 // ##Kr rcteZdZd dZd dZd dZed dZed dZed dZ dddZ d dZ d d Z y )rcyrrr$s rstartzPGcancelConn.start$r0r cyrrr$s rblockingzPGcancelConn.blocking&sr cyrrr$s rpollzPGcancelConn.poll(s3r cyrrr$s rrKzPGcancelConn.status*r;r cyrrr$s rrbzPGcancelConn.socket-r;r cyrrr$s rrTzPGcancelConn.error_message0rUr cyrrrWs rrYzPGcancelConn.get_error_message3rRr cyrrr$s rr/zPGcancelConn.reset5r0r cyrrr$s rr)zPGcancelConn.finish7r*r Nrrrrr) rrrr-r/r1rrKrbrTrYr/r)rr rrr#s> #       ))@ !r rceZdZddZddZy)rcyrrr$s rfreez PGcancel.free;rr cyrrr$s rcancelzPGcancel.cancel=r*r Nr)rrrr:r<rr rrr:s!r rcBeZdZeddZeddZeddZy)Conninfocyrr)rs r get_defaultszConninfo.get_defaultsAs36r cyrrrs rparsezConninfo.parseDs=@r cyrr)roptss r_options_from_arrayzConninfo._options_from_arrayGsORr Nr)rrrr)rDz Sequence[Any]rr)rrrrr@rBrErr rr>r>@s,66@@RRr r>c>eZdZdd dZd dZd dZd dZd dZd dZy) EscapingNcyrr)r%conns r__init__zEscaping.__init__Lrr cyrrr%datas rescape_literalzEscaping.escape_literalNrr cyrrrLs rescape_identifierzEscaping.escape_identifierPrr cyrrrLs r escape_stringzEscaping.escape_stringRrr cyrrrLs r escape_byteazEscaping.escape_byteaTs3r cyrrrLs runescape_byteazEscaping.unescape_byteaVrr r)rIz PGconn | None)rMrrr) rrrrJrNrPrRrTrVrr rrGrGKs78;768r rGN)__doc__ __future__rtypingrrrrrr _enumsr r _compatrrmiscrrrr bytearray memoryviewrrrrrrr>rGrr rr_s #CC!%<<%J67 7S.XS.l4Lx4Ln"8"."x" SxS 9x 9r