,h$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) TYPE_CHECKINGAny AsyncIteratorIterableoverload)asynccontextmanager)errors)pq)ParamsQuery) AsyncCopy AsyncWriter)AsyncRowFactoryRowRowMaker)Self) BaseCursor) AsyncPipeline)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 O/var/www/html/Ai_home/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# 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) rGrHr is_supported _pipelinerI_executemany_gen_pipeline_pipeline_nolock_executemany_gen_no_pipelinerKrLrM)r rN params_seqrSrPs r" executemanyAsyncCursor.executemanyds8  *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 rEsizec 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 modeNr]TF)first)_pgconnpipeline_statusrKProgrammingErrorrGrHrI_stream_send_gen_stream_fetchone_genrangentuples_txload_rowr?rLrMtransaction_statusACTIVE _try_cancel Exception) r rNrOrEr^r`resposrPs 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)zx Return all the remaining records from the current recordset. :rtype: Sequence[Row], with Row defined by `row_factory` N)rtrurhr|rvrgr?)r rnrs r"fetchallAsyncCursor.fetchalls` ""$$$**,(($$TYY T^^LKK  %sA;A9A#A;cb# UR5IShvN UR5nURUR:agURR URUR 5nU=RS- slU7v URUR:aMfggN7f)Nr rs)r rnrows r" __aiter__AsyncCursor.__aiter__s|""$$$**,ii#++%((##DIIt~~>C IINIIii#++% %sB/B-BB/+B/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)rt_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.copys *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"rtAsyncCursor._fetch_pipelines  $ $E 1MM $$zzjjoodjj&:&:&E&ED&E&QRRR'%" 2'R's[ACB5CAB;B7B;! C,B9- C7B;9C;CC  CC)r?rvr*)r!zAsyncConnection[Row])r!AsyncConnection[Any]r'AsyncRowFactory[Row])r!rr'zAsyncRowFactory[Row] | None)returnr)r2ztype[BaseException] | Noner3zBaseException | Noner4zTracebackType | NonerNone)rr)rr)r'rrr)rz RowMaker[Row]r) rNrrO Params | NonerD bool | NonerErrr)rNrrZzIterable[Params]rSboolrr) rNrrOrrErr^intrAsyncIterator[Row])rz Row | None)r)r^rr list[Row])rr)rr)relative)rrrstrrr)rrrOrrzAsyncWriter | NonerzAsyncIterator[AsyncCopy])__name__ __module__ __qualname____firstlineno__ __slots__r r#r.r5r1propertyr'setterrArQr[rprxrrrrr rrt__static_attributes__ __classcell__)r+s@r"rrsJI ==  . @T  48 B(B1 BB,&%    !!// ' !% $"      *PU**(8*HL* *B!%0 # 000  0  0 0d &  "!%' &* ''' # ' " ''.SSr%rrN)&__doc__ __future__rtypesrtypingrrrrr contextlibr r rKr abcrrrrrrowsrrr_compatr _cursor_baser_pipeline_asyncrconnection_asyncrTransactionStatusrkrrr%r"rsh #HH*(00$*1   $ $}S*3S89}Sr%