jUdZddlmZddlmZmZmZmZmZddl m Z m Z m Z m Z ddlmZddlmZddlmZmZmZer(dd lmZdd lmZmZdd lmZdd lmZmZdd lm Z ddl!m"Z"e#dZ$de%d<ee&e'e(fZ)de%d<eee&ddfZ*de%d<ee*efZ+de%d<ee ee e,effZ-de%d<eddZ.e gdfZ/de%d<ee#e0dfZ1de%d<ee,e2dfZ3de%d<e4e,e3fZ5de%d <e e,e3fZ6de%d!<ed"Z7e e0e2d#fd$e7fZ8de%d%< e d#d$e7fZ9de%d&< Gd'd(eZ:e ege)dzfZ;de%d)<e e)gefZGd/d0eZ?Gd1d2eZ@dS)3zN Protocol objects representing different implementations of the same classes. ) annotations) TYPE_CHECKINGAnyProtocol TypeAliasUnion)Callable GeneratorMappingSequence)pq)PyFormat) LiteralStringTemplateTypeVar)sql)RowRowMaker)PGresult)ReadyWait) AdaptersMap)BaseConnectionNtypeNoneTyperBufferzsql.SQLz sql.ComposedQueryNoTemplateQueryParamsConnectionTypezBaseConnection[Any])boundPipelineCommand) DumperKey.r$ ConnParamConnDict ConnMappingRVrz Ready | int PQGenConnPQGenceZdZdZd dd Zd S)WaitFunczU Wait on the connection which generated `PQgen` and return its final result. .gen PQGen[RV]filenointintervalfloatreturnr(cdSN)selfr-r/r1s V/DATA/AppData/hermes/projects/honcho/.venv/lib/python3.11/site-packages/psycopg/abc.py__call__zWaitFunc.__call__<N).)r-r.r/r0r1r2r3r()__name__ __module__ __qualname____doc__r9r6r;r8r,r,7s,VUUUUUUr;r,DumpFuncLoadFunccBeZdZdZeddZed dZdS) AdaptContextaO A context describing how types are adapted. Example of `!AdaptContext` are `~psycopg.Connection`, `~psycopg.Cursor`, `~psycopg.adapt.Transformer`, `~psycopg.adapt.AdaptersMap`. Note that this is a `~typing.Protocol`, so objects implementing `!AdaptContext` don't need to explicitly inherit from this class. r3rcdS)z1The adapters configuration that this object uses.Nr6r7s r8adapterszAdaptContext.adaptersQs  r;BaseConnection[Any] | NonecdS)zThe connection used by this object, if available. :rtype: `~psycopg.Connection` or `~psycopg.AsyncConnection` or `!None` Nr6rEs r8 connectionzAdaptContext.connectionV r;Nr3rr3rG)r<r=r>r?propertyrFrIr6r;r8rCrCEs^     X    X   r;rCcVeZdZUdZded< ded< ddd ZddZddZddZddZ dS)DumperzM Convert Python objects of type `!cls` to PostgreSQL representation. pq.Formatformatr0oidNclsrcontextAdaptContext | NonecdSr5r6)r7rSrTs r8__init__zDumper.__init__or:r;objrr3 Buffer | NonecdS)zlConvert the object `!obj` to PostgreSQL representation. :param obj: the object to convert. Nr6r7rXs r8dumpz Dumper.dumpq r;rcdS)ziConvert the object `!obj` to escaped representation. :param obj: the object to convert. Nr6r[s r8quotez Dumper.quotexr]r;rr$cdS)aReturn an alternative key to upgrade the dumper to represent `!obj`. :param obj: The object to convert :param format: The format to convert to Normally the type of the object is all it takes to define how to dump the object to the database. For instance, a Python `~datetime.date` can be simply converted into a PostgreSQL :sql:`date`. In a few cases, just the type is not enough. For example: - A Python `~datetime.datetime` could be represented as a :sql:`timestamptz` or a :sql:`timestamp`, according to whether it specifies a `!tzinfo` or not. - A Python int could be stored as several Postgres types: int2, int4, int8, numeric. If a type too small is used, it may result in an overflow. If a type too large is used, PostgreSQL may not want to cast it to a smaller type. - Python lists should be dumped according to the type they contain to convert them to e.g. array of strings, array of ints (and which size of int?...) In these cases, a dumper can implement `!get_key()` and return a new class, or sequence of classes, that can be used to identify the same dumper again. If the mechanism is not needed, the method should return the same `!cls` object passed in the constructor. If a dumper implements `get_key()` it should also implement `upgrade()`. Nr6r7rXrQs r8get_keyzDumper.get_keys D r;cdS)aReturn a new dumper to manage `!obj`. :param obj: The object to convert :param format: The format to convert to Once `Transformer.get_dumper()` has been notified by `get_key()` that this Dumper class cannot handle `!obj` itself, it will invoke `!upgrade()`, which should return a new `Dumper` instance, which will be reused for every objects for which `!get_key()` returns the same result. Nr6ras r8upgradezDumper.upgrades  r;r5)rSrrTrU)rXrr3rY)rXrr3r)rXrrQrr3r$rXrrQrr3rO) r<r=r>r?__annotations__rWr\r_rbrdr6r;r8rOrO_s HHHQKKKKK        " " " " H       r;rOc2eZdZUdZded< ddd ZddZdS)LoaderzK Convert PostgreSQL values with type OID `!oid` to Python objects. rPrQNrRr0rTrUcdSr5r6)r7rRrTs r8rWzLoader.__init__r:r;datarr3rcdS)z| Convert the data returned by the database into a Python object. :param data: the data to convert. Nr6)r7rjs r8loadz Loader.loadrJr;r5)rRr0rTrU)rjrr3r)r<r=r>r?rfrWrlr6r;r8rhrhsYKJJJJ      r;rhceZdZUded<ded<dd Zed?d Zed@dZ edAdZ edBdZ ddddCdZ dDdZ dDdZdEd$ZdFd(ZdGd+ZdHd2ZdId5ZdJd8ZdKd;ZdS)L Transformerztuple[int, ...] | Nonetypeszlist[pq.Format] | NoneformatsNrTrUcdSr5r6)r7rTs r8rWzTransformer.__init__r:r;r3cdSr5r6)rSrTs r8 from_contextzTransformer.from_contextsHKr;rGcdSr5r6rEs r8rIzTransformer.connections8;r;strcdSr5r6rEs r8encodingzTransformer.encodings"sr;rcdSr5r6rEs r8rFzTransformer.adapterss'*sr;PGresult | NonecdSr5r6rEs r8pgresultzTransformer.pgresults+.3r;T) set_loadersrQresultr|boolrQpq.Format | NoneNonecdSr5r6)r7r}r|rQs r8 set_pgresultzTransformer.set_pgresults sr; Sequence[int]rPcdSr5r6r7rorQs r8set_dumper_typeszTransformer.set_dumper_typesr:r;cdSr5r6rs r8set_loader_typeszTransformer.set_loader_typesr:r;params Sequence[Any]Sequence[PyFormat]Sequence[Buffer | None]cdSr5r6)r7rrps r8 dump_sequencezTransformer.dump_sequences"%#r;rXrbytescdSr5r6r[s r8 as_literalzTransformer.as_literalr:r;rrOcdSr5r6ras r8 get_dumperzTransformer.get_dumperr:r;row0r0row1make_row RowMaker[Row] list[Row]cdSr5r6)r7rrrs r8 load_rowszTransformer.load_rowsr:r;rowrcdSr5r6)r7rrs r8load_rowzTransformer.load_rowr:r;recordtuple[Any, ...]cdSr5r6)r7rs r8 load_sequencezTransformer.load_sequencer:r;rRrhcdSr5r6)r7rRrQs r8 get_loaderzTransformer.get_loaderr:r;r5)rTrU)rTrUr3rnrL)r3rurK)r3ry)r}ryr|r~rQrr3r)rorrQrPr3r)rrrprr3r)rXrr3rre)rr0rr0rrr3r)rr0rrr3r)rrr3r)rRr0rQrPr3rh)r<r=r>rfrW classmethodrsrMrIrwrFr{rrrrrrrrrrr6r;r8rnrnsF!!!!####@@@@@KKK[K ;;;X; """X" ***X* ...X. !#' UTTTTTTT&&&&1000CCCCXXXXEEEETTTTDDDDDDr;rn)Ar? __future__rtypingrrrrrcollections.abcr r r r r_enumsr_compatrrrrrowsrrpq.abcrwaitingrr _adapters_mapr_connection_baserrrrfr bytearray memoryviewrrrrur r!r#tupler$r0r%dictr&r'r(r)r*r,r@rArCrOrhrnr6r;r8rs #"""""AAAAAAAAAAAAAABBBBBBBBBBBB((((((55555555551########      $$$$$$$$******000000d%J677777"=%N#RSSSSS(233333(3-c)::;;;;;)1FGGG%b$h/////T5)9#::; ;;;;S#t^, ,,,,3 >***** i0 0000  WT]] sF{!3]B!FG GGGG V]B677777VVVVVxVVVuftm344444x}-----     8   4P P P P P XP P P f     X   0/E/E/E/E/E(/E/E/E/E/Er;