rj rddlmZddlZddlZddlmZddlmZddlmZddlmZddlm Z ddlm Z dd lm Z dd lm Z dd lm Z dd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#dd lm$Z%dd!lm&Z&dd"lm'Z'dd#lm(Z(dd$lmZdd%l(m)Z)dd&l(m*Z*dd'l(m+Z+dd$l(mZ,dd(l(m-Z-dd)l.m/Z/dd*l.m0Z0dd+l.m1Z1dd,l2m3Z3dd-l2m4Z4dd.l2m5Z5dd/l2m6Z6dd0l2m7Z7dd1l2m8Z8dd2l2m9Z9dd3l2m:Z:dd4l2m;Z;dd5lm?Z?dd7l>m@Z@dd8lAmBZBdd9lAmCZCdd:lAmDZDdd;lAmEZEddlAmHZHdd?lAmIZIdd@lJmKZKddAlLmMZMddBlLmNZNddClLmOZOerxddDlPmQZQddElPmRZRddFlmSZSddGlTmUZUddHlVmWZWddIlXmYZYddJlXmZZZddKl[m\Z\ddLl]m^Z^ddMl.m_Z_ddNl`maZaddOlmcZcddQlAmdZdddRlAmeZeddSlAmfZfddTlAmgZgddUlAmhZhddVlAmiZiddWljmkZkedXeYZleNdZZmejZoeGjZpGd[d\Zqejd]d^iZsGd_d`e7ZtGdadbetZuGdcddetZvGdedfZwGdgdhewZxGdidjewZye(j,jnjdkdlGdmdnevZ{Gdodpe?e:eIeOemZ|e(j,jnjdkdqGdrdseueBZ}e(j,jnjdkdtGdudveveHZ~ d ddwZ ddxZ ddyZ d ddzZGd{d|ZGd}d~eZGddeZGddeZGddeZGddeZGddeZy)) annotationsN) AbstractSet)Any)cast)Dict)Iterable)List)Optional)Set)Tuple)Type) TYPE_CHECKING)TypeVar)Union) attributes) interfaces)loading)_is_aliased_class)ORMColumnDescription)ORMColumnsClauseRole) PathRegistry)_entity_corresponds_to)_ORMJoin)_TraceAdaptRole) AliasedClass)Bundle) ORMAdapter)ORMStatementAdapter)exc)future)inspect)sql)util) coercions) expression)roles)visitors)is_dml)is_insert_update)is_select_base)_expand_cloned _from_objects)_select_iterables)CacheableOptions) CompileState) Executable)ExecutableStatement) Generative)Options) UpdateBase)GroupedElement) TextClause)CompoundSelectState)LABEL_STYLE_DISAMBIGUATE_ONLY)LABEL_STYLE_NONE)LABEL_STYLE_TABLENAME_PLUS_COL)Select)SelectLabelStyle) SelectState)TypedReturnsRows)InternalTraversal)TupleAny) TypeVarTuple)Unpack)_InternalEntityType)OrmExecuteOptionsParameter) _PostLoad)Mapper)Query)_BindArguments)Session)Result)_CoreSingleExecuteParams)_ColumnsClauseArgument) SQLCompiler)_DMLTableElement) ColumnElement)_JoinTargetElement)_LabelConventionCallable)_SetupJoinsElement)ExecutableReturnsRows) FromClause) SelectBase) TypeEngine_T)bound_TsceZdZUdZded<ded<ded<eddZGd d eZ d dd Z dd Z y ) QueryContext)top_level_context compile_statequeryuser_passed_queryparams load_optionsbind_argumentsexecution_optionssession autoflushpopulate_existinginvoke_all_eagers version_check refresh_statecreate_eager_joinspropagated_loader_optionsrrunidpartialspost_load_pathsidentity_token yield_perloaders_require_bufferingloaders_require_uniquingintrozDict[PathRegistry, _PostLoad]rq_ORMCompileStater`c@t|jjSN)boolr`multi_row_eager_loadersselfs a/var/www/html/python-recuperauto-other/env/lib/python3.12/site-packages/sqlalchemy/orm/context.pyrequires_uniquingzQueryContext.requires_uniquingsD&&>>??c<eZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ dZy)!QueryContext.default_load_optionsFTN)__name__ __module__ __qualname___only_return_tuples_populate_existing_version_check_invoke_all_eagers _autoflush_identity_token _yield_per_refresh_state_lazy_loaded_from_legacy_uniquing_sa_top_level_orm_context_is_user_refreshrr~default_load_optionsrsE#"!    $(! rrNc |_|xstj_|xstj_|_|_|_|_d_ d_ |_ |j_ |jj} |j} t!fdt#| | D_t'|j(_|j*_|j._|j2_|j6_|j:_|j>_ |jB_"y)NFc3`K|]%\}}|jr|j|'ywry)propagate_to_loaders'_adapt_cached_option_to_uncached_option).0opt uncached_optr}s r~ z(QueryContext.__init__..s3/ !\''  7 7l K/ s+.)#rdr% EMPTY_DICTrfrer`rarbrgrtrurcrr_select_statement _with_optionstupleziprndictrrrhrrirrjrrkrrlrrsrrr) r}r` statementrbrcrgrdrfrecached_optionsuncached_optionss ` r~__init__zQueryContext.__init__s),)!2!Edoo,?* "3 ).&(-% !-!G!G&77EE,::*// %(9I%J/ * & }778%00!-!@!@!-!@!@)88)88%00*::rc"|jxs|Sry)r_r|s r~_get_top_level_contextz#QueryContext._get_top_level_contexts%%--r)returnrz)NN)r`r2rLUnion[Select[Unpack[TupleAny]], FromStatement[Unpack[TupleAny]], UpdateBase]rbrrcrNrgrLrdzQUnion[Type[QueryContext.default_load_options], QueryContext.default_load_options]rfz$Optional[OrmExecuteOptionsParameter]rezOptional[_BindArguments])rr^) rrr __slots____annotations__propertyrr6rrrrrr~r^r^lsI6 J22## @@ !w !BCG37)D;#D; D; D;)D;D; D;&@'D;(1)D;L.rr^ _result_disable_adapt_to_contextTczeZdZdZdZe dfd ZedZe ddZedZ xZ S) _AbstractORMCompileStateFci|_| i|_|sJy|jx|_}|r7d|d<|r/|jD] }|js|j |"y|j ddry|jd} |d}|jD]-}|js|js|j |/ d|d<y#t$rYwxYw)NT toplevel_ormFr selectable) rglobal_attributes_global_attributesr_is_criteria_optionprocess_compile_stategetstack_is_compile_stateKeyError) r}rcompilertoplevelprocess_criteria_for_toplevelgarstack_0 toplevel_stmts r~_init_global_attributesz0_AbstractORMCompileState._init_global_attributess  &(D "O8 *2*E*E ED "R !%B~ ,$228C..11$78  VVNE * ..# 4#L1M%22 4((S-D-D--d3 4">   sC CCc &t|||fi|S)aCreate a context for a statement given a :class:`.Compiler`. This method is always invoked in the context of SQLCompiler.process(). For a Select object, this would be invoked from SQLCompiler.visit_select(). For the special FromStatement object used by Query to indicate "Query.from_statement()", this is called by FromStatement._compiler_dispatch() that would be called by SQLCompiler.process(). )supercreate_for_statement)clsrrkw __class__s r~rz-_AbstractORMCompileState.create_for_statements"w+IxF2FFrctryNotImplementedError)rrgrrcrfre is_pre_events r~orm_pre_session_execz-_AbstractORMCompileState.orm_pre_session_exec* "##rc^|j||xsi|}|j||||||S)N)rf)executeorm_setup_cursor_result)rrgrrcrfreconnresults r~orm_execute_statementz._AbstractORMCompileState.orm_execute_statement6sJ v|7H **         rctryrrrgrrcrfrers r~rz0_AbstractORMCompileState.orm_setup_cursor_resultLrr)rr3rrPrrrr2)rrM) rrris_dml_returningr classmethodrrrr __classcell__rs@r~rrs%"NGGG G  GG$ $ $    * $ $rrc0eZdZdZedZedZy)_AutoflushOnlyORMCompileStatez>ORM compile state that is a passthrough, except for autoflush.ctjjddh||j\}}|s|jr|j |||fS)N_sa_orm_load_optionsrh)r^rfrom_execution_options_execution_optionsr)rrgrrcrfrerrds r~rz2_AutoflushOnlyORMCompileState.orm_pre_session_exec\sc  - - D D "    ( (     7 7    +V33rc|Sryrrs r~rz5_AutoflushOnlyORMCompileState.orm_setup_cursor_resultys  rN)rrr__doc__rrrrrr~rrYs+H448  rrceZdZUGddeZded<ded<ded<ded <d ed <d ed <ded<ded<ded<ded<ded<ded<ded<ded<eZded<dZd Z e d-d!Z e d.d"Z d#Z e d/d$Ze d%Ze d&Ze d'Zed(Zd)Zd*Ze d+Zy,)0rwc ZeZdZdejfdejfdejfdej fdejfdejfdej fdejfd ejfd ejfd ejfg Zd Zd Z d Z e Z d Z d ZdZd Zd Zd Zd Zy)(_ORMCompileState.default_compile_options_use_legacy_query_style_for_statement_bake_ok _current_path_enable_single_crit_enable_eagerloads_only_load_props_set_base_alias_for_refresh_state_render_for_subquery_is_starFTN)rrrrB dp_booleandp_has_cache_key dp_plain_obj_cache_key_traversalrrr_path_registryrrrrrrrrrrr~default_compile_optionsrs &(9(D(D E 0;; < *55 6 /@@ A "$5$@$@ A !#4#?#? @ !2!?!? @  1 < < = !#4#?#? @ #%6%A%A B *55 6 &#( & "!"$rrzDict[Any, Any]rrrrz@Union[Select[Unpack[TupleAny]], FromStatement[Unpack[TupleAny]]]rList[_QueryEntity] _entitiesz%Dict[_InternalEntityType, ORMAdapter]_polymorphic_adaptersz=Union[Type[default_compile_options], default_compile_options]compile_optionszOptional[_QueryEntity]_primary_entityrzuse_legacy_query_stylerT_label_conventionzList[ColumnElement[Any]]primary_columnssecondary_columnszSet[ColumnElement[Any]]dedupe_columnszList[TupleAny]rmr current_pathFctryr)r}argrs r~rz_ORMCompileState.__init__ !##rc X|jtd|f|j |d|S)NUnion[Select, FromStatement])rr)_create_orm_contextrr)rrrrs r~rz%_ORMCompileState.create_for_statements@'s&& / ; !'    rc tryr)rrrrrs r~rz$_ORMCompileState._create_orm_contexts "##rcj|j}||vr#|j||j|yyry)raddappend)r}objcol_collectiondedupes r~_append_dedupe_col_collectionz._ORMCompileState._append_dedupe_col_collections3$$ f  JJsO  ! !# & rc<|rdd}|Stj|S)Nc"|r|St|dS)Nkey)getattr)colcol_names r~namez8_ORMCompileState._column_naming_convention..names#O"3..rry)r@_column_naming_convention)r label_stylelegacyrs r~rz*_ORMCompileState._column_naming_conventions$  / K88E Erct|Sry)_column_descriptionsrrs r~get_column_descriptionsz(_ORMCompileState.get_column_descriptionss #I..rctjjdhd||j\}}d|vr5|d}|jjj |j |}|st}n|jt}|jr|jd|ji}t|jddrHt|jjdkDr&|jdd|jdd d }||d < |jd } | r| j |d < |s|j$r|j%|||fS#t"$rJdwxYw)Nr>rhrsrrrisa_top_level_orm_contextrrsr compiled_cacheTz#excess depth for ORM loader options)r _cache_disable_reasonclauseplugin_subjectmapperz0statement had 'orm' plugin but no plugin_subject)r^rrrra merge_withrf_orm_load_exec_optionsunionrr_compile_optionslenrr_propagate_attrsr$rr) rrgrrcrfrerrdctxr#s r~rz%_ORMCompileState.orm_pre_session_execs  - - D D "    ( (   ( &): :#$>?C # < < G G%%'8! ! 6  1 7 78N O   " " 1 7 7l556!  I.. FI..<<=B!%%&6=I"''*.2- $-x  A&778HIN+9+@+@x( 7 7    +V33 M LL L5 Ms EE,c |j}|jj}|jdtj } |j jr|St |||||| ||} tj|| S)Nr) contextcompiledr`rr^rrrr instances) rrgrrcrfrerexecution_contextr`rd querycontexts r~rz(_ORMCompileState.orm_setup_cursor_resultWs#NN)22@@ ),, "L$E$E   ( ( 1 1M#            66rcb|jDcgc]}t|ts|c}Scc}w)zreturn all _MapperEntity objects in the lead entities collection. Does **not** include entities that have been replaced by with_entities(), with_only_columns() )r isinstance _MapperEntity)r}ents r~_lead_mapper_entitiesz&_ORMCompileState._lead_mapper_entities|s. >> Z]-KC   s,,c |jsz|jj|jvrW|jj D]9}|j |t tj||j|;yyy)agiven MapperEntity or ORMColumnEntity, setup polymorphic loading if called for by the Mapper. As of #8168 in 2.0.0rc1, polymorphic adapters, which greatly increase the complexity of the query creation process, are not used at all except in the quasi-legacy cases of with_polymorphic referring to an alias and/or subquery. This would apply to concrete polymorphic loading, and joined inheritance where a subquery is passed to with_polymorphic (which is completely unnecessary in modern use). TODO: What is a "quasi-legacy" case? Do we need this method with 2.0 style select() queries or not? Why is with_polymorphic referring to an alias or subquery "legacy" ? ) equivalentsrN) is_aliased_classr$persist_selectableriterate_to_root"_mapper_loads_polymorphically_withrrWITH_POLYMORPHIC_ADAPTER_equivalent_columns)r}ext_informps r~ _create_with_polymorphic_adapterz1_ORMCompileState._create_with_polymorphic_adapters$))22--.oo557 77'@@$&$:$:#-  .*rc|jxs|gD]?}||j|<|jD]}||j|j<Ayry)_with_polymorphic_mappersrr; local_table)r}r$adapterm2ms r~r<z3_ORMCompileState._mapper_loads_polymorphically_withs^22>vh DB-4D & &r *'') D  rN)rr3rrPrrrrw) rrrrzrOptional[SQLCompiler]rrrrw)rr?rrzrrT)rrrr1rrrr_has_mapper_entitiesrrrrrrrrrrr6rAr<rIrrr~rwrws#"2#J%%"!@@,+  //--//++"0L,/ $            $/$ $ ( $  $ $$'  F* F48 F ! F F//W4W4r"7"7H    BD  rrwc&eZdZdZdZdZdZdZy)_DMLReturningColFilterza base for an adapter used for the DML RETURNING cases Has a subset of the interface used by :class:`.ORMAdapter` and is used for :class:`._QueryEntity` instances to set up their columns as used in RETURNING for a DML statement. )r$columns __weakref__c| |j|jur||_n||_tj|jx|_|_yry)rDr$r%WeakPopulateDictadapt_check_presentrN)r} target_mapperimmediate_dml_mappers r~rz_DMLReturningColFilter.__init__sU ,))'334/DK(DK&*&;&;  $ $'   t|rcftj|D]}|j|}||cSyry)sql_util _find_columnsrR)r}r as_filterccc2s r~__call__z_DMLReturningColFilter.__call__s;((- B))"-B~   rctryr)r}rs r~rRz*_DMLReturningColFilter.adapt_check_presentrrN)rrrrrrr[rRrrr~rMrMs5I  $rrMceZdZdZdZy) _DMLBulkInsertReturningColFiltera[an adapter used for the DML RETURNING case specifically for ORM bulk insert (or any hypothetical DML that is splitting out a class hierarchy among multiple DML statements....ORM bulk insert is the only example right now) its main job is to limit the columns in a RETURNING to only a specific mapped table in a hierarchy. c|j}|jj|d}|y|jjj |Sry)r$_columntopropertyrrDccorresponding_columnr}rr$props r~rRz4_DMLBulkInsertReturningColFilter.adapt_check_presentsH''++C6 <!!##88==rNrrrrrRrrr~r^r^s >rr^ceZdZdZdZy)"_DMLUpdateDeleteReturningColFiltera_an adapter used for the DML RETURNING case specifically for ORM enabled UPDATE/DELETE its main job is to limit the columns in a RETURNING to include only direct persisted columns from the immediate selectable, not expressions like column_property(), or to also allow columns from other mappers for the UPDATE..FROM use case. c|j}|jj|d}|%|jjj |S|Sry)r$r`rr:rarbrcs r~rRz6_DMLUpdateDeleteReturningColFilter.adapt_check_presentsO''++C6  ,,..CCCH H rNrerrr~rgrgs  rrgormorm_from_statementceZdZUdZdZded<ded<dZded<dZdZdZ dZ e jZ e jZe d d Zd Zd Zd Zy)_ORMFromStatementCompileStateNF FromStatementstatement_containerz)Union[SelectBase, TextClause, UpdateBase]requested_statementzOptional[_DMLTableElement] dml_tablec p|}t|tsJ|!|jrtjd|j |}d|_|jj|_ |x|_ |_ |jx|_ }|jr|j|_d|_g|_i|_|j|_|jr_t|t*j,rE|j.s9|js-|j0t2ur|j5t6|_n||_|j;|j.s|js |j0nt2|j|_t>jA||jB|j$d|jjD|_#|jI||dd|jJr/|jJD] }|jLs|jO|"|jPr|jPD] \}} ||g|_)g|_*tW|_,g|_-g|_.d|_/|j8j`roi|_1|j$D]} | je|dx|_3|_4d|_5|jRD] } |jm| d|jn"|Stqtrjt|j8|jv|_<|S)NzThe ORM FromStatement construct only supports being invoked as the topmost statement, as it is only intended to define how result rows should be returned.Tis_current_entitiesF)rr)within_columns_clauseadd_to_result_map)adapt_on_names)=r3rmrsa_exc CompileError__new__rr(rrrnrelementror*tablerprrrrr'rX _is_textual _label_styler<set_label_styler=rrr _QueryEntityto_compile_state _raw_columnsrrrrrr_compile_state_funcsrrsetrrm_fallback_from_clausesorder_by_is_text_clauseextra_criteria_entitiessetup_compile_state_ordered_columns_textual_ordered_columns_loose_column_name_matchingprocess_add_to_result_maprrADAPT_FROM_STATEMENT_adapt_on_names_from_obj_alias) rrrrrrnr}rfnrentityras r~rz1_ORMFromStatementCompileState._create_orm_contexts(-}===  HNN%%=  {{3# 0 0 H H #> ) ) ,.D (.. 1**40 1 H %(I 48H 0))   *.&.&A&A! , $7442BB$D  rc|Sryr)r}colscurrent_adapters r~_adapt_col_listz-_ORMFromStatementCompileState._adapt_col_list rcyryrr|s r~_get_current_adapterz2_ORMFromStatementCompileState._get_current_adaptersrc|jjjdd}|jjr t ||}n;|jj s|jj r t||}nd}|jjr-t|jdk7rtjd|jD]}|j||y)zused by BulkORMInsert, Update, Delete to set up a handler for RETURNING to return ORM objects and expressions r#NrsCan't generate ORM query that includes multiple expressions at the same time as '*'; query for '*' alone if present)rr*r is_insertr^ is_update is_deletergrrr)rrwrx!setup_dml_returning_compile_state)r} dml_mapperrSrErs r~rz?_ORMFromStatementCompileState.setup_dml_returning_compile_states 77;; d  >> # #6zG^^ % %)A)A8zGG    ( (c$...AQ.F%%J  nn DF  4 4T7 C Dr) rrrrzrrJrrrrl)rrrrrKrrp_has_orm_entitiesr{eager_adding_joinscompound_eager_adapterr%rr eager_joinsrrrrrrrr~rlrl sO &&BB,0I)0#!"oo//KD/D D ( D  D 'DDLDrrlc\eZdZUdZdZej ZejZ dZ de d<de d<de jfde jfgej zZed e j$fgzZd Z d dd Zd Zed ZdZfdZedZedZedZedZxZS)rma*Core construct that represents a load of ORM objects from various :class:`.ReturnsRows` and other classes including: :class:`.Select`, :class:`.TextClause`, :class:`.TextualSelect`, :class:`.CompoundSelect`, :class`.Insert`, :class:`.Update`, and in theory, :class:`.Delete`. rjN(Union[ExecutableReturnsRows, TextClause]rzrzrrr(Tc tj|Dcgc])}tjtj ||d+c}|_||_|j|_|j|_ |j|_ |j|_ |j|_ t|r |jnd|_||_ycc}w)NT)apply_propagate_attrs post_inspect)r%to_listr&expectr(ColumnsClauseRolerrzr* is_selectrrrr,r}r)r}entitiesrzrr5s r~rzFromStatement.__init__s||H-    ''&*!    nn  ** ** ** **$27$;G   /% s.Cc |jr|j||j||fi|}|j }|r||_|j |j fi|S)zprovide a fixed _compiler_dispatch method. This is roughly similar to using the sqlalchemy.ext.compiler ``@compiles`` extension. )_collect_params_add_to_params_compile_state_factoryrr`rr)r}rrr`rs r~_compiler_dispatchz FromStatement._compiler_dispatchsi  # #  # #D )333D(IbI ~~% %2H "x 7 7>2>>rcltttj|j}||S)a@Return a :term:`plugin-enabled` 'column descriptions' structure referring to the columns which are SELECTed by this statement. See the section :ref:`queryguide_inspection` for an overview of this feature. .. seealso:: :ref:`queryguide_inspection` - ORM background )r_ORMSelectCompileStater@get_plugin_classr)r}meths r~column_descriptionsz!FromStatement.column_descriptionss3 "K$@$@$F ! ! Dzrc|Sryrr|s r~_ensure_disambiguated_namesz)FromStatement._ensure_disambiguated_names&rrc+Ktjjd|jDEd{t |di|Ed{y77w)Nc34K|]}|jywryr.rrzs r~rz-FromStatement.get_children..*s1 &-G ! !1 r) itertoolschain from_iterablerr get_children)r}rrs r~rzFromStatement.get_children)sY??001 151B1B1    7'-"---  .s!4AAAAAAc.|jjSry)rz_all_selected_columnsr|s r~rz#FromStatement._all_selected_columns/s||111rc\t|jr|jjSdSry)r*rz_return_defaultsr|s r~rzFromStatement._return_defaults3s"06t||0Dt||,,N$Nrc\t|jr|jjSdSry)r*rz _returningr|s r~rzFromStatement._returning7s"*0*>t||&&HDHrc\t|jr|jjSdSry)r+rz_inliner|s r~rzFromStatement._inline;s"'7 'Et||##O4Or)T)rz%Iterable[_ColumnsClauseArgument[Any]]rzrrrz) rrrr__visit_name__rlrr(rr_for_update_argrrBdp_clauseelement_listdp_clauseelementr4_executable_traverse_internals_traverse_internalsrris_from_statementrrrrrrrrrrrrs@r~rmrms8*N4LL:OOO 55 *@@A %667 ::; / .??@2 !% /7/:/ /4?(". 22OOIIPPrrmcompound_selectc eZdZy)_CompoundSelectCompileStateN)rrrrrr~rr@s rrselectceZdZUdZej ZdZdZdZ dZ dZ dZ dZ dZdZdZej"Zded<ej"Zded<e d&dZdZd Zed Zed Zed Zed ZedZdZdZdZ dZ!dZ"d'dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.d Z/e0d!Z1e0d"Z2d#Z3d$Z4d%Z5y)(rrNFzAbstractSet[FromClause]_explicit_correlate_froms_implicit_correlate_fromsc .|j|}|sQ|J|j|jd|jdd|jdd\|_|_|}|j j|j|_|jr5|j|_ tj|j_ n||_ |jj|_|jj |_g|_d|_i|_|j|_|s|xj*dddz c_|j"r@|jj,t.ur$|js t0|_n't4|_n|jj,|_|j6rA|j6Dcic]&}|t8j;||j<gd(c}|_|jA|j,|j"|_!t8j;||j<|j$d|jjD|_#d|_$|jK|||d |r|jLs |j6r|j6D]]}|jLD]L}|jNs|jQ||j>|D cgc]} tS| tTr| c} N_|jjLD] }|jNs|jW|"|jXr|jXD] \} } | |g|_-g|_.t_|_0i|_1i|_2g|_3g|_4|jkd |jlD|_7|jqtsjt||jv|fi||Scc}wcc} w) NasfromFlateralT)rrrrr)rrc34K|]}|jywry)r)rinfos r~rz=_ORMSelectCompileState._create_orm_context..s2 $DOO2 r)>MM  - - E E ##%'"/@@  &+(,%    ' '%%226LL%%#A #@ #44AAD   5 5%>> '& "<#@#@%22(- $A$ 'D # "&!?!?  " "D$?$?"  %%   ) ) NN $ & -==KK  $$  */ %    * *99";; !,:: C,,CC ,0+B+B$5,"$'$.c=#A !$    ,,:: 4((--d3 4  0 0+@@ C4  "!#!e')$"$&(#!112 (8(B(B2     "T4>>8BrB } 'bs +P 4Pctdtd|j|jD]}t|trm|ddk(retdt j |dtd|j|td|j|jt|ts|ddk(std t j |dtd|j|y) Nz5 --------------------------------------------------- zcurrent path: rloaderz Loader: rz path_with_polymorphicz With Polymorphic: )printrrr3rrcoerce__dict__)r}rs r~_dump_option_structz*_ORMSelectCompileState._dump_option_struct s GH t00123?? 5C#u%#a&H*<,\-@-@Q-H,IJKT__S1234T__S1::;<=C'CF6M,M,\-@-@Q-H,IJKT__S1234 5rc  |j}d|_d|_|jjr|j |j D]8}|js|j|j|j|:|jr&|j|j|j|j |jr6|j|_ r#t fd|jD|_ r*|jdvr|j|j n |j|_|j"r#t fd|j"D|_ r=|j$dvr/|jt'j(|j$ n|j$xsd|_|j,r9|j.dj0}|j3|j,|_|j4r"|j|j4 |_nd|_|j8|_|j=j?Dcic]\}}| r  |dn|c}}|_ |jBr5tt'j(d|jBD|_"nT|jF5tt'j(d|jFD|_$n|jJsd |_"|jL|_&|jjNr-tQ|jd k7rtSjTd |jD]}|jW||jXD]}|d}||g|d d|jjZr|j]|j^s2|jj`rJd tSjbd|j.ste|jf|_|j d urd|_|jhr|jk|_n|jm|_|jnr6|jq} | #|jjsd| i|_yyycc}}w)Nrc30K|] }|dywTNrrcritrs r~rz=_ORMSelectCompileState._setup_for_generate..2s -$D$/-sNFc38K|]}r |dn|ywrrrs r~rz=_ORMSelectCompileState._setup_for_generate..As'*0?d+DH*srTc3NK|]}|tj|ndywryrVsurface_selectablesrss r~rz=_ORMSelectCompileState._setup_for_generate..e,&89}H003$N&#%c3NK|]}|tj|ndywryrrs r~rz=_ORMSelectCompileState._setup_for_generate..lrrryrrFz,no columns were included in _only_load_propsz4Query contains no columns with which to SELECT from. deepentity):rr_join_entitiesrr_set_select_from_aliasr _setup_joins_joinrrr_where_criteriar_order_by_clausesrr_having_criteria_group_by_clausesr%flatten_iteratorgroup_byrr_target_adaptercopy_and_process _distinct_on distinct_on _distinctdistinct_get_syntax_extensions_as_dictitemssyntax_extensions _correlate correlate_correlate_exceptcorrelate_except_auto_correlaterrr)rwrxrrmr_adjust_for_extra_criteriarrInvalidRequestErrorlistr_should_nest_selectable_compound_eager_statement_simple_statementr _mapper_zero _annotate) r}rarrErvaluerrecstrategyezerors @r~rz*_ORMSelectCompileState._setup_for_generatesv%%     / /  ' ' )!&!@!@   -- %22++,=>     JJu))4>> :335  #(#8#8D ',- $ 4 4-($5#:#:-#O  !8!8/ J((  ! !$)*!22*%D !5#:#:-#O  %%e&=&=> ((0D    ''*::G")":":4;N;N"OD    #33""O D  "D  $BBDJJL" U -e K"    #%%&"--&DN  $ $ 0$)%%&"44&%D ! &&$DN %44    ( (c$...AQ.F%%J nn -F  & &t , -** %C1vH T $CG $ %    3 3  + + -####44LLLu,,F   $T%@%@ AD  ==E ! DM  ' '!;;=DN!335DN   %%'E "&!9!9!5)"! E" s9S c|j|}g|_d|_i|_|j |j ||_tj||j|jd|S)aCreates a partial ORMSelectCompileState that includes the full collection of _MapperEntity and other _QueryEntity objects. Supports a few remaining use cases that are pre-compilation but still need to gather some of the column / adaption information. NTrr) ryrrrrr}rrrr)rrarr}s r~rIz2_ORMSelectCompileState._create_entities_collectionsv{{3#%'"!%!?!?   "  %% %$$dnn$ &  rcd}t||j}|jD]#}|j||j%|jd|jD|j D][}d|j vr!|j d}|j|2d|j vsA|j|j]|S)aReturn all ORM entities for filter_by() searches. the ORM version for Select is special vs. update/delete since it needs to navigate along select.join() paths which have ORM specific directives. beyond that, it delivers other entities as the Mapper or Aliased object rather than the Table or Alias, which mostly affects how error messages regarding ambiguous entities or entity not found are rendered; class-specific attributes like hybrid, column_property() etc. work either way since _entity_namespace_key_search_all() uses _entity_namespace(). DML Update and Delete objects, even though they also have filter_by() and also accept ORM objects, don't use this routine since they typically just have a single table, and if they have multiple tables it's only via WHERE clause, which interestingly do not maintain ORM annotations when used (that is, (User.name == 'foo').left.table._annotations is empty; the ORMness of User.name is lost in the expression construction process, since we don't annotate (copy) Column objects with ORM entities the way we do for Table. .. versionadded:: 2.1 c3K|D]@^}}t|tjr|j.d|jvs=|Byw)N _no_filter_by)r3rQueryableAttributer _annotations) collectiontarget_s r~_setup_join_targetszK_ORMSelectCompileState._get_filter_by_entities.._setup_join_targetssF * ! !fj&C&CD --'$F,?,?? L  !s ?A A c3vK|]1}d|jvr!d|jvr|jdn|3yw)r+ parententityN)r-)rfrom_objs r~rzA_ORMSelectCompileState._get_filter_by_entities..sK h&;&;; "X%:%::%%n5 s79entity_namespacer+) rrrupdaterrr-r r/)rrr1rmemoizedrzenss r~_get_filter_by_entitiesz._ORMSelectCompileState._get_filter_by_entitiess6 !*9+A+ABC!;; HH OO/0E0EF G H  &//   !-- 7G!W%9%99**+=> S! (<(<< 5 56  7rc#JK|jD]}|jrhd|jvrZ|jd}|js!|jst |gEd{Yt |j Ed{wt |gEd{y7:77 w)Nr5)r is_selectabler- is_mapperr9r0_all_column_expressions)rrrzr8s r~all_selected_columnsz+_ORMSelectCompileState.all_selected_columnss -- 8G%%&'*>*>>**+=>}}S-A-A0';;;01L1LMMM,gY777 8<M7s6A B#"B#B#BB#B!B#B#!B#c|jtjjd|jDS)Nc3K|]<}d|jvr |jn|jdjg>yw)r3N)r-r/__clause_element__rs r~rzB_ORMSelectCompileState.get_columns_clause_froms.. sV *&W-A-AA)) ,,*,,. *sAA)rrrrrrs r~get_columns_clause_fromsz/_ORMSelectCompileState.get_columns_clause_froms s<## OO ) ) * )55 *   rc tjtj||}t |j |}|j j|j|j|j|j|S)N)r)rrrr*) r&rr(ReturnsRowsRolermrrr6rrrr*)rrfrom_statementstmts r~rEz%_ORMSelectCompileState.from_statementsw"))  ! ! "+  Y33^D #11!*!?!?(;;&77   rc|j}|jjsJt|jdk(sJ|j |jd}|r|xjddiz c_||_yy) used only for legacy Query casesrrrFN)rrrr)r_get_select_from_alias_from_objr)r}rarEs r~rz-_ORMSelectCompileState._set_select_from_alias,s{%%##33335??#q(((66uq7IJ   %:E$B B #*D  rc|}d|jvr|jd}t|dr-|jstjd|j St |jtjjrF|j}||jusJttj|j|Sy)rHr3r$zPA selectable (FromClause) instance is expected when the base alias is being set.r8N)r-hasattrr9rw ArgumentError_adapterr3rr$AliasedReturnsRows _all_equivsrrLEGACY_SELECT_FROM_ALIAS)r}r4requivss r~rIz6_ORMSelectCompileState._get_select_from_alias_from_obj9s T.. .$$^4D 4 "((**A }}$ )J)J K%%'F4??* **&88"  rc4|jdjS)z8return the Mapper associated with the first QueryEntity.r)rr$r|s r~r"z#_ORMSelectCompileState._mapper_zeroUs~~a '''rc|jD]!}d|jvs|jdcS|jD]}|js|jcSy)zReturn the 'entity' (mapper or AliasedClass) associated with the first QueryEntity, or alternatively the 'select from' entity if specified.r3N)rr-r entity_zero)r}r5qents r~ _entity_zeroz#_ORMSelectCompileState._entity_zeroYsg $$ 8C!1!11''77 8NN (D''' (rc|j|jgk7rtjd|z|jjS)Nz4%s() can only be used against a single mapped class.)rrrwrrU)r}methnames r~_only_full_mapper_zeroz-_ORMSelectCompileState._only_full_mapper_zerogsK >>d223 3,,)+34 ##///rct|jdkDrtj|xsd|j S)Nrz8This operation requires a Query against a single mapper.)r)rrwrrW)r} rationales r~_only_entity_zeroz(_ORMSelectCompileState._only_entity_zeroosD t~~  ",,++    ""rci}|jjD]L}|Dcgc]}t|tr|c}D]'}|j |j j )N|jDcgc]}t|ts|c}D]'}|j |j j )|Scc}wcc}wry)rvaluesr3r4r6r$r>r)r}rRrr5s r~rPz"_ORMSelectCompileState._all_equivsxs!%!8!8!?!?!A > -c=1 >  cjj<<=  > > >> Z]-KC  :C MM#**88 9 :  sC:CCc f|jrj|jDcgc]4}t|tjjr |j n|6}}t j|j|}ng}d}|j|j|Dcgc]}||jvs|c}z|j|j|j|j|jf|j|j j"|j j$|j&|j(d|j*}|j-}|j/}t1t2j4|||_t9j:|g|j<z}|j|_|j'|jj@|j|_|}|jBjED]#} t jF|| | jH}%|jJjM|||r6|jjL|g|j6jO||jjL|g|jP|Scc}wcc}w)N for_updatehintsstatement_hintsrrrK))rr3r$elements_label_referencerzrV expand_column_list_from_order_byr_select_statementrrrr rrr_hints_statement_hintsrr _select_argsaliasrPrrCOMPOUND_EAGER_STATEMENTrr"rrr}ofrr_ splice_joinsstop_on select_fromnon_generativerr) r}elemunwrapped_order_byorder_by_col_exprrainnerrRr from_clause eager_joins r~r z0_ORMSelectCompileState._compound_eager_statements ==!MM " "$ (E(EFLL" "!) I I$$&8! !# !% '&&  +LQq8K8K/KqL M      ! !    MM ++''.. 11BBnn!22    !!#&9  4 4e' #MMg... "&!1!1   ,$$''/(,(<(_create_raw_selectrr r rrrr  _limit_clause_offset_clause _fetch_clause_fetch_clause_options_independent_ctes_independent_ctes_opts_set_syntax_extensions _prefixes _suffixesrrirjrrrr)r} raw_columnsr4where_criteriahaving_criteriarrrbrcrdrr limit_clause offset_clause fetch_clausefetch_clause_optionsrrprefixessuffixesr independent_ctesindependent_ctes_optsrrs r~rhz(_ORMSelectCompileState._select_statementsK4--$$ (6I % )8I &   ' '5? : ' "&I %0I " "&I    ' '5? : '". #0  ". *> '&6 #+@ (  ,I , , A/@ A "*I  "*I $. ! $I  )8I &  .I   . .y E9 E  ' 5I & & 5 5 , rchd|jvr>|jd}|jj|d}|r|j|St |t j r|}nt|dr |j}ny|jj|d}|r|j|Sy)Nr3r{) r-rr adapt_clauser3r'rWrLr{)r}rzsearchrls r~_adapt_polymorphic_elementz1_ORMSelectCompileState._adapt_polymorphic_elementIs W11 1)).9F..2264@E))'22 gz44 5F Wg &]]F**..vt< %%g. . rcB|r|Dcgc] }||d c}S|Scc}w)NTr)r}rros r~rz&_ORMSelectCompileState._adapt_col_list[s' 6:;OAt,; ;K._adapt_clause..replaces%'!G A} !r)r)replacement_traverse)r"rXrrs r~ _adapt_clausezB_ORMSelectCompileState._get_current_adapter.._adapt_clause{s ! 00WE Er)rr rrr)r}rrs @r~rz+_ORMSelectCompileState._get_current_adapteras_    OO$$,,   % % OOD;; < Frc |D]\}}}}|d}|d}t|}| t|}t|tjr|t j d|}d}nd|j vr|j d}|-|js!t|dst jdt|tjrt|dd} || r| }n|j} |j}|j} |j} t|tj s| }| || j"f|j$vrE|b|| ur^|j j'dd| ur@t j d |j j'd|d ||d} |} ndx} } |j)|| ||| ||y#t$r} t jd|z| d} ~ wwxYw) NisouterfullzUNo 'on clause' argument may be passed when joining to a relationship path as a targetr3r$z9Expected mapped entity or selectable/table as join target_of_typez0Join target %s does not refer to a mapped entityzexplicit from clause z4 does not match left side of relationship attribute )r#r3rPropComparatorrwrr-r;rLrMrrrAttributeError _parententityrr,r_already_joined_edgesr_join_left_to_right) r}argsentities_collectionrightonclausefrom_flagsrrof_typeerrleftrds r~rz_ORMSelectCompileState._joins@-1Z  )E8UEI&G=DENE#"8,%!:!:;' 44= !5#5#55**>:**75(3K ..: (J$=$=>"(J== ' ( 1 1'$)LLE --((!(J,I,IJ#H%*d.H.HH$T)!..22>4H#$%88!& 2 2 6 6~u M ( "#"t  $ $# eZ R .'"("6"6!027!8#$'''s+ G G.G))G.c |}||J|j||||\}} } n|j||\} } ||urtjd|d|d|j ||||\} }}| j s|j | } nd} | d|j| } ||tj||}|jd| t| ||||| gz|j| dzdz|_y| %t|| tsJ|| j} n|} |jt| | |||| gz|_y)zgiven raw "left", "right", "onclause" parameters consumed from a particular key within _join(), add a real ORMJoin object to our _from_obj list (or augment an existing one) NzCan't construct a join from z to z, they are the same entityr)rr_extra_criteriar) "_join_determine_implicit_left_side_join_place_explicit_left_siderwr _join_check_and_adapt_right_sider;_get_extra_criteriarr_join_conditionr3r4r)r}rrrrrd outerjoinr explicit_leftreplace_from_obj_indexuse_entity_indexr_infoextra_criteria left_clauses r~rz*_ORMSelectCompileState._join_left_to_rights  << < 77#T5(  & 334GN &  5=,,)-u6 #'"G"G %4# x##!55f=NN ! -++,BCK(X-=#33M5I!!"9#9:# )!(6   ##$:Q$>$@A B    +"'(89=22BCNN " $ 1 1%$2  5 !D rczt|}dx}}|jrtj|j|j|}t |dk(r|d}|j|}nMt |dkDrt jdt jd|d|ri} t|D]W\} } | j} | t| } | |ur%t| tr| | f| | j<Gd| f| | j<Yt| j}tj||j|}t |dk(r| ||d\}}nQt |dkDrt jdt jd|dt jd|||fS)zWhen join conditions don't express the left side explicitly, determine if an existing FROM or entity in this query can serve as the left hand side. NrraCan't determine which FROM clause to join from, there are multiple FROMS which can join to this entity. Please use the .select_from() method to establish an explicit left side, as well as providing an explicit ON clause if not present already to help resolve the ambiguity.zDon't know how to join to z. Please use the .select_from() method to establish an explicit left side, as well as providing an explicit ON clause if not present already to help resolve the ambiguity.zgNo entities to join from; please use select_from() to establish the left entity/selectable of this join)r#rrVfind_left_clause_to_join_fromrr)rwr enumerateentity_zero_or_selectabler3r4rkeys)r}rrrrrrrindexes potential entity_indexr5rent_info all_clausess r~rz9_ORMSelectCompileState._join_determine_implicit_left_sideMs&488!1   <<!!6#4#4hG7|q )0&(()?@W!00500 9> @!I%./B%C D! c66>"6?v% c=11=v0FIcnn-6:F^Ih112 D y~~/0K<<V..G7|q )2;wqz3J)K& $W!00500 9> @,,1  +-===rcdx}}t|}|jrTtj|j|j}t |dkDrt jd|r|d}|J|rHt|dr, flat=True) construct explicitly, see the linked example.xaj2rK)rr8))r#rwith_polymorphicr3r:r'JoinrrrVselectables_overlaprwr common_parentr$rLris_clause_element _is_lateralris_derived_from descriptionrXr&rr(FromClauseRolerr%warn_deprecatedwarnrr DEPRECATED_JOIN_ADAPT_RIGHT_SIDEr>r<#_has_aliased_polymorphic_fromclause#WITH_POLYMORPHIC_ADAPTER_RIGHT_JOIN ClauseElementrr)r}rrrrdrroverlap right_mapperr4right_selectableright_is_aliased need_adapterraliased_entityrEs r~rz7_ORMSelectCompileState._join_check_and_adapt_right_sidesvx6    ) ),99:??K --D&2C2C1D //%%x22f//#G  v((F,=,==,,<##$  FHd +    F. 6)9&   ..t{{;,,9>J  68 $   F9 ,    # ##{{ ++#'";";"=".,E48E(77 33!44-88(;;GG. 0E0EF'0'7'7,,.>($$(L%\3CD$$D # #  &J.>*>J7!T2EL II@ CO O    < @@(<<G  3 3L' J(($@@  3 3#GG +66 , @ @   h 8 8 9"779O*8T:   & &D%+B*D D &u~uh..rc |jj|jj|j|j|jj |jj |jxsd|jj|jj|jj|jj|jd S)N) rrrrrrr rrrrr) rr|r}rrrrr r~rrrrr|s r~rkz#_ORMSelectCompileState._select_args s!11??!22AA ++--77--77 - 11??%%;; $ 5 5 G G%%<*$6100 -  ?+47100 -zz*e, -zz-, -zz*e, rcdjfjvr.tfdjdjfDSy)Nadditional_entity_criteriac3K|]@}|js|jur$|jr|jBywry)include_aliasesr_should_include_resolve_where_criteria)raer?r}s r~rz=_ORMSelectCompileState._get_extra_criteria.. sH&&"))x*?&&t, **84sAA r)r$rr)r}r?s``r~rz*_ORMSelectCompileState._get_extra_criteria sZ ( OO  # # $0018??C rc |js|jstjS|j |j }|j r|j Dcgc]}|| }}nd}t|j||j ||j|j j|j|j}ttt|Dcgc] }||vs| c}Scc}wcc}w)zReturn the set of FROM objects that will be correlated away from this SELECT, given its current state. This runs ahead of the final statement being generated, so the FROM list is derived from the ORM-level statement. N) rrr% EMPTY_SET _get_fromsrrr_correlate_fromsrrr-r/)r}fromsra to_correlate display_fromsfs r~_get_correlated_fromsz,_ORMSelectCompileState._get_correlated_froms s--..>> ! 5 56 >>'+~~G!AGLGL  ! !%%%%%%55....    5KaA]4JKL   !H$ LsC8&C8 C=(C=c |jjr|jntj|j Dcgc]}|j jdd c}|jjDcgc]:}tj|D] }||j jddf"<c}}Dcgc]5\}}|r.r*|jrtfd|jDs|7c}}z}|D]n}|s|jjd|jf|jvs7||jvsF||j r |j"ndf|j|<pd}t%j&d}tj(|jj+D]\}||j,vr|j r+|j/j0r|j/}n|}|jj2} | Q| \} } | j5||jd} ||| f\} } | j7| r| j9|j:j<r|j?|}|tAfd|Dz }|jCD]:\\}} \}} | jE|}| D]jG|}||fz }<|jI}|r'|D]!}||d }|xj|fz c_#y|xj|z c_ycc}wcc}}wcc}}w) aApply extra criteria filtering. For all distinct single-table-inheritance mappers represented in the columns clause of this query, as well as the "select from entity", add criterion to the WHERE clause of the given QueryContext such that only the appropriate subtypes are selected from the total results. Additionally, add WHERE criteria originating from LoaderCriteriaOptions associated with the global context. r3Nc3TK|]}j|j!ywry) intersection _cloned_set)rrcorrelated_fromss r~rzD_ORMSelectCompileState._adjust_for_extra_criteria..? s*%11%2C2CDs%(rrc>tjtfSry)r% OrderedSetrrrr~zC_ORMSelectCompileState._adjust_for_extra_criteria..Y sT__&.r)r3 parentmapperc3HK|]}rj|n|ywry)traverse)rrrEs r~rzD_ORMSelectCompileState._adjust_for_extra_criteria.. s+0/6G$$T*4?0s"F)%rrrr%rrr-rrVsurface_expressionsr/allr$_single_table_criterionrrr9rN collections defaultdictrr_r _base_alias_is_with_polymorphic _single_table_criteria_componentr#r6r rrrrrin_rr)r} fromclause where_critrsr? ext_infos_where_criteria_to_addmerged_single_crithierarchy_rootsingle_crit_componentpolymorphic_oncriterialist_of_single_critsrr merged_critnew_critrrrErs @@r~rz1_ORMSelectCompileState._adjust_for_extra_criteria s&$$44  & & ( #//   # # ' ' = #'"7"7"G"G#$88D#t((,,^TBC#C# h !&&!%!3!3   4" HOO;;G4hooF--.D$@$@@)1)B)BH%%:,,X6  "$(44 . "&  ( ( / / 1" /  Hg4...))((*?? "*!5!5!7!)%%FF "%0+@(!/!9!9(6(6(=(="2D#^42.$h%++H5LL)''::-1-E-Eh-O*&%0 :0+&Y/ l % % ' 2 &X~)  %))+6H# 6"++H5 6 "xk 1 " 2335 / 0&tU3$$/$ 0  $: : k # s#M?M :M") rrrrzrrJrrrrry)6rrrrr%rrrrKrr{rrrrrr rrrrrrrrrIr9r>rBrErrIr"rWrZr]rPr r!rhrrrrrrrrrrkrrrrrrr~rrGsO #!IO:>6G9=6Gk/k k ( k  k kkZ 5L\277r 8 8  " +8( 0#"Yv(Ob/$ &P[zeNh>T@8D{/z  (  ( $ LK;rrc j|tj||}|}|jDcgc]}||jfc}Dcgc][\}}|j|j t |dd|j|j|js t |ddndd]}}}|Scc}wcc}}w)N)rr9Fr)rtypealiasedexprr) rrIrrU _label_namerrrr)query_or_select_stmtr`rr+_entr5insp_entds r~rr s .JJ K  C25 )-T4## $   COOHHx);UCHH??. 22(D1  A " H   s B*A B/c|}|jr|j}||S|jr7d|jdjvr|jdjdSt |S)Nr3r)r_last_joined_entityrr-_entity_from_pre_ent_zero)query_or_augmented_selectr}r%s r~_legacy_filter_by_entity_zeror( sl %D "66  *& & ~~.DNN1,=,J,JJ~~a --n== $T **rc|}|jsy|jd}d|jvr|jdSt|tr |jSd|jvr|jdS|S)Nrr3bundle)rr-r3rr)r'r}r5s r~r&r& s} %D      A C)))// C- .zz S%% %)) rcl|sy|d\}}}}t|tjr |jS|S)Nr)r3rr,r) setup_joinsrUr/rrrs r~_determine_last_joined_entityr- sA %0_"FHeU%%}} rceZdZUdZdZded<dZdZdZded<ded <d ed <d ed <ddZ ddZ dZ e dZ y)rz:represent an entity column returned within a Query result.rrzsupports_single_entityFz Optional[str]rz!Union[Type[Any], TypeEngine[Any]]rz.Union[_InternalEntityType, ColumnElement[Any]]rzOptional[_InternalEntityType]rUctryrr}r`s r~rz _QueryEntity.setup_compile_state rrctryrr}r`rEs r~rz._QueryEntity.setup_dml_returning_compile_state s "##rctryr)r}r-rs r~ row_processorz_QueryEntity.row_processor rrct|D]4\}}|jr7|jr|j||j||>|j}|j r|j rAd|jvrt||||tj||j||||jjddrt|||||jr$tj||j|||tj||g||||js(t|||7|S)Nr3r*F)r_is_lambda_element _is_sequencer _resolvedrr;r-r4 _ColumnEntity _for_columns_select_iterabler _BundleEntity_is_clause_list is_bundle)rr`rrrsrrs r~rz_QueryEntity.to_compile_state sX%X.9 JKC((&&((%((++  #--F''''%)<)<<%)"// &22)"33// **..x?%)"//   //&22)"33// &22)#H// !!mV5HIs9 Jv#"rN)r`rwrNoner`rwrEz Optional[_DMLReturningColFilter]rr@)rrrrrr_non_hashable_value_null_column_typeuse_id_for_hashrrr5rrrrr~rr sxDI  O ++ 88..$$'$2$  $$>#>#rrceZdZUdZdZded<ded<ded<ded <d ed <d ed <dZdZdZdZ e dZ e dZ dZ dZdZ ddZdZy)r4z mapper/class/AliasedClass entity) rr$rUr9path_extra_entitiesrrCr_polymorphic_discriminatorrFrz Mapper[Any]r$rUrzr9rrFstrrc|j||r!|j||_d|_d|_|jd}|j |x}|_|j}||_|jx|_ }|jf|_ |jr|j|_ n|jj|_ |j|_ |j |_|j$|_|j&|_|j*|_|j.r|j1||j$yy)NTr3)r rrKrr- _post_inspectrUrrr$rGr9rrclass_rrrFrwith_polymorphic_mappersrCrrH _should_select_with_poly_adapterrA)r}r`rrrsr?r$s r~rz_MapperEntity.__init__l s ""4( ,,404 -15M ..2M +$$^4&,,4# '. f $ |  $ $'}}D %}}55D  ( 9 9++ "--)1)J)J&*2*A*A'  2 2  : :$//  3rTc.|jjSry)r$rLr|s r~rz_MapperEntity.type s{{!!!rc|jSry)rUr|s r~rz'_MapperEntity.entity_zero_or_selectable src.t|j|Sry)rrUr}rs r~rz_MapperEntity.corresponds_to s%d&6&6??rc*d}|js3|jr=|jj|jd}n|jj }|r-|j r|j|j }|S|}|S|j }|Sry)r9rrr$rUrNrwrap)r}r`rErets r~_get_entity_clausesz!_MapperEntity._get_entity_clauses s$$22'==AAKK&&//G ,,ll=#@#@A    //C rc |j}|j|}|jr|r|j|j}n|s |j}|j|ur#|j j }|j}ndx}}tj||j|||j||||j }||j|jfS)N)only_load_propsrlpolymorphic_discriminator)r`rVrrTrrrrlr_instance_processorr$rFrHrrG)r}r-rr`rErXrl _instances r~r5z_MapperEntity.row_processor s-- **=9  / /Gll=#G#GHG#::G  ( (D 0+;;LLO#11M.2 2Om//  KK   II +'&*&E&E  $**D,@,@@@rc tj||j||j||j|j |j j|j y)NrrXrY) r_setup_entity_queryr$rFrrCrrrHr3s r~rz/_MapperEntity.setup_dml_returning_compile_state sS ##  KK  II   ) )!;;)99JJ&*&E&E rc |j|}|jj}|d|jf|jvr5|j}||j r |j ndf|j|<tj||j||j||j|j|jj|j |j j#|j$y)Nrr])rVr$rrrUr9rNrrr^rFrrCrrrHrr r)r}r`rEsingle_table_critr?s r~rz!_MapperEntity.setup_compile_state s**=9 KK??  ),dkk:../''H%-%>%>!!D?M 1 1( ; ##  KK  II   ) )!;;)99JJ&*&E&E  ,,33DOODrNrA)rrrrrrrr/rBrDrrrrrVr5rrrrr~r4r4U s* I  $$ #J"O ""  @*A: ' 2    "Err4ceZdZUdZdZded<ded<ded<d ed <d ed <ded < ddZedZedZ dZ edZ dZ ddZ dZy)r=r)r*rrrrr/rrrr*z Type[Any]rrIrrzr/rNc d|_|jd}|r|jj|n|j|t |t j tjfr|j}n|}|x|_ |_ t||_ |j|_g|_|rm|jD]^}d|jvrt!|||||"t |t"rt!|||||Ct$j'||g|d||`|jj(|_y)NTr* parent_bundle)rr-rr r3rr,rrrAr*rrrrexprsr=r_ORMColumnEntityr; single_entityr/)r}r`rrrssetup_entitiesrdr*s r~rz_BundleEntity.__init__ s;+/ '  *   # # * *4 0  & &t ,  :00*2K2KL ,,.FF"(( diL !;;   t000!%++&*  f-!%++&* %11%++&* 2% 6'+kk&?&?#rc8|j}| |jSyry)rUr$)r}r's r~r$z_BundleEntity.mapperO s     << rcJ|jD]}|j}||cSyry)rrUr}r5r's r~rUz_BundleEntity.entity_zeroW s.>> COOE    rcyrrrRs r~rz_BundleEntity.corresponds_to` srcJ|jD]}|j}||cSyry)rrrks r~rz'_BundleEntity.entity_zero_or_selectablee s0>> C11E    rcH|jD]}|j|yry)rr)r}r`r5s r~rz!_BundleEntity.setup_compile_staten s#>> 3C  # #M 2 3rc$|j|Sryrr3s r~rz/_BundleEntity.setup_dml_returning_compile_stater  '' 66rc t|jDcgc]}|j||c}\}}}|jj |j ||}||j |jfScc}wry)rrr5r*create_row_processorrarrG)r}r-rr5procslabelsextraprocs r~r5z_BundleEntity.row_processory so"<@NN KSc0 K vu{{// ufMT%%t';';;; LsA5rrA)rrrrGrrrrr$rUrrrrr5rrr~r=r= sOI"! N O  L9@v 37'727  7>vF"" ++-  / /"99AA&IF'd&&(<(<<!  $ $!11 **4+@+@A5N4++^; ;Jrry) rrrrrr;rrrBrCr5rrr~r:r: sdI//b  --((0rr:cFeZdZdZdZdZdZ ddZdZ d dZ dZ y) rNF)rrrrrGc&||_||_|du|_|jr|xjddiz c_|r |j rd|_n*|r|j|_n|j||_|r|jj|n|j|||_ |jjr|jjdnd|_ |j|jf|_dx|_|_y)NrTr)rr{r|rrrr _proxy_keyrrr rr/rrGryrz)r}r`rrr{rsrds r~rz_RawColumnEntity.__init__ s 0$4D$@! ??  ) )j$-? ? )"f&<&<#D #)#4#4 #0#B#B6#J   # # * *4 0  & &t , ,0KK,E,EDKK % %a (4 &!% 4;;7377T0rcyrrrRs r~rz_RawColumnEntity.corresponds_to- src$|j|Sryrpr3s r~rz2_RawColumnEntity.setup_dml_returning_compile_state0 rqrc|j}|r||jd}| y|j}|jr|j}|jj ||j j|||_yr) rrr-rrr rr ry)r}r`rrs r~rz$_RawColumnEntity.setup_compile_state7 s}'<<> $T[[%8F~[[F   '')F$$((0%%,,V4#rryrA) rrrrUr$r/rrrrrrrr~rr sOK F"I"8H7'727  7$rrcBeZdZdZdZdZ d dZdZ d dZdZ y) rfzColumn/expression based entity.F)rr$rrrrUrGNc|j}|} |jdd} |jd| } | r#t| j| |_d|_n||_|du|_||_|r1|r| r| n |j|_n |j|| |_nd|_| j| x|_ x|_ } | jx|_ } |r|jj|n|j|d|_||_dx|_|_|j|j"f|_| j*r|j-| | j.yy)N proxy_key proxy_ownerF)rT)r-rrrrr|r{rrrrKrUrr$rr rrryrzrGrNrAr)r}r`rrr3r{rsrdrrorm_keyrr'r$s r~rz_ORMColumnEntity.__init__Y se)) "+//+t4%koomW=  2 2G $T[[%8F~$5555%)[["[[F   KK??  ),dkk:../"'"8"8d<M 1 1% 8   v'?'?'')F t{{(( ) 6 6    * *   0 0 7 78H8H I$$((0%%,,V4#rryrA) rrrrr/rrrrrrrr~rfrfJ sI)"I$AF9 9' 92 9  9)$rrfceZdZdZdZdZy)rFcyryrr1s r~rz(_IdentityTokenEntity.setup_compile_state s rc@fd}||j|jfS)Nc0jjSry)rdr)rowr-s r~rz2_IdentityTokenEntity.row_processor..getter s''77 7r)rrG)r}r-rrs ` r~r5z"_IdentityTokenEntity.row_processor s# 8t'')=)===rN)rrrr|rr5rrr~rr s  >rrr)r z#Union[Query, Select, FromStatement]r`z Optional[_ORMSelectCompileState]rrzrzList[ORMColumnDescription])r'z+Union[Query[Any], Select[Unpack[TupleAny]]]r"Optional[_InternalEntityType[Any]]ry)r,zTuple[_SetupJoinsElement, ...]rUrrz=Optional[Union[_InternalEntityType[Any], _JoinTargetElement]]) __future__rr rtypingrrrrrr r r r r rrrrrrbaserrr path_registryrr%rrrrrrrr!rwr"r#r$r&r'r(rVr) sql._typingr*r+r,sql.baser-r/r0r1r2r3r4r5r6sql.dmlr7 sql.elementsr8r9sql.selectabler:r;r<r=r>r?r@rA sql.visitorsrB util.typingrCrDrE_typingrFrGrHr$rIrarJrgrKrLenginerMengine.interfacesrNrO sql.compilerrPrQrRrSrTrUrVrWrX sql.type_apirYrZr\rootrrr^ immutabledictr&rrrwrMr^rg plugin_forrlrmrrrr(r&r-rr4r=r:rrfrrrr~rsi# #,,'(!%" *(%$('#!*! )%0:-;#-(-,"& ,3"' <4**,3936++) T5"")@@y.y.x,++'. i$|i$X*$<*Zn /n b $$$$N>'=>&)?0!!%)=>xD$4xD?xDvxPNJ0@0MxPv!!%):; !#6 < !!%2Y;-{Y;3Y;|27; = 3     < +J +' +J'*7;/3C$\#\#~iELiEX+ >r