o g2@s UdZddlmZddlZddlmZddlZddlm Z ddl Z ddl Z ddl Z ddl Z ddlmZddlZddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddl&m'Z'ddl&m(Z(ddl&m)Z)ddl&m*Z*dd l&m+Z+dd!l&m,Z,dd"l&m-Z-dd#l&m.Z.dd$l&m/Z/dd%l&m0Z0dd&l&m1Z2dd'l3m4Z4dd(l3m5Z5dd)l'm6Z6dd*l'm7Z7dd+l'm8Z8dd,l'm9Z9dd-l'm:Z:dd.l'm;Z;dd/l*mZ>dd2l0m?Z?dd3l@mAZAdd4lBmCZCdd5lBmDZDd6d7l&mEZEd6d&l&m1Z1d6d8l1mFZFd6d9lGmHZHd6d:lGmIZId6d;lGmJZJej$rEddl'mNZNdd?lOmPZPdd@lQmRZRddAlSmTZTddBlSmUZUddClSmVZVddDl*mWZWddEl*mXZXddFl*mYZYddGl*mZZZddHl*m[Z[ddIl+m\Z\ddJl.m]Z]ddKl/m^Z^ddLl/m_Z_ddMl/m`Z`ddNl/maZaddOl/mbZbddPl/mcZcddQl/mdZdddRl/meZeddSl@mfZfd6dTlgmhZhd6dUlimjZjd6dVlimkZkd6dWlimlZld6dXlimmZmd6dYlimnZnd6dZlimoZod6d[limpZpd6d\limqZqd6d]limrZred^esfZthd_Zue vd`e jwZxe vdae jwZydbdcezdddD{degZ|e vdfe jwZ}e vdfe jwZ~e vdge jwZe vdhe jZe vdie jZdjZedkdldmdndodpZie,jdqe,jdre,jdse,jdte,jdue,jdve,jdwe,jdxe,jdye,jdze,jd{e,jd|e,jd}e,jd~e,jde,jde,jdie,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jde,jdiZe+jde+jde+jde+jde+jde+jde+jde+jde+jde+jde+jde+jde+jde+jdiZded<ddddddddddddddddZe/jjde/jjde/jjde/jjde/jjde/jjdiZGdddeZGddÄdeIZdZded<dZded<d6Zded<dZded<Gdd΄deJZGddЄdeddҍZGddԄdeZGddքdeZGdd؄deZGddڄdeFZGdd܄de ZGddބde ZeeՃ\ZZZZGdddedddgZGdddZGddde1jރZGddde-jee*jZGddde-jee*jZGddde݃ZGdddeZGddde݃ZGddde߃ZGdddeZGdddeIZGdddeIZGdddZdS)a]Base SQL and DDL compiler implementations. Classes provided include: :class:`.compiler.SQLCompiler` - renders SQL strings :class:`.compiler.DDLCompiler` - renders DDL (data definition language) strings :class:`.compiler.GenericTypeCompiler` - renders type specification strings. To generate user-defined SQL strings, see :doc:`/ext/compiler`. ) annotationsN)IntEnum) perf_counter)Any)Callable)cast)ClassVar)Dict) FrozenSet)Iterable)Iterator)List)Mapping)MutableMapping) NamedTuple)NoReturn)Optional)Pattern)Sequence)Set)Tuple)Type) TYPE_CHECKING)Union)base) coercions)crud)elements) functions) operators)roles)schema) selectable)sqltypes)utilis_column_element)is_dml) _de_clone) _from_objects) _NONE_NAME) _SentinelDefaultCharacterization) Executable)NO_ARG) ClauseElement) quoted_name)Column) TupleType) TypeEngine)prefix_anon_map) Visitable)exc) FastIntFlag)Literal)Protocol) TypedDict)_AnnotationDict)_AmbiguousTableNameMap) CompileState)CacheKey)ExecutableDDLElement)Insert) UpdateBase) ValuesBase)_truncated_label) BindParameter) ColumnClause) ColumnElement)Label)Function)Table)AliasedReturnsRows)CompoundSelectState)CTE) FromClause)NamedFromClause) ReturnsRows)Select) SelectState)_BindProcessorType)CursorResultMetaData)_CoreSingleExecuteParams)_DBAPIAnyExecuteParams)_DBAPIMultiExecuteParams)_DBAPISingleExecuteParams)_ExecuteOptions)_GenericSetInputSizesType)_MutableCoreSingleExecuteParams)Dialect)SchemaTranslateMapTyperN>^asdoinisonortoallandanyascendfornewnotoffoldsetbothcaserdescelsefromfullintojoinleftlikenullonlysomethentrueuserwhenarraycheckcrossfalsegrantgroupilikeinnerlimitorderouterrighttableunionusingwherebinarycolumncreateexceptfreezehavingisnulloffsetselectuniqueanalyseanalyzebetweencollatedefaultforeignleadingnaturalnotnullplacingprimarysimilarverbosedistinctoverlapstrailing initially intersect localtime symmetric asymmetric constraint deferrable references current_date current_role current_time current_user session_user authorizationlocaltimestampcurrent_timestampz ^[A-Z0-9_$]+$z^[A-Z0-9_ $]+$cCsh|]}t|qS)str).0xrrY/var/www/html/ecg_monitoring/venv/lib/python3.10/site-packages/sqlalchemy/sql/compiler.py r $z5^(?:RESTRICT|CASCADE|SET NULL|NO ACTION|SET DEFAULT)$z^(?:DEFERRED|IMMEDIATE)$z%(? z >= z = z IS DISTINCT FROM z IS NOT DISTINCT FROM z || z MATCH z NOT MATCH z IN z NOT IN , z FROM  AS z IS z IS NOT z COLLATE zEXISTS DISTINCT zNOT zANY zALL z DESCz ASCz NULLS FIRSTz NULLS LASTz ^ z | z & ~z << z >> coalesce CURRENT_DATE CURRENT_TIMECURRENT_TIMESTAMP CURRENT_USER LOCALTIMELOCALTIMESTAMPrandomsysdate SESSION_USERUSERCUBEROLLUPz GROUPING SETSzDict[Type[Function[Any]], str] FUNCTIONSmonthdayyearsecondhourdoyminutequarterdowweekepoch milliseconds microseconds timezone_hourtimezone_minute)rrrrrrrrrrrrrrrUNIONz UNION ALLEXCEPTz EXCEPT ALL INTERSECTz INTERSECT ALLc@s8eZdZUdZded< ded< ded< ded<d S) ResultColumnsEntryaTracks a column expression that is expected to be represented in the result rows for this statement. This normally refers to the columns clause of a SELECT statement but may also refer to a RETURNING clause, as well as for dialect-specific emulations. rkeynamenameTuple[Any, ...]objectsTypeEngine[Any]typeN__name__ __module__ __qualname____doc____annotations__rrrrr[s  rc@seZdZd d d Zd S)_ResultMapAppenderrrrr Sequence[Any]type_rreturnNonecCdSNrselfrrrrrrr__call__{z_ResultMapAppender.__call__N) rrrrrrrrrrrrrrrrrrrzrz Literal[0]RM_RENDERED_NAMEz Literal[1]RM_NAMEz Literal[2] RM_OBJECTSz Literal[3]RM_TYPEc@s&eZdZUded<ded<ded<dS)_BaseCompilerStackEntryzSet[FromClause] asfrom_fromscorrelate_fromsrPr#Nrrrrrrrrrs  rc@s6eZdZUded<ded<ded<ded<ded <d S) _CompilerStackEntryr> compile_stateboolneed_result_map_for_nestedneed_result_map_for_compoundrPselect_0 Select[Any]insert_from_selectNrrrrrrs  rF)totalc@s`eZdZUdZded< ded< ded< ded < d ed < edddZedddZdS) ExpandedStatearepresents state to use when producing "expanded" and "post compile" bound parameters for a statement. "expanded" parameters are parameters that are generated at statement execution time to suit a number of parameters passed, the most prominent example being the individual elements inside of an IN expression. "post compile" parameters are parameters where the SQL literal value will be rendered into the SQL statement at execution time, rather than being passed as separate parameters to the driver. To create an :class:`.ExpandedState` instance, use the :meth:`.SQLCompiler.construct_expanded_state` method on any :class:`.SQLCompiler` instance. r statementrU parameters%Mapping[str, _BindProcessorType[Any]] processorsOptional[Sequence[str]] positiontupzMapping[str, List[str]]parameter_expansionrrcs,jdur tdtfddjDS)zrTuple of positional parameters, for statements that were compiled using a positional paramstyle. Nz.statement does not use a positional paramstylec3s|]}j|VqdSrrrkeyrrr sz6ExpandedState.positional_parameters..)r#r7InvalidRequestErrortupler(rr(rpositional_parameterss z#ExpandedState.positional_parameterscC|jS)z.synonym for :attr:`.ExpandedState.parameters`.r%r(rrradditional_parameterssz#ExpandedState.additional_parametersN)rr)rrU)rrrrrpropertyr,r.rrrrrs    rc@seZdZUdZded< ded< ded< ded < d Zded < d Zded < d Zded< dZded< d Z ded< d Z ded< d Z ded<d S)_InsertManyValuesarepresents state to use for executing an "insertmanyvalues" statement. The primary consumers of this object are the :meth:`.SQLCompiler._deliver_insertmanyvalues_batches` and :meth:`.DefaultDialect._deliver_insertmanyvalues_batches` methods. .. versionadded:: 2.0 ris_default_exprrsingle_values_exprList[crud._CrudParamElementStr]insert_crud_paramsintnum_positional_params_countedFsort_by_parameter_orderincludes_upsert_behaviorsNOptional[Sequence[Column[Any]]]sentinel_columnsrnum_sentinel_columnsr"sentinel_param_keysimplicit_sentinelembed_values_counter) rrrrrr7r8r:r;r<r=r>rrrrr0s0         r0c@sbeZdZUdZded<ded<ded<ded <d ed <d ed <d ed<d ed<ded<ded<dS)_InsertManyValuesBatchasrepresents an individual batch SQL statement for insertmanyvalues. This is passed through the :meth:`.SQLCompiler._deliver_insertmanyvalues_batches` and :meth:`.DefaultDialect._deliver_insertmanyvalues_batches` methods out to the :class:`.Connection` within the :meth:`.Connection._exec_insertmany_context` method. .. versionadded:: 2.0.10 rreplaced_statementrVreplaced_parameters#Optional[_GenericSetInputSizesType]processed_setinputsizesz#Sequence[_DBAPISingleExecuteParams]batchzSequence[Tuple[Any, ...]]sentinel_valuesr5current_batch_sizebatchnum total_batchesr rows_sorted is_downgradedNrrrrrr?Ns   r?c@s<eZdZdZdZdZdZdZeeBeBZeeBZ dZ dZ dS) InsertmanyvaluesSentinelOptszcbitflag enum indicating styles of PK defaults which can work as implicit sentinel columns rr6@N) rrrr NOT_SUPPORTED AUTOINCREMENTIDENTITYSEQUENCEANY_AUTOINCREMENT_SUPPORTED_OR_NOTUSE_INSERT_FROM_SELECTRENDER_SELECT_COL_CASTSrrrrrKgs rKc@seZdZdZ dZ dZdS) CompilerStaterrr6N)rrr COMPILINGSTRING_APPLIED NO_STATEMENTrrrrrXysrXc@s*eZdZdZdZ dZ dZ eeBZdS)Lintingzrepresent preferences for the 'SQL linting' feature. this feature currently includes support for flagging cartesian products in SQL statements. rrr6N)rrrr NO_LINTINGCOLLECT_CARTESIAN_PRODUCTS WARN_LINTING FROM_LINTINGrrrrr\sr\c@s$eZdZdZdddZd ddZdS) FromLinterzKrepresents current state for the "cartesian product" detection feature.Ncs|j}|sdSt|j}t|}|dur|}||n|}t|g}|rQ|rQ||fdd|D}| fdd|D| ||rQ|s*|rW||fSdS)NNNcsh|]}|vr|qSrrredgenoderrrz"FromLinter.lint..c3s |] }|| VqdSr)indexrcrerrr)sz"FromLinter.lint..) fromsroedgesremovepop collectionsdequepopleftdiscard extendleftdifference_update)rstartrirjthe_rest start_withstack to_removerrerlints(     zFromLinter.lintSELECTcs`\}}|r,|}|r.d}dfdd|D}|j||j|d}t|dSdSdS)Nz{stmt_type} statement has a cartesian product between FROM element(s) {froms} and FROM element "{start}". Apply join condition(s) between each element to resolve.rc3s"|] }dj|dVqdS)"N)ri)rfrom_r(rrr)s z"FromLinter.warn..) stmt_typerirs)rxrwrrir%warn)rr|rtruritemplate froms_strmessagerr(rr}s" zFromLinter.warnr)ry)rrrrrxr}rrrrras %rarirjcs@eZdZUdZdZded< dZded< ded < d Zd ZdZ d ed <dZ d ed<dZ ded<e j Zded< ded<e j Zded<dZded< dZded< dZded< ded< dd e fdEd$d%ZdFfd(d) Zed*d+Zd,d-Zd.d/Zed0d1ZdGd6d7ZdHd8d9Z   :dIdJdAdBZedCdDZZ S)KCompiledaRepresent a compiled SQL or DDL expression. The ``__str__`` method of the ``Compiled`` object should produce the actual text of the statement. ``Compiled`` objects are specific to their underlying database dialect, and also may or may not be specific to the columns referenced within a particular set of bind parameters. In no case should the ``Compiled`` object be dependent on the actual values of those bind parameters, even though it may reference those values as defaults. NOptional[ClauseElement]rrstringrXstateFzOptional[CursorResultMetaData]_cached_metadataz"Optional[List[ResultColumnsEntry]]_result_columns Optional[SchemaTranslateMapType]schema_translate_maprYexecution_optionsIdentifierPreparerpreparerr< _annotationszOptional[CompileState]rdml_compile_stateOptional[CacheKey] cache_keyfloat _gen_timedialectr\render_schema_translatercompile_kwargsMapping[str, Any]cCs||_|jj|_|r||_|j||_|durRtj|_||_|j |_ |j |_ |j r7t r3t |ts3J|j|_|j|jfi||_|rM|j|j||_tj|_ntj|_t|_dS)aConstruct a new :class:`.Compiled` object. :param dialect: :class:`.Dialect` to compile against. :param statement: :class:`_expression.ClauseElement` to be compiled. :param schema_translate_map: dictionary of schema names to be translated when forming the resultant SQL .. seealso:: :ref:`schema_translating` :param compile_kwargs: additional kwargs that will be passed to the initial call to :meth:`.Compiled.process`. N)ridentifier_preparerrr_with_schema_translaterXrYrrsupports_execution can_executerr isinstancer-_execution_optionsrprocessr_render_schema_translatesrZr[rrrrrrrrrrr__init__;s0   zCompiled.__init__rrcs|tSr)_init_compiler_clssuper__init_subclass__cls __class__rrrss zCompiled.__init_subclass__cCrrrrrrrrwzCompiled._init_compiler_clscCs |jr ||||St|jr)r_execute_compiledr7ObjectNotExecutableErrorr)r connectiondistilled_paramsrrrr_execute_on_connection{s  zCompiled._execute_on_connectioncKst|t||rr7UnsupportedCompilationErrorrrelementerrkwrrrvisit_unsupported_compilationz&Compiled.visit_unsupported_compilationcCt)zReturn a Compiled that is capable of processing SQL expressions. If this compiler is one, it would likely just return 'self'. NotImplementedErrorr(rrr sql_compilerszCompiled.sql_compilerobjr5kwargsrcKs|j|fi|Sr_compiler_dispatch)rrrrrrrrzCompiled.processcCs|jtjur |jSdS)z3Return the string text of the generated SQL or DDL.r)rrXrZrr(rrr__str__s zCompiled.__str__Tparams"Optional[_CoreSingleExecuteParams]extracted_parameters&Optional[Sequence[BindParameter[Any]]] escape_names)Optional[_MutableCoreSingleExecuteParams]cCr)zReturn the bind params for this compiled object. :param params: a dict of string/object pairs whose values will override bind values compiled in to the statement. rrrrrrrrconstruct_paramss zCompiled.construct_paramscCs|S)z0Return the bind params for this compiled object.rr(rrrrszCompiled.params) rr\rrrrrrrr)rr)rr5rrrr)rrNNTrrrrrrrr)!rrrrrrris_sqlis_ddlrrrr% EMPTY_DICTrrrrr immutabledictrr classmethodrrrr/rrrrr __classcell__rrrrrsX           8      rc@s2eZdZdZdZdddZdd dZdddZdS) TypeCompilerz2Produces DDL specification for TypeEngine objects.z visit_\w+rr\cCs ||_dSr)r)rrrrrr zTypeCompiler.__init__rrrrrrcKs4|jr|jj|jvr|j|jj}|j|fi|Sr)_variant_mappingrrrrrrrrrrs zTypeCompiler.processrr ExceptionrcKst|||r)r7rrrrrrsz*TypeCompiler.visit_unsupported_compilationN)rr\)rrrrrr)rrrrrrrr)rrrr ensure_kwargrrrrrrrrs   rc@sBeZdZdZdZdZdddZeddZed d Z d d Z d S) _CompileLabelz;lightweight label object which acts as an expression.Label.labelrr _alt_namesrcCs||_||_|f||_dSrr)rcolr alt_namesrrrrsz_CompileLabel.__init__cC|jjSrr proxy_setr(rrrrz_CompileLabel.proxy_setcCrrrrr(rrrrrz_CompileLabel.typecK|Srrrrrrr self_groupz_CompileLabel.self_groupN)r) rrrr__visit_name__ __slots__rr/rrrrrrrrs    rc@sHeZdZdZdZdZddZeddZedd Z d d Z d d Z dS)ilike_case_insensitiveaproduce a wrapping element for a case-insensitive portion of an ILIKE construct. The construct usually renders the ``lower()`` function, but on PostgreSQL will pass silently with the assumption that "ILIKE" is being used. .. versionadded:: 2.0 ilike_case_insensitive_operandr comparatorcCs||_|j|_dSrr)rrrrrrs zilike_case_insensitive.__init__cCrrrr(rrrrrz ilike_case_insensitive.proxy_setcCrrrr(rrrrrzilike_case_insensitive.typecKrrrrrrrrrz!ilike_case_insensitive.self_groupcCst|j|Sr)rr_with_binary_element_type)rrrrrrs z0ilike_case_insensitive._with_binary_element_typeN) rrrrrrrr/rrrrrrrrrs    rc @s eZdZUdZeZedddddddddZde d < d e d <de d <d Z e Z dZ de d<dZde d<dZde d< de d< dZde d< dZde d< dZde d< dZde d<de d< de d < d!e d"< dZde d#< dZde d$< dZde d%< d&e d'< d&e d(< d&e d)< d*e d+< dZde d,< dZde d-< d Zde d.< dZde d/< dZde d0< dZde d1< dZd2e d3< dZd4e d5< dZd6e d7<dZ d8e d9<dZ!d:e d;<e"Z#d< ej%Z&d?e d@< dZ' dZ( dZ)dAe dB< dZ*d6e dC< dZ+d6e dD<dZ,d6e dE<dZ-de dF<dGe dH<dIe dJ<dKe dL<de dM<e./dNZ0e./dOZ1e./e1j2dPe0j2Z3e4dQdRZ5e4dSdTZ6ddde7dfd dddeZ8e9ddgdhZ:ej;ddidjZe9dodpZ?ej@ddrdsZAejBddudvZCeDjEdwdxZFdydzZGd{d|ZHej@dd~dZIddZJe9ddZK  ddddZL    ddddZMejBddZNe9ddZO ddddZPeQdddZRde d<ej@dddZSej@eQdddZTej@eQdddZUddZVddZWdddZXddZY dddZZ dddZ[     dddZ\ddZ]ddZ^   ddddĄZ_ddƄZ`ddȄZaddʄZbdd̄Zcdd΄ZdddЄZeddd҄Zf dddԄZgddքZhdd؄ZiddڄZjdd܄ZkddބZlddZmddZnddZoddZpddZqddZrddZsddZtddZuddZvddZwddZx ddddZyddZzddZ{ddZ| d ddZ}ddZ~ddZ d!ddZd d Zd d Zd dZddZddZddZddZddZ dddZddZ    d"ddZdd Zd!d"Zd#d$Zd%d&Zd'd(Z dd)d*Zd+d,Zd-d.Zej@d/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9d:Zd;d<Zd=d>Zd?d@ZdAdBZdCdDZdEdFZdGdHZdIdJZdKdLZdMdNZdOdPZdQdRZdSdTZdUdVZdWdXZdYdZZd[d\Z     d#d]d^Zd_d`ZedfdadbZdcddZdedfZd$djdkZd%dldmZ      d&d'dwdxZdydzZdddddedfd(ddZddZddZ        d)ddZddZddZdddZddZd ddZddZddZd*ddZ dddZ      d+ddZĐddZŐddZƐddZǐddZȐddZɐde d<ejːsede"fde"fgZ dddZdZdce d<       d,ddZϐd-ddZАddZѐddÄZҐdĐdńZ  ddƐdDŽZԐdȐdɄZՐdʐd˄Z֐d̐d̈́ZאdΐdτZؐdАdфZِd.dאd؄ZڐdِdڄZ   d/dېd܄Z      d0dݐdބZݐd dߐdZސddZeejejejejejejejejejejiZeejejiZd1ddZd2ddZ d3ddZddZddZddZddZdddZddZddZdddZddZd d Zd d ZdS(4 SQLCompilerz~Default implementation of :class:`.Compiled`. Compiles :class:`_expression.ClauseElement` objects into SQL strings. PAZC_)%():.[] zClassVar[Mapping[str, str]]bindname_escape_characterszClassVar[Pattern[str]]_bind_translate_re_bind_translate_charsTFrisdeleteisinsertisupdatezOptional[List[Column[Any]]] postfetchrzSequence[Column[Any]]insert_prefetchupdate_prefetchN&Optional[Sequence[ColumnElement[Any]]]implicit_returning isplaintextzDict[str, BindParameter[Any]]bindszDict[BindParameter[Any], str] bind_nameszList[_CompilerStackEntry]rvreturning_precedes_values'render_table_with_column_in_update_fromansi_bind_rulesr bindtemplatecompilation_bindtemplate_numeric_binds_identifier_charzList[ResultColumnsEntry]r_textual_ordered_columns_ad_hoc_textual_ordered_columns_loose_column_name_matching_numeric_binds_render_postcompilezOptional[ExpandedState]_post_compile_expanded_state Optional[str]_pre_expanded_stringOptional[List[str]]_pre_expanded_positiontupzOptional[_InsertManyValues]_insertmanyvaluesz!Optional[crud._CrudParamSequence]_insert_crud_paramszFrozenSet[BindParameter[Any]]literal_execute_paramspost_compile_paramszutil.immutabledict[str, str]escaped_bind_nameszbOptional[Tuple[Dict[BindParameter[Any], List[BindParameter[Any]]], Dict[str, BindParameter[Any]]]]_cache_key_bind_matchr#_values_bindparam_visited_bindparaminlinez"Optional[MutableMapping[CTE, str]]cteszDict[Tuple[int, str], CTE]ctes_by_level_namez/Dict[CTE, Tuple[int, str, selectable._CTEOpts]]level_name_by_ctectes_recursivez"__\[POSTCOMPILE_(\S+?)(~~.+?~~)?\]z%\(([^)]+?)\)s|cCs |dSr)_init_bind_translaterrrrr2s zSQLCompiler._init_compiler_clscCs2td|j}td|d|_|j|_dS)Nrrr)reescaperwrcompilerr)rregrrrr'6s z SQLCompiler._init_bind_translaterr\rrrr column_keysr"for_executemanylintingr\_supporting_againstOptional[SQLCompiler]rrc Ks||_||_|rdd|dD} dd|dD} | | f|_||_||_i|_t|_g|_ g|_ |j |_ |j rS|j d|_} | rO|j dkrLdnd|_t|_nt|j |_d |_|jpa|j|_t|_i|_i|_tj|||fi||js|js|jrtrt |t!sJ|js|jrtrt |t"sJ|j#rd |_$n|jr|jr|j%j&r|j'rd |_$t|j |_(|r|j)*d d|j)+D|j,t-j.ur|j r|jr|/n|0|j1r|j2d d d } |j3| d dd Sd Sd S)aConstruct a new :class:`.SQLCompiler` object. :param dialect: :class:`.Dialect` to be used :param statement: :class:`_expression.ClauseElement` to be compiled :param column_keys: a list of column names to be compiled into an INSERT or UPDATE statement. :param for_executemany: whether INSERT / UPDATE statements should expect that they are to be invoked in an "executemany" style, which may impact how the statement will be expected to return the values of defaults and autoincrement / sequences and similar. Depending on the backend and driver in use, support for retrieving these values may be disabled which means SQL expressions may be rendered inline, RETURNING may not be rendered, etc. :param kwargs: additional keyword arguments to be consumed by the superclass. cSsi|]}|j|qSrr'rbrrr arz(SQLCompiler.__init__..rcSsi|]}||gqSrrr2rrrr4brrrrrNTcSsi|] \}}|dvr||qS)>rrr positionalr rr rrkvrrrr4sFr_no_postcompile)_populate_self)4r,rrr-r.rr% column_dictrrvrr5 paramstyle startswithrr _pyformat_templater BIND_TEMPLATESr" label_lengthmax_identifier_lengthr4anon_maptruncated_names_truncated_countersrrrrrrrrBrC_inliner!rinsert_executemany_returning_return_defaultsr __dict__updateitemsrrXrZ_process_numeric_process_positionalrr#_process_parameters_for_postcompile) rrrrr,r-r.r/rcksmckbmnbrrrrr<s          zSQLCompiler.__init__rcCs|jdurdS|jjS)aWhen an INSERT is compiled with a single set of parameters inside a VALUES expression, the string is assigned here, where it can be used for insert batching schemes to rewrite the VALUES expression. .. versionadded:: 1.3.8 .. versionchanged:: 2.0 This collection is no longer used by SQLAlchemy's built-in dialects, in favor of the currently internal ``_insertmanyvalues`` collection that is used only by :class:`.SQLCompiler`. N)rr2r(rrrinsert_single_values_exprs z%SQLCompiler.insert_single_values_exprcCs6|jr|jS|jdurt|jrdd|jjDSdS)aThe effective "returning" columns for INSERT, UPDATE or DELETE. This is either the so-called "implicit returning" columns which are calculated by the compiler on the fly, or those present based on what's present in ``self.statement._returning`` (expanded into individual columns using the ``._all_selected_columns`` attribute) i.e. those set explicitly using the :meth:`.UpdateBase.returning` method. .. versionadded:: 2.0 NcSsg|]}t|r|qSrr&rcrrr s z3SQLCompiler.effective_returning..)rrr(_all_selected_columnsr(rrreffective_returnings zSQLCompiler.effective_returningcCr-)zVbackwards compatibility; returns the effective_returning collection. )rWr(rrr returningszSQLCompiler.returningc Cs4z|jddWSty}ztd|d}~ww)aReturn the current 'executable' that is being compiled. This is currently the :class:`_sql.Select`, :class:`_sql.Insert`, :class:`_sql.Update`, :class:`_sql.Delete`, :class:`_sql.CompoundSelect` object that is being compiled. Specifically it's assigned to the ``self.stack`` list of elements. When a statement like the above is being compiled, it normally is also assigned to the ``.statement`` attribute of the :class:`_sql.Compiler` object. However, all SQL constructs are ultimately nestable, and this attribute should never be consulted by a ``visit_`` method, as it is not guaranteed to be assigned nor guaranteed to correspond to the current statement being compiled. .. versionadded:: 1.3.21 For compatibility with previous versions, use the following recipe:: statement = getattr(self, "current_executable", False) if statement is False: statement = self.stack[-1]["selectable"] For versions 1.4 and above, ensure only .current_executable is used; the format of "self.stack" may change. r#z$Compiler does not have a stack entryN)rv IndexError)rierrrcurrent_executables  zSQLCompiler.current_executablecCst|jt|jSr)listrrr(rrrprefetch%szSQLCompiler.prefetchDict[Any, Any]cCsiSrrr(rrr_global_attributes)rzSQLCompiler._global_attributesMutableMapping[CTE, str]cCs$t}||_i|_i|_d|_|S)zInitialize collections related to CTEs only if a CTE is located, to save on the overhead of these collections otherwise. F)r% OrderedDictr"r#r$r%)rr"rrr_init_cte_state-s  zSQLCompiler._init_cte_statec cs|j|j}}gd|_|_z'|jr|jd}d|d<nd}|j|jfVW|r.|d|||_|_dS|r>|d|||_|_w)z;special API to support the use case of 'nested result sets'FrYTrN)rrrvrl)rresult_columnsordered_columnsentryrrr_nested_resultEs*     zSQLCompiler._nested_resultcsjrJjtjus JjrJjjdkrdn jjdks#Jdgdfd d tj j _ j r\d d j Dt j t ksQJfd dD_n_jrgtj jj}fddjjD}jj||d_dSdS)Nr%srrm re.Match[str]rrcs6|d}|r|S|d|dS)Nrr6r)rappend)ri normal_bind) placeholder positionsrr find_positionjs   z6SQLCompiler._process_positional..find_positioncSi|]\}}||qSrrr6rrrr4yz3SQLCompiler._process_positional..csg|]}||qSrgetrr)reverse_escaperrrU{s z3SQLCompiler._process_positional..c s4g|]}|d|dtj|d|dfqS)rrr6r)r(sub_positional_patternrr8)rorrrrUsr2r4)rirjrr)r#rrXrZrrr=r(rvrwrrrKlenrr2r4_replace)rr2r4r)rormrnrurrrM]sD         zSQLCompiler._process_positionalc sZjsJjtjus Jd}ijr-jdur-tfddj Dj }nj }|D]*}|vr;q4j |}|j vsJ|j vrOd|<q4j |}|d7}||<q4|_t_jrt}fddDt|ksJjfddj_jrjj}dd jjD}jj||d _dSdS) Nrc3s|] }|jvr|VqdSr)rrtr(rrr)s z/SQLCompiler._process_numeric..cs i|] \}}j|||qSr)rrs)rrposr(rrr4z0SQLCompiler._process_numeric..c|dSNrrri param_posrrz.SQLCompiler._process_numeric..cSs$g|]}|d|dd|dfqS)rrrhrrrxrrrrUsz0SQLCompiler._process_numeric..ry)rrrXrZrr itertoolschainrvaluesrrrr next_numeric_posr]r#rrzrK_pyformat_patternrvrr2r4r{) rnumr bind_namebindph len_beforer2r4r)rrrrLs\           zSQLCompiler._process_numericVMutableMapping[str, Union[_BindProcessorType[Any], Sequence[_BindProcessorType[Any]]]]csddfddjDDS)NcSsi|] \}}|dur||qSrrrr'valuerrrr4s z0SQLCompiler._bind_processors..c3sP|]#}j||jjs|jjntfddtt|jjDfVqdS)c3s|] }|jVqdSr)_cached_bind_processorr)r elem_typer(rrr)  z9SQLCompiler._bind_processors...N) rr_is_tuple_typerrr+rr2types)r bindparamr(rrr)s  z/SQLCompiler._bind_processors..)rr(rr(r_bind_processorss  zSQLCompiler._bind_processorscCst|jdkSr)rzrvr(rrr is_subqueryzSQLCompiler.is_subquerycCrrrr(rrrrrzSQLCompiler.sql_compilerrrrrcCs|j||dd}||S)aRReturn a new :class:`.ExpandedState` for a given parameter set. For queries that use "expanding" or other late-rendered parameters, this method will provide for both the finalized SQL string as well as the parameters that would be used for a particular parameter set. .. versionadded:: 2.0.0rc1 Tr9)rrN)rrrrrrrconstruct_expanded_statesz$SQLCompiler.construct_expanded_staterr _group_number Optional[int]_checkr:r[cs |jr|s|jdus J|st|jjStd|ot|j}|rK|jdur,t d|jd}|j } | dus:J| \} fddt ||D} nd} |ri} |j D]]\} }|rc|j||n|}| j|vrr|| j| |<qV||vr}||| |<qV|r| jr|rtjd| j|fdd tjd | jdd | r| | | }n| }| jr|j| |<qV|j| |<qV| Si} |j D]E\} }|r|j||n|}|r| jr|rtjd| j|fdd tjd | jdd | r| | | }n| }| jr|j| |<q|j| |<q| S) z5return a dictionary of bind parameter keys and valuesNzcan't construct new parameters when render_postcompile is used; the statement is hard-linked to the original parameters. Use construct_expanded_state to generate a new statement and parameters.zcThis compiled object has no original cache key; can't pass extracted_parameters to construct_paramsrcs$i|]\}}|D]}||q qSrr)rr3 extractedrrPrrr4Gsz0SQLCompiler.construct_params..z@A value is required for bind parameter %r, in parameter group %dcd3x)codez)A value is required for bind parameter %r)rrdictrr7r*rrr CompileErrorrziprrKrsr'requiredcallableeffective_valuer)rrrrrrr:has_escaped_namesorig_extracted ckbm_tuplerresolved_extractedpdrr escaped_name value_paramrrrrs             zSQLCompiler.construct_paramscs|jjjjfddi}|j}|jD]#}||vr$q|jjr9fddtt |jj D||<q|j||<q|S)Ncs@|}|durdus|vrdus|vr|SdSr)_unwrapped_dialect_implget_dbapi_type)typdbtype)dbapir exclude_types include_typesrr lookup_types z.lookup_typecg|]}|qSrr)rr)rrrrUsz;SQLCompiler._get_set_input_sizes_lookup..) rinclude_set_input_sizesexclude_set_input_sizesrrrrrrr2r)r inputsizesrrr)rrrrrr_get_set_input_sizes_lookups      z'SQLCompiler._get_set_input_sizes_lookupcCs |jddS)zReturn the bind param dictionary embedded into this compiled object, for those values that are present. .. seealso:: :ref:`faq_sql_expression_string` - includes a usage example for debugging use cases. F)rrr(rrrrs zSQLCompiler.paramsrr;csi}j}|dur j}jrg}j}|durj}nd}}j}td|td|i}ii} d} jrD|durD|} jrCg} nj } j } | D]| rX| n} j }|j vru| vrtj||| d| <qN|jvr| vr| | }d}n|}| ||}|\}}|| | <|| <|js|||jjr|dusJ|fddt|dDn |fdd|D| dur| d d|Dn|dur|d d|Dd d |D|<qN|dur|qNfd d}tj||}| dur5|dusJfddt| jDjfdd|}|| t|||||}|r\|_|_|j_jrVt |jpTdnd_|_!|S)ahandle special post compile parameters. These include: * "expanding" parameters -typically IN tuples that are rendered on a per-parameter basis for an otherwise fixed SQL statement string. * literal_binds compiled with the literal_execute flag. Used for things like SQL Server "TOP N" where the driver does not accommodate N as a bound parameter. Nr z/Mapping[str, Sequence[_BindProcessorType[Any]]]render_literal_valuec3sb|],\}}t|dD]"\}}vr-|ddur d||f|dfVq qdS)rN%s_%s_%s enumerate)ri tuple_elementjr)rtuple_processorsrrr)=s zBSQLCompiler._process_parameters_for_postcompile..rc3s(|]\}}vr|fVqdSrr)rr'r)rsingle_processorsrrr)Hs cs|]\}}|VqdSrrrrrrrrr)Ns csrrrrrrrr)UscSsg|]\}}|qSrr)r expand_keyrrrrrUVszCSQLCompiler._process_parameters_for_postcompile..csb|d}|}|dr/|dd}|d|ddfdd|dD}|S)Nrr6~~rrc3s|] }d|fVqdSz%s%s%sNr)rexpbe_leftbe_rightrrr)e  z]SQLCompiler._process_parameters_for_postcompile..process_expanding..)rsplitrw)rir'exprtok)replacement_expressionsrrprocess_expanding\s  zJSQLCompiler._process_parameters_for_postcompile..process_expandingcs i|] \}}|j|qSrr )rrr'r(rrr4qr}zCSQLCompiler._process_parameters_for_postcompile..cr~rrrrrrryrzASQLCompiler._process_parameters_for_postcompile..r)"rrr5rr#rrrrrrrsrrrender_literal_bindparamrlr$_literal_execute_expanding_parameterliteral_executerJrrrextendrkr(rv_post_compile_patternrrrrr]r)rrr;expanded_parameterspre_expanded_stringnew_positiontuppre_expanded_positiontupr!new_processorsto_update_setsnumeric_positiontupnamesebnr parameter to_updaterleep_resreplacement_exprrrexpanded_stater)rrrrrrrrNs                   z/SQLCompiler._process_parameters_for_postcompilezsqlalchemy.engine.cursorcCstjj}|j|jS)z(utility method used for unit tests only.)r% preloaded engine_cursorrT_create_description_match_mapr)rcursorrrr_create_result_mapszSQLCompiler._create_result_map_BindNameForColProtocol_get_bind_name_for_colCallable[[Any], str]cCs |j}|Sr)r)rgetterrrr_within_exec_param_key_gettersz)SQLCompiler._within_exec_param_key_getterzsqlalchemy.engine.resultcstjj}|j|jdusJ|jj}trt|tsJ|j }fdd|j Dd|j durKj |jd|jvrJfdd}|nd|dd|j Dfdd}|S)Ncs"g|] }td|d|fqS)rsN)operator methodcallerrr)param_key_getterrrrUszKSQLCompiler._inserted_primary_key_from_lastrowid_getter..cs||}|dur |S|Srrr) lastrowidr param_value) autoinc_keyrr_autoinc_getters zPSQLCompiler._inserted_primary_key_from_lastrowid_getter.._autoinc_gettercSg|]}|jqSrr1rrrrrUcsJdurdurfddDSfddDS)agiven cursor.lastrowid value and the parameters used for INSERT, return a "row" that represents the primary key, either by using the "lastrowid" or by extracting values from the parameters that were sent along with the INSERT. Nc3s|] \}}|VqdSrrrrrr%rrr)zWSQLCompiler._inserted_primary_key_from_lastrowid_getter..get..c3s:|]\}}|urdurnn|VqdSrrr) autoinc_colautoinc_getterrrrrr)s   rrr)rrgetterslastrowid_processorrow_fnrrrss zDSQLCompiler._inserted_primary_key_from_lastrowid_getter..get)r%r engine_resultrrrrrrAr primary_key_autoincrement_columnr_cached_result_processorrr result_tuple)rresultrrrrsr)rrrrrrrr+_inserted_primary_key_from_lastrowid_getters2    z7SQLCompiler._inserted_primary_key_from_lastrowid_gettercstjr ddlm}ntjj}|jdusJ|jj}tr"t |t s"J|j |j }|j }|dus1Jddt|Dtdfdd|jD|dd|jDfd d }|S) Nr6)r cSrprr)ridxrrrrr4 rqzKSQLCompiler._inserted_primary_key_from_returning_getter..z'List[Tuple[Callable[[Any], Any], bool]]cs<g|]}|vrt|dfn td|ddfqS)TrsNF)r itemgetterrr)rretrrrU s  zKSQLCompiler._inserted_primary_key_from_returning_getter..cSrrr1rrrrrU rcsfddDS)Nc3s(|]\}}|r |n|VqdSrr)rruse_rowrrowrrr)" s  zWSQLCompiler._inserted_primary_key_from_returning_getter..get..r)rr)rrrrrs! szDSQLCompiler._inserted_primary_key_from_returning_getter..get)typingrenginer r%rrrrrrArrrrrrr )rr rrrXrsr)rrrrr+_inserted_primary_key_from_returning_getters*   z7SQLCompiler._inserted_primary_key_from_returning_gettercCdS)zCalled when a SELECT statement has no froms, and no FROM clause is to be appended. Gives Oracle Database a chance to tack on a ``FROM DUAL`` to the string output. rrr(rrr default_from) szSQLCompiler.default_fromc Ks|jj|fi|}|jD]n}||jvrq |j|}|j|j|jddd}|j|}||j|<|j|<||j|<|j|d||jvrN|j|hO_||j vr[|j |hO_ |j }|r{|\} } |j D]}|j| vrz| |j} | |  |qgq |S)aSQL compile the nested element of an _OverrideBinds with bindparams swapped out. The _OverrideBinds is not normally expected to be compiled; it is meant to be used when an already cached statement is to be used, the compilation was already performed, and only the bound params should be swapped in at execution time. However, there are test cases that exericise this object, and additionally the ORM subquery loader is known to feed in expressions which include this construct into new queries (discovered in #11173), so it has to do the right thing at compile time as well. TF) maintain_keyrN) rr translater _with_valuer'rrlrrr _cloned_setrk) roverride_bindsrsqltextr7bpnew_bprrrPrOcbrrrvisit_override_binds3 s6          z SQLCompiler.visit_override_bindscKsd|jj|fi|dSNrrrr)rgroupingasfromrrrrvisit_groupings zSQLCompiler.visit_groupingcKsd|jj|fi|dSr#r$)rr%rrrrvisit_select_statement_groupingv r(z+SQLCompiler.visit_select_statement_groupingc Ks|jrN|jjrNz td|jdd}Wnty%}ztd|d}~ww|j\}}}|r1|} n|} |jj } | durN| j | vrN| | | j rN|jj |d<|j |jfd|i|S)N'Union[SelectState, CompoundSelectState]rYrECan't resolve label reference for ORDER BY / GROUP BY / DISTINCT etc.render_label_as_labelwithin_columns_clause) rvrsupports_simple_order_by_labelrKeyErrorr7r_label_resolve_dictr_order_by_label_elementrshares_lineager) rrr-rrke with_cols only_froms only_cols resolve_dict order_by_elemrrrvisit_label_referencey sL   z!SQLCompiler.visit_label_referencec Ks|js ||jSz td|jdd}Wnty2}ztj|jdtj |dWYd}~nd}~ww|j \}}}z|rB||j} n||j} Wntyf} ztj|jdtj | dWYd} ~ dSd} ~ ww| |d<|j| fd|i|S)Nr*rYrr+)extraexc_clsrr,r-) rvr _text_clauserr/r_no_text_coercionrr7rr0) rrr-rrr3r4r5r6rrrrrvisit_textual_label_reference sN      z)SQLCompiler.visit_textual_label_referencec Ks|o| }||u} | s |rt|jtjr|d|j} n|j} |rN|dur5|| |j|| f|j||j|jj|fddd|t t j |j || S| rW|j || S|jj|fddi|S)NcolidentT)r-within_label_clauser-F)rrrrD_truncated_identifierrrrr OPERATORSr as_r format_label) rradd_to_result_mapr@r-r,result_map_targetsrrender_label_with_asrender_label_only labelnamerrr visit_label sJ  zSQLCompiler.visit_labelcCs td)Nz:Cannot compile Column object until its 'name' is assigned.r7rrrrrr_fallback_column_name sz!SQLCompiler._fallback_column_namecKs|j}|j|fi|Sr) _resolvedr)rrr sql_elementrrrvisit_lambda_element sz SQLCompiler.visit_lambda_elementrColumnClause[Any]rEOptional[_ResultMapAppender] include_tablerFrambiguous_table_name_map Optional[_AmbiguousTableNameMap]cKs6|j}}|dur||}|j} | st|tjr|d|}|dur<|||jf|} |jr4| |jf7} |||| |j | rD| |}n|j |}|j } | dusV|rV| jsX|S|j | } | ri|j | d} nd} trtt| tstJ| j}| s|r||vr||}t|tjr|d|}| |j |d|S)Nr?rralias)rrM is_literalrrrDrAr' _tq_labelrescape_literal_columnrquoternamed_with_columnschema_for_object quote_schemarrO)rrrErSrFrTrr orig_namerWtargetsreffective_schema schema_prefix tablenamerrr visit_column sD         zSQLCompiler.visit_columncKs|j|jSr)rformat_collation collationrrrrrrvisit_collationJ rzSQLCompiler.visit_collationcK|jSrr)r fromclauserrrrvisit_fromclauseM zSQLCompiler.visit_fromclausecKrhrri)rrhrrrr visit_indexP rlzSQLCompiler.visit_indexcKs*||d<|j|d<|jjj|jfi|S)Ntype_expressionr)rrtype_compiler_instancerr)r typeclauserrrrvisit_typeclauseS s zSQLCompiler.visit_typeclausecC|jjr |dd}|SNr%%r_double_percentsreplacertextrrrpost_process_textZ  zSQLCompiler.post_process_textcCrrrsrurxrrrrY_ r{z!SQLCompiler.escape_literal_columnc sRfdd}jsd_|r|ddftjtddt|jS)Ncs>|d}|jvrjj|fiSj|fiSr)r _bindparamsrbindparam_string)rirrr textclauserr do_bindparame s  z2SQLCompiler.visit_textclause..do_bindparamTcSs |dSrrrrrrrw s z.SQLCompiler.visit_textclause..) rvrr$NULLTYPEBIND_PARAMS_ESCrv BIND_PARAMSrzry)rrrErrrr~rvisit_textclaused s zSQLCompiler.visit_textclausec Ks|j }|r |jn|jd}tt|d}|j||jr%||||p6|dko0|ddp6|dd}|rY|j|_|_ |j oHt |j |_ |j D] } |j | d|jdqM|j |jfi|} |jrw|smt|jnd} |j| d | } |jd| S) NrYrrr#rrFrT)r-rE nesting_level)rv_default_stack_entryrork_independent_ctes_dispatch_independent_ctesrsr5rrr column_argsrr_add_to_result_maprr"rz_render_cte_clauserl) rtafcompound_indexr&rtoplevelrf new_entrypopulate_result_maprTryrrrrvisit_textual_select} sB        z SQLCompiler.visit_textual_selectcKrNNULLrrrrrrr visit_null rzSQLCompiler.visit_nullcK|jjrdSdS)Nr~1rsupports_native_booleanrrrr visit_true zSQLCompiler.visit_truecKr)Nr0rrrrr visit_false rzSQLCompiler.visit_falsec s$|ddfdd|DDS)Ncs|]}|r|VqdSrrrsrrrr)  z7SQLCompiler._generate_delimited_list..c3"|] }|jfiVqdSrrrSrrrrr)  rw)rr separatorrrrr_generate_delimited_list s z$SQLCompiler._generate_delimited_listc sltjtjtjjtjj|\}}|dkr|djfiSt tj}| ddfdd|DDS)Nrrcsrrrrrrrr) rz;SQLCompiler._generate_delimited_and_list..c3rrrrSrrrr) r) rBooleanClauseList_process_clauses_for_booleanr and_True_ _singletonFalse_rrBrw)rclausesrlccrrrr_generate_delimited_and_list s  z(SQLCompiler._generate_delimited_and_listcKsd|j|fi|SN(%s))visit_clauselist)r clauselistrrrr visit_tuple szSQLCompiler.visit_tuplecKs4|j}|dur d}nt|j}|j|j|fi|SNr)rrBrr)rrrseprrrr s  zSQLCompiler.visit_clauselistc Ks||j}||dd}|r|||fi|Szt|}Wnty.}zt|||d}~wwd|d<|j|j|fi|S)Nexpression_clauselistT_in_operator_expression)r_get_operator_dispatchrBr/r7rrr)rrr operator_dispopstringrrrrvisit_expression_clauselist s$ z'SQLCompiler.visit_expression_clauselistcKsd}|jdur||jj|fi|d7}|jD]\}}|d|j|fi|d|j|fi|d7}q|jdurL|d|jj|fi|d7}|d7}|S)NzCASE rzWHEN z THEN zELSE END)rrwhenselse_)rclauserrcondr rrr visit_case s*  zSQLCompiler.visit_casecK|jj|fi|Sr)typed_expressionr)r type_coercerrrrvisit_type_coerce zSQLCompiler.visit_type_coercecKs^|jj|fi|}td|}d|jj|fi||r!|dn||r+|dfSdfS)Nz(.*)( COLLATE .*)zCAST(%s AS %s)%srr6r)rprr(matchrr)rrr type_clauserrrr visit_cast s  zSQLCompiler.visit_castc Ksd|dtjur dn2|dtjurdn)|ddkr,d|jtt|dfi|fnd|jt|dfi|f|dtjurGdfS|dtjurRdfS|ddkrmd|jtt|dfi|ffSd|jt|dfi|ffS) Nz %s AND %srzUNBOUNDED PRECEDINGz CURRENT ROWz %s PRECEDINGz %s FOLLOWINGrzUNBOUNDED FOLLOWING)rRANGE_UNBOUNDED RANGE_CURRENTrliteralabs)rrange_rrrr_format_frame_clause sJ  !"z SQLCompiler._format_frame_clausec s|jjfi}|jrdj|jfi}n|jr*dj|jfi}nd}d|dfddd|jfd|jffD|rF|gngfS) NzRANGE BETWEEN %szROWS BETWEEN %sz %s OVER (%s)rcs:g|]\}}|durt|rd||jfifqS)Nz%s BY %s)rzr)rwordrrrrrrUP sz*SQLCompiler.visit_over.. PARTITIONORDER)rrrrrowsrw partition_byorder_by)roverrryrrrr visit_over@ s4    zSQLCompiler.visit_overcK,d|jj|fi||jj|fi|fS)Nz%s WITHIN GROUP (ORDER BY %s))rrr)r withingrouprrrrvisit_withingroup] zSQLCompiler.visit_withingroupcKr)Nz%s FILTER (WHERE %s))funcr criterion)r funcfilterrrrrvisit_funcfilterc rzSQLCompiler.visit_funcfiltercKs.|j|j|j}d||jj|fi|fS)NzEXTRACT(%s FROM %s)) extract_maprsfieldrr)rextractrrrrr visit_extracti s zSQLCompiler.visit_extractcKs2|j|jfi|}|j|fi|}d||fS)Nz(%s).%s)visit_functionfnrc)rrr compiled_fn compiled_colrrrvisit_scalar_function_columnp s z(SQLCompiler.visit_scalar_function_columnr Function[Any]c s|dur||j|j|jf|jtd|jd}|r&||fi|}nJt|jdr9|jr8d7n|jj sHt t j rNj nddfdd|jDgdj|fi|i}|jrw|d7}|S)Nz visit_%s_funcz%(expr)srcs4g|]}j|sttjrj|n|qSr)r_requires_quotes_illegal_charsrrr0rZ)rrrrrrrU s  z.SQLCompiler.visit_function..rz WITH ORDINALITY)rrgetattrlowerrrs _deannotater _has_argsrrrrr0rZrw packagenamesfunction_argspec_with_ordinality)rrrErrryrrrru s<      zSQLCompiler.visit_functioncKs ||jSr)visit_sequencesequence)r next_valuerrrrvisit_next_value_func  z!SQLCompiler.visit_next_value_funccKtd|jj)Nz2Dialect '%s' does not support sequence increments.rrrrrrrrrr zSQLCompiler.visit_sequencecKrr) clause_exprr)rrrrrrr rzSQLCompiler.function_argspecc  slj }|j|fi}|rjs|_|j}|rjnjd}|p-| o-|dd} |dkr6||d<j|d|d||| d|jrO|j |j } d | d  fd d t |j D} dd <| j|fitdd i7} | j|fi7} |jr| j|fi7} jr|stjnd} j| dd| } jd| S)NrYrFrrrr)rrr#rrrc3s,|]\}}|jf|dVqdS))r&rNr)rrrTr&rrrrr) s z4SQLCompiler.visit_compound_select..rSr&Trinclude_following_stackr)rv_compile_state_factoryrrrrsrkrrcompound_keywordskeywordrwrselectsgroup_by_clauserorder_by_clause_has_row_limiting_clause_row_limit_clauser"rzrrl) rcsr&rrrr compound_stmtrfneed_result_maprryrrrrvisit_compound_select sX      $ z!SQLCompiler.visit_compound_selectcKs.|jdur|j|fi|S|j|fi|Sr) _fetch_clause fetch_clause limit_clause)rrrrrrr  s zSQLCompiler._row_limit_clausecCs(d|j||r d|ndf}t||dS)Nz visit_%s_%s%srr)rr)rr qualifier1 qualifier2attrnamerrrr s  z"SQLCompiler._get_operator_dispatchcKs|dur||f7}||d<||d<|jr=|jrtd||jdd}|r0|||jfi|S|j|t|jfi|S|jra||jdd}|rT|||jfi|S|j|t|jfi|Std)NrErFzFUnary expression does not support operator and modifier simultaneouslyunaryrmodifierz,Unary expression has no operator or modifier)rrr7rr _generate_generic_unary_operatorrB _generate_generic_unary_modifier)rrrErFrrrrr visit_unary sB   zSQLCompiler.visit_unarycKs|jjr,|j|jfi|d|jt|j|jjjt j ur!|jjnt fi|S|j|jfi|d|j|jfi|S)N / ) rdiv_is_floordivrrxrCastrr_type_affinityr$Numericrrrrrrrvisit_truediv_binary$ s0 z SQLCompiler.visit_truediv_binarycKst|jjr"|jjjtjur"|j|jfi|d|j|jfi|Sd|j|jfi|d|j|jfi|S)Nrz FLOOR(%s)) rrrrr r$Integerrrxr"rrrvisit_floordiv_binary? s z!SQLCompiler.visit_floordiv_binarycKs:|js|jjr|j|jfi|Sd|j|jfi|S)Nz%s = 1_is_implicitly_booleanrrrrrrrrrrrvisit_is_true_unary_operatorP s z(SQLCompiler.visit_is_true_unary_operatorcKs>|js|jjrd|j|jfi|Sd|j|jfi|S)NNOT %sz%s = 0r&r(rrrvisit_is_false_unary_operatorY s z)SQLCompiler.visit_is_false_unary_operatorcKsd|j|tjdS)Nr*)override_operator) visit_binaryr match_opr"rrrvisit_not_match_op_binaryb sz%SQLCompiler.visit_not_match_op_binarycKsd|j|t|fi|Sr)_generate_generic_binaryrBr"rrrvisit_not_in_op_binaryg s z"SQLCompiler.visit_not_in_op_binarycKsn|tjurt|dkrdddd|DSdS|tjur2t|dkr0dddd|DSd S||S) Nrz(%s)) OR (1 = 1rcs|]}dVqdSrNrrrrrrr)s z6SQLCompiler.visit_empty_set_op_expr..zNULL) OR (1 = 1z(%s)) AND (1 != 1csr2r3rr4rrrr)z r5zNULL) AND (1 != 1)r not_in_oprzrwin_opvisit_empty_set_expr)rr expand_oprrrrvisit_empty_set_op_expro s     z#SQLCompiler.visit_empty_set_op_exprcKr)Nz3Dialect '%s' does not support empty set expression.rr element_typesrrrrr8 rz SQLCompiler.visit_empty_set_exprc sbjj}|s.|jr!jjrdndjjj}d|fSjgj}d|fS|jsE|jrgt |dt j rgt |dt t fsg|jrLtdjjrRdnddfddt|D}d|fS|rj}||}|rx|ds|Jd |dd }|d |d dfd d|D}d|fSdfdd|D}d|fS)NVALUES rrz?bind_expression() on TupleType not supported with literal_bindsrc3s:|]\}}ddfddt|jjDVqdS)rrc3s |] \}}||VqdSrr)rr param_typer(rrr) s  z[SQLCompiler._literal_execute_expanding_parameter_literal_binds...N)rwrrr)rrrrrrrr) s  zQSQLCompiler._literal_execute_expanding_parameter_literal_binds..r6)unexpected format for expanding parameterrrrc3s(|]}d|jfVqdSrrrrrrrrrrrr) s  c3s|] }|jVqdSrrArBr?rrr) rr)rrrrtuple_in_valuesr:rr9_isnullrcollections_abcrrbytes_has_bind_expressionrrwrrsearchrr) rrrbind_expression_templatetyp_dialect_implreplacement_expressionpost_compile_patternrirrrCr2_literal_execute_expanding_parameter_literal_binds s` = 6 ' z>SQLCompiler._literal_execute_expanding_parameter_literal_bindscsdjr |Sj}j|jrjnjjjr-j r-fddnfdd|sTgj rG jj j }|fS jgj }|fSj skjrt|dtjrt|dttfsjrpJfddt|dD|jrdnd d fd d t|D}|fSfd dt|dDd fdd D}|fS)Ncsjd|iSNr)render_bind_castrri) bind_templaterrrKrr_render_bindtemplate s  zNSQLCompiler._literal_execute_expanding_parameter.._render_bindtemplatecs d|iSrOrri)rQrrrR rrcs6g|]\}}t|dD] \}}d||f|fq qS)rrr)rrrrrrirrrU szDSQLCompiler._literal_execute_expanding_parameter..rr=rrc3s:|]\ddfddtDVqdS)rrc3s0|]\}}t|dVqdS)rN)rz)rrr)rRrrrrrr) s zMSQLCompiler._literal_execute_expanding_parameter...N)rwr)r)rRr)rrrr) s  zCSQLCompiler._literal_execute_expanding_parameter..cs g|] \}}d|f|fqS)z%s_%sr)rrrrirrrU r}c3s|] \}}|VqdSrrr)rRrrr) s  )rrNrrrrr r _bind_typing_render_castsrPrr:rr9rErrFrrrG _is_arrayrrDrw)rrrrrrLr)rRrQrrrrrKrr sd   + '     z0SQLCompiler._literal_execute_expanding_parameterc Ks|r;t|jr;|dur)|d}|jtt|jj |gt|j j |gn|jtt|jj t|j j |j rPt |jt jrPt |j t jrPd|d<|pT|j}||dd} | rg| ||fi|Szt|} Wnty} zt||| d} ~ ww|j|| f||d|S)Nenclosing_lateralTrr) from_linterlateral_from_linter)r is_comparisonrrjrJrproductr)rxr*rr rrrErrBr/r7rr0) rrr,eager_groupingrVrWrrUrrrrrrrr- sZ           zSQLCompiler.visit_binarycKs|j|jfi|Sr)r sql_functionr(rrr&visit_function_as_comparison_op_binaryX rz2SQLCompiler.visit_function_as_comparison_op_binarycKs`|jjr|j|jfi|d|j|jfi|S|j|jfi|d|j|jfi|S)Nz %% r)rrvrrxrr"rrrvisit_mod_binary[ szSQLCompiler.visit_mod_binarycKs.|j|d<|j|d||jdfi|S)NrZr)rZr0rYrr(rrrvisit_custom_op_binaryi s z"SQLCompiler.visit_custom_op_binarycKs |j|||jdfi|Sr)rrYrr(rrrvisit_custom_op_unary_operatorq z*SQLCompiler.visit_custom_op_unary_operatorcKs |j|d||jfi|Sr)rrYrr(rrrvisit_custom_op_unary_modifierv r`z*SQLCompiler.visit_custom_op_unary_modifiercKsf|dd}d|d<|j|d<|jj|fd|i|||jj|fd|i|}|r1|r1d|}|S)NrFT _binary_oprZr)rsrrxrr)rrrrZrrryrrrr0{ s0   z$SQLCompiler._generate_generic_binarycKs||jj|fi|Srr$rrrrrrrr z,SQLCompiler._generate_generic_unary_operatorcKs|jj|fi||Srr$rcrrrr rdz,SQLCompiler._generate_generic_unary_modifiercCstjdtjdS)Nz'%')r)rliteral_columnr$ STRINGTYPEr(rrr_like_percent_literal sz!SQLCompiler._like_percent_literalcKsd|jj|fi|dS)Nzlower(rr$rfrrr$visit_ilike_case_insensitive_operand r(z0SQLCompiler.visit_ilike_case_insensitive_operandcK6|}|j}||j||_|j||fi|Sr_clonergconcatrvisit_like_op_binaryrrrrpercentrrrvisit_contains_op_binary z$SQLCompiler.visit_contains_op_binarycKrirrkrgrlrvisit_not_like_op_binaryrnrrrvisit_not_contains_op_binary rqz(SQLCompiler.visit_not_contains_op_binarycKF|}|j}t|j|_|t|j||_|j||fi|Srrkrgrrxrlrvisit_ilike_op_binaryrnrrrvisit_icontains_op_binary  z%SQLCompiler.visit_icontains_op_binarycKrurrkrgrrxrlrvisit_not_ilike_op_binaryrnrrrvisit_not_icontains_op_binary ryz)SQLCompiler.visit_not_icontains_op_binarycK0|}|j}||j|_|j||fi|Sr)rkrg_rconcatrrmrnrrrvisit_startswith_op_binary z&SQLCompiler.visit_startswith_op_binarycKr}r)rkrgr~rrsrnrrrvisit_not_startswith_op_binary rz*SQLCompiler.visit_not_startswith_op_binarycK@|}|j}t|j|_|t|j|_|j||fi|Sr)rkrgrrxr~rrwrnrrrvisit_istartswith_op_binary  z'SQLCompiler.visit_istartswith_op_binarycKrr)rkrgrrxr~rr{rnrrrvisit_not_istartswith_op_binary rz+SQLCompiler.visit_not_istartswith_op_binarycKr}rrjrnrrrvisit_endswith_op_binary rz$SQLCompiler.visit_endswith_op_binarycKr}rrrrnrrrvisit_not_endswith_op_binary rz(SQLCompiler.visit_not_endswith_op_binarycKrrrvrnrrrvisit_iendswith_op_binary rz%SQLCompiler.visit_iendswith_op_binarycKrrrzrnrrrvisit_not_iendswith_op_binary rz)SQLCompiler.visit_not_iendswith_op_binarycKZ|jdd}d|jj|fi||jj|fi|f|dur*d||tjSdS)Nr)z %s LIKE %s ESCAPE r modifiersrsrxrrrr$rfrrrrr)rrrrm sz SQLCompiler.visit_like_op_binarycKr)Nr)z%s NOT LIKE %srrrrrrrrs sz$SQLCompiler.visit_not_like_op_binarycK>|tjur|}t|j|_t|j|_|j||fi|Sr)r ilike_oprkrrxrrmr"rrrrw   z!SQLCompiler.visit_ilike_op_binarycKrr)r not_ilike_oprkrrxrrsr"rrrr{rz%SQLCompiler.visit_not_ilike_op_binarycK*|jdd}|j||rdndfi|S)NrFz BETWEEN SYMMETRIC z BETWEEN rrsr0rrrrrrrrvisit_between_op_binarys  z#SQLCompiler.visit_between_op_binarycKr)NrFz NOT BETWEEN SYMMETRIC z NOT BETWEEN rrrrrvisit_not_between_op_binarys z'SQLCompiler.visit_not_between_op_binarycKtd|jjNz/%s dialect does not support regular expressionsr7rrrr"rrrvisit_regexp_match_op_binary& z(SQLCompiler.visit_regexp_match_op_binarycKrrrr"rrr visit_not_regexp_match_op_binary,rz,SQLCompiler.visit_not_regexp_match_op_binarycKr)Nz;%s dialect does not support regular expression replacementsrr"rrrvisit_regexp_replace_op_binary2rz*SQLCompiler.visit_regexp_replace_op_binarycKs|sW|j|j}|jrW||} |j| fd||o|j ||d|} |jrUtd| } | s3Jdd| d| d| df} |rU|j |fd| d |} d | S| S|si|pb|j pb|ob|j }|pg|j} nd } |r|j |fd di|} |jrd | } | S| |}||jvr|j|}||ur|js|jr|j|js|j|jstd ||j|jkrtd|f|js|jr|jr|jrtdtd|jd|jd||j|j<|j|<|j}|r |\}}|jD]}|j|vr||j}|||q|jrd|_| r-|rd|_|r%|j|hO_n|j|hO_|j|f| |j|jd|} |jrDd | } | S)NT)skip_bind_expressionr- literal_bindsrrender_postcompilez&^(.*)\(__\[POSTCOMPILE_(\S+?)\]\)(.*)$r@z$(__[POSTCOMPILE_%s~~%s~~REPL~~%s~~])r6rr)r-rJrFr-zIBind parameter '%s' conflicts with unique bind parameter of the same nameaCan't reuse bound parameter name '%s' in both 'expanding' (e.g. within an IN expression) and non-expanding contexts. If this parameter is to receive a list/array value, set 'expanding=True' on it for expressions that aren't IN, otherwise use a different parameter name.a)Encountered unsupported case when compiling an INSERT or UPDATE statement. If this is a multi-table UPDATE statement, please provide string-named arguments to the values() method with distinct names; support for multi-table UPDATE statements that target multiple tables for UPDATE is very limitedzbindparam() name 'z' is reserved for automatic usage in the VALUES or SET clause of this insert/update statement. Please use a name other than column name when using bindparam() with insert() or update() (for example, 'b_z').) post_compile expandingbindparam_type)r dialect_implrrHbind_expressionrrr(rrrrr _truncate_bindparamrrr intersectionrr7r_is_crudr'rrk isoutparamhas_out_parametersrrrr})rrr-rrrrrimplrwrappedrirrrexistingrrPrOrr!rrrvisit_bindparam8s                   zSQLCompiler.visit_bindparamcCrrr)rr dbapi_typerrrrrPrlzSQLCompiler.render_bind_castc Ks|tur|}n/|jdur3|jdur3|dd}|r)|tjtjfvr)td|j f|j t j fi|S|j }|jrG|j}||||d\}} | S|||jS)NrbzBound parameter '%s' rendering literal NULL in a SQL expression; comparisons to NULL should not use operators outside of 'is' or 'is not')rJ)r.rrrsr is_is_notr% warn_limitedr'rr$rrrrNrr) rrrrJrropleeprrrrrrs(  z$SQLCompiler.render_literal_bindparamc Cs|dur|js|tjS||j}|r9z||WSty8}zt dt |d|d|d}~wwt dt |d|)aRender the value of a bind parameter as a quoted literal. This is used for statement sections that do not accept bind parameters on the target driver/database. This should be implemented by subclasses using the quoting services of the DBAPI. Nz Could not render literal value "z" with datatype z); see parent stack trace for more detail.z:No literal value renderer is available for literal value ") should_evaluate_nonerrNull _instance_cached_literal_processorrrr7rsql_util_repr_single_value)rrr processorerrrrs2    z SQLCompiler.render_literal_valuecCs@||jvr |j|S|j}t|tjr|d|}||j|<|S)Nr)rr'rrrDrA)rrrrrrr&s     zSQLCompiler._truncate_bindparam ident_classrrDcCs||f|jvr|j||fS||j}t||jdkrB|j|d}|dt|jdddt|dd}|d|j|<n|}||j||f<|S)Nrrrr6) rD apply_maprCrzrArErsmaxhex)rrranonnamecounter truncnamerrrrA3s z!SQLCompiler._truncated_identifiercCs ||jSrrCrrrrr _anonymizeHrzSQLCompiler._anonymizerr escaped_fromrOptional[TypeEngine[Any]]accumulate_bind_namesOptional[Set[str]]visited_bindparamrc  s|dur |||dur|||s)j|r)jfdd|} |}| }|r4j||i_|rTd|} |r>| S|durR|j} | j rR || | } | Sj t j urbjd|i} njd|i} |durjjr|j} | j r || | } | S)Ncsj|dS)Nr)rrrr(rrrez.SQLCompiler.bindparam_string..z__[POSTCOMPILE_%s]r)addrkrrIrvrrrrrender_literal_castrPrrXrYr r rS) rrrrrrrrrnew_namer type_implrr(rr}KsJ      zSQLCompiler.bindparam_stringcCsF|}|ddt|j|jD]\}}|j|fd|i|qdS)Ncte_opts)copyrlrr_independent_ctes_optsr)rstmtrlocal_kwcteoptrrrrs  z&SQLCompiler._dispatch_independent_ctesrrMr&ashint fromhintsOptional[_FromHintsType] visiting_cte Optional[CTE]rVOptional[FromLinter]rselectable._CTEOptsc s} | jus J||d<|j} t| tjrd| } d} d} |} |jp+|j}| j vrxj | \}}}|| ks?J|| f}j |}|jrw|jrSt d|| f}|r^t jnd}|| f}}j |=|j |<||fj | <n|rt jnd}|| f}|j vrj |}nd}|dur||u} ||jus||urd} n6||jur| |=|}|| usJ||usJj |=n|jdus|jdur||rd} nt d| |s| sdS|jdur|j}|jj}t|tjrd|}n|}d}| r|j |<||fj | <|jvrj|fi||s|| vr|jr-d_j|| }|jrU|j}dd |dD}|d d fd d |D7}|dddus`Jjsp|jjfd|i|Sj||jfi|}|jjfddi|}|d||f7}|jr|dj||jfi|7}|| |<|r|r| |j |!<| s| rj|| S|rj||}j"| r׈j#| } |$| 7}|Sj|| SdS)NrrVTFz6CTE is stated as 'nest_here' in more than one locationrz5Multiple, unrelated CTEs found with the same name: %rcSs"g|] \}}}}}|s|p|qSrr)rr proxy_namefallback_label_namerTrepeatedrrrrUsz)SQLCompiler.visit_cte..rrc3s"|] }jj|jdVqdS)rN)rformat_label_namerC)ridentr(rrr)- z(SQLCompiler.visit_cte..subqueryr&z AS %s (%s)r)%rcr"rrrrDrA_get_reference_ctenestingr$r#r7rrzrv _restates _is_clone_ofcompare _cte_alias visit_cte recursiver%r format_aliasr_generate_columns_plus_namesrwrsr_generate_prefixes _prefixes _suffixesrir)_requires_quotesrZget_render_as_alias_suffix)rrr&rrrrVrr self_ctescte_name is_new_cteembedded_in_current_named_cte_reference_cter cte_levelrexisting_cte_optscte_level_name existing_cteold_level_namenew_level_nameexisting_cte_reference_cte pre_alias_ctecte_pre_alias_namery col_source recur_colsprefixesrrr(rrs                           zSQLCompiler.visit_ctecKs8|jrd|d<|jr|j|fi|S|j|fi|S)NrV)joins_implicitly _is_lateral visit_lateral visit_aliasrfrrrvisit_table_valued_aliasas z$SQLCompiler.visit_table_valued_aliascK|j|fi|Sr)rcrfrrrvisit_table_valued_columnirz%SQLCompiler.visit_table_valued_columnc  s|rdvrjs Jd<| rdvrdvr| d<|durD|jurDjjf|||||d} |rB|s=|rBd| f} | S}d<|sN|r`tjtjr]dj} nj} |rij | S|r| rt| | j <jjfd|d} |rd| f} |  j | } j rjr| dd fd d jD7} |r|vr| ||} | Sjjfd |iS) NrUrW)r&riscrudrlateralenclosing_aliasrrrVT)r&rrc3sH|]}dj|jjrdjjj|jfindfVqdS)z%s%s %srN)rrZr_render_derived_w_typesrrorrrrVrrrrr)s"   z*SQLCompiler.visit_alias..r)r rrrrrrDrArrrir)r_supports_derived_columns_render_derivedrwrTformat_from_hint_text)rrVr&rrrrrrrVrr alias_namerrrrr ls          zSQLCompiler.visit_aliascKsd|d<|j|fi|S)NTrr )rrrrrrvisit_subqueryszSQLCompiler.visit_subquerycKsd|d<d|j|fi|S)NTrz LATERAL %sr)rlateral_rrrrr szSQLCompiler.visit_lateralcKsZd|j|fddi||j|fi|f}|jdur+|d|jj|fi|7}|S)Nz%s TABLESAMPLE %sr&Tz REPEATABLE (%s))r  _get_methodrseed)r tablesampler&rryrrrvisit_tablesamples zSQLCompiler.visit_tablesamplec s6djdfddjD}d|S)Nrrc3s>|]}|D]}jtj|djifiVqqdS)rN)rrr _column_typesr)rchunkelemrrrrrr)s" z-SQLCompiler._render_values..r=) setdefaultrrw_data)rrrtuplesrr#r_render_valuess  zSQLCompiler._render_valuesc sj|fi}|jrd}nt|jtjrd|j}n|j}|jr'd}nd}|rc|r:|dur3|nd|j| <|r]dd<d|| j |d fd d |jDf}|Sd ||f}|S) NrzLATERAL rz(unnamed VALUES element)FrSz %s(%s)%s (%s)rc3rrrrSrrrr)s  z+SQLCompiler.visit_values..z%s(%s))r'_unnamedrrrrDrAr rir)rrrZrwcolumns)rrr&rVrr8rrrrr visit_valuess4  zSQLCompiler.visit_valuescKsd|j|fi|dSr#)r'rfrrrvisit_scalar_valueszSQLCompiler.visit_scalar_valuescCsd|S)Nrr)ralias_name_textrrrrz&SQLCompiler.get_render_as_alias_suffixrrrrrcCsN|sJ|dus |dkrd|_d|_|jrtd|jt||||dS)N*FTzxMost backends don't support SELECTing from a tuple() object. If this is an ORM query, consider using the Bundle object.)rrrr7rrrkrrrrrrs  zSQLCompiler._add_to_result_mapcKs&|jd||d|dur in|fi|S)aLRender a column with necessary labels inside of a RETURNING clause. This method is provided for individual dialects in place of calling the _label_select_column method directly, so that the two use cases of RETURNING vs. SELECT can be disambiguated going forward. .. versionadded:: 1.4.21 NF_label_select_column)rrrrcolumn_clause_argsrrrr_label_returning_column8s z#SQLCompiler._label_returning_columnc sj|j} | jr| s|r| }n}|r4|j}| r&|fdd}n|ur3|fdd}nd}| s.add_to_result_mapcs||f||dSrrr4rrrrrE{sNzX_label_select_column is only relevant within the columns clause of a SELECT or RETURNING)rz*proxy_name is required if 'name' is passedTF)r-rErS)rrr_has_column_expressioncolumn_expressionrrrrHrrrrXrFrWr TextClauseUnaryExpressionwraps_column_expression NamedColumn_non_anon_label_anon_name_labelrDrJr)rrrrr&r2rrrr-column_is_repeatedneed_column_expressionsrSrcol_exprrE result_exprrender_with_labelrr5rr1Ms           z SQLCompiler._label_select_columncCs |||}|r|d|7}|Sr)get_from_hint_text)rrrhintrhinttextrrrrs  z!SQLCompiler.format_from_hint_textcCrrr)rbyfromsrrrget_select_hint_textrz SQLCompiler.get_select_hint_textcCrrrrrryrrrrCrzSQLCompiler.get_from_hint_textcCrrrrHrrrget_crud_hint_textrzSQLCompiler.get_crud_hint_textcCs d|Srr)r hint_textsrrrget_statement_hint_textrz#SQLCompiler.get_statement_hint_textrrrrc Ksj|j }|r |jn|jd}|||}|d}|d} |r,|s,|j|| dd} | S|j|| d} | S)NrYrrrexplicit_correlate_fromsimplicit_correlate_froms)rvrr_get_display_froms difference) r select_stmtr&rrrrfrrrrirrr_display_froms_for_select s$  z%SQLCompiler._display_froms_for_selecttranslate_select_structurec  s|dusJdd| d<jfi| } | j| d<| jj } | r*js*| _|dup/|} jrUjfdi| } | urU| }}| jfi| } | j| rZjnjd}| pl|ddpl|dd|rsds|d | vr|| d =| |||}|  ddd d }j r \}}|r||d 7}nd}j r| jr|jjfi| 7}|jfi| 7}d dfdd| jDD}r|durttdd| jDdd|jDfddjD_|| |||| | }jr-fddjD}|r-|d |7}jrI| r7| rI| s?tjnd}j|d|}jr\|d jjfi| 7}jd|S)NzpSQLAlchemy 1.4 requires use of the translate_select_structure hook for structural translations of SELECT objectsFr-rTr&rYrrrE)r@r-zSELECT rcSsg|]}|dur|qSrrrSrrrrUs z,SQLCompiler.visit_select..cs4g|]\}}}}}j|||||d qS))rrrr>r?r0rrrrrr)r&r2r?rrQrrrrUs( cSg|] \}}}}}|qSrrrr'rrrrrrrrUcSrUrrrVrrrrUrWc s4g|]\}}}}t||tfdd|D|qS)c3s|] }||VqdSrrr)rorrrr)rz6SQLCompiler.visit_select...)rr+)rr'rrrrYrrrUs  cs$g|]\}}|djjfvr|qSr/rr)r dialect_namehtr(rrrUs r)r_ambiguous_table_name_maprrvrrSrrs_setup_select_stackrrJ_hints_setup_select_hintsrrrrget_select_precolumnscolumns_plus_namesrrr_compose_select_body_statement_hintsrKr"rzrrrl)rrQr& insert_intorrselect_wraps_forrrVrrris_embedded_selectnew_select_stmtcompile_state_wraps_forrfriry hint_textbyfrom inner_columns per_dialectrr)r&r2r?rrQrrr visit_select.s              zSQLCompiler.visit_selectrrTuple[str, _FromHintsType]cs*fdd|jD}|}||fS)Nc s<i|]\\}}}|djjfvr||d|jddiqS)r/rT)rrrr)rr{rrEr(rrr4s z3SQLCompiler._setup_select_hints..)r`rKrG)rrrlrkrr(rras  zSQLCompiler._setup_select_hintscCs|d}|d}|dkr||d<n"|r3|d} t| j} t|j| kr3tdd| |dt|jf|rB|sB|j||dd} n|j||d} tt| } | |} | | ||d }|j || S) Nrrrrz}All selectables passed to CompoundSelect must have identical numbers of columns; select #%d has %d columns, select #%d has %drrrL)rrr#r) rzrVrcr7rrOrPror*rrvrk)rrrrfr&rrrrrnumcolsrinew_correlate_fromsall_correlate_fromsrrrrr_sJ      zSQLCompiler._setup_select_stackc s|d|7}jt@rtitjt@} |r_ndd} |s'|}|rS|d7}|jrB|dfdd|D7}n|dfdd|D7}n| 7}|j rpj |j fdi} | rp|d| 7}| r|dusxJ |j r|j|fi7}|jrj |jfi} | r|d | 7}|jr|j|fi7}|jr|j|fi7}|jdur|j|fi7}|S) NrFz FROM cs&g|]}|jfddqS)T)r&rrVrrfrlrVrrrrrU`sz4SQLCompiler._compose_select_body..cs$g|]}|jfddqS)Tr&rVrru)rVrrrrrUmsrVz WHERE z HAVING )rwr.r^raror_rVrstripr`r_where_criteriarr}_group_by_clausesr _having_criteria_order_by_clausesr r r _for_update_argfor_update_clause) rryrrrmrirlrr warn_lintingtrrwrrd;sn          z SQLCompiler._compose_select_bodyc s*dfdd|D}|r|d7}|S)Nrc3s:|]\}}|dvs|jjkr|jfiVqdS))Nr/Nrq)rprefixr\rrrr)sz1SQLCompiler._generate_prefixes..r)rrrrrrrrrs zSQLCompiler._generate_prefixesc Cs,|jsdS|rB|dkrBt}t|jD]*}|j|\}}}|jp'|j}||kp3|o3||dk} |r8| s9q|j|||<qn|j}|sIdStdd|D} | | d} | d dd| D7} | d7} |r|dkrt|D]}|j|\}}}|j|=|j ||f=|j|=qw| S) z include_following_stack Also render the nesting CTEs on the next stack. Useful for SQL structures like UNION or INSERT that can wrap SELECT statements containing nesting CTEs. rrcSrr)r)rrrrrrUrz2SQLCompiler._render_cte_clause..r, cSsg|]}|qSrr)rtxtrrrrUrz ) r"r%rbr]keysr$rrrgget_cte_preamblerwrr#) rrrr"rrrrris_rendered_levelr%cte_textrrrrs@      zSQLCompiler._render_cte_clausecCs |rdSdS)NzWITH RECURSIVEWITHr)rrrrrrszSQLCompiler.get_cte_preamblecKs"|jr tjddd|jrdSdS)zcCalled when building a ``SELECT`` statement, position is just before column list. a DISTINCT ON is currently supported only by the PostgreSQL dialect. Use of DISTINCT ON for other backends is currently silently ignored, however this usage is deprecated, and will raise CompileError in a future release for all backends that do not support this syntax.z1.4versionrr) _distinct_onr%warn_deprecated _distinctrrrrrrrbs z!SQLCompiler.get_select_precolumnscK,|j|jttjfi|}|rd|SdS)z5allow dialects to customize how GROUP BY is rendered.z GROUP BY r)rr{rBr comma_op)rrrgroup_byrrrr s zSQLCompiler.group_by_clausecKr)z5allow dialects to customize how ORDER BY is rendered.z ORDER BY r)rr}rBr r)rrrrrrrr s zSQLCompiler.order_by_clausecKr)Nz FOR UPDATErrrrrrrzSQLCompiler.for_update_clauserrBreturning_colsSequence[ColumnElement[Any]]rc s6fddjdt|dD}dd|S)Nc s6g|]\}}}}}j|f||||dqS))rr>rr)r3rTrrrrrrrUs( z0SQLCompiler.returning_clause..T)cols RETURNING r)rr_select_iterablesrwrrrrrr)rrrreturning_clause s  zSQLCompiler.returning_clausecKsfd}|jdur|d|j|jfi|7}|jdur1|jdur#|d7}|d|j|jfi|7}|S)Nrz LIMIT z LIMIT -1z OFFSET ) _limit_clauser_offset_clause)rrrryrrrr)s   zSQLCompiler.limit_clausec Ks|dur |j}|j}nddd}d}|jdur5|j}|r%||r%|}|j|fi|} |d| 7}n|r;|d7}|durf|rJ||rJ|}|d|j|fi||drZdnd|d rad nd f7}|S) NF)ro with_tiesrz OFFSET %s ROWSz OFFSET 0 ROWSz FETCH FIRST %s%s ROWS %sroz PERCENTrz WITH TIESONLY)r_fetch_clause_optionsr_simple_int_clauserender_literal_executer) rrrrequire_offset"use_literal_execute_for_simple_intrfetch_clause_optionsry offset_clause offset_strrrrr3s8  zSQLCompiler.fetch_clausec Ks|r|j|j|<|s |r]|j|} |r&| r&|j| d|j|j} n%|j|j} | sK|rK|j|vrK|d||j} | ||j d| } |r[||vr[| | ||||} | SdS)NrrVr) fullnamerirr\r]rZrrArrr) rrr&rrr use_schemarVrTrr`r anon_namerrr visit_table\s:         zSQLCompiler.visit_tablecKs|r|jtt|jjt|jj|jrd}n|j r d}nd}|jj |fd|d|||jj |fd|d|d|j j |fd|i|S)Nz FULL OUTER JOIN z LEFT OUTER JOIN z JOIN Trxz ON rV) rjrJrrYr)rxr*rruisouterronclause)rrwr&rVr join_typerrr visit_joinsP   zSQLCompiler.visit_joincsBfdd|jD}|j|vr||j||jd}||fS)Ncs*i|]\\}}}|djjfvr||qSrZr[)rrrrkr(rrr4s  z1SQLCompiler._setup_crud_hints..T)r`rKrr)rr table_text dialect_hintsrr(r_setup_crud_hintss  zSQLCompiler._setup_crud_hintsrrJr9cCs~|jj}|j}|j}|durdS|jr|j|jd}n|j|jd}||@r*|S|j r=t d|dd|jj ddS)a)given a :class:`.Table`, return a usable sentinel column or columns for this dialect if any. Return None if no sentinel columns could be identified, or raise an error if a column was marked as a sentinel explicitly but isn't compatible with this dialect. NrzColumn z@ can't be explicitly marked as a sentinel column when using the a dialect, as the particular type of default generation on this column is not currently compatible with this dialect's specific INSERT..RETURNING syntax which can receive the server-generated value in a deterministic way. To remove this error, remove insert_sentinel=True from primary key autoincrement columns; these columns are automatically used as sentinels for supported dialects in any case.) r"insertmanyvalues_implicit_sentinel _sentinel_column_characteristicsr) is_autoinc_sentinel_col_autoinc_lookuprsdefault_characterization _sentinel_col_non_autoinc_lookup is_explicitr7r*r)rr sentinel_optssentinel_characteristics sent_colsbitmaskrrr_get_sentinel_column_for_tables*  z*SQLCompiler._get_sentinel_column_for_tablerWcompiled_parameters%List[_MutableCoreSingleExecuteParams]generic_setinputsizesrB batch_sizer5r7rr Iterator[_InsertManyValuesBatch]c1 #s j}|dus J|jsdntj|jt } |jr& jjs&d} d} n jjr7|r< j r<|j dus7|j r.cs@|D]}||}|jd|ijd|di}q|S)Nr__EXECMANY_INDEX__)rsrwr )r formattedr')rrrrapply_placeholderss   zISQLCompiler._deliver_insertmanyvalues_batches..apply_placeholdersz, _IMV_VALUES_COUNTERrrc3s"|] \}}}}||VqdSrr)rrr bind_keys)rrrr)s   z@SQLCompiler._deliver_insertmanyvalues_batches..c3s.|]\}}}}|D] }||Vq qdSrrr)rrrr')rrrr)s  csi|] }|d|qS)rrr&r%rrr4s zASQLCompiler._deliver_insertmanyvalues_batches..z, _IMV_VALUES_COUNTER), z), rcsh|] \}}|vr|qSrr)rrr)all_names_we_will_expandrrrs z@SQLCompiler._deliver_insertmanyvalues_batches..z\d+rhcSsg|] \}}}|||fqSrr)rnew_keylen_rrrrrUsc3s4|]}D]\}}}|d|||fVqqdS)rNr)rrhr'rr)rrrr)s rc3s|] }|VqdSrrr2)expand_pos_lower_indexexpand_pos_upper_indexrrr)rc3s$|] \}}dt|VqdS)_IMV_VALUES_COUNTERN)rwrrrr)executemany_values_w_commarrr)s c3s|] }j|VqdSrrrrr(rrr)4rEXECMANY_INDEX__rcs i|] }|d|qS)__rr&)rparamrrr4Us crrr)rr!)_sentinel_from_paramsrrrUcr)3rr<rrrzr1rsupports_default_metavaluesupports_multivalues_insertrr:r8rrrr? functoolspartialrrr2rwinsertmanyvalues_max_parametersrr4minr]r5rror>rwrrPrJr#rrr(r)r rvranger6r+rr from_iterablerrrk)1rrrrrrr7rimv lenparamsuse_row_at_a_time downgradedrGcompiled_paramimv_single_values_exprexecutemany_values max_paramstotal_num_of_paramsnum_params_per_batchnum_params_outside_of_batchbatchescompiled_batchesrCrHr4all_keysimv_values_counterformatted_values_clausekeys_to_replacebase_parametersr"r#all_expand_positionsescapedrDcompiled_batchrFnum_ins_paramsextra_params_leftextra_params_rightbatch_iteratorexpanded_values_stringrsrirnr@rAreplaced_values_clausesfmvr) rrrrrrrrrrrrrr!_deliver_insertmanyvalues_batchess                                 z-SQLCompiler._deliver_insertmanyvalues_batchesc s|j|fi|}|j}|dur||d<d}nj }|r-d_js'|_js-|_jtt|dd}d}jrF|durFg}t j |||fd|i|}jrr|durrt |}j rrj duroj |7_ n|_ |j} | sjjsjjsjjstdjj|jrjjstdjjjs|jr|jrtd |j} n|j} j} jj} d } |jr| j||jfi|7} | d 7} | |j} |j r߈!|| \}} |j"r#||| | 7} | s| s| d d $dd| D7} |j%}d}d}d}jp |j}|r|j&}|durm|sJdd| D}g}|D]!}||vr4d}n'|}|||vrDd}n||q)|durejj(t)j*@r[d}n |dj+reJdt,|t,|}j-|||d}j.r| d|7} nd}|j/durj0jddfddi|}j1rjj2r|st jnd}| dj3|dd|f7} n| d|7} n| s| r| d7} |rt4djj5t6d| ||j|j7du||rt |nd|d _8n|jr| dd $dd |j9Df7} nd $d!dt6d| D}|r|rXjj(t)j:@rX|j;sXd}jj(t)j<@}d $d"d t=| D}|rGd $fd#d t=| D}n|}| d$|d%|d&|d'7} n d}| d(|d)7} t4d|t6d| ||j|j7du||rxt |nd|||d* _8n| d(|d)7} |j7durj0|j7fi|}|r| d|7} |rj.s| d|7} j1rˈjj2s|st jnd}j3|dd| } j>d| S)+NrFTrrrzWThe '%s' dialect with current database version settings does not support empty inserts.zcThe '%s' dialect with current database version settings does not support in-place multirow inserts.zcRETURNING cannot be determinstically sorted when using an INSERT which includes multi-row values().zINSERT zINTO  (%s)rcSsg|]\}}}}|qSrr)rrrrrrrUrgz,SQLCompiler.visit_insert..cSsi|] \}}}}||qSrr)rrr param_namesrrrr4s z,SQLCompiler.visit_insert..zTsentinel selection rules should have prevented us from getting here for this dialectrrrYrrfz %s%srrz DEFAULT VALUESr3)r7r8r:r;r=z VALUES %scss(|]}dddd|DVqdS)rrcss|] \}}}}|VqdSrrrrrrrrr)grz5SQLCompiler.visit_insert...Nr)rcrud_param_setrrrr)es z+SQLCompiler.visit_insert..cSsg|]\}}}}|qSrrrrrrrUms css|] \}}d|VqdSpNrrrrrr) c3s8|]\}^}}|j|jjd|VqdSr)rPrrr)rrrrr(rrr)s   z SELECT z FROM (VALUES (z)) AS imp_sen(z#, sen_counter) ORDER BY sen_counterz VALUES (r) r1r2r4r6r7r8r:r;r<r=r>)?rrrvrrrrkror5r_get_crud_paramsrzrr single_paramsrsupports_default_valuesrsupports_empty_insertr7rr_has_multi_parametersrr _returning_sort_by_parameter_orderrrr format_tablerr`rrrrwuse_insertmanyvaluesuse_sentinel_columnsrrrKrT_insert_sentinelr]rrrrr"cte_follows_insertrr0default_metavalue_tokenr_post_values_clauserall_multi_paramsrVis_default_metavalue_onlyrWrrl) r insert_stmtrrrrrcounted_bindparamcrud_params_structcrud_params_singlerrryrrrnamed_sentinel_paramsadd_sentinel_colsr=r_params_by_col_add_sentinel_col param_namer select_textrrRembed_sentinel_valuerender_bind_castscolnamescolnames_w_castpost_values_clauserr(r visit_insertos                            zSQLCompiler.visit_insertcCr)z3Provide a hook for MySQL to add LIMIT to the UPDATENr)r update_stmtrrrupdate_limit_clauserzSQLCompiler.update_limit_clausecCr)z3Provide a hook for MySQL to add LIMIT to the DELETENr)r delete_stmtrrrdelete_limit_clauserzSQLCompiler.delete_limit_clausecKsd|d<|j|fddi|S)z|Provide a hook to override the initial table clause in an UPDATE statement. MySQL overrides this. Tr&rr)rr& from_table extra_fromsrrrrupdate_tables_clausesz SQLCompiler.update_tables_clausecKtd)z~Provide a hook to override the generation of an UPDATE..FROM clause. MySQL and MSSQL override this. zCThis backend does not support multiple-table criteria within UPDATErrr&r*r+ from_hintsrrrrupdate_from_clauses zSQLCompiler.update_from_clausec s|j||fi|}|j}|dur||d<d}n|j }|r-d|_|js'||_|js-||_|jt@rCtit }|jt @}|rB||_ nd}d}|j }t |} | rft t|jfdd|D} |} ng} |jh} |j| | |dd} |jr| |j||jfi|7} |j||j| fd|i|} tj||||fi|}|j}|jr||| \}} nd}|jr|||| | 7} | d 7} | d d d td |D7} |js|jr|j r| d|j!||jp|j|d7} |r|j"||j| |fd|i|}|r| d|7} |j#r |j$|j#fd|i|}|r | d|7} |%|}|r.| d|7} |js6|jrK|j sK| d|j!||jpE|j|d7} |j&ra|sWt'|jnd}|j(|d| } |rq|duskJ|j)dd|j*d| S)NrFTcsg|]}|vr|qSrrru main_fromsrrrU#sz,SQLCompiler.visit_update..rzUPDATE rVz SET rcss$|] \}}}}|d|VqdS)=Nr)rrrrrrrr)Ss   z+SQLCompiler.visit_update..zList[Tuple[Any, str, str, Any]]rr WHERE rUPDATEr|rY)+rrrvrrrr.r^raror_rV _extra_fromsrr*rrrkrrr,rrrr`rrrrwrrr rrr0rzrr'r"rzrr}rl)rr&rrrrrVrr+ is_multitablerender_extra_fromsrryrr crud_paramsrextra_from_textrrrrr1r visit_updates                   zSQLCompiler.visit_updatecKr-)zProvide a hook to override the generation of an DELETE..FROM clause. This can be used to implement DELETE..USING for example. MySQL and MSSQL override this. zCThis backend does not support multiple-table criteria within DELETErr.rrrdelete_extra_from_clauses z$SQLCompiler.delete_extra_from_clausecKs|j|fddd|S)NT)r&rr)rr(r*r+rrrrdelete_table_clauseszSQLCompiler.delete_table_clausecKs|j||fi|}|j}|dur||d<d}n|j }|r-d|_|js'||_|js-||_|jt@rCtit }|jt @}|rB||_ nd}d}|j }|j h|} |j| | |dd} |jrm| |j||jfi|7} | d7} z |j||j ||d} Wnty|||j |} |r|j|j |d} Ynwtj||||fi||jr||| \} } nd} |jr|||| | 7} |js|jr|jr| d|j||jp|j|d 7} |r|j||j || fd |i|}|r| d|7} |j r |j!|j fd |i|}|r | d |7} |"|}|r| d|7} |js!|jr6|js6| d|j||jp0|j|d 7} |j#rL|sBt$|jnd}|j%|d | } |r\|dusVJ|j&d d|j'd| S)NrFTrzDELETE FROM )rVrrrVr4rDELETEr6rY)(rrrvrrrr.r^raror_rVr7rrrkrrr> TypeErrorrrrr`rrrrr rrr=rzrr)r"rzrr}rl)rr(rrrrrVrr+rryrrrr;rrrrrr visit_deletes                 zSQLCompiler.visit_deletecKd|j|S)Nz SAVEPOINT %srformat_savepointrsavepoint_stmtrrrrvisit_savepoint&zSQLCompiler.visit_savepointcKrC)NzROLLBACK TO SAVEPOINT %srDrFrrrvisit_rollback_to_savepoint)z'SQLCompiler.visit_rollback_to_savepointcKrC)NzRELEASE SAVEPOINT %srDrFrrrvisit_release_savepoint.rKz#SQLCompiler.visit_release_savepoint)rr\rrrrr,r"r-rr.r\r/r0rr)rr)rr)rr_)rra)rr)NT)rrrrrr)NNTNTF)rrrrrrrrrrr:rrr[F)rr[r;rrr)rr)NFFNr)NTrN)rrQrErRrSrrFrrTrUrrrrr)NF)rrrErRrrrr)FNNr)NFNN)FFFFF)rrrrDrr)rrrr)FFNNNN)rrrrrrrrrrrrrrrrrr)rrMr&rrrrrrrrVrrrrrrr)FFFNFFNN) rrrrrrrrrr)NNNTFFT)FFNNNFN)rrrrp rrBrrrrrrrr)NFF)FFFNTNN)rrJrr9)rrrrWrrrrBrr5r7rrrrrrb)rrrr EXTRACT_MAPrr%rrrrCOMPOUND_KEYWORDSrrrrrrrrrr r rrrrrrrrrrr frozensetrrrrrpostfetch_lastrowidrr#rr r!r(r*rrpatternrwrrr'r]rr/rRro_memoized_propertyrWrXr\r^memoized_propertyr`memoized_instancemethodrc contextlibcontextmanagerrgrMrLrrrrrrrrNpreload_modulerrr rrr"r'r)r9r>rJrMrPrcrgrkrmrqrzrYrrrrrrrrrrrrrrrrrrrrrrrrr rrr#r%r)r+r/r1r:r8rNrr-r\r]r^r_rar0rrrgrhrprtrxr|rrrrrrrrrmrsrwr{rrrrrrrPr.rrrrArr}rr#_CTEOptsrr rr rr rr'r*r+rrr3r1rrGrCrIrKrrrrRrSrorar_rdrrrrbr r rrrrrrrr, CLIENTSIDErKrUSENTINEL_DEFAULTNONErRrSrrrQrrrr%r'r)r,r0r<r=r>rBrHrJrLrrrrr sH                                   "  ;I  & F  R . @ 0 0 1;  4  *.  A   &      JR 8                        & ! %  C  L  d   &  %      N 4 _  5     ,0 >^ t       rcseZdZdZddZedfddZddZd d Z d d Z d dZ d+ddZ ddZ ddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*ZZS),StrSQLCompileraA :class:`.SQLCompiler` subclass which allows a small selection of non-standard SQL features to render into a string value. The :class:`.StrSQLCompiler` is invoked whenever a Core expression element is directly stringified without calling upon the :meth:`_expression.ClauseElement.compile` method. It can render a limited set of non-standard SQL constructs to assist in basic stringification, however for more substantial custom or dialect-specific SQL constructs, it will be necessary to make use of :meth:`_expression.ClauseElement.compile` directly. .. seealso:: :ref:`faq_sql_expression_string` cCr)NzrrLrrrrMHrz$StrSQLCompiler._fallback_column_namezsqlalchemy.engine.urlc s`|jdkr)tjj}|j|j}|j|d|d}t|t s)|j |fi|St ||S)Nr)r/) stringify_dialectr%r engine_urlURLr get_dialectstatement_compilerrr_rrr)rrrrurlrcompilerrrrrKs  z,StrSQLCompiler.visit_unsupported_compilationcKs,d|j|jfi||j|jfi|fS)Nz%s[%s])rrxrr"rrrvisit_getitem_binaryYrz#StrSQLCompiler.visit_getitem_binarycK|j||fi|Srrgr"rrrvisit_json_getitem_op_binary_rz+StrSQLCompiler.visit_json_getitem_op_binarycKrhrrir"rrr!visit_json_path_getitem_op_binarybrz0StrSQLCompiler.visit_json_path_getitem_op_binarycKsd|j|dS)Nz)rformat_sequencerrrrreszStrSQLCompiler.visit_sequencerrBrrrrrrrrc s&fddt|D}dd|S)Nc sg|] }d|ddiqS)NTFr0rSr(rrrUrsz3StrSQLCompiler.returning_clause..rr)rrrwrrr(rrjs zStrSQLCompiler.returning_clausec s(dd<ddfdd|DS)NTr&r?rc3&|]}|jfdiVqdSrNrrrr/rrrrr)|  z4StrSQLCompiler.update_from_clause..rr.rrqrr0x z!StrSQLCompiler.update_from_clausec s(dd<ddfdd|DS)NTr&rc3rnrorrprqrrr)rrz:StrSQLCompiler.delete_extra_from_clause..rr.rrqrr=rsz'StrSQLCompiler.delete_extra_from_clausecKr)NzSELECT 1 WHERE 1!=1rr;rrrr8rz#StrSQLCompiler.visit_empty_set_exprcCsd|S)Nz[%s]rrHrrrrCr.z!StrSQLCompiler.get_from_hint_textcK|j|dfi|S)Nz r0r"rrrrrz+StrSQLCompiler.visit_regexp_match_op_binarycKrt)Nz rur"rrrrrz/StrSQLCompiler.visit_not_regexp_match_op_binarycKs,d|jj|fi||jj|fi|fS)Nz(%s, %s))rxrrr"rrrrrz-StrSQLCompiler.visit_regexp_replace_op_binarycKr)NzTRY_CAST(%s AS %s))rrrp)rrrrrrvisit_try_castrzStrSQLCompiler.visit_try_castrO)rrrrrMr%rZrrgrjrkrrr0r=r8rCrrrrvrrrrrr_4s$    r_c@seZdZdZer   dpdqd dZejddZejddZ   drdsddZ ddZ dd Z d!d"Z d#d$Zdtd&d'Z dud(d)Zd*d+Zd,d-Zd.d/Z dvd0d1Zd2d3Zdtd4d5Zd6d7Zd8d9Zd:d;Zdd?Zd@dAZdBdCZdDdEZdudFdGZdHdIZ dJdKZ!dLdMZ"dNdOZ#dPdQZ$dRdSZ%dTdUZ&dVdWZ'dXdYZ(dZd[Z)d\d]Z*d^d_Z+d`daZ,dbdcZ-dddeZ.dfdgZ/dhdiZ0djdkZ1dldmZ2dndoZ3dS)w DDLCompilerT.rr\rr@rrrrrrcCrrrrrrrrszDDLCompiler.__init__cCs|jj|jd|jdS)Nr)rrdrr(rrrrs zDDLCompiler.sql_compilercCrr)rror(rrr type_compilerrzDDLCompiler.type_compilerNrrrrrrrcCrrrrrrrrrzDDLCompiler.construct_paramscKs|j}t|jtjrD|}|j}||j}t|dkr%|dd}}n |d|d}}| d|| d|| d| |j|j |j |S)NrrrrYrr"r)contextrtargetr"rJrrformat_table_seqrzr$r rrzr)rddlrryrpathrschrrr visit_ddls    zDDLCompiler.visit_ddlcK$d}|jr |d7}||j|jS)NzCREATE SCHEMA IF NOT EXISTS ) if_not_existsr format_schemar)rrrryrrrvisit_create_schemazDDLCompiler.visit_create_schemacKs6d}|jr |d7}||j|j7}|jr|d7}|S)Nz DROP SCHEMA IF EXISTS  CASCADE) if_existsrrrcascaderdroprryrrrvisit_drop_schemaszDDLCompiler.visit_drop_schemac KsF|j}|j}d}|jr|d|jd7}|d7}|jr |d7}|||d7}||}|r6||d7}|d7}d}d}|jD]D} | j} z"|j| | j oO| d} | durb||7}d }|d | 7}| j rgd }WqAt j y} zt d |j | j | jd f| d} ~ ww|j||jd} | r||d | 7}|d||7}|S)Nz CREATE rzTABLE rr Ffirst_pkr Tz (in table '%s', column '%s'): %sr) _include_foreign_key_constraintsz )%s )rrrrwrr create_table_suffixr)rrr7r descriptionrargscreate_table_constraintsinclude_foreign_key_constraintspost_create_table)rrrrrryrrr create_columnr processedceconstrrrvisit_create_tables\     zDDLCompiler.visit_create_tableFc sL|j}|jrdSj||d}dfdd|jD}|r$|d|7}|S)Nrrc3s|]}|VqdSr)rrrr(rrr) s  z2DDLCompiler.visit_create_column..)rsystemget_column_specificationrw constraints)rrrrrryrrr(rvisit_create_columns zDDLCompiler.visit_create_columnc stg}jr |jj}|dur||nt|fddjDdddfdd|DDS)Ncs"g|] }|jur|vr|qSr)rrS) omit_fkcsrrrrU8s z8DDLCompiler.create_table_constraints..z, css|] }|dur|VqdSrr)rrrrrr)?s  z7DDLCompiler.create_table_constraints..c3s8|]}|rjjrt|dds|VqdS) use_alterFN)_should_create_for_compilerrsupports_alterrrrr(rrr)As  )rrkforeign_key_constraintsrPror_sorted_constraintsrw)rrrrrall_fkcsr)rrrrr(s"     z$DDLCompiler.create_table_constraintscKr)Nz DROP TABLE r)rrr rrrrrvisit_drop_tableMrzDDLCompiler.visit_drop_tablecKsd|j|jS)Nz DROP VIEW rr rrrrrrrvisit_drop_viewSrzDDLCompiler.visit_drop_viewcCs|jdur td|jdS)Nz,Index '%s' is not associated with any table.)rr7rrrrhrrr_verify_index_tableVs zDDLCompiler._verify_index_tablec s|j}|j}d}|jr|d7}|jdurtd|d7}|jr)|d7}|dj||d|j |j |dd fd d |j Df7}|S) NzCREATE zUNIQUE z0CREATE INDEX requires that the index have a namezINDEX rz %s ON %s (%s)include_schemarrc3s"|] }jj|dddVqdS)FTrSrN)rr)rrr(rrr)srz1DDLCompiler.visit_create_index..) rrrrrr7rr_prepared_index_namer rrw expressions)rrrinclude_table_schemarrhrryrr(rvisit_create_index\s.    zDDLCompiler.visit_create_indexcKs>|j}|jdur tdd}|jr|d7}||j|ddS)Nz.DROP INDEX requires that the index have a namez DROP INDEX rTr)rrr7rrr)rrrrhryrrrvisit_drop_index|s zDDLCompiler.visit_drop_indexcCsX|jdur |j|j}nd}|r|r|j|}nd}|j|}|r*|d|}|SNr)rrr\r] format_index)rrhrr` schema_name index_namerrrrs   z DDLCompiler._prepared_index_namecKs d|j|jj||jfS)NzALTER TABLE %s ADD %s)rr rrrrrrrrrvisit_add_constraints z DDLCompiler.visit_add_constraintcKs(d|j|j|j|jjtfS)NzCOMMENT ON TABLE %s IS %s)rr rrrcommentr$Stringrrrrvisit_set_table_comments   z#DDLCompiler.visit_set_table_commentcKsd|j|jS)NzCOMMENT ON TABLE %s IS NULLrrrrrvisit_drop_table_commentsz$DDLCompiler.visit_drop_table_commentcKs.d|jj|jddd|j|jjtfS)NzCOMMENT ON COLUMN %s IS %sT) use_tabler)r format_columnrrrrr$rrrrrvisit_set_column_comments z$DDLCompiler.visit_set_column_commentcKsd|jj|jddS)NzCOMMENT ON COLUMN %s IS NULLT)r)rrrrrrrvisit_drop_column_commentsz%DDLCompiler.visit_drop_column_commentcKt|t|rrrrrrvisit_set_constraint_commentrIz(DDLCompiler.visit_set_constraint_commentcKrrrrrrrvisit_drop_constraint_commentrIz)DDLCompiler.visit_drop_constraint_commentcCsg}|jdur|d|j|jdur|d|j|jdur)|d|j|jdur6|d|j|jdur@|d|jdurJ|d|jdurW|d|j|jdurf||jrcdnd d |S) NzINCREMENT BY %dz START WITH %dz MINVALUE %dz MAXVALUE %dz NO MINVALUEz NO MAXVALUEzCACHE %dCYCLEzNO CYCLEr) incrementrkrsminvaluemaxvalue nominvalue nomaxvaluecachecyclerw)ridentity_optionsryrrrget_identity_optionss$           z DDLCompiler.get_identity_optionscKsPd}|jr |d7}||j|j7}|r||7}||j}|r&|d|7}|S)NzCREATE SEQUENCE rr)rrrmrr)rrrrryoptionsrrrvisit_create_sequences  z!DDLCompiler.visit_create_sequencecKr)NzDROP SEQUENCE r)rrrmrrrrrvisit_drop_sequencerzDDLCompiler.visit_drop_sequencecKsn|j}|jdur|j|}nd}|durtd|jd|j|jj|jr*dnd||j r3dfSdfS)Nz.) rzrrrrw_implicit_generatedcolumns_autoinc_firstr)rrrr(rvisit_primary_key_constraintHs     z(DDLCompiler.visit_primary_key_constraintc s|jd}|jdur|j|}|dur|d|7}t|jdjj}|ddfdd|jD|||dfdd|jDf7}|| |7}|| |7}|| |7}|S) Nrrrz"FOREIGN KEY(%s) REFERENCES %s (%s)rc3|] }|jjVqdSr)rZparentrrurrrr)erz;DDLCompiler.visit_foreign_key_constraint..c3rr)rZrrrurrrr)kr) rrrr]rrrrwdefine_constraint_remote_tabledefine_constraint_matchdefine_constraint_cascadesr)rrrryr remote_tablerrrvisit_foreign_key_constraint\s,    z(DDLCompiler.visit_foreign_key_constraintcCs ||S)z=Format the remote table clause of a CREATE CONSTRAINT clause.)r )rrrrrrrrt z*DDLCompiler.define_constraint_remote_tablec st|dkrdSd}|jdurj|}|dur|d|7}|dj|fi|dfdd|Df7}||7}|S)Nrrrz UNIQUE %s(%s)rc3rrrrSr(rrr)sz6DDLCompiler.visit_unique_constraint..)rzrrr!define_unique_constraint_distinctrwrrrr(rvisit_unique_constraintys    z#DDLCompiler.visit_unique_constraintcKrrrrrrrrrz-DDLCompiler.define_unique_constraint_distinctcCsLd}|jdur|d|j|jt7}|jdur$|d|j|jt7}|S)Nrz ON DELETE %sz ON UPDATE %s)ondeletervalidate_sql_phrase FK_ON_DELETEonupdate FK_ON_UPDATErrryrrrrs    z&DDLCompiler.define_constraint_cascadescCsLd}|jdur|jr|d7}n|d7}|jdur$|d|j|jt7}|S)Nrz DEFERRABLEz NOT DEFERRABLEz INITIALLY %s)rrrr FK_INITIALLYrrrrrs    z+DDLCompiler.define_constraint_deferrabilitycCs d}|jdur|d|j7}|S)Nrz MATCH %s)rrrrrrs z#DDLCompiler.define_constraint_matchcKsDd|jj|jddd}|jdur|d7}|S|jdur |d7}|S)NzGENERATED ALWAYS AS (%s)FTrz STOREDz VIRTUAL)rrr persisted)r generatedrryrrrvisit_computed_columns  z!DDLCompiler.visit_computed_columncKs2d|jrdndf}||}|r|d|7}|S)NzGENERATED %s AS IDENTITYALWAYSz BY DEFAULTr)alwaysr)rrrryrrrrvisit_identity_columns   z!DDLCompiler.visit_identity_column)...) rr\rr@rrrrrrrrrMr)FT)4rrrrrrr%rVrrxrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrrwst     4 %          rwc@seZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZddZddZd`d d!Zd"d#Zd$d%Zd&d'Zd(d)Zd*d+Zd,d-Zd.d/Zd0d1Zd2d3Zd4d5Zd6d7Zd8d9Zd:d;Zdd?Z!d@dAZ"dBdCZ#dDdEZ$dFdGZ%dHdIZ&dJdKZ'dLdMZ(dNdOZ)dPdQZ*dRdSZ+dTdUZ,dVdWZ-dXdYZ.dZd[Z/d\d]Z0d^d_Z1dS)aGenericTypeCompilercKr)NFLOATrrrrr visit_FLOATrzGenericTypeCompiler.visit_FLOATcKr)NDOUBLErrrrr visit_DOUBLErz GenericTypeCompiler.visit_DOUBLEcKr)NzDOUBLE PRECISIONrrrrrvisit_DOUBLE_PRECISIONrz*GenericTypeCompiler.visit_DOUBLE_PRECISIONcKr)NREALrrrrr visit_REALrzGenericTypeCompiler.visit_REALcK8|jdurdS|jdurdd|jiSd|j|jdS)NNUMERICzNUMERIC(%(precision)s) precisionz!NUMERIC(%(precision)s, %(scale)s)rscalerrrrr visit_NUMERIC  z!GenericTypeCompiler.visit_NUMERICcKr)NDECIMALzDECIMAL(%(precision)s)rz!DECIMAL(%(precision)s, %(scale)s)rrrrrr visit_DECIMALrz!GenericTypeCompiler.visit_DECIMALcKr)NINTEGERrrrrr visit_INTEGERrz!GenericTypeCompiler.visit_INTEGERcKr)NSMALLINTrrrrrvisit_SMALLINTrz"GenericTypeCompiler.visit_SMALLINTcKr)NBIGINTrrrrr visit_BIGINTrz GenericTypeCompiler.visit_BIGINTcKr)N TIMESTAMPrrrrrvisit_TIMESTAMPrz#GenericTypeCompiler.visit_TIMESTAMPcKr)NDATETIMErrrrrvisit_DATETIMErz"GenericTypeCompiler.visit_DATETIMEcKr)NDATErrrrr visit_DATErzGenericTypeCompiler.visit_DATEcKr)NTIMErrrrr visit_TIMErzGenericTypeCompiler.visit_TIMEcKr)NCLOBrrrrr visit_CLOBrzGenericTypeCompiler.visit_CLOBcKr)NNCLOBrrrrr visit_NCLOBrzGenericTypeCompiler.visit_NCLOBNcCsB|}|r |d|7}n |jr|d|j7}|jr|d|j7}|S)N(%d)z COLLATE "%s")lengthre)rrrlength_overrideryrrr_render_string_typesz'GenericTypeCompiler._render_string_typecK ||dS)NCHARr4rrrr visit_CHARrzGenericTypeCompiler.visit_CHARcKr5)NNCHARr7rrrr visit_NCHAR rzGenericTypeCompiler.visit_NCHARcKr5)NVARCHARr7rrrr visit_VARCHAR rz!GenericTypeCompiler.visit_VARCHARcKr5)NNVARCHARr7rrrrvisit_NVARCHARrz"GenericTypeCompiler.visit_NVARCHARcKr5)NTEXTr7rrrr visit_TEXTrzGenericTypeCompiler.visit_TEXTcKr)NUUIDrrrrr visit_UUIDrzGenericTypeCompiler.visit_UUIDcKr)NBLOBrrrrr visit_BLOBrzGenericTypeCompiler.visit_BLOBcKd|jr d|jp dS)NBINARYr1rr2rrrr visit_BINARYrdz GenericTypeCompiler.visit_BINARYcKrE)N VARBINARYr1rrGrrrrvisit_VARBINARYrdz#GenericTypeCompiler.visit_VARBINARYcKr)NBOOLEANrrrrr visit_BOOLEAN!rz!GenericTypeCompiler.visit_BOOLEANcKs0|jr|jjs|j|dddS|j|fi|S)Nr6 )r3) native_uuidrsupports_native_uuidr4rBrrrr visit_uuid$szGenericTypeCompiler.visit_uuidcKr r)rDrrrrvisit_large_binary*rz&GenericTypeCompiler.visit_large_binarycKr r)rLrrrr visit_boolean-rz!GenericTypeCompiler.visit_booleancKr r)r,rrrr visit_time0rzGenericTypeCompiler.visit_timecKr r)r(rrrrvisit_datetime3rz"GenericTypeCompiler.visit_datetimecKr r)r*rrrr visit_date6rzGenericTypeCompiler.visit_datecKr r)r$rrrrvisit_big_integer9rz%GenericTypeCompiler.visit_big_integercKr r)r"rrrrvisit_small_integer<rz'GenericTypeCompiler.visit_small_integercKr r)r rrrr visit_integer?rz!GenericTypeCompiler.visit_integercKr r)rrrrr visit_realBrzGenericTypeCompiler.visit_realcKr r)rrrrr visit_floatErzGenericTypeCompiler.visit_floatcKr r)rrrrr visit_doubleHrz GenericTypeCompiler.visit_doublecKr r)rrrrr visit_numericKrz!GenericTypeCompiler.visit_numericcKr rr<rrrr visit_stringNrz GenericTypeCompiler.visit_stringcKr rr]rrrr visit_unicodeQrz!GenericTypeCompiler.visit_unicodecKr rr@rrrr visit_textTrzGenericTypeCompiler.visit_textcKr rr`rrrrvisit_unicode_textWrz&GenericTypeCompiler.visit_unicode_textcKr rr]rrrr visit_enumZrzGenericTypeCompiler.visit_enumcKstd|)NzKCan't generate DDL for %r; did you forget to specify a type on this Column?rKrrrrr]s zGenericTypeCompiler.visit_nullcKs|j||jfi|Sr)r type_enginerrrrrvisit_type_decoratordr,z(GenericTypeCompiler.visit_type_decoratorcKs|jdi|SrN) get_col_specrrrrvisit_user_definedgrIz&GenericTypeCompiler.visit_user_definedr)2rrrrrrrrrr r"r$r&r(r*r,r.r0r4r8r:r<r>r@rBrDrHrJrLrPrQrRrSrTrUrVrWrXrYrZr[r\r^r_rarbrcrrergrrrrrs`     rc@s4eZdZddZddZddZddZd d Zd S) StrSQLTypeCompilercKs@z|j}Wnty|j|fi|YSw||fi|Sr)rAttributeError_visit_unknown)rrrrrrrrls   zStrSQLTypeCompiler.processcCs|dr|jSt|)Nvisit_)r>rjri)rr'rrr __getattr__ts zStrSQLTypeCompiler.__getattr__cKs$|jj|jjkr|jjSt|Sr)rrupperreprrrrrrjzsz!StrSQLTypeCompiler._visit_unknowncKrrrrrrrrrzStrSQLTypeCompiler.visit_nullcKs4z|j}Wn tyt|YSw|di|SrN)rfrirn)rrrrfrrrrgs    z%StrSQLTypeCompiler.visit_user_definedN)rrrrrlrjrrgrrrrrhks  rhc@eZdZdddZdS) _SchemaForObjectCallable_SchemaForObjectCallable__objrrrcCrrr)rrqrrrrz!_SchemaForObjectCallable.__call__N)rqrrrr rrrrrpr rpc@ro) rrrQrrcCrrr)rrrrrrrrz _BindNameForColProtocol.__call__N)rrQrrr rrrrrr rc@seZdZUdZeZeZeZ de d<de d<de d<e dZ de d < d Zd e d <   dTddZddZddZdUddZdUddZddZdUddZdVd d!Zd"d#ZdWdXd&d'ZdWdYd)d*Zd+d,ZdZd-d.Z dWd[d3d4Z dWd\d7d8ZdWd9d:Ze d;dZdd?Z"dZd@dAZ#dBdCZ$dDdEZ%d]dFdGZ&dHdIZ' dWdJdKZ(   d^dLdMZ)dZdNdOZ*ej+dPdQZ,dRdSZ-dS)_rz@Handle quoting and case-folding of identifiers based on options.r initial_quote final_quotezMutableMapping[str, str]_stringsr"rpr\Fr_includes_none_schema_translaterzNTcCsN||_||_|p |j|_||_|jd|_||_||_i|_|jjdv|_ dS)asConstruct a new ``IdentifierPreparer`` object. initial_quote Character that begins a delimited identifier. final_quote Character that ends a delimited identifier. Defaults to `initial_quote`. omit_schema Prevent prepending schema name. Useful for databases that do not support schemae. r6)rrN) rrsrt escape_quoteescape_to_quote omit_schemaquote_case_sensitive_collationsrur=rv)rrrsrtrwrzryrrrrs  zIdentifierPreparer.__init__cs@|j|j}|j|jd|vfdd}||_|_|S)NcsX|j}|jr)|dus r)|durd|vsd|vrtd|td|p$dddS|jS)NrrzJSquare bracket characters ([]) not supported in schema translate name '%s'z __[SCHEMA_%s]_noneFrZ)r"_use_schema_mapr7rr0)rr includes_nonerr symbol_getters z@IdentifierPreparer._with_schema_translate..symbol_getter)r__new__rIrJr\rv)rrpreprrr~rrs z)IdentifierPreparer._with_schema_translatecsD|dvrjstddd<fdd}td||S)Nzschema translate map which previously did not have `None` present as a key now has `None` present; compiled statement may lack adequate placeholders. Please use consistent keys in successive schema_translate_map dictionaries.r{csV|d}|vr|}n |dvrtd|}|s&jj}|s&td|S)Nr6)Nr{zschema translate map which previously had `None` present as a key now no longer has it present; don't know how to apply schema for compiled statement. Please use consistent keys in successive schema_translate_map dictionaries.zLDialect has no default schema name; can't use None as dynamic schema target.)rr7r*rdefault_schema_namerr])rirr`drrrrws   z=IdentifierPreparer._render_schema_translates..replacez(__\[SCHEMA_([^\]]+)\]))rvr7r*r(rv)rrrrwrrrrs z,IdentifierPreparer._render_schema_translatesrrcCs&||j|j}|jr|dd}|S)zEscape an identifier. Subclasses should override this to provide database-dependent escaping behavior. rrt)rwrwrxrvrrrrr_escape_identifiers z%IdentifierPreparer._escape_identifiercCs||j|jS)zCanonicalize an escaped identifier. Subclasses should override this to provide database-dependent unescaping behavior that reverses _escape_identifier. )rwrxrwrrrr_unescape_identifier!sz'IdentifierPreparer._unescape_identifiercCs*|dur||std||jf|S)zkeyword sequence filter. a filter for elements that are intended to represent keyword sequences, such as "INITIALLY", "INITIALLY DEFERRED", etc. no special characters should be present. .. versionadded:: 1.3 Nz/Unexpected SQL phrase: %r (matching against %r))rr7rrT)rrr+rrrr*s z&IdentifierPreparer.validate_sql_phrasecCs|j|||jS)z~Quote an identifier. Subclasses should override this to provide database-dependent quoting behavior. )rsrrtrrrrquote_identifier<s z#IdentifierPreparer.quote_identifiercCs:|}||jvp|d|jvp|jt| p||kS)z5Return True if the given identifier requires quoting.r)rreserved_wordsillegal_initial_characterslegal_charactersrr)rrlc_valuerrrrIs  z#IdentifierPreparer._requires_quotescCs|jt| S)zjReturn True if the given identifier requires quoting, but not taking case convention into account.)rrrrrrrrSsz1IdentifierPreparer._requires_quotes_illegal_charsforcercCs |dur tjddd||S)aConditionally quote a schema name. The name is quoted if it is a reserved word, contains quote-necessary characters, or is an instance of :class:`.quoted_name` which includes ``quote`` set to ``True``. Subclasses can override this to provide database-dependent quoting behavior for schema names. :param schema: string schema name :param force: unused .. deprecated:: 0.9 The :paramref:`.IdentifierPreparer.quote_schema.force` parameter is deprecated and will be removed in a future release. This flag has no effect on the behavior of the :meth:`.IdentifierPreparer.quote` method; please refer to :class:`.quoted_name`. NzThe IdentifierPreparer.quote_schema.force parameter is deprecated and will be removed in a future release. This flag has no effect on the behavior of the IdentifierPreparer.quote method; please refer to quoted_name().0.9r)r%rrZ)rr"rrrrr]Xs  zIdentifierPreparer.quote_schemarcCs|dur tjdddt|dd}|dur7||jvr|j|S||r-|||j|<n||j|<|j|S|r>||S|S)aConditionally quote an identifier. The identifier is quoted if it is a reserved word, contains quote-necessary characters, or is an instance of :class:`.quoted_name` which includes ``quote`` set to ``True``. Subclasses can override this to provide database-dependent quoting behavior for identifier names. :param ident: string identifier :param force: unused .. deprecated:: 0.9 The :paramref:`.IdentifierPreparer.quote.force` parameter is deprecated and will be removed in a future release. This flag has no effect on the behavior of the :meth:`.IdentifierPreparer.quote` method; please refer to :class:`.quoted_name`. NzThe IdentifierPreparer.quote.force parameter is deprecated and will be removed in a future release. This flag has no effect on the behavior of the IdentifierPreparer.quote method; please refer to quoted_name().rrrZ)r%rrrurr)rrrrrrrZs        zIdentifierPreparer.quotecCs|jr||S|Sr)rzrZ)rcollation_namerrrrds z#IdentifierPreparer.format_collationcCs>||j}||}|js|r|dur||d|}|Sr)rZrr\ryr])rrrrr`rrrrms  z"IdentifierPreparer.format_sequencer Label[Any]rrcCs||p|jSrrZr)rrrrrrrDszIdentifierPreparer.format_labelrVOptional[AliasedReturnsRows]cCs*|dur|dus J||jS||Srr)rrVrrrrrs   zIdentifierPreparer.format_aliascCs"|p|j}||r||}|Sr)rrr)r savepointrrrrrrEs   z#IdentifierPreparer.format_savepointzsqlalchemy.sql.namingcCsZtjj}|jtur|||j}|durdSn|j}|jdkr&|j||dS|j ||dS)Nrh)_alembic_quote) r%r sql_namingrr+_constraint_name_for_tablerrtruncate_and_render_index_name#truncate_and_render_constraint_name)rrrnamingrrrrrs   z$IdentifierPreparer.format_constraintcC|jjp|jj}||||Sr)rmax_index_name_lengthrB _truncate_and_render_maxlen_namerrrmax_rrrr z1IdentifierPreparer.truncate_and_render_index_namecCrr)rmax_constraint_name_lengthrBrrrrrrrz6IdentifierPreparer.truncate_and_render_constraint_namecCs^t|tjr t||kr|d|ddt|dd}n|j||s*|S||S)NrrMr) rrrDrzr%md5_hexrvalidate_identifierrZ)rrrrrrrr s  &  z3IdentifierPreparer._truncate_and_render_maxlen_namecC ||Sr)rrrrrrrzIdentifierPreparer.format_indexcCsF|dur|j}||}||}|js!|r!|r!||d|}|S)z'Prepare a quoted table and schema name.Nr)rrZr\ryr])rrrrr r`rrrr s  zIdentifierPreparer.format_tablecCr)zPrepare a quoted schema name.r|rrrrr)rz IdentifierPreparer.format_schemacCs(|durt|tjr||}||S)Prepare a quoted column name.N)rrrDrrZ)rrrCrrrr.s   z$IdentifierPreparer.format_label_namecCs|dur|j}|durt|tjr||}t|dds3|r.|j|j||dd||S||S|rB|j|j||dd|S|S)rNrWF)rrr) rrrrDrrr rrZ)rrrr table_namerrCrrrr<s6     z IdentifierPreparer.format_columncCs@||}|js|r|r|||j|ddfS|j|ddfS)z(Format table name and schema as a tuple.Fr)r\ryr]r )rrrr`rrrr{is  z#IdentifierPreparer.format_table_seqcCs@dd|j|j||jfD\}}}td|||d}|S)Ncss|]}t|VqdSr)r(r)rrrrr)|s  z4IdentifierPreparer._r_identifiers..zM(?:(?:%(initial)s((?:%(escaped)s|[^%(final)s])+)%(final)s|([^\.]+))(?=\.|$))+)initialfinalr)rsrtrr(r*)rrr escaped_finalrrrr_r_identifierszs   z!IdentifierPreparer._r_identifierscs(j}fdddd||DDS)z:Unpack 'schema.table.column'-like strings into components.csg|]}|qSr)rrr(rrrUsz;IdentifierPreparer.unformat_identifiers..cSsg|]\}}|p |qSrr)rar3rrrrUrg)rfindall)r identifiersrrr(runformat_identifierss z'IdentifierPreparer.unformat_identifiers)rzNrzTF)rrrr)rrrrr)r"rrrrr)rrrrrr)T)rrrrrr)rVrrrrr)TN)FNNFN).rrrrRESERVED_WORDSrLEGAL_CHARACTERSrILLEGAL_INITIAL_CHARACTERSrrr attrgetterr\rvrrrrrrrrrr]rZrdrmrDrrEr%rZrrrrrr rrrr{rVrrrrrrrsl   $ )     '4          -  r)r __future__rrmcollections.abcabcrFrXenumrrrrr(timerrrrrrr r r r r rrrrrrrrrrrrrrrrrrr r!r"r#r$r%r_typingr'r(r)r*r+r,r-r.r/r0r1r2type_apir3visitorsr4r5r7r8 util.typingr9r:r; annotationr<r=r>rr?r|r@dmlrArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrS engine.cursorrTengine.interfacesrUrVrWrXrYrZr[r\r]r_FromHintsTyperr*IrLEGAL_CHARACTERS_PLUS_SPACErrrrrrUNICODErrr?r@ror_rmulrvmodnegltlenegtgeeqis_distinct_fromis_not_distinct_from concat_opr. not_match_opr7r6rr{rCrrrexists distinct_opinvany_opall_opdesc_opasc_opnulls_first_op nulls_last_opbitwise_xor_op bitwise_or_opbitwise_and_opbitwise_not_opbitwise_lshift_opbitwise_rshift_oprBrrrrrrrrrrrcuberollup grouping_setsrrrP_CompoundSelectKeywordr UNION_ALLr EXCEPT_ALLr INTERSECT_ALLrQrrr r r rrrrr0r?rKrXr\r+r]r^r_r` namedtuplerar EnsureKWArgrBinaryElementRoleCompilerColumnElementrrrr_rwrrhrprrrrrrs~                                                                                            a       !#$%&1     =w BL    &Uo.!