R h$dZddlmZddlmZddlmZmZmZm Z m Z ddl m Z ddl mZddl mZdd lmZmZdd lmZmZdd lmZmZmZdd lmZdd lmZddlm Z erddl!m"Z"ej#j$Z$Gdde defZ%dS)z Psycopg Cursor object. ) annotations) TracebackType) TYPE_CHECKINGAnyIterableIteratoroverload)contextmanager)errors)pq)ParamsQuery)CopyWriter)Row RowFactoryRowMaker)Self)Pipeline) BaseCursor) ConnectioncDeZdZdZdZedGdZedHd 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)\Cursorpsycopg connectionConnection[Row]cdSNr)selfrs Y/var/www/html/01_SiteInternet/03_Maps/venv/lib/python3.11/site-packages/psycopg/cursor.py__init__zCursor.__init__#s58SConnection[Any] row_factoryRowFactory[Row]cdSr r)r!rr&s r"r#zCursor.__init__&s  sr$N)r&RowFactory[Row] | Nonecft||p|j|_dSr )superr#r& _row_factory)r!rr& __class__s r"r#zCursor.__init__+s3 $$$'A:+Ar$returnrc|Sr rr!s r" __enter__zCursor.__enter__1s r$exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | NoneNonec.|dSr )close)r!r2r4r6s r"__exit__zCursor.__exit__4s r$c.|dS)zI Close the current cursor and free associated resources. N)_closer0s r"r:z Cursor.close<s r$c|jS)z9Writable attribute to control how result rows are formed.r,r0s r"r&zCursor.row_factoryBs   r$cF||_|jr|||_dSdSr )r,pgresult _make_row)r!r&s r"r&zCursor.row_factoryGs3' = /([..DNNN / /r$ RowMaker[Row]c,||Sr r?r0s r"_make_row_makerzCursor._make_row_makerMs  &&&r$preparebinaryqueryrparams Params | NonerG bool | NonerHc   |jj5|j|||||dddn #1swxYwYn,#tj$r}|dd}~wwxYw|S)z= Execute a query or command to the database. rFN)_connlockwait _execute_gene _NO_TRACEBACKwith_traceback)r!rIrJrGrHexs r"executezCursor.executePs *   %%eVWV%TT                * * *##D)) ) * s: A2A  A AAAAB'A<<BF) returning params_seqIterable[Params]rWboolc  tjr|jj5|jj}|r/|j||||dddn #1swxYwY|s|j5|jj5|j||||dddn #1swxYwYdddn#1swxYwYdSdSdS|jj5|j||||ddddS#1swxYwYdS#tj $r}| dd}~wwxYw)zI Execute the same command with a sequence of input data. N) r is_supportedrNrO _pipelinerP_executemany_gen_pipelinepipeline_executemany_gen_no_pipelinerRrSrT)r!rIrXrWprUs r" executemanyzCursor.executemanyds  *$&& Z_ ,A  ::5*iXX,,..   ::5*iXX Z_JOO99%YWW * * *##D)) ) *sE>A+ E+A//E2A/3E C10C C1C C1!C "C1% E1C55E8C59E E0E > E EEEEF'E<<Fr rHsizerdint Iterator[Row]c #K|jjrtjd|jj5 |j|||||d}|j||rit|D]*}|j ||j }|n|V+d}|j||in,#tj $r}|dd}~wwxYw|jjt kr|j |j|dr/ |j|d/n#t$$rYnwxYw |j|dn#t$$rYnwxYwn#|jjt kr|j |j|dr/ |j|d/n#t$$rYnwxYw |j|dw#t$$rYwwxYwwxYwddddS#1swxYwYdS)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 modercTNF)first)_pgconnpipeline_statusrRProgrammingErrorrNrOrP_stream_send_gen_stream_fetchone_genrange_txload_rowrBrSrTtransaction_statusACTIVE _try_cancel Exception) r!rIrJrHrdrhposrecrUs r"streamz Cursor.streams < ' Q$%OPP P Z_    ))%T)RRjood&?&?&F&FGG"$T{{"""h//T^DD;!E! !E jood&?&?&F&FGG"? . . .''--- .<2f<<J**,,,"jood.G.Ge.G.T.TUU! #jood.G.Ge.G.T.TUU!$  (A(A(A(N(NOOOO$=4<2f<<J**,,,"jood.G.Ge.G.T.TUU! #jood.G.Ge.G.T.TUU!$  (A(A(A(N(NOOOO$=!                  sK4C C;:H;D$ DD$$H'.K4AF43K44 G>K4GK4.G43K44 H>K4HK4/K$5AJK$ J K$J K$$.KK$ K K$K K$$K44K8;K8 Row | Nonec|||j|j|j}||xjdz c_|S)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_fetchrorp_posrB)r!records r"fetchonezCursor.fetchones]  $$&&&""49dn==   IINII r$r list[Row]c@|||jsJ|s|j}|j|jt|j|z|jj|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` ) rzr{rA arraysizero load_rowsr|minntuplesrBlen)r!rdrecordss r" fetchmanyzCursor.fetchmanys  $$&&&} ">D($$ Is49t+T]-BCCT^   S\\! r$c|||jsJ|j|j|jj|j}|jj|_|S)z Return all the remaining records from the current recordset. :rtype: Sequence[Row], with Row defined by `row_factory` )rzr{rArorr|rrB)r!rs r"fetchallzCursor.fetchallsi  $$&&&}($$TY 0Et~VVM) r$c#Kdfd } |j}|dSxjdz c_|V)) Nrurer.rxcDj|jSr )rorprB)rur!s r"loadzCursor.__iter__..loads8$$S$.99 9r$Tr )rurer.rx)rzr{r|)r!rrows` r"__iter__zCursor.__iter__s  $$&&& : : : : : : $ty//C{ IINIIIII  r$relativevaluemodestrcZ||||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)rz_scroll)r!rrs r"scrollz Cursor.scrolls0  UD!!!!!r$writer statementr Writer | NoneIterator[Copy]c#K |jj5|j|||dddn #1swxYwYt ||5}|Vdddn #1swxYwYn,#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"rz Cursor.copysa * I I  4 4Y G GHHH I I I I I I I I I I I I I I Id6*** d                 * * *##D)) ) * ##A&&&&&s] B/A  B ABAB'A8, B8A<<B?A<BB-B((B-c|jdurr|jsm|jjrc|jj5|j|jjdddddS#1swxYwYdSdSdSdS)NFT)flush)_execmany_returningrArNr]rOrP _fetch_genr0s r"rzzCursor._fetch_pipelines  $E 1 1] 2 $ 2 M M  4 ? ?d ? K KLLL M M M M M M M M M M M M M M M M M M 2 1 1 1 1 1s9A//A36A3)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) rIrrJrKrHrLrdrer.rf)r.rx)r)rdrer.r)r.r)r.rf)r)rrerrr.r8)rrrJrKrrr.r)__name__ __module__ __qualname__ __slots__r r#r1r;r:propertyr&setterrErVrbrwr~rrrrr rrz __classcell__)r-s@r"rrsrJI 888X8    X UYBBBBBBBB  !!!X!//// '''' !% $" *PU******B!%1 # 111111f    (         " " " " "!%' !% '''''^'.MMMMMMMMr$rr%N)&__doc__ __future__rtypesrtypingrrrrr contextlibr r rRr abcrrrrrrowsrrr_compatrr]r _cursor_baserrrTransactionStatusrrrrr$r"rs #"""""CCCCCCCCCCCCCC%%%%%%++++++++++$$$$$$'&&&&&&  $AMAMAMAMAMZ)3. /AMAMAMAMAMr$