9hSrSSKrSSKrSSKrSSKJrJ r SSK r SSK r SSK J r SSK Jr SSK Jr SSK JrJr SS KJr SS KJrJrJrJrJr SS K J!r!J"r"J#r#J$r$J%r% SS K&J'r'J(r(J)r)J*r*J+r+J,r,J-r-J.r. SS K/J0r0 "SS\5r1"SS\5r2"SS\15r3"SS\45r5"SS\5r6"SS\15r7"SS\ 5r8"SS\5r9"SS\5r:\"S 5S!5r;\<"\;5\:l;"S"S#\5r="S$S%\5r>"S&S'\=5r?"S(S)\>5r@"S*S+\5rA"S,S-\5rB"S.S/\C5rD"S0S1\5r"S2S35rESGS4jrF"S5S65rGSGS7jrHS8rIS9rJ"S:S;5rKSHS<jrL"S=S>5rMSIS?jrNS@rOSJSAjrPSKSBjrQSCrR\R"SD\R"SE5-SF-5rUg)LzMiscellaneous goodies for psycopg2 This module is a generic place used to hold little helper functions and classes until a better place in the distribution is found. N) namedtuple OrderedDict) extensions)cursor) connection)adapt quote_ident) lru_cache)REPLICATION_PHYSICALREPLICATION_LOGICALReplicationConnectionReplicationCursorReplicationMessage)jsonJson register_jsonregister_default_jsonregister_default_jsonb)Range NumericRange DateRange DateTimeRangeDateTimeTZRangeregister_range RangeAdapter RangeCaster)register_ipaddressc`^\rSrSrSrU4SjrU4SjrS U4SjjrU4SjrU4Sjr Sr U=r $) DictCursorBaseAz%Base class for all dict-like cursors.c>SU;a USnUS O [S5e[TU]"U0UD6 SUlSUlX0lg)N row_factoryz;DictCursorBase can't be instantiated without a row factory.F)NotImplementedErrorsuper__init___query_executed _prefetchr#)selfargskwargsr# __class__s A/var/www/html/env/lib/python3.13/site-packages/psycopg2/extras.pyr&DictCursorBase.__init__DsV F " /K}%%MO O $)&)$&c>UR(a[TU] 5nUR(aUR 5 UR(d[TU] 5nW$N)r(r%fetchoner' _build_indexr)resr,s r-r2DictCursorBase.fetchonePE >>'"$C       ~~'"$C r/c>UR(a[TU] U5nUR(aUR 5 UR(d[TU] U5nW$r1)r(r% fetchmanyr'r3)r)sizer5r,s r-r9DictCursorBase.fetchmanyYsI >>'#D)C       ~~'#D)C r/c>UR(a[TU] 5nUR(aUR 5 UR(d[TU] 5nW$r1)r(r%fetchallr'r3r4s r-r=DictCursorBase.fetchallbr7r/c#@># UR(a[TU] 5n[U5nUR(aUR 5 UR(d[TU] 5n[U5nWv [W5v M![ a gf=f7fr1)r(r%__iter__nextr'r3 StopIteration)r)r5firstr,s r-r@DictCursorBase.__iter__ks ~~g&(S ##!!#>>g&(S K3i   s#BB B BBBB)r(r'r#r1) __name__ __module__ __qualname____firstlineno____doc__r&r2r9r=r@__static_attributes__ __classcell__r,s@r-r r As$/ 'r/r c,^\rSrSrSrU4SjrSrU=r$)DictConnection}z2A connection that uses `DictCursor` automatically.cv>URSUR=(d [5 [TU]"U0UD6$Ncursor_factory) setdefaultrR DictCursorr%rr)r*r+r,s r-rDictConnection.cursors3*D,?,?,M:Nw~t.v..r/rErFrGrHrIrrJrKrLs@r-rNrN}s<//r/rNcR^\rSrSrSrU4SjrSU4SjjrSU4SjjrSrSr U=r $) rTzzA cursor that keeps a list of column name -> index mappings__. .. __: https://docs.python.org/glossary.html#term-mapping cF>[US'[TU]"U0UD6 SUlg)Nr#T)DictRowr%r&r(rUs r-r&DictCursor.__init__s& '} $)&)r/cN>[5UlSUl[TU]X5$NT)rindexr'r%executer)queryvarsr,s r-raDictCursor.executes# ] #wu++r/cN>[5UlSUl[TU]X5$r_)rr`r'r%callprocr)procnamerdr,s r-rgDictCursor.callprocs$ ] #w//r/cUR(a]UR(aK[[UR55H!nXRURUS'M# SUlgggNrF)r' descriptionrangelenr`)r)is r-r3DictCursor._build_indexsY   D$4$43t//0156 4++A.q122#(D %5 r/)r(r'r`r1 rErFrGrHrIr&rargr3rJrKrLs@r-rTrTs!  , 0 ))r/rTc^\rSrSrSrSrSrU4SjrU4SjrU4Sjr Sr U4S jr SS jr S r S rU4S jrSrSrSrU=r$)r\z6A row object that allow by-column-name access to data._indexc^URUlS/[UR5-USS&gr1)r`rvrorm)r)rs r-r&DictRow.__init__s(ll &3v1122Qr/cv>[U[[45(dURUn[TU]U5$r1) isinstanceintslicervr% __getitem__)r)xr,s r-r}DictRow.__getitem__s1!c5\** AAw"1%%r/cx>[U[[45(dURUn[TU]X5 gr1)rzr{r|rvr% __setitem__)r)r~vr,s r-rDictRow.__setitem__s.!c5\** AA A!r/cJ>^^[TT]mUU4SjTR5$)Nc3P># UHoT"TRU54v M g7fr1ru.0ngr)s r- DictRow.items..s!< 1Adkk!n%& s#&r%r}rvr)rr,s`@r-items DictRow.itemss G < <^^[TT]mUU4SjTR5$)Nc3N># UHnT"TRU5v M g7fr1rurs r-r!DictRow.values..s!7;a$++a.!!;s"%rrs`@r-valuesDictRow.valuess G 74;;77r/c0X$![a Us$f=fr1) Exception)r)r~defaults r-get DictRow.gets" 7N N s  c4[UR55$r1)rrrs r-copy DictRow.copys4::<((r/cXR;$r1ru)r)r~s r- __contains__DictRow.__contains__sKKr/c >[TU]5$r1)r% __reduce__)r)r,s r-rDictRow.__reduce__sw!##r/c@USSURR54$r1)rvrrs r- __getstate__DictRow.__getstate__sAw ((***r/c(USUSS&USUlgNrrru)r)datas r- __setstate__DictRow.__setstate__sq'Q1g r/r1)rErFrGrHrI __slots__r&r}rrrrrrrrrrrJrKrLs@r-r\r\sL@I3& " =!8 ) $+r/r\c,^\rSrSrSrU4SjrSrU=r$)RealDictConnectionz6A connection that uses `RealDictCursor` automatically.cv>URSUR=(d [5 [TU]"U0UD6$rQ)rSrRRealDictCursorr%rrUs r-rRealDictConnection.cursors3*D,?,?,Q>Rw~t.v..r/rWrXrLs@r-rrs@//r/rcR^\rSrSrSrU4SjrSU4SjjrSU4SjjrSrSr U=r $) ra=A cursor that uses a real dict as the base type for rows. Note that this cursor is extremely specialized and does not allow the normal access (using integer indices) to fetched data. If you need to access database rows both as a dictionary and a list, then use the generic `DictCursor` instead of `!RealDictCursor`. c8>[US'[TU]"U0UD6 g)Nr#) RealDictRowr%r&rUs r-r&RealDictCursor.__init__s +} $)&)r/c>>/UlSUl[TU] X5$r_)column_mappingr'r%rarbs r-raRealDictCursor.executes" #wu++r/c>>/UlSUl[TU] X5$r_)rr'r%rgrhs r-rgRealDictCursor.callprocs# #w//r/cUR(a>UR(a,URVs/sHoSPM snUlSUlgggs snfrl)r'rmr)r)ds r-r3RealDictCursor._build_indexsG   D$4$4151A1A"B1AAQ41A"BD #(D %5 "BsA)r'rr1rrrLs@r-rrs!*, 0 ))r/rc8^\rSrSrSrU4SjrU4SjrSrU=r$)rz.A `!dict` subclass representing a data record.c>U(a#[US[5(a USnUSSnOSn[TU] "U0UD6 UbFUR(a!UR (dUR 5 UR U['ggr)rz_cursorr%r&rmrr3r)r)r*r+rr,s r-r&RealDictRow.__init__s{ JtAw00!WF8DF $)&)  !!&*?*?##% !' 5 5D  r/c>[U;a5U[n[TU] X1U5 U[U5S- :XaU[ g[TU] X5 g)Nr)rr%rro)r)keyvaluemappingr,s r-rRealDictRow.__setitem__sO $ ;'G G  e 4c'lQ&&%  C'r/rW) rErFrGrHrIr&rrJrKrLs@r-rrs86& ( (r/rc,^\rSrSrSrU4SjrSrU=r$)NamedTupleConnectioniz8A connection that uses `NamedTupleCursor` automatically.cv>URSUR=(d [5 [TU]"U0UD6$rQ)rSrRNamedTupleCursorr%rrUs r-rNamedTupleConnection.cursors4*D,?,?,SCSTw~t.v..r/rWrXrLs@r-rrsB//r/rc^\rSrSrSrSrSrSU4SjjrU4SjrSU4Sjjr U4Sjr SU4S jjr U4S jr U4S jr S r\S 5rSrU=r$)ri#aA cursor that generates results as `~collections.namedtuple`. `!fetch*()` methods will return named tuples instead of regular tuples, so their elements can be accessed both as regular numeric items as well as attributes. >>> nt_cur = conn.cursor(cursor_factory=psycopg2.extras.NamedTupleCursor) >>> rec = nt_cur.fetchone() >>> rec Record(id=1, num=100, data="abc'def") >>> rec[1] 100 >>> rec.data "abc'def" Nic0>SUl[TU] X5$r1)Recordr%rarbs r-raNamedTupleCursor.execute6s wu++r/c0>SUl[TU] X5$r1)rr% executemanyrbs r-rNamedTupleCursor.executemany:s w"5//r/c0>SUl[TU] X5$r1)rr%rgrhs r-rgNamedTupleCursor.callproc>s w//r/c>[TU]5nUb6URnUcUR5=o lUR U5$gr1)r%r2r_make_nt_make)r)tntr,s r-r2NamedTupleCursor.fetchoneBsF G   =Bz#'==?2[88A;  r/c>[TU]U5nURnUcUR5=o0l[ [ UR U55$r1)r%r9rrlistmapr)r)r:tsrr,s r-r9NamedTupleCursor.fetchmanyJsF W t $ [[ :#}} .BC"%&&r/c>[TU]5nURnUcUR5=o l[ [ UR U55$r1)r%r=rrrrr)r)rrr,s r-r=NamedTupleCursor.fetchallQsD W   [[ :#}} .BC"%&&r/c#># [TU]5n[U5nURnUcUR 5=o0lUR U5v UR [U55v M![ a gf=f7fr1)r%r@rArrrrB)r)itrrr,s r-r@NamedTupleCursor.__iter__Xsy !#BRABz#'==?2[((1+ hhtBx((   s#BA0A55 B?BBBcUR(a[SUR55OSnURU5$)Nc3*# UH oSv M g7f)rNrW)rrs r-r,NamedTupleCursor._make_nt..is3"2QaD"2srW)rmtuple_cached_make_nt)r)rs r-rNamedTupleCursor._make_nths37;7G7Ge3$"2"233R##C((r/c/nUHKn[RSU5nUSS:XdSUSs=::aS::aO OSU-nURU5 MM [SU5nU$)N_r09fr) _re_cleansubappendr)clsrfieldssrs r- _do_make_ntNamedTupleCursor._do_make_ntlsfA c1%Ats{cQqT0S0!G MM!  & ) r/)rr1)rErFrGrHrIr MAX_CACHErarrgr2r9r=r@r classmethodrrJrKrLs@r-rr#sPFI,00'' )  r/ric$URU5$r1)r)rrs r-rr{s ??3 r/cJ^\rSrSrSrSrSrSrSrSr U4Sjr S r U=r $) LoggingConnectionizvA connection that logs all queries to a file or logger__ object. .. __: https://docs.python.org/library/logging.html cXl[(aA[U[R[R45(aUR UlgURUlg)zInitialize the connection to log to `!logobj`. The `!logobj` parameter can be an open file object or a Logger/LoggerAdapter instance from the standard logging module. N)_logobj_loggingrzLogger LoggerAdapter _logtologgerlog _logtofile)r)logobjs r- initializeLoggingConnection.initializesH  8 (*@*@ACC((DHDHr/cU$)zFilter the query before logging it. This is the method to overwrite to filter unwanted queries out of the log or to add some extra data to the output. The default implementation just does nothing. rWr)msgcurss r-filterLoggingConnection.filters  r/cURX5nU(ao[U[5(a-UR[R UR S5nURRU[R-5 gg)Nreplace) rrzbytesdecode_ext encodingsencodingrwrite_oslineseprs r-r LoggingConnection._logtofiles]kk#$ #u%%jj !> J LL  sS[[0 1 r/clURX5nU(aURRU5 ggr1)rrdebugrs r-r LoggingConnection._logtologgers*kk#$  LL  s # r/cH[US5(dURS5eg)Nrz3LoggingConnection object has not been initialize()d)hasattrProgrammingErrorrs r-_checkLoggingConnection._checks,tY''''EG G(r/c>UR5 URSUR=(d [5 [TU]"U0UD6$rQ)r&rSrR LoggingCursorr%rrUs r-rLoggingConnection.cursors< *D,?,?,P=Qw~t.v..r/)rr ) rErFrGrHrIr rr r r&rrJrKrLs@r-rrs, '2$ G //r/rc@^\rSrSrSrSU4SjjrSU4SjjrSrU=r$)r)izCA cursor that logs queries using its connection logging facilities.c>[TU]X5URRURU5 $!URRURU5 f=fr1)r%rarr rcrbs r-raLoggingCursor.executesE 27?5/ OO   D 1DOO   D 1 8(A c>[TU]X5URRURU5 $!URRURU5 f=fr1)r%rgrr rcrhs r-rgLoggingCursor.callprocsF 27#H3 OO   D 1DOO   D 1r.rWr1) rErFrGrHrIrargrJrKrLs@r-r)r)sM2 22r/r)c.\rSrSrSrSSjrSrSrSrg) MinTimeLoggingConnectioniaA connection that logs queries based on execution time. This is just an example of how to sub-class `LoggingConnection` to provide some extra filtering for the logged queries. Both the `initialize()` and `filter()` methods are overwritten to make sure that only queries executing for more than ``mintime`` ms are logged. Note that this connection uses the specialized cursor `MinTimeLoggingCursor`. c:[RX5 X lgr1)rr _mintime)r)r mintimes r-r #MinTimeLoggingConnection.initializes$$T2 r/c [R"5UR- S-nX0R:aZ[ U[ 5(a-UR [RURS5nU[RSUS3$g)Nirz (execution time: z ms)) _timetime timestampr4rzrrrrrrr)r)rrrs r-rMinTimeLoggingConnection.filtersp ZZ\DNN *d 2 }} #u%%jj !> JU3;;-':1#TB B r/cURSUR=(d [5 [R"U/UQ70UD6$rQ)rSrRMinTimeLoggingCursorrr)r)r*r+s r-rMinTimeLoggingConnection.cursors=*    7#7 9 ''>t>v>>r/)r4N)r) rErFrGrHrIr rrrJrWr/r-r2r2s  C?r/r2c,\rSrSrSrSSjrSSjrSrg)r=iz=The cursor sub-class companion to `MinTimeLoggingConnection`.Ncb[R"5Ul[R XU5$r1)r8r9r:r)ra)r)rcrds r-raMinTimeLoggingCursor.executes"$$T$77r/cb[R"5Ul[R XU5$r1)r8r9r:r)rg)r)rirds r-rgMinTimeLoggingCursor.callprocs"%%dd;;r/)r:r1)rErFrGrHrIrargrJrWr/r-r=r=sG8[US'[TU]"U0UD6 gNreplication_type)r r%r&rUs r-r&%LogicalReplicationConnection.__init__s %8!" $)&)r/rWrErFrGrHr&rJrKrLs@r-rErE **r/rEc(^\rSrSrU4SjrSrU=r$)PhysicalReplicationConnectionic8>[US'[TU]"U0UD6 grG)r r%r&rUs r-r&&PhysicalReplicationConnection.__init__s %9!" $)&)r/rWrJrLs@r-rMrMrKr/rMc\rSrSrSrSrg)StopReplicationiz Exception used to break out of the endless loop in `~ReplicationCursor.consume_stream()`. Subclass of `~exceptions.Exception`. Intentionally *not* inherited from `~psycopg2.Error` as occurrence of this exception does not indicate an error. rWN)rErFrGrHrIrJrWr/r-rQrQs  r/rQc<\rSrSrSrS SjrSrS SjrSrSr g) ri z;A cursor used for communication on replication connections.NcvS[X5S3nUcURRnU[:Xa+Uc[R "S5eUS[X053- nOKU[ :XaUb[R "S5eUS- nO"[R "S[U535eURU5 g) z"Create streaming replication slot.zCREATE_REPLICATION_SLOT  NzAoutput plugin name is required to create logical replication slotLOGICAL zIcannot specify output plugin name when creating physical replication slotPHYSICALunrecognized replication type: ) r rrHr psycopg2r%r reprra)r) slot_name slot_type output_plugincommands r-create_replication_slot)ReplicationCursor.create_replication_slot s-[-I,J!L  88I + +$///00 +m"B!CD DG . .(//011 z !G++1$y/1BCE E Wr/cBS[X53nURU5 g)z Drop streaming replication slot.zDROP_REPLICATION_SLOT N)r ra)r)rZr]s r-drop_replication_slot'ReplicationCursor.drop_replication_slot+s"+;y+G*HI Wr/c SnUcURRnU[:Xa6U(aUS[X5S3- nO[R "S5eUS- nOFU[ :XaU(aUS[X5S3- nO"[R "S[U535e[U5[La5URS5n [U S S 5S S[U S S 5S 3n OUS- S-S SUS-S 3n X- nUS :wa(U[:Xa[R "S5eUSU3- nU(aU[ :Xa[R "S5eUS- nUR5HEupURS5(dUS- nU[X5S[[U 553- nMG US- nURXUS9 g)zStart replication stream.zSTART_REPLICATION NzSLOT rTz-slot name is required for logical replicationrUrW/rXr08X lz/cannot specify timeline for logical replicationz TIMELINE z=cannot specify output plugin options for physical replicationz ((z, ))rstatus_interval)rrHr r rXr%r rYtypestrsplitr{rendswith_Astart_replication_expert) r)rZr[ start_lsntimelineoptionsrrkr]lsnkrs r-start_replication#ReplicationCursor.start_replication1s '  88I + +U;y#?"@BB//CEE z !G . .U;y#?"@BB++1$y/1BCE E  ?c !//#&CQ_Q'qSVR(=>C"_z1!4Ai*6LS5QRC q=////EGG H:. .G 00//SUU tOG '',,tOGk!231RAZLAA( sNG %% O & Er/c6URR5$r1)rfilenors r-rzReplicationCursor.filenols%%''r/rWNN)NNrrNF ) rErFrGrHrIr^rarwrzrJrWr/r-rr s#E<=>DF8Ev(r/rc0\rSrSrSrSrSrSrSrSr g) UUID_adapterirzAdapt Python's uuid.UUID__ type to PostgreSQL's uuid__. .. __: https://docs.python.org/library/uuid.html .. __: https://www.postgresql.org/docs/current/static/datatype-uuid.html cXlgr1_uuid)r)uuids r-r&UUID_adapter.__init__y r/c.U[RLaU$gr1r ISQLQuoter)protos r- __conform__UUID_adapter.__conform__| DNN "K #r/c@SURS3RS5$)N''::uuidutf8)rencoders r- getquotedUUID_adapter.getquoteds DJJU=(a TRU5=(d S$r1)r)rrrs r-register_uuid..s!9$))D/!AT!Ar/zUUID[]) rrzrrrnew_typernew_array_type UUIDARRAY register_typeregister_adapterr)oids conn_or_cursoid1oid2rs @r- register_uuidrs  D4- ( ( d th ACDI(($(DIIFDNtyy,/t~~|4$))\2 99r/c<\rSrSrSrSrSrSrSrSr Sr S r g ) Inetia/Wrap a string to allow for correct SQL-quoting of inet values. Note that this adapter does NOT check the passed value to make sure it really is an inet-compatible address but DOES call adapt() on it to make sure it is impossible to execute an SQL-injection by passing an evil value to the initializer. cXlgr1)addr)r)rs r-r& Inet.__init__s r/cPURRSUR<S3$)Nrirj)r,rErrs r-__repr__ Inet.__repr__s$..))*!DII=::r/cXlgr1)_connr)conns r-prepare Inet.preparerr/c[UR5n[US5(aURUR5 UR 5S-$)Nrs::inet)rprr$rrr)r)objs r-rInet.getquoteds=m 3 " " KK #}}**r/c.U[RLaU$gr1rrs r-rInet.__conform__rr/c,[UR5$r1)rmrrs r-r Inet.__str__s499~r/)rrN) rErFrGrHrIr&rrrrrrJrWr/r-rrs%;+ r/rcSSKnURS[5 U(dSnSnO$[U[[ 45(aUup4OUnSn[ R"U4SS5[ l[ R"U4S[ R5[ l [ R"[ RU5 [ R"[ RU5 [ R$) a4Create the INET type and an Inet adapter. :param oid: oid for the PostgreSQL :sql:`inet` type, or 2-items sequence with oids of the type and the array. If not specified, use PostgreSQL standard oids. :param conn_or_curs: where to register the typecaster. If not specified, register it globally. rNz4the inet adapter is deprecated, it's not very usefulieiINETc<U=(a [U5=(d S$r1)r)rrs r-rregister_inet..s!4$t*!<!  C$ ' ' d th <>DI(($; JDNtyy,/t~~|4 99r/c\SSKnSSKJnJnJn UR 5nXR:XagXS:Xa#URUR 5///5 OWait until a connection or cursor has data available. The function is an example of a wait callback to be registered with `~psycopg2.extensions.set_wait_callback()`. This function uses :py:func:`~select.select()` to wait for data to become available, and therefore is able to handle/receive SIGINT/KeyboardInterrupt. rN)POLL_OK POLL_READ POLL_WRITEzbad state from poll: ) selectpsycopg2.extensionsrrrpollrzOperationalErrorKeyboardInterruptcancel)rrrrrstates r- wait_selectrsBB  IIKE# t{{}or26$ b4;;=/26++.CE7,KLL !  KKM  s"B 'B 'B 7B B+*B+cUc[R"S5e[US5(a"URnUR [ S9nX4$UnUR [ S9nX4$)zEReturn the connection and a DBAPI cursor from a connection or cursor.z no connection or cursor providedra)rR)rXr%r$rrr)rrrs r-_solve_conn_cursrsk''(JKK|Y''&&{{'{2 :{{'{2 :r/c\rSrSrSrSrSrSrSr\r \ R"S\ R5r \\ R"S54S j5r\S 5r\S 5rS rg ) HstoreAdapteriz)Adapt a Python dict to the hstore syntax.cXlgr1)wrapped)r)rs r-r&HstoreAdapter.__init__s r/chXlURRS:aURUlgg)Ni_)rinfoserver_version _getquoted_8rrs r-rHstoreAdapter.prepares-  99 # #e +!..DN ,r/cUR(dg[Rn/nURR5Hup4U"U5nUR UR 5 UR 5nUb4U"U5nUR UR 5 UR 5nOSnURSU-S-U-S-5 M SSRU5-S-$)z*Use the operators available in PG pre-9.0. ''::hstoresNULL(s => )s||) rrr rrrrrjoin)r)r rvrvrs r-rHstoreAdapter._getquoted_8 s||   LL&&(DAaA IIdii  A}!H $))$KKM IIdQh(1,t3 4)ejjn$t++r/cUR(dg[R"[URR 555nUR UR 5 [R"[URR555nUR UR 5 SUR5-S-UR5-S-$)z(Use the hstore(text[], text[]) function.rshstore(s, r) rrr rrrrrr)r)rvrs r- _getquoted_9HstoreAdapter._getquoted_98s|| JJtDLL--/0 1 $)) JJtDLL//12 3 $))AKKM)E1AKKMADHHr/am # hstore key: # a string of normal or escaped chars "((?: [^"\\] | \\. )*)" \s*=>\s* # hstore value (?: NULL # the value can be null - not catched # or a quoted string like the key | "((?: [^"\\] | \\. )*)" ) (?:\s*,\s*|$) # pairs separated by comma or end of string. z\\(.)cUcg0nSnURRU5HnUbUR5U:wa[R"SU35eUR SUR S55nUR S5nUbUR SU5nXU'UR5nM U[U5:a[R"SU35eU$)zParse an hstore representation in a Python string. The hstore is represented as something like:: "a"=>"1", "b"=>"2" with backslash-escaped strings. Nrz"error parsing hstore pair at char \1rz/error parsing hstore: unparsed data after char ) _re_hstorefinditerstartrXInterfaceErrorrgroupendro) r)rcur_bsdecrrmrvrs r-parseHstoreAdapter.parseRs 9 ))!,AyAGGI.--8@BB 5!''!*-A A}JJua(qEEEGE- 3q6>))A%IK K r/cUcgUR[RURR5nUR X5$)z2Parse an hstore returning unicode keys and values.N)rrrrrr)r)rrs r- parse_unicodeHstoreAdapter.parse_unicodess< 9 HHT^^CNN$;$;< =zz!!!r/c[U5up#URnURRS:=(a S=(d Sn//pvUR SUS35 UH+nUR US5 UR US5 M- U[ R:wa!UR(dUR5 [U5[U54$)zBReturn the lists of OID of the hstore and hstore[] types. 9typarrayNULLzSELECT t.oid, z\ FROM pg_type t JOIN pg_namespace ns ON typnamespace = ns.oid WHERE typname = 'hstore'; rr) rstatusrrrarrSTATUS_IN_TRANSACTION autocommitrollbackr) r)rrr conn_statusrrv0rv1rs r-get_oidsHstoreAdapter.get_oids|s&l3 kk 99++u4CMvrS z2  D JJtAw  JJtAw  455 5 MMOSz5:%%r/)rrrN)rErFrGrHrIr&rrrr_recompileVERBOSErrrrrrJrWr/r-rrs3/,0 II   J#&;;x#8@""&&r/rcUcB[RU5nUb US(d[R"S5eUSnUSn[ U[ 5(aU4nUb=[ U[ 5(aU4nO$[ UVs/sH oU(dM UPM sn5n[R"US[R5n[R"Xa(+=(a U=(d S5 [R"[[5 U(aF[R"USU5n[R"Xq(+=(a U=(d S5 ggs snf)aRegister adapter and typecaster for `!dict`\-\ |hstore| conversions. :param conn_or_curs: a connection or cursor: the typecaster will be registered only on this object unless *globally* is set to `!True` :param globally: register the adapter globally, not only on *conn_or_curs* :param unicode: if `!True`, keys and values returned from the database will be `!unicode` instead of `!str`. The option is not available on Python 3 :param oid: the OID of the |hstore| type if known. If not, it will be queried on *conn_or_curs*. :param array_oid: the OID of the |hstore| array type if known. If not, it will be queried on *conn_or_curs*. The connection or cursor passed to the function will be used to query the database and look for the OID of the |hstore| type (which may be different across databases). If querying is not desirable (e.g. with :ref:`asynchronous connections `) you may specify it in the *oid* parameter, which can be found using a query such as :sql:`SELECT 'hstore'::regtype::oid`. Analogously you can obtain a value for *array_oid* using a query such as :sql:`SELECT 'hstore[]'::regtype::oid`. Note that, when passing a dictionary from Python to the database, both strings and unicode keys and values are supported. Dictionaries returned from the database have keys/values according to the *unicode* parameter. The |hstore| contrib module must be already installed in the database (executing the ``hstore.sql`` script in your ``contrib`` directory). Raise `~psycopg2.ProgrammingError` if the type is not found. Nrz\hstore type not found in the database. please install it from your 'contrib/hstore.sql' filerHSTORE HSTOREARRAY)rrrXr%rzr{rrrrrrdictr)rgloballyunicoder array_oidr~r r s r-register_hstorers> {$$\2 ;c!f++HI IAIa&C#sf i % %" I)9)Qqq)9:I]]3-*=*= >Fv|< DE$ .)))]FK  ; (E(MN:s  EEc\rSrSrSrS SjrSrSr\R"S\R5r \R"S5r \ S 5rS r\ S 5rS rg)CompositeCasteriaYHelps conversion of a PostgreSQL composite type into a Python object. The class is usually created by the `register_composite()` function. You may want to create and register manually instances of the class if querying the database at registration time is not desirable (such as when using an :ref:`asynchronous connections `). NcXlXPlX lX@lUVs/sHofSPM snUlUVs/sHofSPM snUlUR XR5 [R"U4XR5Ul U(a,[R"U4US3UR5Ul gSUl gs snfs snf)NrrARRAY) nameschemarrattnamesatttypes _create_typerrr typecasterrarray_typecaster)r)rrattrsrras r-r&CompositeCaster.__init__s  "',-u!1u- ',-u!1u-  $ .--jjA $($7$7 endoo%?D !%)D !.-s C CcUcgURU5n[U5[UR5:waB[R"S[UR5UR [U54-5e[ URU5VVs/sHupEURXE5PM nnnURU5$s snnf)Nz9expecting %d components for the type %s, %d found instead) tokenizerorrX DataErrorrzipcastmake)r)rrtokensrtokenrs r-rCompositeCaster.parses 9q! v;#dmm, ,$$KT]]#TYYF <=> > "$--8:8 ))C'8 :yy  :sCc$URU5$)zReturn a new Python object representing the data being casted. *values* is the list of attributes, already casted into their Python representation. You can subclass this method to :ref:`customize the composite cast `. )_ctor)r)rs r-r$CompositeCaster.makeszz&!!r/z \(? ([,)]) # an empty token, representing NULL | \(? " ((?: [^"] | "")*) " [,)] # or a quoted string | \(? ([^",)]+) [,)] # or an unquoted string z (["\\])\1c /nURRU5HnUc[R"SU<35eUR S5bUR S5 MEUR S5b<UR UR RSUR S555 MUR UR S55 M U$)Nzcan't parse type: rrr) _re_tokenizerrXrrr _re_undoubler)r)rrrs r-r CompositeCaster.tokenizes ""++A.Ay--0B1%.HIIwwqz% $' $++//qwwqzBC !''!*%/ r/c[RSU5n[X5UlURRUlg)Nr)rrrrlrr))r)rrs r-rCompositeCaster._create_type#s-}}S$'t. YY__ r/c[U5up4URnSU;aURSS5upgOUnSnURRS:=(a S=(d SnUR SU-Xv45 UR 5n U (dSn UR[R:XaUR S 5 S n UR S U-U45 UR 5n U (aU S S nU S SnW (aUR S5 U[R:wa!UR(dUR5 U (d[R"SUS35eU S S n U S Sn U V s/sH oSU S4PM nn U"X{UXS9$![Ra Nf=f!W (aUR S5 ff=fs sn f)zmReturn a `CompositeCaster` instance for the type *name*. Raise `ProgrammingError` if the type is not found. .rpublicrrrzSELECT t.oid, %s, attname, atttypid FROM pg_type t JOIN pg_namespace ns ON typnamespace = ns.oid JOIN pg_attribute a ON attrelid = typrelid WHERE typname = %%s AND nspname = %%s AND attnum > 0 AND NOT attisdropped ORDER BY attnum; FzSAVEPOINT register_typeTzSELECT t.oid, %s, attname, atttypid, typname, nspname FROM pg_type t JOIN pg_namespace ns ON typnamespace = ns.oid JOIN pg_attribute a ON attrelid = typrelid WHERE t.oid = %%s::regtype AND attnum > 0 AND NOT attisdropped ORDER BY attnum; rz#ROLLBACK TO SAVEPOINT register_typezPostgreSQL type 'z ' not foundrr,)rr) rrrnrrrar=rrrXr%rr)r)rrrrrrtnamerrecs savepointtype_oidrr type_attrss r-_from_dbCompositeCaster._from_db(s &l3 kk  $; JJsA.MFEEF99++u4CMv  !}} H! ;;$"<"<<LL!:; $I }} GAJE!!WQZFLL!FG $44 4T__ MMO++#D657 771:GAJ ,01DqtQqTlD 1EZ0 0/,,  LL!FG2s1A F!'F;G!F85F;7F88F;;G) r)rrrrrrrrlrr|)rErFrGrHrIr&rr$rrrr-r.rr rr=rJrWr/r-rrsq) ! ";;   L ;;|,L  % O0O0r/rc4Uc[nURX5n[R"URU(+=(a U=(d S5 UR b8[R"UR U(+=(a U=(d S5 U$)aRegister a typecaster to convert a composite type into a tuple. :param name: the name of a PostgreSQL composite type, e.g. created using the |CREATE TYPE|_ command :param conn_or_curs: a connection or cursor used to find the type oid and components; the typecaster is registered in a scope limited to this object, unless *globally* is set to `!True` :param globally: if `!False` (default) register the typecaster only on *conn_or_curs*, otherwise register it globally :param factory: if specified it should be a `CompositeCaster` subclass: use it to :ref:`customize how to cast composite types ` :return: the registered `CompositeCaster` or *factory* instance responsible for the conversion N)rr=rrrr)rrr factorycasters r-register_compositerB{sy!   d 1Fv((h,*G<*O4P *   # #\%Bl%Jd L Mr/c## /n[U5n[U5HnUR[U55 M Uv /nM5![a U(aUv gf=f7f)zoConsume an iterable and return it in chunks. Every chunk is at most `page_size`. Never return an empty chunk. N)rrnrrArB)seq page_sizepagerrps r- _paginaterGsf D cB  9% DH%&JD     s(A!2AA!AA!AA!c[X#S9HCnUVs/sHoPRX5PM nnURSRU55 ME gs snf)aYExecute groups of statements in fewer server roundtrips. Execute *sql* several times, against all parameters set (sequences or mappings) found in *argslist*. The function is semantically similar to .. parsed-literal:: *cur*\.\ `~cursor.executemany`\ (\ *sql*\ , *argslist*\ ) but has a different implementation: Psycopg will join the statements into fewer multi-statement commands, each one containing at most *page_size* statements, resulting in a reduced number of server roundtrips. After the execution of the function the `cursor.rowcount` property will **not** contain a total result. rE;N)rGmogrifyrar)rsqlargslistrErFr*sqlss r- execute_batchrOsE((837844 C&48 DIIdO$98sAc SSKJn [X5(aURU5n[U[5(d6UR [ RURR5n[U5upxU(a/OSn [X$S9Hn Uc'SSRS/[U S5-5-S-nUSSn U H4n U RURX<55 U RS5 M6 XS S&UR!S RU 55 U(dMU R#UR%55 M U $) aExecute a statement using :sql:`VALUES` with a sequence of parameters. :param cur: the cursor to use to execute the query. :param sql: the query to execute. It must contain a single ``%s`` placeholder, which will be replaced by a `VALUES list`__. Example: ``"INSERT INTO mytable (id, f1, f2) VALUES %s"``. :param argslist: sequence of sequences or dictionaries with the arguments to send to the query. The type and content must be consistent with *template*. :param template: the snippet to merge to every item in *argslist* to compose the query. - If the *argslist* items are sequences it should contain positional placeholders (e.g. ``"(%s, %s, %s)"``, or ``"(%s, %s, 42)``" if there are constants value...). - If the *argslist* items are mappings it should contain named placeholders (e.g. ``"(%(id)s, %(f1)s, 42)"``). If not specified, assume the arguments are sequence and use a simple positional template (i.e. ``(%s, %s, ...)``), with the number of placeholders sniffed by the first element in *argslist*. :param page_size: maximum number of *argslist* items to include in every statement. If there are more items the function will execute more than one statement. :param fetch: if `!True` return the query results into a list (like in a `~cursor.fetchall()`). Useful for queries with :sql:`RETURNING` clause. .. __: https://www.postgresql.org/docs/current/static/queries-values.html After the execution of the function the `cursor.rowcount` property will **not** contain a total result. While :sql:`INSERT` is an obvious candidate for this function it is possible to use it with other statements, for example:: >>> cur.execute( ... "create table test (id int primary key, v1 int, v2 int)") >>> execute_values(cur, ... "INSERT INTO test (id, v1, v2) VALUES %s", ... [(1, 2, 3), (4, 5, 6), (7, 8, 9)]) >>> execute_values(cur, ... """UPDATE test SET v1 = data.v1 FROM (VALUES %s) AS data (id, v1) ... WHERE test.id = data.id""", ... [(1, 20), (4, 50)]) >>> cur.execute("select * from test order by id") >>> cur.fetchall() [(1, 20, 3), (4, 50, 6), (7, 8, 9)]) r) ComposableNrIr,s%srr/) psycopg2.sqlrQrz as_stringrrrrrr _split_sqlrGrrorrKraextendr=) rrLrMtemplaterEfetchrQprepostresultrFpartsr*s r-execute_valuesr^sx(#""mmC  c5 ! !jj(?(?@A3ICRdF(8  dii#d1g,(>??$FHAD LLX4 5 LL bc  CHHUO$ 5 MM#,,. )9 Mr/ct/=p/n[R"SU5nUHn[U5S:wd USSS:waURU5 M.USSS:XaXLaUnM?[ S5eUSSS:XaURS5 Mf[ SUSSR S S 5-5e XLa [ S 5eX#4$) z}Split *sql* on a single ``%s`` placeholder. Split on the %s, perform %% replacement and return pre, post lists of snippets. s(%.)rNr%sz1the query contains more than one '%s' placeholderz"unsupported format character: '%s'asciirz.the query doesn't contain any '%s' placeholder)rrnror ValueErrorr)rLcurrrZr[r%r&s r-rVrVs OD D YYx %F u:?eBQi4/ KK   9 { GII 12Y$  KK A)""7I678 8" {IJJ 9r/[z !"#$%&'()*+,-./:;<=>?@[\]^`{|}~]r|)FFNN)FN)d)NrgF)VrIosrr9r8rer collectionsrrloggingrrXrrrrr _connectionr rpr functoolsr psycopg2._psycopgr r r_replicationConnectionr_replicationCursorrpsycopg2._jsonrrrrrpsycopg2._rangerrrrrrrrpsycopg2._ipaddressrr rNrTrr\rrrrrrrrr)r2r=rErMrrQrrrrrrrrrrBrGrOr^rVrescaperrWr/r-rus8/')10NN /// 39W9x/[/))83d3l//)^)8 (+ (F/;/UwUp 3  $/#? 0/ 0/f 2G 2 ?0?8 <= <*#9**$:*  i  c(*c(P''*D>B8 E&E&P;@(,9Ox`0`0F8&%2TnB KK#**9 ::S@ B r/