gi$dZddlmZddlmZddlmZmZmZm Z m Z ddl m Z ddl mZddl mZdd lmZmZdd lmZmZdd lmZmZmZdd lmZdd lmZddlm Z erddl!m"Z"ej#j$Z$GddedefZ%dS)z Psycopg AsyncCursor object. ) annotations) TracebackType) TYPE_CHECKINGAny AsyncIteratorIterableoverload)asynccontextmanager)errors)pq)ParamsQuery) AsyncCopy AsyncWriter)AsyncRowFactoryRowRowMaker)Self) BaseCursor) AsyncPipeline)AsyncConnectioncDeZdZdZdZedGdZedHd Zd d dIfd ZdJdZdKdZdLdZe dMdZ e j dNdZ dOdZ dPd d ddQd&Z d'd(dRd-Z dPd d.d/dSd3ZdTd5ZdUdVd8ZdWd9ZdXd:ZdYdZd?Ze dPd d@d[dEZdLdFZxZS)\ AsyncCursorpsycopg connectionAsyncConnection[Row]cdSNr)selfrs d/var/www/html/Pagina-Ingenieria-Requisitos/venv/lib/python3.11/site-packages/psycopg/cursor_async.py__init__zAsyncCursor.__init__ s:=#AsyncConnection[Any] row_factoryAsyncRowFactory[Row]cdSr r)r!rr&s r"r#zAsyncCursor.__init__#s  sr$N)r&AsyncRowFactory[Row] | Nonecft||p|j|_dSr )superr#r& _row_factory)r!rr& __class__s r"r#zAsyncCursor.__init__(s3 $$$'A:+Ar$returnrc K|Sr rr!s r" __aenter__zAsyncCursor.__aenter__1s  r$exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NoneNonec>K|d{VdSr )close)r!r2r4r6s r" __aexit__zAsyncCursor.__aexit__4s. jjllr$c2K|dS)zI Close the current cursor and free associated resources. N)_closer0s r"r:zAsyncCursor.close<s r$c|jS)z9Writable attribute to control how result rows are formed.r,r0s r"r&zAsyncCursor.row_factoryBs   r$cF||_|jr|||_dSdSr )r,pgresult _make_row)r!r&s r"r&zAsyncCursor.row_factoryGs3' = /([..DNNN / /r$ RowMaker[Row]c,||Sr r?r0s r"_make_row_makerzAsyncCursor._make_row_makerMs  &&&r$preparebinaryqueryrparams Params | NonerG bool | NonerHc @K |jj4d{V|j|||||d{Vdddd{Vn#1d{VswxYwYn,#tj$r}|dd}~wwxYw|S)z= Execute a query or command to the database. NrF)_connlockwait _execute_gene _NO_TRACEBACKwith_traceback)r!rIrJrGrHexs r"executezAsyncCursor.executePsQ *z        joo%%eVWV%TT                            * * *##D)) ) * s:A28A A2 A**A2-A*.A22BBBF) returning params_seqIterable[Params]rWboolc K |jj4d{Vtjr|jjr6|j||||d{Vn|j4d{V|j||||d{Vdddd{Vn#1d{VswxYwYn5|j||||d{Vdddd{VdS#1d{VswxYwYdS#tj $r}| dd}~wwxYw)zI Execute the same command with a sequence of input data. N) rNrOr is_supported _pipelinerP_executemany_gen_pipeline_pipeline_nolock_executemany_gen_no_pipelinerRrSrT)r!rIrXrWrUs r" executemanyzAsyncCursor.executemanyds  *z         -//z+ "joo ::5*iXX $(:#>#>#@#@"&*// $ > >$):y!"!"##*//99%YWW#                              ( * * *##D)) ) *s_EA5D- 6CD- C D- C !9D-E- D77E:D7;EE)E$$E)r rHsizercintAsyncIterator[Row]c K|jjrtjd|jj4d{V |j|||||d{Vd}|j||d{Vx}rqt|j D]%}|j ||j WV&d}|j||d{Vx}qn,#tj$r}|dd}~wwxYw|jjt"kr|jd{V |j|dd{Vr5 |j|dd{V5n#t&$rYnwxYw |j|dd{Vn #t&$rYnwxYwn#|jjt"kr|jd{V |j|dd{Vr5 |j|dd{V5n#t&$rYnwxYw |j|dd{Vw#t&$rYwwxYwwxYwdddd{VdS#1d{VswxYwYdS)a 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_statusrRProgrammingErrorrNrOrP_stream_send_gen_stream_fetchone_genrangentuples_txload_rowrBrSrTtransaction_statusACTIVE _try_cancel Exception) r!rIrJrHrcrgresposrUs r"streamzAsyncCursor.streams < ' Q$%OPP P:?         joo))%T)RR#':??43L3LU3S3S#T#TTTTTTTTc"$S[11EE"h//T^DDDDDDD!E$(:??43L3LU3S3S#T#TTTTTTTTc"? . . .''--- .<2f<<*00222222222$(JOO 55E5BB%%!!%)JOO 55E5BB%%!% "jood.G.Ge.G.T.TUUUUUUUUUU$!=4<2f<<*00222222222$(JOO 55E5BB%%!!%)JOO 55E5BB%%!% "jood.G.Ge.G.T.TUUUUUUUUUU$!=                              sMCDH:E&D;;EH:4M8A)G"!M" G/,M.G//M34H)'M) H63M5H66M:5L10A)KL1 K' $L1&K' 'L1+4L L1 L- *L1,L- -L11M MM Row | NonecK|d{V|}|j|jkr7|j|j|j}|xjdz c_|SdS)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_fetch_posrnrorprB)r!rurecords r"fetchonezAsyncCursor.fetchones""$$$$$$$$$**,, 9s{ " "X&&ty$.AAF IINIIMtr$r list[Row]c4K|d{V|}|s|j}|j|jt |j|z|j|j}|xjt|z c_|S)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) r{r| arraysizero load_rowsr}minrnrBlen)r!rcrurecordss r" fetchmanyzAsyncCursor.fetchmanys""$$$$$$$$$**,, ">D($$ Is49t+S[994>   S\\! r$cK|d{V|}|j|j|j|j}|j|_|S)z Return all the remaining records from the current recordset. :rtype: Sequence[Row], with Row defined by `row_factory` N)r{r|rorr}rnrB)r!rurs r"fetchallzAsyncCursor.fetchallsj ""$$$$$$$$$**,,($$TY T^LLK r$cK|d{V|}|j|jkrL|j|j|j}|xjdz c_|WV|j|jkJdSdS)Nr rz)r!rurows r" __aiter__zAsyncCursor.__aiter__s""$$$$$$$$$**,,i#+%%(##DIt~>>C IINIIIIIIi#+%%%%%%r$relativevaluemodestrcjK|d{V|||dS)a 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!rrs r"scrollzAsyncCursor.scrollsF""$$$$$$$$$ UD!!!!!r$writer statementrAsyncWriter | NoneAsyncIterator[AsyncCopy]cK |jj4d{V|j|||d{Vdddd{Vn#1d{VswxYwYt ||4d{V}|WVdddd{Vn#1d{VswxYwYn,#t j$r}|dd}~wwxYw|ddS)zU Initiate a :sql:`COPY` operation and return an object to manage it. Nrr) rNrOrP_start_copy_genrrRrSrT_select_current_result)r!rrJrcopyrUs r"rzAsyncCursor.copys; *z O O O O O O O Ojood&:&:9f&M&MNNNNNNNNN O O O O O O O O O O O O O O O O O O O O O O O O O O O!f555                                    * * *##D)) ) * ##A&&&&&s^B/5A B/ A''B/*A'+B/B B/ B''B/*B'+B//C>CCc8K|jdur|js|jjr{|jj4d{V|j|jjdd{Vdddd{VdS#1d{VswxYwYdSdSdSdS)NFT)flush)_execmany_returningrArNr]rOrP _fetch_genr0s r"r{zAsyncCursor._fetch_pipelinesk  $E 1 1M 2 $ 2z S S S S S S S Sjoodj&:&E&ED&E&Q&QRRRRRRRRR S S S S S S S S S S S S S S S S S S S S S S S S S S S S S S 2 1 1 1 1 1s?B B B )rr)rr%r&r')rr%r&r))r.r)r2r3r4r5r6r7r.r8)r.r8)r.r')r&r'r.r8)r.rCr ) rIrrJrKrGrLrHrLr.r)rIrrXrYrWrZr.r8) rIrrJrKrHrLrcrdr.re)r.rx)r)rcrdr.r)r.r)r.re)r)rrdrrr.r8)rrrJrKrrr.r)__name__ __module__ __qualname__ __slots__r r#r1r;r:propertyr&setterrErVrarwrrrrrr rr{ __classcell__)r-s@r"rrsqJI ===X=    X 48 BBBBBBBB !!!X!//// '''' !% $" *PU******B!%0 # 000000d &     " " " " "!%' &* ''''''.SSSSSSSSr$rr%N)&__doc__ __future__rtypesrtypingrrrrr contextlibr r rRr abcrrrrrrowsrrr_compatr _cursor_baser_pipeline_asyncrconnection_asyncrTransactionStatusrrrrr$r"rs #"""""HHHHHHHHHHHHHH******((((((((0000000000$$$$$$******2111111  $}S}S}S}S}S*3S89}S}S}S}S}Sr$