]j,.SrSSKJr SSKJr SSKJrJrJr SSK J r SSK J r J r SSKJr SS KJr SS KJrJrJr SS KJrJr SS KJrJrJr SS KJrJr SSK J!r! SSK"J#r# \(aSSK$J%r% \RLRNr'"SS\!S\45r(g)z Psycopg AsyncCursor object. ) annotations) TracebackType) TYPE_CHECKINGAnyoverload)asynccontextmanager) AsyncIteratorIterable)errors)pq)ParamsQueryQueryNoTemplate) AsyncCopy AsyncWriter)AsyncRowFactoryRowRowMaker)SelfTemplate) BaseCursor) AsyncPipeline)AsyncConnectioncR^\rSrSrSrSr\S%Sj5r\S&Sj5rSS.S'U4SjjjrS(S jrS)S jrS*S jr \ S+S j5r \ RS,S j5r S-Sjr \S.SSS.S/Sjjj5r\SSS.S0Sjj5rS.SSS.S1SjjjrSS.S2SjjrS.SSS.S3SjjjrS4SjrS5SjrS6SjrS7S8SjjrS9SjrS(SjrS:SjrS;S AsyncCursorpsycopgcgNr)self connections Q/home/mande/repo/quber/.venv/lib/python3.13/site-packages/psycopg/cursor_async.py__init__AsyncCursor.__init__!s:=cgr!r)r"r# row_factorys r$r%r&$s r'N)r)cX>[TU]U5 U=(d URUlgr!)superr%r) _row_factory)r"r#r) __class__s r$r%r&)s% $'A:+A+Ar'c# U$7fr!rr"s r$ __aenter__AsyncCursor.__aenter__2s  sc@# UR5IShvN gN7fr!)close)r"exc_typeexc_valexc_tbs r$ __aexit__AsyncCursor.__aexit__5s jjls c,# UR5 g7f)z9 Close the current cursor and free associated resources. N)_closer/s r$r3AsyncCursor.close=s scUR$)z9Writable attribute to control how result rows are formed.r,r/s r$r)AsyncCursor.row_factoryCs   r'cNXlUR(aU"U5Ulggr!)r,pgresult _make_row)r"r)s r$r)r>Hs ' ==(.DN r'c$URU5$r!r=r/s r$_make_row_makerAsyncCursor._make_row_makerNs  &&r'preparebinaryc # g7fr!r)r"queryparamsrFrGs r$executeAsyncCursor.executeQs c # g7fr!r)r"rIrFrGs r$rKrL[s rMc l# URRIShvN URRURXX4S95IShvN SSS5IShvN U$NGNN !,IShvN (df  U$=f![R anUR S5eSnAff=f7f)z- Execute a query or command to the database. NrE)_connlockwait _execute_gene _NO_TRACEBACKwith_traceback)r"rIrJrFrGexs r$rKrLds *zzjjoo%%eW%T'  ''   *##D) ) *sB4BA&B-A,A(A, BA* B$B4&B(A,*B,B2A5 3 B?BB4BB1B,,B11B4F) returningc R# URRIShvN [R"5(aURR(a4URR UR XU55IShvN OURR5IShvN URR UR XU55IShvN SSS5IShvN O3URR URXU55IShvN SSS5IShvN gGNNNN`NR!,IShvN (df  N3=fN:N,!,IShvN (df  g=f![RanURS5eSnAff=f7f)z9 Execute the same command with a sequence of input data. N) rPrQr is_supported _pipelinerR_executemany_gen_pipeline_pipeline_nolock_executemany_gen_no_pipelinerTrUrV)r"rI params_seqrXrWs r$ executemanyAsyncCursor.executemanyxs8  *zz --//zz++"jjoo ::5iX $(::#>#>#@#@"&**// $ > >$)y!"#$A#@#@**//99%YW#'  $A$A#@#@#@#'( *##D) ) *sF'E:D7E:A$E D:#E *D<+E ./ED>E" E -E.3E !E"E & E:1E2E:6F'7E::E <E >EE E E  E E E: E7&E) ' E73E:6F'7E::F$FF$$F'r rGsizec z# URR(a[R"S5eURR IShvN URR URXX4S95IShvN SnURR URU55IShvN =n(a[UR5H+nURRXpR57v M- SnURR URU55IShvN =n(aMURR [":XaURR%5IShvN URR URSS95IShvN (a8URR URSS95IShvN (aM8URR URSS95IShvN OSSS5IShvN gGNGNGNGN ![RanURS5eSnAff=fNNN![&a Nf=fNf![&a Nnf=f!URR [":XaURR%5IShvN URR URSS95IShvN (a9URR URSS95IShvN (aM9O![&a Of=fURR URSS95IShvN f![&a ff=ff=fGNq!,IShvN (df  g=f7f)z Iterate row-by-row on a result from the database. :param size: if greater than 1, results will be retrieved by chunks of this size from the server (but still yielded row-by-row); this is only available from version 17 of the libpq. z(stream() cannot be used in pipeline modeNrbTF)first)_pgconnpipeline_statusrTProgrammingErrorrPrQrR_stream_send_gen_stream_fetchone_genrangentuples_txload_rowrArUrVtransaction_statusACTIVE _try_cancel Exception) r"rIrJrGrcreresposrWs r$streamAsyncCursor.streams  << ' '$$%OP P::??? jjoo))%)R#'::??43L3LU3S#TTTcT$S[[1"hh//^^DD 2!E$(::??43L3LU3S#TTTcT<<22f<**00222$(JJOO 55E5B%!%)JJOO 55E5B%"jjood.G.Ge.G.TUUU=#??U?? .''-- . 3% V$!<<22f<**00222$(JJOO 55E5B%!%)JJOO 55E5B%% "jjood.G.Ge.G.TUUU$!=#???sA N;H3N;N!,H?H63H?4H95A>H?3H<4 H?;N!<I,=N!+I2-I..5I2#I0$ I20+JJJ N!" N;-N.N;6H?9H?<H??I)I$$I))J,N!.I20I22 I?<N!>I??N!J JN!JN!>D(($$ IIs499t+S[[94>>  S\!  %sB2B0BB2c# UR5IShvN UR5nURRURUR UR 5nUR UlU$Nb7f)zy Return all the remaining records from the current result set. :rtype: Sequence[Row], with Row defined by `row_factory` N)rrrmrrrlrA)r"rsrs r$fetchallAsyncCursor.fetchalls` ""$$$**,(($$TYY T^^LKK  %sA;A9A#A;cU$r!rr/s r$ __aiter__AsyncCursor.__aiter__ s r'c6# UR5IShvN UR5nURUR:aGURR URUR 5nU=RS- slU$[S5eN7f)Nr zno more records to return)rrrrlrmrnrAStopAsyncIterationrs r$ __anext__AsyncCursor.__anext__#sv""$$$**, 99s{{ "XX&&tyy$..AF IINIM !<== %sBBBBcb# UR5IShvN URX5 gN7f)av Move the cursor in the result set to a new position according to mode. If `!mode` is ``'relative'`` (default), `!value` is taken as offset to the current position in the result set; if set to ``'absolute'``, `!value` states an absolute target position. Raise `!IndexError` in case a scroll operation would leave the result set. In this case the position will not change. N)r_scroll)r"valuemodes r$scrollAsyncCursor.scroll,s*""$$$ U! %s /-/writerc# URRIShvN URRURX55IShvN [ XS9IShvN nU7v SSS5IShvN SSS5IShvN URS5 gNNON?N,!,IShvN (df  NA=fN8!,IShvN (df  NM=f![ R anURS5eSnAff=f7f)zE Initiate a :sql:`COPY` operation and return an object to manage it. Nrr) rPrQrR_start_copy_genrrTrUrVr)r" statementrJrcopyrWs r$rAsyncCursor.copy:s *zzjjood&:&:9&MNNN$T99TJ:9' ##A&'N9999'  *##D) ) *sD CBC.CB C"B"#C&B&, C7B$8C< CCC D C C"C$C&B= ,B/- B= 9CCCC CCD CD0DDD c# URSLaUR(dURR(atURRIShvN URR URRR SS95IShvN SSS5IShvN ggggN\NN !,IShvN (df  g=f7f)NFT)flush)_execmany_returningr@rPr[rQrR _fetch_genr/s r$rAsyncCursor._fetch_pipelineRs  $ $E 1MM $$zzjjoodjj&:&:&E&ED&E&QRRR'%" 2'R's[ACB5CAB;B7B;! C,B9- C7B;9C;CC  CC)rArr,)r#zAsyncConnection[Row])r#AsyncConnection[Any]r)AsyncRowFactory[Row])r#rr)zAsyncRowFactory[Row] | None)returnr)r4ztype[BaseException] | Noner5zBaseException | Noner6zTracebackType | NonerNone)rr)rr)r)rrr)rz RowMaker[Row]r!) rIrrJ Params | NonerF bool | NonerGrrr)rIrrFrrGrrr) rIrrJrrFrrGrrr)rIrr_zIterable[Params]rXboolrr) rIrrJrrGrrcintrzAsyncIterator[Row])rzAsyncIterator[Self])rrrr)rz Row | None)r)rcrr list[Row])rr)rr)relative)rrrstrrr)rrrJrrzAsyncWriter | NonerzAsyncIterator[AsyncCopy])__name__ __module__ __qualname____firstlineno__ __slots__rr%r0r7r3propertyr)setterrCrKr`ruryrrrrrrrrrr__static_attributes__ __classcell__)r-s@r$rrsJI ==  . @T  48 B(B1 BB,&%    !!// '!% $"       $"      !% $"      *PU**(8*HL* *B!%0 # 000  0  0 0d 4 & > "!%' &* ''' # ' " ''.SSr'rrN))__doc__ __future__rtypesrtypingrrr contextlibrcollections.abcr r r rTr abcrrrrrrrowsrrr_compatrr _cursor_baser_pipeline_asyncrconnection_asyncrTransactionStatusrprrr'r$rsn #//*3//(00#$*1   $ $|S*3S89|Sr'