(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 Cursor object. ) annotations) TracebackType)AnyIteratorIterable TYPE_CHECKINGoverload)contextmanager)pq)errors)QueryParams)CopyWriter)RowRowMaker RowFactory)Self)Pipeline) BaseCursor) Connectionc^\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$)5CursorpsycopgcgNr)self connections A/var/www/html/venv/lib/python3.13/site-packages/psycopg/cursor.py__init__Cursor.__init__#s58cgrr)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%cU$rrr s r" __enter__Cursor.__enter__1s r%c$UR5 gr)close)r exc_typeexc_valexc_tbs r"__exit__Cursor.__exit__4s r%c$UR5 g)z9 Close the current cursor and free associated resources. N)_closer-s r"r1 Cursor.close<s  r%cUR$)z9Writable attribute to control how result rows are formed.r*r-s r"r'Cursor.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_makerCursor._make_row_makerMs  &&r%preparebinaryc URR URRURXX4S95 SSS5 U$!,(df  U$=f![R anUR S5eSnAff=f)z- Execute a query or command to the database. rCN)_connlockwait _execute_gene _NO_TRACEBACKwith_traceback)r queryparamsrDrEexs r"executeCursor.executePsv * %%eW%T!  !   *##D) ) *s4A*A A AAAB2BBF) returningc j[R"5(aURR URRnU(a+URR UR XU55 SSS5 W(dnURR5 URR URR UR XU55 SSS5 SSS5 ggURR URR URXU55 SSS5 g!,(df  N=f!,(df  Nt=f!,(df  g=f!,(df  g=f![RanURS5eSnAff=f)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" executemanyCursor.executemanyds$  *$$&&ZZ__ ,,A  ::5iX%,,.   ::5iX1@.. ZZ__JJOO99%YW%_%_1@.. %_ *##D) ) *s0FA E;)F$E&;,E'E&/F9F,E7;F EF E# E&& E40F4F7 FFFF2F--F2r rEsizec #R# URR(a[R"S5eURR  URR URXX4S95 SnURR URU55(as[U5H1nURRX`R5nUc OUv M3 SnURR URU55(aMsURR[ :XaURR#5 URR URSS95(a0URR URSS95(aM0URR URSS95 OSSS5 g![RanURS5eSnAff=f![$a Nmf=f![$a NRf=f!URR[ :XaURR#5 URR URSS95(a0URR URSS95(aM0O![$a Of=fURR URSS95 f![$a ff=ff=f!,(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 moder^TNF)first)_pgconnpipeline_statusrKProgrammingErrorrGrHrI_stream_send_gen_stream_fetchone_genrange_txload_rowr?rLrMtransaction_statusACTIVE _try_cancel Exception) r rNrOrEr_raposrecrPs r"stream Cursor.streams << ' '$$%OP P ZZ__  ))%)Rjjood&?&?&FGG$T{"hh//^^D;!! + "E jjood&?&?&FGG<<22f<JJ**,"jjood.G.Ge.G.TUU #jjood.G.Ge.G.TUU (A(A(A(NO=!_?? .''-- .%%<<22f<JJ**,"jjood.G.Ge.G.TUU #jjood.G.Ge.G.TUU$  (A(A(A(NO$=!_sAL' L C G#8LAH0(H L L'#H 7HH  H0 HLHL H-*L,H--L09L*AKL K LK L(LL L LL LL L$ L'cUR5 UR5 URRURUR 5nUbU=RS- slU$)z Return the next record from the current recordset. Return `!None` the recordset is finished. :rtype: Row | None, with Row defined by `row_factory` r )_fetch_pipeline_check_result_for_fetchrhri_posr?)r records r"fetchoneCursor.fetchonesR  $$&""499dnn=   IINI r%cUR5 UR5 UR(deU(d URnURR UR [UR U-URR5UR5nU=R [U5- slU$)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` ) rsrtr> arraysizerh load_rowsruminntuplesr?len)r r_recordss r" fetchmanyCursor.fetchmanys  $$&}}}>>D(($$ IIs499t+T]]-B-BCT^^  S\! r%c,UR5 UR5 UR(deURR UR URR UR5nURR UlU$)zx Return all the remaining records from the current recordset. :rtype: Sequence[Row], with Row defined by `row_factory` )rsrtr>rhr{rur}r?)r rs r"fetchallCursor.fetchallsh  $$&}}}(($$TYY 0E0Et~~VMM)) r%c#^# TR5 TR5 SU4SjjnU"TR5nUcgT=RS- slUv M17f)NcP>TRRUTR5$r)rhrir?)rnr s r"loadCursor.__iter__..loads88$$S$..9 9r%r )rnintreturn Row | None)rsrtru)r rrows` r"__iter__Cursor.__iter__sT  $$& :tyy/C{ IINII sAAcFUR5 URX5 g)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"scroll Cursor.scrolls  U!r%writerc## URR URRURX55 SSS5 [ XS9nUv SSS5 URS5 g!,(df  N6=f!,(df  N1=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"r Cursor.copys *  4 4Y GH!d*d + ##A&!+* *##D) ) *scCB+A5BBB#C5 B?B BBCBC+B<<CCcXURSLaUR(dxURR(a\URR URR URRR SS95 SSS5 gggg!,(df  g=f)NFT)flush)_execmany_returningr>rGrVrHrI _fetch_genr-s r"rsCursor._fetch_pipelinesu  $ $E 1]] $$  4 4 ? ?d ? KL!%# 2!s =B B))r?rur*)r!zConnection[Row])r!Connection[Any]r'RowFactory[Row])r!rr'zRowFactory[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_rr Iterator[Row])rr)r)r_rr list[Row])rr)rr)relative)rrrstrrr)rrrOrrz Writer | NonerzIterator[Copy])__name__ __module__ __qualname____firstlineno__ __slots__r r#r.r5r1propertyr'setterrArQr\rprwrrrrr rrs__static_attributes__ __classcell__)r+s@r"rrsJI 88  ) ;J  UYB)B;QBB ,&%    !!// ' !% $"      *PU**(8*HL* *B!%1 # 111  1  1 1f (   "!%' !% '''  '  ''.MMr%rrN)&__doc__ __future__rtypesrtypingrrrrr contextlibr r r rKabcrrrrrrowsrrr_compatrrVr _cursor_baserr!rTransactionStatusrkrrr%r"rsh #CC%++$&   $ $AMZ)3. /AMr%