(ph%SrSSKJr SSKJr SSKJrJrJrJ r J r SSK J r SSK Jr SSK Jr SS KJrJr SS KJrJr SS KJrJrJr SS KJr SS KJr SSKJ r \ (aSSK!J"r" \RFRHr$"SS\ S\45r%g)z Psycopg AsyncCursor object. ) annotations) TracebackType)Any AsyncIteratorIterable TYPE_CHECKINGoverload)asynccontextmanager)pq)errors)QueryParams) AsyncCopy AsyncWriter)RowRowMakerAsyncRowFactory)Self)Pipeline) BaseCursor)AsyncConnectionc^\rSrSrSrSr\S Sj5r\S!Sj5rSS.S"U4SjjjrS#S jrS$S jrS%S jr \ S&S j5r \ RS'S j5r S(Sjr S)SSS.S*SjjjrSS.S+SjjrS)SSS.S,SjjjrS-SjrS.S/SjjrS0SjrS1SjrS2S3Sjjr\S)SS.S4Sjjj5rS%SjrSrU=r$)5 AsyncCursorpsycopgcgNr)self connections G/var/www/html/venv/lib/python3.13/site-packages/psycopg/cursor_async.py__init__AsyncCursor.__init__ s:=cgrr)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$7frrr s r" __aenter__AsyncCursor.__aenter__1s  sc@# UR5IShvN gN7fr)close)r exc_typeexc_valexc_tbs r" __aexit__AsyncCursor.__aexit__4s jjls c,# UR5 g7f)z9 Close the current cursor and free associated resources. N)_closer-s r"r1AsyncCursor.close<s scUR$)z9Writable attribute to control how result rows are formed.r*r-s r"r'AsyncCursor.row_factoryBs   r%cNXlUR(aU"U5Ulggr)r*pgresult _make_row)r r's r"r'r<Gs ' ==(.DN r%c$URU5$rr;r-s r"_make_row_makerAsyncCursor._make_row_makerMs  &&r%preparebinaryc l# URRIShvN URRURXX4S95IShvN SSS5IShvN U$NGNN !,IShvN (df  U$=f![R anUR S5eSnAff=f7f)z- Execute a query or command to the database. NrC)_connlockwait _execute_gene _NO_TRACEBACKwith_traceback)r queryparamsrDrEexs r"executeAsyncCursor.executePs *zzjjoo%%eW%T'  ''   *##D) ) *sB4BA&B-A,A(A, BA* B$B4&B(A,*B,B2A5 3 B?BB4BB1B,,B11B4F) returningc # [R"5(GaURRIShvN URRnU(a3URR UR XU55IShvN SSS5IShvN W(dURR5IShvN URRIShvN URR UR XU55IShvN SSS5IShvN SSS5IShvN ggURRIShvN URR URXU55IShvN SSS5IShvN gGNfGNGN !,IShvN (df  GN"=fNNNN!,IShvN (df  N=fN!,IShvN (df  g=fNNyNk!,IShvN (df  g=f![RanURS5eSnAff=f7f)z9 Execute the same command with a sequence of input data. N) r is_supportedrGrH _pipelinerI_executemany_gen_pipelinepipeline_executemany_gen_no_pipelinerKrLrM)r rN params_seqrSprPs r" executemanyAsyncCursor.executemanyds *$$&& ::??? ,,A"jjoo ::5iX+?#zz2244djjooo"jjoo ::5iX7Fo444  ::???**//99%YW+??++??? 5o7Fooo4444 ++??? *##D) ) *sI5H!FH!A F( F" F( H!F%)H!GH!G'"G#G'&/G GG  G'%G &G'* H!5G%6H!:I<H!HH!/H H H H!HH!IH!"F(%H!(G.F1 / G; H!G'G  G' G" G G" G'%H!'G>-G0 . G>:H!=I>H!HH!H H  HH!IH!!I 5II  Ir rEsizec l# URR(a[R"S5eURR IShvN URR URXX4S95IShvN SnURR URU55IShvN (a|[U5H2nURRX`R5nUc O U7v M4 SnURR URU55IShvN (aM|URR[ :XaURR#5IShvN URR URSS95IShvN (a8URR URSS95IShvN (aM8URR URSS95IShvN OSSS5IShvN gGNGNGN~GN![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 modeNr^TF)first)_pgconnpipeline_statusrKProgrammingErrorrGrHrI_stream_send_gen_stream_fetchone_genrange_txload_rowr?rLrMtransaction_statusACTIVE _try_cancel Exception) r rNrOrEr_raposrecrPs r"streamAsyncCursor.streams  << ' '$$%OP P::???" jjoo))%)R JJOOD,E,Ee,LMMM$T{"hh//^^D;!! + "E !JJOOD,E,Ee,LMMM<<22f<**00222$(JJOO 55E5B%!%)JJOO 55E5B%"jjood.G.Ge.G.TUUU=%#??N?? .''-- .3% V$!<<22f<**00222$(JJOO 55E5B%!%)JJOO 55E5B%% "jjood.G.Ge.G.TUUU$!=%#???sA N4H,N4N,H8H/3H84H25A9H8.H5/ H8:;N5I%6N;+I+&I''5I+I) I+)+I=I;I=N N4&N'N4/H82H85H88I" II""J %N'I+)I++ I85N7I88N;I== J N J  N <6M2L5 3 M?N M N M N+N<M? =NN N NN NNN4N1 N# ! N1-N4c# UR5IShvN UR5 URRURUR 5nUbU=RS- slU$N^7f)z Return the next record from the current recordset. Return `!None` the recordset is finished. :rtype: Row | None, with Row defined by `row_factory` Nr )_fetch_pipeline_check_result_for_fetchrhri_posr?)r records r"fetchoneAsyncCursor.fetchones`""$$$ $$&""499dnn=   IINI %sA7A5AA7c# UR5IShvN UR5 UR(deU(d URnURR UR [UR U-URR5UR5nU=R [U5- slU$N7f)z Return the next `!size` records from the current recordset. `!size` default to `!self.arraysize` if not specified. :rtype: Sequence[Row], with Row defined by `row_factory` N) rsrtr> arraysizerh load_rowsruminntuplesr?len)r r_recordss r" fetchmanyAsyncCursor.fetchmanys""$$$ $$&}}}>>D(($$ II  D $--"7"7 8 NN  S\!  %sCC B7CcH# UR5IShvN UR5 UR(deURR UR URR UR5nURR UlU$N7f)zx Return all the remaining records from the current recordset. :rtype: Sequence[Row], with Row defined by `row_factory` N)rsrtr>rhr{rur}r?)r rs r"fetchallAsyncCursor.fetchallsv ""$$$ $$&}}}(($$TYY 0E0Et~~VMM))  %sB"B B B"c^# TR5IShvN TR5 SU4SjjnU"TR5nUcgT=RS- slU7v M2NO7f)NcP>TRRUTR5$r)rhrir?)rnr s r"load#AsyncCursor.__aiter__..loads88$$S$..9 9r%r )rnintreturn Row | None)rsrtru)r rrows` r" __aiter__AsyncCursor.__aiter__s_""$$$ $$& :tyy/C{ IINII  %sA)A'AA)cb# 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)rs_scroll)r valuemodes r"scrollAsyncCursor.scrolls*""$$$ U! %s /-/writerc# URRIShvN URRURX55IShvN SSS5IShvN [ XS9IShvN nU7v SSS5IShvN URS5 gNNONA!,IShvN (df  NV=fNKN8!,IShvN (df  NM=f![ R anURS5eSnAff=f7f)zE Initiate a :sql:`COPY` operation and return an object to manage it. Nrr) rGrHrI_start_copy_genrrKrLrM_select_current_result)r statementrOrcopyrPs r"rAsyncCursor.copy s *zzjjood&:&:9&MNNN'!55 65 ##A&'N'6555 *##D) ) *sD CBC.B$B B$ C B"!C2B>3C6C< CCC D C B$"C$B;*B- + B;7CCCC CCD CD0DDD c# URSLaUR(dURR(atURRIShvN URR URRR SS95IShvN SSS5IShvN ggggN\NN !,IShvN (df  g=f7f)NFT)flush)_execmany_returningr>rGrVrHrI _fetch_genr-s r"rsAsyncCursor._fetch_pipeline#s  $ $E 1MM $$zzjjoodjj&:&:&E&ED&E&QRRR'%" 2'R's[ACB5CAB;B7B;! C,B9- C7B;9C;CC  CC)r?rur*)r!zAsyncConnection[Row])r!AsyncConnection[Any]r'AsyncRowFactory[Row])r!rr'zAsyncRowFactory[Row] | None)rr)r2ztype[BaseException] | Noner3zBaseException | Noner4zTracebackType | NonerNone)rr)rr)r'rrr)rz RowMaker[Row]r) rNrrO Params | NonerD bool | NonerErrr)rNrrZzIterable[Params]rSboolrr) rNrrOrrErr_rrAsyncIterator[Row])rr)r)r_rr list[Row])rr)rr)relative)rrrstrrr)rrrOrrzAsyncWriter | NonerzAsyncIterator[AsyncCopy])__name__ __module__ __qualname____firstlineno__ __slots__r r#r.r5r1propertyr'setterrArQr\rprwrrrrr rrs__static_attributes__ __classcell__)r+s@r"rrsJI ==  . @T  48 B(B1 BB,&%    !!// ' !% $"      2 * *% *  *  *J!%5 # 555  5  5 5n ,   "!%' &* ''' # ' " ''.SSr%rrN)&__doc__ __future__rtypesrtypingrrrrr contextlibr r r rKabcrrrrrrowsrrr_compatrrVr _cursor_baserconnection_asyncrTransactionStatusrkrrr%r"rsh #HH*(00$1   $ $NS*3S89NSr%