o DDi@srUdZddlmZddlmZmZmZmZmZddl m Z m Z m Z m Z ddlmZddlmZddlmZmZmZercdd 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<edddZ.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(d(eZ:e ege)dBfZ;de%d)<e e)gefZGd/d0d0eZ?Gd1d2d2eZ@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 PQGenConnPQGenc@seZdZdZddd d Zd S)WaitFunczU Wait on the connection which generated `PQgen` and return its final result. .gen PQGen[RV]filenointintervalfloatreturnr'cCdSN)selfr+r-r/r4r4D/var/www/Datamplify/venv/lib/python3.10/site-packages/psycopg/abc.py__call__<zWaitFunc.__call__N).)r+r,r-r.r/r0r1r')__name__ __module__ __qualname____doc__r7r4r4r4r6r*7sr*DumpFuncLoadFuncc@s,eZdZdZed ddZed ddZd S) 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. r1rcCdS)z1The adapters configuration that this object uses.Nr4r5r4r4r6adaptersQszAdaptContext.adaptersBaseConnection[Any] | NonecCr@)zThe connection used by this object, if available. :rtype: `~psycopg.Connection` or `~psycopg.AsyncConnection` or `!None` Nr4rAr4r4r6 connectionVzAdaptContext.connectionNr1rr1rC)r9r:r;r<propertyrBrDr4r4r4r6r?Es  r?c@sZeZdZUdZded< ded< ddd d ZdddZdddZd ddZd!ddZ dS)"DumperzM Convert Python objects of type `!cls` to PostgreSQL representation. pq.Formatformatr.oidNclsrcontextAdaptContext | NonecCr2r3r4)r5rMrNr4r4r6__init__or8zDumper.__init__objrr1 Buffer | NonecCr@)zlConvert the object `!obj` to PostgreSQL representation. :param obj: the object to convert. Nr4r5rQr4r4r6dumpqz Dumper.dumprcCr@)ziConvert the object `!obj` to escaped representation. :param obj: the object to convert. Nr4rSr4r4r6quotexrUz Dumper.quoterr#cCr@)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()`. Nr4r5rQrKr4r4r6get_keys"zDumper.get_keycCr@)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. Nr4rWr4r4r6upgrades zDumper.upgrader3)rMrrNrO)rQrr1rR)rQrr1r)rQrrKrr1r#rQrrKrr1rI) r9r:r;r<__annotations__rPrTrVrXrYr4r4r4r6rI_s     $rIc@s2eZdZUdZded< ddd d ZdddZdS)LoaderzK Convert PostgreSQL values with type OID `!oid` to Python objects. rJrKNrLr.rNrOcCr2r3r4)r5rLrNr4r4r6rPr8zLoader.__init__datarr1rcCr@)z| Convert the data returned by the database into a Python object. :param data: the data to convert. Nr4)r5r]r4r4r6loadrEz Loader.loadr3)rLr.rNrO)r]rr1r)r9r:r;r<r[rPr^r4r4r4r6r\s  r\c@seZdZUded<ded<dLdMdd ZedNd d ZedOddZedPddZ edQddZ edRddZ ddddSd!d"Z dTd%d&Z dTd'd(ZdUd-d.ZdVd2d3ZdWd6d7ZdXd>d?ZdYdBdCZdZdFdGZd[dJdKZdS)\ Transformerztuple[int, ...] | Nonetypeszlist[pq.Format] | NoneformatsNrNrOcCr2r3r4)r5rNr4r4r6rPr8zTransformer.__init__r1cCr2r3r4)rMrNr4r4r6 from_contextzTransformer.from_contextrCcCr2r3r4rAr4r4r6rDrczTransformer.connectionstrcCr2r3r4rAr4r4r6encodingrczTransformer.encodingrcCr2r3r4rAr4r4r6rBrczTransformer.adaptersPGresult | NonecCr2r3r4rAr4r4r6pgresultrczTransformer.pgresultT) set_loadersrKresultrhboolrKpq.Format | NoneNonecCr2r3r4)r5rirhrKr4r4r6 set_pgresultrEzTransformer.set_pgresult Sequence[int]rJcCr2r3r4r5r`rKr4r4r6set_dumper_typesr8zTransformer.set_dumper_typescCr2r3r4ror4r4r6set_loader_typesr8zTransformer.set_loader_typesparams Sequence[Any]Sequence[PyFormat]Sequence[Buffer | None]cCr2r3r4)r5rrrar4r4r6 dump_sequenceszTransformer.dump_sequencerQrbytescCr2r3r4rSr4r4r6 as_literalr8zTransformer.as_literalrrIcCr2r3r4rWr4r4r6 get_dumperr8zTransformer.get_dumperrow0r.row1make_row RowMaker[Row] list[Row]cCr2r3r4)r5rzr{r|r4r4r6 load_rowsr8zTransformer.load_rowsrowrcCr2r3r4)r5rr|r4r4r6load_rowr8zTransformer.load_rowrecordtuple[Any, ...]cCr2r3r4)r5rr4r4r6 load_sequencer8zTransformer.load_sequencerLr\cCr2r3r4)r5rLrKr4r4r6 get_loaderr8zTransformer.get_loaderr3)rNrO)rNrOr1r_rG)r1rdrF)r1rf)rirfrhrjrKrkr1rl)r`rnrKrJr1rl)rrrsrartr1ru)rQrr1rwrZ)rzr.r{r.r|r}r1r~)rr.r|r}r1r)rrur1r)rLr.rKrJr1r\)r9r:r;r[rP classmethodrbrHrDrerBrgrmrprqrvrxryrrrrr4r4r4r6r_s4               r_)Ar< __future__rtypingrrrrrcollections.abcrr r r r _enumsr_compatrrrrrowsrrpq.abcrwaitingrr _adapters_mapr_connection_baserrrr[rw bytearray memoryviewrrrrdrr r"tupler#r.r$dictr%r&r'r(r)r*r=r>r?rIr\r_r4r4r4r6sJ          S