(ph0%SrSSKJr SSKJrJr SSKJrJrJ r SSK J r SSK J r SSKJr SS KJrJr SS KJr \ (a SS KJr SS KJr S rS\S'\ R6R8r\ R6R:r"SS\5r"SS5rg)z! Support for prepared statements ) annotations)IntEnumauto)AnySequence TYPE_CHECKING) OrderedDict)pq)PQGen)Deque TypeAlias) PostgresQuery)PGresult)BaseConnectionztuple[bytes, tuple[int, ...]]rKeyc>\rSrSr\"5r\"5r\"5rSrg)PrepareN) __name__ __module__ __qualname____firstlineno__rNOYESSHOULD__static_attributes__rE/var/www/html/venv/lib/python3.13/site-packages/psycopg/_preparing.pyrrs B &C VFrrc\rSrSr%SrS\S'SrS\S'SSjr\SS j5r SSS jjr SS jr \SS j5r SSjr SSjrSSjrSSjrSSjrSrg )PrepareManager"z int | Noneprepare_thresholddint prepared_maxct[5Ul[5UlSUl[S"5Ulg)Nrz bytes | None)r _counts_names _prepared_idxr _to_flushselfs r __init__PrepareManager.__init__)s/.9m 0;} ~.0rc2URUR4$N)querytypes)r4s r keyPrepareManager.key5s U[[))rNcUSLd URc[RS4$URU5nURR U5nU(a[R U4$URR US5nXPR:dU(aDSUR3R5nU=RS- sl[RU4$[RS4$)z@ Check if a query is prepared, tell back whether to prepare it. Frr_pg3_r ) r%rrr6r+getrr*r,encoder)r/r4preparer6namecounts r r:PrepareManager.get9s e t55=::s? "hhuo{{s# ;;$ $   a( ** *g4--./668D   ! # >>4' '::s? "rcUR(dU[R:XabUH\nUR[:waMUR nU(dM.UR S5(dUS:XdMLUR5s $ g)zCheck if we need to discard our entire state: it should happen on rollback or on dropping objects, because the same object may get recreated and postgres would fail internal lookups. sDROP sROLLBACKF)r+rrstatus COMMAND_OKcommand_status startswithclear)r/prepresultsresultcmdstats r _should_discardPrepareManager._should_discardSsg ;;$'..0!==J. //7 2 28 < <;@V::<' " rct[U5S:wagUSRn[Us=:wa [:wag gg)zCReturn False if 'results' are invalid for prepared statement cache.r FrT)lenrArB TUPLES_OK)rGrAs r _check_resultsPrepareManager._check_resultsas< w<1 ""  ,9 , -rc2[UR5UR:aURRSS9 [UR5UR:a8URRSS9SnUR R U5 gg)zEvict an old value from the cache. If it was prepared, deallocate it. Do it only once: if the cache was resized, deallocate gradually. F)lastr N)rMr*r(popitemr+r-append)r/r=s r _rotatePrepareManager._rotateosz t|| t00 0 LL e , t{{ d// /;;&&E&215D NN ! !$ ' 0rcURcgURU5nX@R;abU[RLaURU X0R U'gURU==S- ss'URR U5 gX@R ;aUR R U5 gU[RLaX0R U'U$SURU'U$)zHandle 'query' for possible addition to the cache. If a new entry has been added, return its key. Return None otherwise (meaning the query is already in cache or cache is not enabled). Nr )r%r6r*rrr+ move_to_end)r/r4rFr=r6s r maybe_add_to_cache!PrepareManager.maybe_add_to_cache|s  ! ! )hhuo ,, w~~%LL%#' C  S!Q&! ((- KK  KK # #C (w~~%#' C J%& S!JrcURX$5(agURU5(d9URRUS5 URRUS5 gUR 5 g)zValidate cached entry with 'key' by checking query 'results'. Possibly record a command to perform maintenance on database side. N)rJrOr+popr*rU)r/r6rFr=rGs r validatePrepareManager.validatesX    . . ""7++ KKOOC & LL  S$ ' LLNrcURR5 UR(aPURR5 URR5 URR S5 gg)zClear the cache of the maintenance commands. Clear the internal state and prepare a command to clear the state of the server. NTF)r*rEr+r-rTr.s r rEPrepareManager.clearsS  ;; KK    NN " NN ! !$ 'rc## UR(aGURR5nURU5ShvN UR(aMFggN7f)z Generator to send the commands to perform periodic maintenance Deallocate unneeded command in the server, or flush the prepared statements server state entirely if necessary. N)r-popleft _deallocate)r/connr=s r maintain_genPrepareManager.maintain_gensBnn>>))+D''- - -nnn -sAAAAA)r*r+r,r-)returnNone)r4rrgrr3)r4rr<z bool | Nonergztuple[Prepare, bytes])rFrrGSequence[PGresult]rgbool)rGrirgrj)r4rrFrr=bytesrgz Key | None) r6rrFrr=rkrGrirgrh)rgrj)rdzBaseConnection[Any]rgz PQGen[None])rrrrr%__annotations__r(r0 staticmethodr6r:rJrOrUrYr]rErerrrr r"r""s$%z%L# 1**<@#"#-8# #4    ("*19> B   $   (  .rr"N) __doc__ __future__renumrrtypingrrr collectionsr r abcr _compatr r_queriesrpq.abcr_connection_baserrrl ExecStatusrBrNrr"rrr rzsp #//#%# 00Y0 ]] % % MM # # g g.g.r