[ui H d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlmZ ddlm Z dd lm
Z
dd
lm Z dd lm Z dd lm
Z dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ej dej ej z Z ej dej ej z Z G d dej Z G d de Z G d de ej Z G d de ej! Z" G d d e ej# Z$ G d d e Z% G d d!ej& Z'e'e _( dS )"a Default implementations of per-dialect sqlalchemy.engine classes.
These are semi-private implementation classes which are only of importance
to database dialect authors; dialects will usually use the classes here
as the base class for their own corresponding classes.
N )
interfaces)
reflection)result )event)exc)pool)
processors)types)util)compiler)
expression)schema) quoted_namez-\s*(?:UPDATE|INSERT|CREATE|DELETE|DROP|ALTER)z \s*SELECTc e Zd ZdZej Zej Zej Z
ej Z dZ
dZdZdZeZdZdZdZdZdZdZdZdZdZdZ dZ dZ dZ e j! d e j" d fde j# fd e j" d fd
e j" d fd e j# fd e j# fd
e j# fde j$ fg Z%dZ&e j' r dZ(dZ)dZ*dZ+ndZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2i Z3dZ4dZ5dZ6dZ7dZ8dZ9dZ:dZ;dZ< dZ=dZ> e j! Z? e j@ d d?d ZAe jB d ZCeDd ZEeDd ZFeGd ZHeGd ZId ZJd ZKd! ZLd" ZMd@d#ZNd$ ZOd% ZPd& ZQd@d'ZRd( ZSd) ZTd* ZUd+ ZVd, ZWd- ZXd. ZYd/ ZZd0 Z[d1 Z\e jB d2 Z]d3 Z^d4 Z_d5 Z`d6 Zad7 Zbd@d8Zcd@d9Zdd@d:Zed; Zfd< Zgd= Zhd> ZidS )ADefaultDialectz!Default implementation of DialectTFr convert_unicodeforce pool_timeoutechodebug echo_pool pool_recycle pool_size max_overflowpool_threadlocalN use_encodingdefaulti' named )z1.3zThe :paramref:`_sa.create_engine.convert_unicode` parameter and corresponding dialect-level parameters are deprecated, and will be removed in a future release. Modern DBAPIs support Python Unicode natively and this parameter is unnecessary.)r utf-8staticc t | dd s t j d| j z || _ || _ d| _ d | _ || _ ||| _ n%| j | j j | _ n | j
| _ ||| _ | j dv | _ | | | _
| | | _ ||| _ ||| _ || _ | | _ | dk rd| _ n+| dv rd| _ | dk | _ nt+ j d |
| _ | j r | j | _ | | _ | j d
k rt7 j | | _ n%| j t7 j | j | _ t= j | j | _ t7 j | j | _! d S ) Nported_sqla_06Tz2The %s dialect is not yet ported to the 0.6 formatF)qmarkformatnumericr# )dynamic dynamic_warnr* z?empty_in_strategy may be 'static', 'dynamic', or 'dynamic_warn'r )"getattrr
warnnamer encoding
positional_ischemadbapi
paramstyledefault_paramstyleimplicit_returningprepareridentifier_preparer
type_compilersupports_right_nested_joinssupports_native_booleancase_sensitiveempty_in_strategy_use_static_in_warn_on_empty_inr
ArgumentError#_user_defined_max_identifier_lengthmax_identifier_length label_lengthdescription_encodingr to_unicode_processor_factory_description_decodercodecs
getencoder_encoder_decoder)
selfr r. r2 r1 r4 r8 r: r9 r; r@ rA kwargss
m/builddir/build/BUILD/cloudlinux-venv-1.0.10/venv/lib64/python3.11/site-packages/sqlalchemy/engine/default.py__init__zDefaultDialect.__init__ s 2 t -t44 ID)
/
! (DOO
Z
# "j 3DOO " 5DO )&8D # /-KK#'==#6#6 ! / / 5 5 & 2/JD , " .+BD ( ,!2 ( ("&D
"=
=
="'D %6.%HD " "#/
4I0 3 8
& ) $ 6 67) )D % %
&
27')) ))D % )$-88
"?
NN
c ( t j S N)weakrefWeakKeyDictionaryrI s rK _type_memoszDefaultDialect._type_memos s (***rM c & | j dz | j z S )N+)r- driverrR s rK dialect_descriptionz"DefaultDialect.dialect_description s y3,,rM c | j S )zTrue if this dialect supports sane rowcount even if RETURNING is
in use.
For dialects that don't support RETURNING, this is synonymous with
``supports_sane_rowcount``.
)supports_sane_rowcountrR s rK supports_sane_rowcount_returningz/DefaultDialect.supports_sane_rowcount_returning s
**rM c 8 t | dt j S )N poolclass)r+ r
QueuePool)clsurls rK get_pool_classz DefaultDialect.get_pool_class) s sK 888rM c d | j d dd } t |dz d S # t $ r Y d S w xY w)N.r z
.provision)join
__module__split
__import__ ImportError)r^ packages rK load_provisioningz DefaultDialect.load_provisioning- sl ((3>//44QrT:;; w - . . . . . DD s A
AAc | | | _ n# t $ r
d | _ Y nw xY w | | | _ n# t $ r
d | _ Y nw xY w | |j | _ n# t $ r
d | _ Y nw xY w| | | _ | j
#| | rd x| _ | _
| j
s | | }|r|| _ | j r3| j | j k r%t# j d| j | j fz d S d S )NzQLabel length of %d is greater than this dialect's maximum identifier length of %d)_get_server_version_infoserver_version_infoNotImplementedError_get_default_schema_namedefault_schema_nameget_default_isolation_level
connectiondefault_isolation_level_check_unicode_returnsreturns_unicode_stringsrB _check_unicode_descriptionrD r? _check_max_identifier_lengthr@ rA r r> )rI rr max_ident_lengths rK
initializezDefaultDialect.initialize5 s ,'+'D'D( (D $ $ # , , ,'+D $ $ $ , ,'+'D'D( (D $ $ # , , ,'+D $ $ $ , 0+/+K+K%, ,D ( ( # 0 0 0+/D ( ( ( 0 (,'B'B:'N'N$
% 1//
;;
2 EI HD %(A7 > # @ @ L L
>-=*
!D$>>>#3$d&@AB
>>s/ 11A A$#A$( B B B c d S rO r! rR s rK
on_connectzDefaultDialect.on_connecta s trM c dS )zPerform a connection / server version specific check to determine
the max_identifier_length.
If the dialect's class level max_identifier_length should be used,
can return None.
.. versionadded:: 1.3.9
Nr! )rI rr s rK rw z+DefaultDialect._check_max_identifier_lengthe s trM c , | | S )a Given a DBAPI connection, return its isolation level, or
a default isolation level if one cannot be retrieved.
May be overridden by subclasses in order to provide a
"fallback" isolation level for databases that cannot reliably
retrieve the actual isolation level.
By default, calls the :meth:`_engine.Interfaces.get_isolation_level`
method, propagating any exceptions raised.
.. versionadded:: 1.3.22
)get_isolation_levelrI
dbapi_conns rK rq z*DefaultDialect.get_default_isolation_levelq s ''
333rM c t j r j s
t j n t j j r ni fdt j t j d t j d t j t j d t j d g}|r||z
}fd|D }|
ddg rdS |dhk S ) Nc t j | g } j } || | }| t |d t j
S # t j $ r"}t j
d|z Y d }~dS d }~ww xY w)Ndialectr z2Exception attempting to detect unicode returns: %rF)r selectcompilerr cursor_cursor_executefetchoneclose
isinstancer
text_typer
DBAPIErrorr, ) test statementr rowdecast_torr
parametersrI s rK
check_unicodez.check_unicode s !4&))11$1?? I
:#.5577**69jIII oo'' "#a&$.999 >
1356 uuuuu
s AB- -C <CC z'test plain returns'< z'test unicode returns'c & h | ]
} | S r! r! ).0r r s rK z8DefaultDialect._check_unicode_returns.. s# 9994==&&999rM TF conditional)r
py2ksupports_unicode_statements binary_typer r/ execute_sequence_formatr castliteral_columnsqltypesVARCHARUnicode
issuperset)rI rr additional_teststestsresultsr r r s `` @@@rK rt z%DefaultDialect._check_unicode_returns s3 9 %T = %&GGnG ? 5577JJJ : : : : : : : :,
O)*@AA $$
O)*BCC $$
& % %E99995999 tUm , , % =tf$ $rM c t j r| j s
t j }n t j }|j } | |t j t j
d d g | t |j d d t j | S # | w xY w)Nz'x'
some_labelr r )r
r r r r rr r executer r r labelr r descriptionr )rI rr r r s rK rv z)DefaultDialect._check_unicode_description s
9 %T = %&GGnG&--//
NN %#2599?? MMN gdg++
f 0 3A 6GG LLNNNNFLLNNNNs
BC0 0Dc 6 t j || j S )a) Provide a database-specific :class:`.TypeEngine` object, given
the generic object which comes from the types module.
This method looks for a dictionary called
``colspecs`` as a class or instance-level variable,
and passes on to :func:`_types.adapt_type`.
)r
adapt_typecolspecs)rI typeobjs rK type_descriptorz DefaultDialect.type_descriptor s "7DM:::rM c b t j | } |j ||||fi |S rO )r Inspector from_engine reflecttable)rI rr tableinclude_columnsexclude_columns resolve_fksoptsinsps rK r zDefaultDialect.reflecttable sG #//
;; t ?O[
DH
rM c ( d | j ||fd|i|iS )zCompatibility method, adapts the result of get_primary_keys()
for those dialects which don't implement get_pk_constraint().
constrained_columnsr )get_primary_keys)rI conn
table_namer kws rK get_pk_constraintz DefaultDialect.get_pk_constraint s=
"#84#8j$ $)/$35$ $
rM c r t | | j k r t j d|| j fz d S )Nz7Identifier '%s' exceeds maximum length of %d characters)lenr@ r IdentifierError)rI idents rK validate_identifierz"DefaultDialect.validate_identifier sF u::2 2 2%I$456
3 2rM c & | j j |i |S rO )r1 connect)rI cargscparamss rK r zDefaultDialect.connect s !tz!54G444rM c f | }| |j g |gS rO )translate_connect_argsupdatequery)rI r_ r s rK create_connect_argsz"DefaultDialect.create_connect_args s1 ))++ CI DzrM c d|v r)|d t j |d fd }d|v rCt j |d |_ t j |d fd }d S d S )Nisolation_levelengine_connectc < |s | d S d S rO )_set_connection_isolation)rr branchr rI s rK
set_isolationzBDefaultDialect.set_engine_execution_options..set_isolation s4 P22:OOOOOP PrM schema_translate_mapc | _ d S rO )schema_for_object)rr r getters rK set_schema_translate_mapzMDefaultDialect.set_engine_execution_options..set_schema_translate_map s /5
,,,rM )r listens_forr _schema_getterr )rI enginer r r r r s ` @@rK set_engine_execution_optionsz+DefaultDialect.set_engine_execution_options s $ $ "#4 5O
v'7
8
8
P
P
P
P
P 9
8
P "T ) )*40F+GHHF'-F $
v'7
8
8
6
6
6
6 9
8
6
6
6 * )rM c d|v r | ||d d|v r#t j |d }||_ d S d S )Nr r )r r r r )rI rr r r s rK set_connection_execution_optionsz/DefaultDialect.set_connection_execution_options s` $ $ * *:t>> 0BII &
rM c d S rO r! rI dbapi_connections rK do_beginzDefaultDialect.do_begin* rM c . | d S rO )rollbackr s rK do_rollbackzDefaultDialect.do_rollback- s !!#####rM c . | d S rO )commitr s rK do_commitzDefaultDialect.do_commit0 s !!!!!rM c . | d S rO )r r s rK do_closezDefaultDialect.do_close3 s rM c n t t j dg | S )Nr r )strr r r rR s rK _dialect_specific_select_onez+DefaultDialect._dialect_specific_select_one6 s. :$aS))11$1??@@@rM c 2 d } | } | | j | n# | w xY w dS # | j j $ r#}| ||| rY d }~dS d }~ww xY wNTF)r r r r r1 Error
is_disconnect)rI r r errs rK do_pingzDefaultDialect.do_ping: s %,,..F
t @AAA 4
z !!#'7@@
uuuuu s3 A$ A A$ A A$ $B3BBBc 8 dt j dddz z S )zCreate a random two-phase transaction ID.
This id will be passed to do_begin_twophase(), do_rollback_twophase(),
do_commit_twophase(). Its format is unspecified.
z _sa_%032xr r )randomrandintrR s rK
create_xidzDefaultDialect.create_xidJ s V^AqCx 8 888rM c T | t j | d S rO )r r SavepointClauserI rr r- s rK do_savepointzDefaultDialect.do_savepointS s' :5d;;<<<<.process s E> !rM r! )rI r r` s rK literal_processorz!_RendersLiteral.literal_processor s " " " rM N)r+ re r, ra r! rM rK r\ r\ s# rM r\ c e Zd ZdS ) _StrDateTimeNr+ re r, r! rM rK rc rc DrM rc c e Zd ZdS )_StrDateNrd r! rM rK rg rg re rM rg c e Zd ZdS )_StrTimeNrd r! rM rK ri ri re rM ri c e Zd Zej Zej Zej Z ej
Z dZ dZ
dZdZdZdZej eej eej eiZdS )StrCompileDialectTFN)r+ re r, r StrSQLCompilerr/ r0 r1 StrSQLTypeCompilerr7 r3 r5 r: r; r< r4 r9 rA r DateTimerc Daterg Timeri r r! rM rK rk rk sr !0'L /M*H ).& "%)" <
x
xHHHrM rk c p e Zd ZdZdZdZdZdZdZdZ dZ
dZ dZ dZ
dZdZdZ ej Zed Zed Zd Zed Zed Zej d Zej d Z ej d
Z ej d Z ej d Z ej d
Z ej d Z!d Z"e#d Z$d Z%d Z&d Z'd Z(d Z)d Z*d Z+d Z,d Z-d Z.e#d Z/d Z0d Z1d Z2d Z3d Z4d! Z5d" Z6 d+d#Z7d$ Z8dZ9 d,d&Z:d' Z;d( ZdS )-DefaultExecutionContextFNc z | | }||_ ||_ |j |_ |x|_ }d|_ |j |_ |j r8t |j |_ |j |j |j
s?t j | |_
| |j
d |_ n t j | x|_ |_
| |_ g |_ |j r| g|_ ni g|_ |S )z8Initialize execution context for a DDLElement construct.Tr )__new__root_connection_dbapi_connectionr compiledisddlexecution_options_execution_optionsdictr r r
r unicode_statementrG r
create_cursorr compiled_parametersr/ r r )r^ r rr r compiled_ddlrI rw s rK _init_ddlz!DefaultExecutionContext._init_ddl s( {{3 ) !1 !) #//
!)!; ( I%)$*@%A%AD " " ) )**G H H H2 O%)^H%=%=D " $ - -d.D E Ea HDNN6:nX6N6N NDNT 3((** #% # & > > @ @ ADOO !dDO rM c | | }||_ ||_ |j |_ |_ j sJ j |j |_ j j
j f|_ t j |_ j s*|j |j j |_ n |j |_ j |_ j |_ j |_ j |_ |s g|_ n8fdt7 | D |_ t9 | dk |_ | |_ |j s|j s|j rKd|_ tC j j" |_# tC j$ o j j" |_% |j j& s |j j' r0|j r|( n|) j* j+ r&tY |- }nj. r |j j/ }g }j. r|j D ]{ g }|D ]L} | v r+|0 | | 1|0 | M|0 1 | |ncj }
|j D ]S |
r tY fd D }n tY fd D }|0 | T1 | |_2 |S )z6Initialize execution context for a Compiled construct.c D g | ] \ }} || S ))
_group_number)construct_params)r grpmrw s rK
z:DefaultExecutionContext._init_compiled... s@ ( ( (C ))!3)??( ( (rM r Tc 3 K | ]B} | d |v r | | n| fV CdS )r NrG )r keycompiled_paramsr r s rK z9DefaultExecutionContext._init_compiled.._ s ! ! $ , ,S 1 1! 4 "j 0 0 ,JsOOC,@ A A A!0!5 ! ! ! ! ! !rM c 3 b K | ])}||v r | | n| fV *d S rO r! )r r r r s rK r z9DefaultExecutionContext._init_compiled..i sl ! ! "j 0 0 ,JsOOC,@ A A A!0!5 ! ! ! ! ! !rM )3rt ru rv r rw can_executery unionrz _result_columns_ordered_columns_textual_ordered_columnsresult_column_structr
r r| r r( r. r isinsertisupdateisdelete isplaintextis_textr r~ enumerater r r} r is_crudbool
_returning_is_explicit_returning returning_is_implicit_returninginsert_prefetchupdate_prefetch _process_executemany_defaults _process_executesingle_defaults_bind_processors contains_expanding_parametersr{ _expand_in_parametersr/ positiontupr r r )
r^ r rr r rw r rI r paramr r( r r s
` ` @@rK _init_compiledz&DefaultExecutionContext._init_compiled s {{3 ) !1 !)
####!)!;!A!A )"
"
$ % -%
! "& !9!9 2 4 ! 3 : : % DNN " 3DN )
)
)
+ 3(0(A(A(C(C'DD $ $( ( ( ( '
3 3( ( (D $
#: 2D ((** = DM T] DL*.x/A/L*M*MD '*."H8+=+H'H+ +D ' = ( 7DM,I 7
722444444666 .
1 4 j))J 44XzJJKK
4 -3K
" )#'#;
J
J& ; ;Cj(( _Z__S5I%J%JKKKK _S%9::::!!'"A"A%"H"HIIII
J !<. sh < < < 0=,5mQ,G,G< < !)5 ,044AA 6 >< < < <rM r zVALUES , c 3 K | ];\ d d fdt D z V .. ss ( ( %-Au
!%
:$*I()C
,>,>(>(B-&&'-)#"!"( ( ( ( ( ( rM N)rd r )r r r rI r s @@rK r z@DefaultExecutionContext._expand_in_parameters.. s & & !1= # "ii ( ( ( ( ( ( ( 1:-0H0H( ( ( & & & & & &rM c ( g | ]\ }}d ||fS )r r! )r r r_ r- s rK r zADefaultExecutionContext._expand_in_parameters.. s= < < < (5 )-aa 0% 8< < <rM c 3 @ K | ]\ }}j j d |iz V dS )r- N)rw r )r r r_ rI s rK r z@DefaultExecutionContext._expand_in_parameters.. sQ B B *U !M 6&# FB B B B B BrM c 3 : K | ]\ }}v | fV d S rO r! )r r r_ r- r s rK r z@DefaultExecutionContext._expand_in_parameters.. sH " ""Uz)) *T*+))))" "rM c 3 K | ] \ }}|V
d S rO r! )r r- r_ s rK r z@DefaultExecutionContext._expand_in_parameters.. s& &I&I et&I&I&I&I&I&IrM c g | ]\ }}|S r! r! )r
expand_keyr_ s rK r zADefaultExecutionContext._expand_in_parameters.. s) 3 3 3#4:uJ3 3 3rM c : | d S )Nr )group)r replacement_expressionss rK process_expandingzHDefaultExecutionContext._expand_in_parameters..process_expanding s *1771::6 6rM z\[EXPANDING_(\S+)\]) r r InvalidRequestErrorrw r/ _numeric_bindsrn _expanded_parametersr~ r binds expandingpopvisit_empty_set_expr_expanding_in_typestyper r8 listr r rB rd r extendr resubr ) rI rw r r r to_update_sets parametervaluesr r- r r s ` ` @@@rK r z-DefaultExecutionContext._expand_in_parametersy s
)L
= #
(D %5
%'! 215 KK K"$ "
%DM % % $H ) H )D
+D1I" B
)222 .t 4II - 0 0 6 6F! ';== N4$8 !M > > ( < 2I 9 9"+.!1 0 $F1It}== < < < <4=fa4H4H< < < N4$8 *. )E MII2 II & & & & & 5>f4E4E & & & 9/55 < < < <,5fa,@,@< < < N4$8 9= B B B B.7B B B 9 9/5
&&y111!
! " " " " "&/" " "
& J &&&I&Iy&I&I&IIII3 38A3 3 3)$// $
)""4((( 7 7 7 7 7 "$5t~
rM c | | }||_ ||_ |j |_ d|_ |j |_ |s0|j j r g|_ ni g|_ nwt |d j r||_ nTt |d t r&j r||_ n*fd|D pi g|_ nfd|D |_ t | dk |_ j sBt |t j r(||_ | d |_ n|x|_ |_ | |_ |S )z8Initialize execution context for a string SQL statement.Tr c 0 g | ]fd D S )c T i | ]$} | d | %S )r r )r kdr s rK
zFDefaultExecutionContext._init_statement... s2 ===aW%%a((+QqT===rM r! )r r r s @rK r z;DefaultExecutionContext._init_statement.. sA # # # >====1===# # #rM c : g | ]} | S r! )r )r pr s rK r z;DefaultExecutionContext._init_statement.. s4 78//22 rM r )rt ru rv r r rz ry r/ r r r r{ r r r r
r r| rG r r} r )r^ r rr r r r rI s ` rK _init_statementz'DefaultExecutionContext._init_statement s {{3 ) !1 !) ",!> |&
'#*#B#B#D#D"E#%$
1
w'F
G
G
(DOO
1
t
,
, 2
",# # # # '# # # # T
((** rM c | j r | j j S d| j v r*| j j | j d S | j j S )Nr )rw r5 ry r r6 _with_schema_translaterR s rK r6 z+DefaultExecutionContext.identifier_preparer# s[ = 4=) )
#t'=
=
=<3JJ&'=>
<3 3rM c | j j S rO )ru r rR s rK r z DefaultExecutionContext.engine. s #**rM c | j j S rO )rw postfetchrR s rK postfetch_colsz&DefaultExecutionContext.postfetch_cols2 s
}&&rM c R | j r | j j S | j r | j j S dS )Nr! )r rw r r r rR s rK
prefetch_colsz%DefaultExecutionContext.prefetch_cols6 s1 = =0 0
] =0 02rM c | j j d S rO )rw r rR s rK returning_colsz&DefaultExecutionContext.returning_cols? s
rM c 8 | j dd S )N
no_parametersF)ry getrR s rK r z%DefaultExecutionContext.no_parametersC s %))/5AAArM c | j d| j r| j r t j pd }|t j u r| | j S |S )N
autocommitF)ry r rw r r PARSE_AUTOCOMMITshould_autocommit_textr| )rI r s rK should_autocommitz)DefaultExecutionContext.should_autocommitG sq +//
,
,+
4 4 4..t/EFF F rM c | j }t |t j r,| j j s | j | d }| j j r| j }ni }| | j
||| | j
d }|>| | j | j
j
d d }|r || S |S )a Execute a string statement on the current cursor, returning a
scalar result.
Used to fire off sequences, default phrases, and "select lastrowid"
types of statements individually or in the context of a parent INSERT
or UPDATE statement.
r )r Nr )ru r r
r r r rG r/ r r r r _cached_result_processorr )rI stmttype_r default_paramsrprocs rK _execute_scalarz'DefaultExecutionContext._execute_scalarV s # tT^ , , 2L< 2 <((..q1D < " !\ A A C CNN N T[$ MMM K " "1 % 11 dk 5a 8 ; D
tAwwrM c 4 | j S rO )ru _branchrR s rK rr z"DefaultExecutionContext.connectionw s #++---rM c 6 t | S rO )AUTOCOMMIT_REGEXPmatch)rI r s rK r z.DefaultExecutionContext.should_autocommit_text{ s &&y111rM c | j j sdS | j j r| j dd o|| j r$t
| j j t j pQ| j p#t
| j j t j
o%| j o t | j }n| j dd }|S )NFstream_resultsT)
r rQ server_side_cursorsry r rw r r r
Selectable
TextClauseSERVER_SIDE_CURSOR_REr )rI use_server_sides rK _use_server_side_cursorz/DefaultExecutionContext._use_server_side_cursor~ s |8 5 < + " 4 8 8 $ M "
/1F
!%
- ) $
79N H !N
H 2 7 7 G G!
O* # 4 8 8 % O rM c | rd| _ | S d| _ | j S r )r _is_server_sidecreate_server_side_cursorrv r rR s rK r} z%DefaultExecutionContext.create_cursor sM ' ' ) ) 3#'D 1133 3#(D )0022 2rM c t rO )rn rR s rK r z1DefaultExecutionContext.create_server_side_cursor s !###rM c d S rO r! rR s rK pre_execz DefaultExecutionContext.pre_exec r rM c d S rO r! rR s rK post_execz!DefaultExecutionContext.post_exec r rM c 8 | | j | S )zReturn a 'result processor' for a given type as present in
cursor.description.
This has a default implementation that dialects can override
for context-sensitive result type handling.
)r r )rI r colnamecoltypes rK get_result_processorz,DefaultExecutionContext.get_result_processor s --dlGDDDrM c | j j S )a return self.cursor.lastrowid, or equivalent, after an INSERT.
This may involve calling special cursor functions,
issuing a new SELECT on the cursor (or a new one),
or returning a stored value that was
calculated within post_exec().
This function will only be called for dialects
which support "implicit" primary key generation,
keep preexecute_autoincrement_sequences set to False,
and when no explicit id value was bound to the
statement.
The function is called once, directly after
post_exec() and before the transaction is committed
or ResultProxy is generated. If the post_exec()
method assigns a value to `self._lastrowid`, the
value is used in place of calling get_lastrowid().
Note that this method is *not* equivalent to the
``lastrowid`` method on ``ResultProxy``, which is a
direct proxy to the DBAPI ``lastrowid`` accessor
in all cases.
)r lastrowidrR s rK
get_lastrowidz%DefaultExecutionContext.get_lastrowid s 4 {$$rM c d S rO r! )rI r s rK handle_dbapi_exceptionz.DefaultExecutionContext.handle_dbapi_exception r rM c ` | j rt j | S t j | S rO )r r BufferedRowResultProxy ResultProxyrR s rK get_result_proxyz(DefaultExecutionContext.get_result_proxy s/ ,066 6%d++ +rM c | j j S rO )r rowcountrR s rK r z DefaultExecutionContext.rowcount s
{##rM c | j j S rO )r rY rR s rK rY z.DefaultExecutionContext.supports_sane_rowcount s
|22rM c | j j S rO )r rL rR s rK rL z4DefaultExecutionContext.supports_sane_multi_rowcount s
|88rM c t | j rV| j sO| j s-| j j s!| j j r| n| j s| | }| j rg| j rB |j
}|| _ | | |j
d |_ nv| j s |j
d |_ nX| j r4| j r- |j
}|| _ |j
d |_ n |j |j |j
|S rO )r r r rw inliner r= _setup_ins_pk_from_lastrowid_setup_ins_pk_from_emptyr r returned_defaults%_setup_ins_pk_from_implicit_returning _soft_close _metadatar r r )rI r r s rK _setup_crud_result_proxyz0DefaultExecutionContext._setup_crud_result_proxy sr =
0!1
0/
0
,
0 L4
0 1133330
0--///&&(( = !*
(%fo''),&::3???""$$$#' 0
(""$$$#'
] !t : !!&/##C%(D " F #F
%
OO F
rM c r | j j d | j j j }| j d | S|j -j | j d }| | fd|j
D | _ d S fd|j
D | _ d S )Nr r c Z g | ]'}|u rn | d (S rO r )r c autoinc_colr
key_getterr s rK r zHDefaultExecutionContext._setup_ins_pk_from_lastrowid.. sU ) ) ) ## $((A ==) ) )rM c N g | ]!} | d "S rO r& r r' r r) s rK r zHDefaultExecutionContext._setup_ins_pk_from_lastrowid..' sA ) ) ) ##JJqMM488) ) )rM ) rw _key_getters_for_crud_columnr r r~ r _autoincrement_columnr r r primary_keyinserted_primary_key)rI r r r( r r) r s @@@@rK r z4DefaultExecutionContext._setup_ins_pk_from_lastrowid s ]?B
'- 215&&(( 5K&"'@@L$ # $YI) ) ) ) ) ) ) * ) ) )D % % %) ) ) ) ) *) ) )D % % %rM c | j j d | j j j }| j d fd|j D | _ d S )Nr r c N g | ]!} | d "S rO r& r+ s rK r zDDefaultExecutionContext._setup_ins_pk_from_empty..0 s> %
%
%
9:O
1
t 4 4%
%
%
rM )rw r, r r r~ r. r/ )rI r r r) s @@rK r z0DefaultExecutionContext._setup_ins_pk_from_empty, sf ]?B
'- 215%
%
%
%
%
>C>O%
%
%
!!!rM c d | _ d S | j j d | j j j }| j d fdfd|j D D | _ d S )Nr r c . g | ]\ }}|| n|S rO r! )r colr_ r s rK r zQDefaultExecutionContext._setup_ins_pk_from_implicit_returning..< s9 %
%
%
U
CHH5%
%
%
rM c R g | ]#}| | d f$S rO r& )r r4 r r) s rK r zQDefaultExecutionContext._setup_ins_pk_from_implicit_returning..> sF o))**S//4@@A rM )r/ rw r, r r r~ r. )rI r r r r) s ` @@rK r z=DefaultExecutionContext._setup_ins_pk_from_implicit_returning4 s ;(,D % F]?B
'- 215%
%
%
%
, %
%
%
!!!rM c P | j s| j ot | j j S rO )r r r rw r rR s rK lastrow_has_defaultsz,DefaultExecutionContext.lastrow_has_defaultsD s,
.
D M #5
5
rM c z t | j d sdS i }| j j D ]p}|j | j }t | }| | j j |r |vr||vr|r |v s||v r ||< kd||< q| j j r2| j j
|| j | j | j
| | j j rg }| j j D ]|} | j j | }| |d P| | j v r2| gt) | j | z g| } | j j | dS # t. $ r)}
| j |
ddd| Y d}
~
dS d}
~
ww xY wi } | j j D ]\ }} | |d |r| | | } | j j s | j | d } | | j v r-| fd| j | D | | < | j j di | dS # t. $ r)}
| j |
ddd| Y d}
~
dS d}
~
ww xY w)a& Given a cursor and ClauseParameters, call the appropriate
style of ``setinputsizes()`` on the cursor, using DB-API types
from the bind parameter's ``TypeEngine`` objects.
This method only called by those dialects which require it,
currently cx_oracle.
bind_namesNr c 3 K | ]}|fV d S rO r! )r r dbtypes rK r z:DefaultExecutionContext.set_input_sizes.. s< 2 2 * ( 02 2 2 2 2 2rM r! ) hasattrrw r9 r _unwrapped_dialect_implr get_dbapi_typer1 _has_eventsdispatchdo_setinputsizesr r r r/ r r r r r r r
setinputsizes
BaseExceptionru _handle_dbapi_exceptionitemsr' rG r )
rI translate
include_types
exclude_types
inputsizes bindparam dialect_impldialect_impl_clspositional_inputsizesr r keyword_inputsizesr; s
@rK set_input_sizesz'DefaultExecutionContext.set_input_sizesI s t}l33 F
1 - -I$>AA$,OOL #L 1 1 !00 1CDDF "% # ]22(
== & > ..'=88 )/
9%%(,
9%% < # L ! 2 2DK $
< " * $& !}0
=
= M / 4 # 488%d 777-44 #Hs4+DS+I'J'J J .44V<<<
) )+@AAAA
$<<tT4
"$ "&-":"@"@"B"B
9
9 3# 488% 6 (mmC 5 5 <> < "l 3 3C 8 8 ;d 777*11 2 2 2 2.2.G.L2 2 2
39*3/
) )??,>?????
$<<tT4
s0 .E? ?
F2 F--F23J
J: J55J:c |j r| || S |j r || _ | | S |j r| j }|j st j |j | }n|j }t j
|g | }| |di
S |j S )N)bindr! ) is_sequence
fire_sequence is_callablecurrent_columnargis_clause_elementrr
_arg_is_typedr type_coercer r _execute_compiledscalar)rI columnr r r default_argr' s rK
_exec_defaultz%DefaultExecutionContext._exec_default s %%gu55 5
"(D ;;t$$ $
& ?D(
* ( 4W[% H H %k !;-0088d8CCA))!R44;;== =; rM Tc | j | j }n"# t $ r t j d w xY w|r| j r| j j j r|j r$|j
dz |j j |j i}n|j |j i}d| j j j
d }| fd|D |S S )ai Return a dictionary of parameters applied to the current row.
This method can only be used in the context of a user-defined default
generation function, e.g. as described at
:ref:`context_default_functions`. When invoked, a dictionary is
returned which includes entries for each column/value pair that is part
of the INSERT or UPDATE statement. The keys of the dictionary will be
the key value of each :class:`_schema.Column`,
which is usually synonymous
with the name.
:param isolate_multiinsert_groups=True: indicates that multi-valued
INSERT constructs created using :meth:`_expression.Insert.values`
should be
handled by returning only the subset of parameters that are local
to the current column default invocation. When ``False``, the
raw parameters of the statement are returned including the
naming convention used in the case of multi-valued INSERT.
.. versionadded:: 1.2 added
:meth:`.DefaultExecutionContext.get_current_parameters`
which provides more functionality over the existing
:attr:`.DefaultExecutionContext.current_parameters`
attribute.
.. seealso::
:attr:`.DefaultExecutionContext.current_parameters`
:ref:`context_default_functions`
zdget_current_parameters() can only be invoked in the context of a Python side column default functionr r c 3 6 K | ]}|d |fz fV dS )z%s_m%dNr! )r r indexr s rK r zADefaultExecutionContext.get_current_parameters.. sG ?BjS%L!89: rM )current_parametersrU AttributeErrorr r r rw r _has_multi_parameters_is_multiparam_columnra originalr r keysr )rI isolate_multiinsert_groupsr\ r rg ra r s @@rK get_current_parametersz.DefaultExecutionContext.get_current_parameters s- B 0J(FF )C
'
'=
+
q(_(*VZ*@AZFJ!78=*5a8==??D
HH FJ
H s 2c V |j d S | ||j |j S rO )r r^ r rI r\ s rK get_insert_defaultz*DefaultExecutionContext.get_insert_default s+ > !4%%ffnfkJJ JrM c V |j d S | ||j |j S rO )onupdater^ r rk s rK get_update_defaultz*DefaultExecutionContext.get_update_default s+ ? "4%%ffov{KK KrM c | j j d }i }| j j }| j j }|D ]$}|j r|j j r|j j ||< %|D ]$}|j r|j j r|j j ||< %| j D ]w}|| _ |D ]4}||v r || }n|
| }||| || < 5|D ]4}||v r || }n| | }||| || < 5x| ` d S )Nr ) rw r, r r r is_scalarrV rn r~ rb rl ro )rI r) scalar_defaultsr r r' r vals rK r z5DefaultExecutionContext._process_executemany_defaults sc ]?B
-7 -7
! 3 3Ay
3QY 0
3%&Y]" 4 4Az
4aj 2
4%&Z^"- / /E&+D #$
/
/'')!,CC 11!44C?+.E**Q--($
/
/'')!,CC 11!44C?+.E**Q--(
/
# # #rM c ~ | j j d }| j d x| _ }| j j D ]S}|j r%|j j s|j j r
|j j }n| | }||| || < T| j j
D ]'}| | }||| || < (| `d S )Nr r ) rw r, r~ rb r r rR rq rV rl r ro )rI r) r~ r' rs s rK r z7DefaultExecutionContext._process_executesingle_defaults: s ]?B
$Q ' ( . 9 9Ay
1!6
119;N
1im--a0058#JJqMM2 . 9 9A))!,,C58#JJqMM2 # # #rM )NNN)T)?r+ re r, r r r r r rx r rw r r r r r _translate_colnamer
rC r rZ r r r r r rX r6 r r r r r r r rY rr r r r} r r r r
r r r r rY rL r# r r r r7 rO r^ rb ri rl ro r r r! rM rK rr rr s HHHGG EKHI " " -4-// [ @ s s [sjl l l\ - - [-^ [
4 4 4
+ + +
' ' '
B B B
B . . X.2 2 2 @3 3 3$ $ $
E E E% % %8
, , , $ $ X$3 3 39 9 9% % %N :
AEV V V Vp & 0: : : : xK K K L L L #$ #$ #$J$ $ $ $ $rM rr ))r- rE r r rP r r r r r r r
r r r r
sqlr r r sql.elementsr r IUNICODEr r Dialectr objectr\ rn rc ro rg rp ri rk ExecutionContextrr execution_ctx_clsr! rM rK r~ s
& & & & & & BJ4bdRZ6G
#
<
1BCC s s s s s Z' s s s l f ?H$5
.A$ A$ A$ A$ A$j 9 A$ A$ A$H $; rM