U
|
¸ý°d/ ã ^ @ sJ
|
U d Z ddlmZ ddlZddlmZ ddlZddlm Z ddl
|
Z
|
ddl Z ddl Z ddl mZ ddlZddlmZ ddlmZ ddlmZ dd lmZ dd
|
lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddlm Z ddlm Z ddlm Z ddlm!Z! ddlm"Z" ddlm#Z# ddlm$Z$ dd l%m&Z& dd l%m'Z' dd l%m(Z( dd l%m)Z) dd l%m*Z* dd!l%m+Z+ dd"l%m,Z, dd#l%m-Z- dd$l%m.Z. dd%l%m/Z/ dd&l%m0Z1 dd'l2m3Z3 dd(l2m4Z4 dd)l&m5Z5 dd*l&m6Z6 dd+l&m7Z7 dd,l&m8Z8 dd-l&m9Z9 dd.l)m:Z: dd/l)m;Z; dd0l-m<Z< dd1l/m=Z= dd2l>m?Z? dd3l@mAZA dd4l@mBZB d5d6l%mCZC d5d&l%m0Z0 d5d7l0mDZD d5d8lEmFZF d5d9lEmGZG d5d:lEmHZH ej#rdd;lImJZJ dd<l&mKZK dd=l&mLZL dd>lMmNZN dd?lOmPZP dd@lQmRZR ddAlQmSZS ddBlQmTZT ddCl)mUZU ddDl)mVZV ddEl)mWZW ddFl)mXZX ddGl)mYZY ddHl*mZZZ ddIl-m[Z[ ddJl.m\Z\ ddKl.m]Z] ddLl.m^Z^ ddMl.m_Z_ ddNl.m`Z` ddOl.maZa ddPl.mbZb ddQl.mcZc ddRl>mdZd ddSl>meZe d5dTlfmgZg d5dUlhmiZi d5dVlhmjZj d5dWlhmkZk d5dXlhmlZl d5dYlhmmZm d5dZlhmnZn d5d[lhmoZo d5d\lhmpZp d5d]lhmqZq ed^erf Zsd_d`dadbdcdddedfdgdhdidjdkdldmdndodpdqdrdsdtdudvdwdxdydzd{d|d}d~ddddddd
ddddddddddddddddddddddddddd d¡d¢d£d¤d¥d¦d§d¨d©dªd«d¬dd®d¯d°d±d²d³d´dµd¶d·d¸d¹dºd»d¼h^Zte ud½e jv¡Zwe ud¾e jv¡Zxd¿dÀ eyddÁD zdÂg¡Z{e udÃe jv¡Z|e udÃe jv¡Z}e udÄe jv¡Z~e udÅe j¡Ze udÆe j¡ZdÇZedÈdÉdÊdËdÌdÍZe+jdÎe+j
dÏe+jdÐe+jdÑe+jdÒe+jdÓe+jdÔe+jdÕe+jdÖe+jd×e+jdØe+jdÙe+jdÚe+jdÛe+jdÜe+jdÝe+jdÞe+jdße+jdàe+jdáe+jdâe+jdãe+jdäe+jdåe+jdæe+jdçe+jdèe+jdée+j dêe+j¡dëe+j¢dìe+j£díe+j¤dîe+j¥dïe+j¦dðe+j§dñe+j¨dòe+j©dóe+jªdôe+j«dõe+j¬döi)Ze*j®d÷e*j¯døe*j°dùe*j±dúe*j²dûe*j³düe*j´dýe*jµdþe*j¶dÿe*j·d e*j¸de*j¹de*jºde*j»diZ¼de½d< ddd d
|
d d d dddddddddZ¾e.j¿jÀde.j¿jÁde.j¿jÂde.j¿jÃde.j¿jÄde.j¿jÅd iZÆG d d d eZÇG d d d eGZÈdZÉd!e½d"< dZÊd#e½d$< d5ZËd%e½d&< d'ZÌd(e½d)< G d*d+ d+eHZÍG d,d- d-eÍd.d/ZÎG d0d1 d1eZÏG d2d3 d3eZÐG d4d5 d5eZÑG d6d7 d7eDZÒG d8d9 d9e ZÓG d:d; d;e ZÔeÕeÔ\ZÖZ×ZØZÙG d<d= d=e Úd=d>d?g¡ZÛG d@dA dAZÜG dBdC dCe0jÝZÞG dDdE dEe,jße e)jàZáG dFdG dGe,jße e)jàZâG dHdI dIeÜZãG dJdK dKeãZäG dLdM dMeÜZåG dNdO dOeÞZæG dPdQ dQeæZçG dRdS dSeGZèG dTdU dUeGZéG dVdW dWZêdS (X 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)Úutil©Úis_column_element)Úis_dml)Ú _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)Ú_SentinelProcessorType)ÚCursorResultMetaData)Ú_CoreSingleExecuteParams)Ú_DBAPIAnyExecuteParams)Ú_DBAPIMultiExecuteParams)Ú_DBAPISingleExecuteParams)Ú_ExecuteOptions)Ú_GenericSetInputSizesType)Ú _MutableCoreSingleExecuteParams)ÚDialect)ÚSchemaTranslateMapTyperM ÚallZanalyseZanalyzeÚandÚanyÚarrayÚasZascZ
|
asymmetricÚ authorizationZbetweenÚbinaryZbothZcaser ÚcheckÚcollateÚcolumnÚ
|
constraintÚcreateZcrossÚ current_dateZ current_roleÚ current_timeÚcurrent_timestampÚ current_userÚdefaultÚ
|
deferrableÚdescZdistinctZdoÚelseÚendÚexceptÚfalseÚforZforeignÚfreezeÚfromÚfullZgrantÚgroupZhavingZilikeÚinÚ initiallyÚinnerZ intersectZintoÚisZisnullÚjoinÚleadingÚleftZlikeÚlimitÚ localtimeÚlocaltimestampZnaturalÚnewÚnotZnotnullÚnullÚoffÚoffsetÚoldÚonÚonlyÚorÚorderÚouterÚoverlapsZplacingZprimaryZ
|
referencesÚrightÚselectÚ session_userÚsetZsimilarZsomeÚ symmetricÚtableZthenÚtoZtrailingÚtrueÚunionÚuniqueÚuserZusingÚverboseÚwhenÚwherez ^[A-Z0-9_$]+$z^[A-Z0-9_ $]+$c C s h | ] }t |qS © )Ústr)Ú.0Úxr r úNd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/sql/compiler.pyÚ <setcomp>å s r£ é
|
ú$z5^(?:RESTRICT|CASCADE|SET NULL|NO ACTION|SET DEFAULT)$z^(?:DEFERRED|IMMEDIATE)$z%(?<![:\w\$\x5c]):([\w\$]+)(?![:\w\$])z\x5c(:[\w\$]*)(?![:\w\$])z %%(%(name)s)sú?z%%sz :[_POSITION]z $[_POSITION]z :%(name)s)ÚpyformatÚqmarkÚformatÚnumericÚnumeric_dollarÚnamedz AND z OR z + z * z - ú % ú-z < z <= z != 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 >> ÚcoalesceZ CURRENT_DATEZ CURRENT_TIMEZCURRENT_TIMESTAMPZ CURRENT_USERZ LOCALTIMEZLOCALTIMESTAMPÚrandomÚsysdateZ SESSION_USERÚUSERZCUBEZROLLUPz GROUPING SETSz Dict[Type[Function[Any]], str]Ú FUNCTIONSÚmonthÚdayÚyearÚsecondÚhourÚdoyÚminuteÚquarterÚdowÚweekÚepochÚ millisecondsÚ microsecondsÚ timezone_hourÚtimezone_minute)r¸ r¹ rº r» r¼ r½ r¾ r¿ rÀ rÁ r rà rÄ rÅ rÆ ÚUNIONz UNION ALLÚEXCEPTz
|
EXCEPT ALLÚ INTERSECTz INTERSECT ALLc @ s2 e Zd ZU dZded< ded< ded< ded< d S )
|
ÚResultColumnsEntrya Tracks 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.
|
|
r ÚkeynameÚnameúTuple[Any, ...]ÚobjectsúTypeEngine[Any]ÚtypeN©Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__Ú__annotations__r r r r¢ rÊ Z s
|
rÊ c @ s" e Zd ZddddddddZdS ) Ú_ResultMapAppenderr ú Sequence[Any]rÏ ÚNone©rË rÌ rÎ Útype_Úreturnc C s d S ©Nr ©ÚselfrË rÌ rÎ rÛ r r r¢ Ú__call__z s z_ResultMapAppender.__call__N©rÒ rÓ rÔ rà r r r r¢ r× y s r× z
|
Literal[0]ÚRM_RENDERED_NAMEz
|
Literal[1]ÚRM_NAMEz
|
Literal[2]Ú
|
RM_OBJECTSé z
|
Literal[3]ÚRM_TYPEc @ s& e Zd ZU ded< ded< ded< dS )Ú_BaseCompilerStackEntryzSet[FromClause]Ú asfrom_fromsÚcorrelate_fromsrO r# N©rÒ rÓ rÔ rÖ r r r r¢ rç s
|
rç c @ s6 e Zd ZU ded< ded< ded< ded< ded < d
|
S ) Ú_CompilerStackEntryr= Ú compile_stateÚboolÚneed_result_map_for_nestedÚ need_result_map_for_compoundrO Úselect_0ú Select[Any]Úinsert_from_selectNrê r r r r¢ rë s
|
|
rë F)Útotalc @ s^ e Zd ZU dZded< ded< ded< ded < d
|
ed < ed d ddZedd ddZdS )Ú ExpandedStatea¹ represents 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]]Ú
|
processorsúOptional[Sequence[str]]Ú positiontupzMapping[str, List[str]]Zparameter_expansionrÍ ©rÜ c s, j dkrt d¡t fdd j D S )zrTuple of positional parameters, for statements that were compiled
|
using a positional paramstyle.
|
|
Nz.statement does not use a positional paramstylec 3 s | ]} j | V qd S rÝ ©rö ©r Úkey©rß r r¢ Ú <genexpr>Ï s z6ExpandedState.positional_parameters.<locals>.<genexpr>)rú r6 ÚInvalidRequestErrorÚtuplerÿ r rÿ r¢ Úpositional_parametersÅ s
|
|
ÿz#ExpandedState.positional_parametersc C s | j S )z.synonym for :attr:`.ExpandedState.parameters`.rü rÿ r r r¢ Úadditional_parametersÑ s z#ExpandedState.additional_parametersN)rÒ rÓ rÔ rÕ rÖ Úpropertyr r r r r r¢ rô s
|
|
rô c @ s e Zd ZU dZded< ded< ded< ded < d
|
Zded < d
|
Zded < d Zded< dZded< d Z ded< d
|
Z
|
ded< d
|
Z ded< d S )Ú_InsertManyValuesa represents 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
|
|
rí Úis_default_exprr Úsingle_values_exprú List[crud._CrudParamElementStr]Úinsert_crud_paramsÚintÚ num_positional_params_countedFÚsort_by_parameter_orderÚincludes_upsert_behaviorsNú Optional[Sequence[Column[Any]]]Úsentinel_columnsr Únum_sentinel_columnsz#Optional[Sequence[Union[str, int]]]Úsentinel_param_keysÚimplicit_sentinelÚembed_values_counter) rÒ rÓ rÔ rÕ rÖ r r r r r r r r r r r¢ r × s
|
|
r c @ sZ e Zd ZU dZded< ded< ded< ded < d
|
ed < d
|
ed < d
|
ed < ded< ded< dS )Ú_InsertManyValuesBatchas represents 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
|
|
r Úreplaced_statementrV Úreplaced_parametersú#Optional[_GenericSetInputSizesType]Úprocessed_setinputsizesú#Sequence[_DBAPISingleExecuteParams]Úbatchr Ú
|
batch_sizeÚbatchnumÚ total_batchesrí Z rows_sortedZ is_downgradedNrÑ r r r r¢ r J s
|
r c @ s< e Zd ZdZdZdZdZdZeeB eB ZeeB Z dZ
|
dZ dS ) Ú InsertmanyvaluesSentinelOptszcbitflag enum indicating styles of PK defaults
|
which can work as implicit sentinel columns
|
|
r r5 é é é é@ N) rÒ rÓ rÔ rÕ Z NOT_SUPPORTEDÚ AUTOINCREMENTÚIDENTITYÚSEQUENCEÚANY_AUTOINCREMENTÚ_SUPPORTED_OR_NOTÚUSE_INSERT_FROM_SELECTÚRENDER_SELECT_COL_CASTSr r r r¢ r b s r c @ s e Zd ZdZdZdZdS )Ú CompilerStater r r5 N)rÒ rÓ rÔ Ú COMPILINGÚSTRING_APPLIEDÚ NO_STATEMENTr r r r¢ r+ t s r+ c @ s$ e Zd ZdZdZdZdZeeB ZdS )ÚLintingzrepresent preferences for the 'SQL linting' feature.
|
|
this feature currently includes support for flagging cartesian products
|
in SQL statements.
|
|
r r r5 N)rÒ rÓ rÔ rÕ Ú
|
NO_LINTINGÚCOLLECT_CARTESIAN_PRODUCTSÚ WARN_LINTINGÚ FROM_LINTINGr r r r¢ r/ s r/ c @ s$ e Zd ZdZdddZd ddZdS )
|
Ú
|
FromLinterzKrepresents current state for the "cartesian product" detection
|
feature.Nc s° | j }|sdS t| j}t|}|d k r8|}| |¡ n| ¡ }t |g¡}|r|r| ¡ | ¡ fdd|D }| fdd|D ¡ |
|
|¡ qL|r¨||fS dS d S )N)NNc s h | ]} |kr|qS r r ©r Zedge©Únoder r¢ r£ ¼ s z"FromLinter.lint.<locals>.<setcomp>c 3 s | ]}|| ¡ V qd S rÝ )Úindexr5 r6 r r¢ r À s z"FromLinter.lint.<locals>.<genexpr>) Úfromsr ÚedgesÚremoveÚpopÚ collectionsÚdequeÚpopleftÚdiscardÚ
|
extendleftÚdifference_update)rß Ústartr9 r: Úthe_restÚ
|
start_withÚstackZ to_remover r6 r¢ Úlint¤ s&
|
|
zFromLinter.lintÚSELECTc sX ¡ \}}|rT|}|rTd}d fdd|D ¡}|j|| j| d}t |¡ d S )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.r¯ c 3 s | ]}d j | d V qdS )ú"N)r9 )r Úfrom_rÿ r r¢ r × s z"FromLinter.warn.<locals>.<genexpr>)Ú stmt_typer9 rC )rG r~ r© r9 r% Úwarn)rß rK rD rE r9 ÚtemplateZ froms_strÚmessager rÿ r¢ rL É s ÿÿýzFromLinter.warn)N)rH )rÒ rÓ rÔ rÕ rG rL r r r r¢ r4 s
|
%r4 r9 r: c sP e Zd ZU dZdZded< dZded< ded < d
|
Zd
|
ZdZ d ed < dZ
|
d ed< dZ ded< e j Zded< ded< e j Zded< dZded< dZded< dZded< d ed < dd
|
e ¡ fd ddd d d!d"d#Zd$d% fd&d' Zed(d) Zd*d+ Zd,d- Zed.d/ Zd0d1dd2d3d4Z dd%d5d6Z d@d8d9d d:d;d<d=Z ed>d? Z Z S )AÚCompileda Represent 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.
|
NúOptional[ClauseElement]rõ Ú r Ústringr+ ÚstateFz Optional[CursorResultMetaData]Ú_cached_metadataz"Optional[List[ResultColumnsEntry]]Ú_result_columnsú Optional[SchemaTranslateMapType]Úschema_translate_maprY Úexecution_optionsÚIdentifierPreparerÚpreparerr; Ú _annotationszOptional[CompileState]rì Údml_compile_stateúOptional[CacheKey]Ú cache_keyÚfloatÚ _gen_timer\ rí úMapping[str, Any]©Údialectrõ rW Úrender_schema_translateÚcompile_kwargsc C s´ || _ | j j| _|r(|| _| j |¡| _|dk r tj| _|| _|j | _
|
|j | _ | j
|
rnt rft |tsft|j| _| j| jf|| _|r| j | j|¡| _tj| _ntj| _t | _dS )aû Construct 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)rc Úidentifier_preparerrZ rW Ú_with_schema_translater+ r, rS rõ Zsupports_executionÚ can_executer[ r Ú
|
isinstancer, ÚAssertionErrorZ_execution_optionsrX ÚprocessrR Ú_render_schema_translatesr- r. r r` ©rß rc rõ rW rd re r r r¢ Ú__init__8 s2
|
ÿ ÿ
|
zCompiled.__init__rÙ rû c s | ¡ t ¡ S rÝ )Ú_init_compiler_clsÚsuperÚ__init_subclass__©Úcls©Ú __class__r r¢ rq p s zCompiled.__init_subclass__c C s d S rÝ r rr r r r¢ ro t s zCompiled._init_compiler_clsc C s$ | j r| | ||¡S t | j¡d S rÝ )rh Z_execute_compiledr6 ZObjectNotExecutableErrorrõ )rß Ú
|
connectionZdistilled_paramsrX r r r¢ Ú_execute_on_connectionx s ÿz Compiled._execute_on_connectionc K s t | t|¡|d S rÝ ©r6 ÚUnsupportedCompilationErrorrÐ ©rß ÚelementÚerrÚkwr r r¢ Ú visit_unsupported_compilation s z&Compiled.visit_unsupported_compilationc C s
|
t dS )zReturn a Compiled that is capable of processing SQL expressions.
|
|
If this compiler is one, it would likely just return 'self'.
|
|
N©ÚNotImplementedErrorrÿ r r r¢ Ú sql_compiler
s zCompiled.sql_compilerr4 r )ÚobjÚkwargsrÜ c K s |j | f|S rÝ ©Ú_compiler_dispatch)rß r r r r r¢ rk s zCompiled.processc C s | j tjkr| jS dS dS )z3Return the string text of the generated SQL or DDL.rQ N)rS r+ r- rR rÿ r r r¢ Ú__str__ s zCompiled.__str__Tú"Optional[_CoreSingleExecuteParams]ú&Optional[Sequence[BindParameter[Any]]]ú)Optional[_MutableCoreSingleExecuteParams]©ÚparamsÚextracted_parametersÚ escape_namesrÜ c C s
|
t dS )zâReturn 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.
|
Nr ©rß r r r r r r¢ Úconstruct_params s zCompiled.construct_paramsc C s | ¡ S )z0Return the bind params for this compiled object.©r rÿ r r r¢ r © s zCompiled.params)NNT)!rÒ rÓ rÔ rÕ rõ rÖ rR Úis_sqlÚis_ddlrT rU rW r% Ú
|
EMPTY_DICTrX r[ rì r\ r^ Ú immutabledictrn rq Ú classmethodro rw r~ r r rk r r r Ú __classcell__r r rt r¢ rO ã sF
|
ú8
|
|
|
|
ürO c @ sH e Zd ZdZdZddddZddd d
|
d d Zdd dddddZdS )Ú TypeCompilerz2Produces DDL specification for TypeEngine objects.z visit_\w+r\ ©rc c C s
|
|| _ d S rÝ r )rß rc r r r¢ rn ´ s zTypeCompiler.__init__rÏ r r )rÛ r} rÜ c K s0 |j r"| jj|j kr"|j | jj }|j| f|S rÝ )Z_variant_mappingrc rÌ r
©rß rÛ r} r r r¢ rk · s ÿ þzTypeCompiler.processÚ Exceptionr )r{ r| r} rÜ c K s t | |¡|d S rÝ )r6 ry rz r r r¢ r~ ¿ s z*TypeCompiler.visit_unsupported_compilationN)rÒ rÓ rÔ rÕ Z ensure_kwargrn rk r~ r r r r¢ r ¯ s
|
r c @ sB e Zd ZdZdZdZdddZedd Zed d
|
Z d d Z
|
d S )Ú _CompileLabelz;lightweight label object which acts as an expression.Label.Úlabel©r{ rÌ Ú
|
_alt_namesr c C s || _ || _|f| | _d S rÝ r )rß ÚcolrÌ Ú alt_namesr r r¢ rn Ð s z_CompileLabel.__init__c C s | j jS rÝ ©r{ Ú proxy_setrÿ r r r¢ r¢ Õ s z_CompileLabel.proxy_setc C s | j jS rÝ ©r{ rÐ rÿ r r r¢ rÐ Ù s z_CompileLabel.typec K s | S rÝ r ©rß r} r r r¢ Ú
|
self_groupÝ s z_CompileLabel.self_groupN)r ) rÒ rÓ rÔ rÕ Ú__visit_name__Ú __slots__rn r r¢ rÐ r¥ r r r r¢ r Ç s
|
|
|
r c @ sH e Zd ZdZdZdZdd Zedd Zedd Z d
|
d Z
|
d d Z dS )Úilike_case_insensitivea produce 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
|
|
Z ilike_case_insensitive_operand©r{ Z
|
comparatorc C s || _ |j| _d S rÝ r© )rß r{ r r r¢ rn ò s z ilike_case_insensitive.__init__c C s | j jS rÝ r¡ rÿ r r r¢ r¢ ö s z ilike_case_insensitive.proxy_setc C s | j jS rÝ r£ rÿ r r r¢ rÐ ú s zilike_case_insensitive.typec K s | S rÝ r r¤ r r r¢ r¥ þ s z!ilike_case_insensitive.self_groupc C s t | j |¡S rÝ )r¨ r{ Ú_with_binary_element_type)rß rÛ r r r¢ rª s
|
ÿz0ilike_case_insensitive._with_binary_element_typeN) rÒ rÓ rÔ rÕ r¦ r§ rn r r¢ rÐ r¥ rª r r r r¢ r¨ á s
|
|
r¨ c @ sò e Zd ZU dZeZe ddddddddd¡Zde 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 < d e d < d e 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< dZ de d1< dZ d2e d3< dZ d4e d5< dZ d6e d7< dZ d8e d9< dZ!d:e d;< e" Z#d<e d=< e" Z$d<e 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. /dN¡Z0e. /dO¡Z1e. /e1j2 dPe0j2 ¡Z3e4dQdR Z5e4dSdT Z6ddde7fdUdVdWdXddYdZd[d\d]Z8e9d4d^d_d`Z:ej;dd^dadbZ<e9dcdd Z=e9dedf Z>e9dgdh Z?ej@did^djdkZAejBdld^dmdnZCeDjEdodp ZFdqdr ZGdsdt ZHej@dud^dvdwZIej@dxd^dydzZJd{d| ZKe9d}d~ ZLdåddddddZMdædddd
ddddddZNejBdd ZOe9dd ZPdçddddddZQe Rd¡dd ZSde d< ej@dd^ddZTej@e Rd¡dd ZUej@e Rd¡dd ZVdd ZWdèd d¡ZXd¢d£ ZYdéd¤d¥ZZdêd¦d§Z[dëd¨d©Z\dªd« Z]d¬d Z^dìd®d¯dd°d±dZd&d²d³d´Z_dµd¶ Z`d·d¸ Zad¹dº Zbd»d¼ Zcd½d¾ Zdd¿dÀ ZedídÁdÂZfdîdÃdÄZgdÅdÆ ZhdÇdÈ ZidÉdÊ ZjdËdÌ ZkdÍdÎ ZldÏdÐ ZmdÑdÒ ZndÓdÔ ZodÕdÖ Zpd×dØ ZqdÙdÚ ZrdÛdÜ ZsdÝdÞ Ztdßdà Zudádâ Zvdãdä Zwdådæ Zxdïdçd¯dZd&dèdédêZydëdì Zzdídî Z{dïdð Z|dðdñdòZ}dódô Z~dõdö Zdñd÷døZdùdú Zdûdü Zdýdþ Zdÿd Zdd Z
dd Zdd Zdd Zdòd d
|
Zd d Zdód dZdd Zdd Zdd Zdd Zdd ZdôddZdd Zd d Zej@d d Zd!d" Zd#d$ Zd%d& Zd'd( Zd)d* Zd+d, Zd-d. Zd/d0 Zd1d2 Zd3d4 Zd5d6 Zd7d8 Z d9d: Z¡d;d< Z¢d=d> Z£d?d@ Z¤dAdB Z¥dCdD Z¦dEdF Z§dGdH Z¨dIdJ Z©dKdL ZªdõdMdNZ«dOdP Z¬edfdQdRZ®dSdT Z¯dUdV Z°d&dWd&dXdYdZZ±d&d&d[d\d]Z²död&ddd4d^d_d6dZd&d` dadbZ³dcdd Z´dddddeµ ¶d¡fdedddfdgdhdidZd4dj dkdlZ·dmdn Z¸dodp Z¹d÷dqdrZºdsdt Z»dudv Z¼dødwdxZ½dydz Z¾dùd{d|Z¿d}d~ ZÀdd ZÁd&d&d°ddddd
ZÂdúddZÃdûddZÄdd ZÅdd ZÆdd ZÇdd ZÈdd ZÉde d< eÊjË sÂe de" fde" fg¡ZÌdüddZÍdZÎdZe d< dýddZÏdddd d¡ZÐd¢d£ ZÑd¤d¥ ZÒd¦d§ ZÓdþd¨d©ZÔdªd« ZÕd¬d ZÖd®d¯ Z×d°d± ZØd²d³ ZÙd´dµddZd&d¶d·d¸ZÚd¹dº ZÛdÿd»d¼ZÜd d½d¾ZÝdd¿dÀZÞdÁd Zße eàjáeâjãeàjäeâjãeàjåeâjãeàjæeâjæeàjçeâjçi¡Zèeè éeàjåeâjêi¡ZëdÃdÄdÅdÆdÇZìd&dÈdÉdÊddËdÌdÍdÎZíddÏdÐZîdÑdÒ ZïdÓdÔ ZðdÕdÖ Zñd×dØ ZòdÙdÚ ZódÛdÜ ZôdÝdÞ Zõdßdà Zödádâ Z÷dãdä ZødS ( Ú SQLCompilerz~Default implementation of :class:`.Compiled`.
|
|
Compiles :class:`_expression.ClauseElement` objects into SQL strings.
|
|
ÚPÚAÚZÚCÚ_)ú%ú(ú)ú:Ú.ú[ú]ú zClassVar[Mapping[str, str]]Úbindname_escape_characterszClassVar[Pattern[str]]Ú_bind_translate_reÚ_bind_translate_charsTFrí ÚisdeleteÚisinsertÚisupdatezOptional[List[Column[Any]]]Z postfetchr zSequence[Column[Any]]Úinsert_prefetchÚupdate_prefetchNz&Optional[Sequence[ColumnElement[Any]]]Úimplicit_returningÚ isplaintextz Dict[str, BindParameter[Any]]Úbindsz Dict[BindParameter[Any], str]Ú
|
bind_nameszList[_CompilerStackEntry]rF Úreturning_precedes_valuesÚ'render_table_with_column_in_update_fromÚansi_bind_rulesr Ú bindtemplateÚcompilation_bindtemplateÚ _numeric_binds_identifier_charzList[ResultColumnsEntry]rU Ú_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_stringzOptional[List[str]]Ú_pre_expanded_positiontupzOptional[_InsertManyValues]Ú_insertmanyvaluesz!Optional[crud._CrudParamSequence]Ú_insert_crud_paramsz FrozenSet[BindParameter[Any]]Úliteral_execute_paramsÚpost_compile_paramsz util.immutabledict[str, str]Úescaped_bind_nameszbOptional[Tuple[Dict[BindParameter[Any], List[BindParameter[Any]]], Dict[str, BindParameter[Any]]]]Ú_cache_key_bind_matchrú Ú_values_bindparamÚ_visited_bindparamÚinlinez"Optional[MutableMapping[CTE, str]]ÚcteszDict[Tuple[int, str], CTE]Úctes_by_level_namez/Dict[CTE, Tuple[int, str, selectable._CTEOpts]]Úlevel_name_by_cteÚctes_recursivez"__\[POSTCOMPILE_(\S+?)(~~.+?~~)?\]z%\(([^)]+?)\)sú|c C s | ¡ d S rÝ )Ú_init_bind_translaterr r r r¢ ro 0 s z SQLCompiler._init_compiler_clsc C s2 t d | j¡¡}t d| d¡| _| j| _d S )NrQ r¶ r· )ÚreÚescaper~ r¹ Úcompilerº r» )rs Úregr r r¢ rã 4 s z SQLCompiler._init_bind_translater\ rP r] rù r/ r )rc rõ r^ Ú column_keysÚfor_executemanyÚlintingr c K sÜ || _ || _|r>dd |d D }dd |d D } | |f| _|| _|| _i | _t ¡ | _g | _ g | _
|
|j | _ | j r¦|j d¡ | _}
|
|
|
r|j dkrdnd| _t| _n t|j | _d | _|jpÂ|j| _t | _i | _i | _tj| ||f| | j s| j s| j rxt rt |t!st"| j s*| j rxt r@t |t#s@t"|j$rPd
|
| _%n(| jrx| j rr| j&j'rx|j(rxd
|
| _%t|j | _)| j*t+j,krØ| j r´| jr¬| -¡ n| .¡ | j/rØ| j0d d
|
d } | j1| d
|
d d S )a Construct 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.
|
|
c S s i | ] }|j |qS r ©rþ ©r Úbr r r¢ Ú
|
<dictcomp>^ s z(SQLCompiler.__init__.<locals>.<dictcomp>r c S s i | ] }||gqS r r rì r r r¢ rî _ s rª r« r¥ r´ NTF©r Ú_no_postcompile)Ú_populate_self)2rè r^ rÚ ré rê rà r% Z column_dictrÄ rF rU Ú
|
positionalÚ
|
paramstyleÚ
|
startswithrÏ rÊ Ú_pyformat_templaterÉ ÚBIND_TEMPLATESrÞ Ú label_lengthÚmax_identifier_lengthr3 Úanon_mapÚtruncated_namesÚ_truncated_countersrO rn r½ r¾ r¼ r ri rA rj rB Z_inlinerÝ rc Z insert_executemany_returningZ_return_defaultsrÈ rS r+ r- Ú_process_numericÚ_process_positionalrÐ r Ú#_process_parameters_for_postcompile) rß rc rõ r^ rè ré rê r ÚcksmÚckbmÚnbrö r r r¢ rn : st
|
|
ÿ
|
ÿÿýü
|
þ ÿzSQLCompiler.__init__rû c C s | j dkrdS | j jS dS )aø When 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)rÕ r rÿ r r r¢ Úinsert_single_values_expr¹ s
|
z%SQLCompiler.insert_single_values_exprc C s: | j r | j S | jdk r2t| jr2dd | jjD S dS dS )aâ The 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
|
|
Nc S s g | ]}t |r|qS r r& ©r Úcr r r¢ Ú
|
<listcomp>Ü s þz3SQLCompiler.effective_returning.<locals>.<listcomp>)rÁ rõ r( Ú_all_selected_columnsrÿ r r r¢ Úeffective_returningÌ s þz SQLCompiler.effective_returningc C s | j S )zVbackwards compatibility; returns the
|
effective_returning collection.
|
|
)r rÿ r r r¢ Ú returningå s zSQLCompiler.returningc
|
C sB z| j d d W S tk
|
r< } ztd|W 5 d}~X Y nX dS )a± Return 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)rF Ú
|
IndexError)rß Zier r r¢ Úcurrent_executableí s z SQLCompiler.current_executablec C s t | jt | j S rÝ )Úlistr¿ rÀ rÿ r r r¢ Úprefetch s zSQLCompiler.prefetchzDict[Any, Any]c C s i S rÝ r rÿ r r r¢ Ú_global_attributes s z SQLCompiler._global_attributeszMutableMapping[CTE, str]c C s$ 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á )rß rÞ r r r¢ Ú_init_cte_state s zSQLCompiler._init_cte_statec c sp | j | j }}g d | _ | _z0| jr8| jd }d|d< nd}| j | jfV W 5 |r\| d¡ || | _ | _X dS )z;special API to support the use case of 'nested result sets'Frî r TN)rU rÍ r< rF )rß Zresult_columnsZordered_columnsÚentryr r r¢ Ú_nested_result0 s þ
|
|
|
þzSQLCompiler._nested_resultc s< j r
|
tjtjkstjr$tjjdkr6dnjjdksFtdg dddfdd t j
|
j ¡_ j r¾d
|
d j ¡ D tj tks¨tfd d D _ n_ jr8g t j
|
jj¡} fdd jjD }jjd k r fdd jjD nd }jj|||d_d S )Nr© ú%sr¨ r¦ z re.Match[str]r )ÚmrÜ c s: | d¡}|r |¡ S | d¡¡ | d¡S d S )Nr r5 r )ry Úappend)r Z normal_bind)Ú placeholderÚ positionsr r¢ Ú find_positionU s
|
|
z6SQLCompiler._process_positional.<locals>.find_positionc S s i | ]\}}||qS r r )r ÚkÚvr r r¢ rî d s z3SQLCompiler._process_positional.<locals>.<dictcomp>c s g | ]} ||¡qS r ©Úget©r rÌ )Úreverse_escaper r¢ r f s z3SQLCompiler._process_positional.<locals>.<listcomp>c
|
s4 g | ],}|d |d t j |d ¡|d fqS )r r r5 rå )rä ÚsubÚ_positional_pattern©r r )r rß r r¢ r t s ûüc s g | ]} j tt|¡qS r ©rú r8 r r ©r Z
|
_param_keyrÿ r r¢ r s ÿ©r r
|
r )rú rj rS r+ r- rÏ rc ró rä r r rR rÙ ÚitemsÚlenrÕ r r
|
r Ú_replace)rß r r
|
Úsentinel_param_int_idxsr )r r r r rß r¢ rý H sT
|
|
|
ÿ
|
ÿ
|
ý ù
|
üþú ýz SQLCompiler._process_positionalc
|
s j s
|
tjtjkstd}i jrZjd k rZt fddj
|
¡ D j
|
¡ ¡}n
|
j
|
¡ }|D ]T}| krvqhj | }|j ks|j krd |< qhj | }|d7 }| |< qh|_t _jrt }fdd ¡ D t |kstj fddj¡_jrjj }dd jjD }jjd k rjfd
|
d jjD nd } jj||| d _d S ) Nr c 3 s | ]}| j kr|V qd S rÝ )rÛ r rÿ r r¢ r s
|
þz/SQLCompiler._process_numeric.<locals>.<genexpr>c s i | ]\}} j ||¡|qS r )rÙ r )r rÌ Úposrÿ r r¢ rî ¸ s ÿ z0SQLCompiler._process_numeric.<locals>.<dictcomp>c s | d¡ S ©Nr ©ry ©r ©Ú param_posr r¢ Ú<lambda>À ó z.SQLCompiler._process_numeric.<locals>.<lambda>c S s$ g | ] }|d |d d|d fqS )r r r rå r r! r r r¢ r Ê s ÿz0SQLCompiler._process_numeric.<locals>.<listcomp>c s g | ]} j tt|¡qS r r" r# rÿ r r¢ r Ð s ÿr$ ) rÏ rj rS r+ r- rÕ rÛ Ú itertoolsÚchainrÄ Úvaluesrà rØ r× rÊ Únext_numeric_posr rú rÙ r& r% Ú_pyformat_patternr rR r r
|
r r' )
|
rß Únumr Ú bind_nameÚbindÚphZ
|
len_beforer r
|
r( r )r. rß r¢ rü sn
|
|
þú
|
|
ÿþ
|
|
|
|
þ
|
ÿÿýþ
|
|
üþú ûz SQLCompiler._process_numericzVMutableMapping[str, Union[_BindProcessorType[Any], Sequence[_BindProcessorType[Any]]]]c s dd fdd j D D S )Nc S s i | ]\}}|d k r||qS rÝ r ©r rþ Úvaluer r r¢ rî é s ó z0SQLCompiler._bind_processors.<locals>.<dictcomp>c 3 sN | ]F} j | |jjs$|j j¡n t fd dtt|jjD fV qdS )c 3 s | ]}| j¡V qd S rÝ )Ú_cached_bind_processorrc )r Z elem_typerÿ r r¢ r ð s ÿz9SQLCompiler._bind_processors.<locals>.<genexpr>.<genexpr>N) rÄ rÐ Ú_is_tuple_typer< rc r r r1 Útypes)r Ú bindparamrÿ r r¢ r ë s
|
øÿ þüz/SQLCompiler._bind_processors.<locals>.<genexpr>)rÄ rÿ r rÿ r¢ Ú_bind_processorsà s
|
|
|
öþz SQLCompiler._bind_processorsz9Optional[Sequence[Optional[_SentinelProcessorType[Any]]]]c sH j }|d ks|jd kr d S fdd|jD }tj |¡r@d S |S d S )Nc s g | ]}|j j¡qS r )rÐ Z _cached_sentinel_value_processorrc )r Z_scolrÿ r r¢ r s ÿz=SQLCompiler._imv_sentinel_value_resolvers.<locals>.<listcomp>)rÕ r r% ZNONE_SETÚ
|
issuperset)rß ÚimvZsentinel_value_resolversr rÿ r¢ Ú _imv_sentinel_value_resolversú s
|
þ z)SQLCompiler._imv_sentinel_value_resolversc C s t | jdkS r* )r& rF rÿ r r r¢ Ú is_subquery s zSQLCompiler.is_subqueryc C s | S rÝ r rÿ r r r¢ r s zSQLCompiler.sql_compilerr rô )r r rÜ c C s | j ||dd}| |¡S )aR Return 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
|
|
Trï )r rþ )rß r r rö r r r¢ Úconstruct_expanded_state s ýÿz$SQLCompiler.construct_expanded_stater z Optional[int]r[ )r r r Ú _group_numberÚ_checkrð rÜ c s2 | j r2|s2| jdk st|s(t| jjS t d¡|o>t| j}|r| j dkrZt
|
d¡n
|
| j d }| j } | dk svt| \ }
|
fddt ||D } nd} |ri } | j ¡ D ]Ê\} }|rÊ| j ||¡n|}| j|krè|| j | |< q°||kr || | |< q°|rD| jrD|r.tjd| j|f dd ntjd
|
| j dd q°| rX| | | ¡}n| }| jrp|j| |< q°|j| |< q°| S i } | j ¡ D ]\} }|rª| j ||¡n|}|rð| jrð|rÜtjd| j|f dd ntjd
|
| j dd | r| | | ¡}n| }| jr |j| |< n
|
|j| |< q| S dS ) z5return a dictionary of bind parameter keys and valuesNzÂcan'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_paramsr c s$ i | ] \}} | D ]
|
}||qqS r r )r rí Z extractedr8 ©r r r¢ rî U s
|
|
þ z0SQLCompiler.construct_params.<locals>.<dictcomp>z@A value is required for bind parameter %r, in parameter group %dZcd3x)Úcodez)A value is required for bind parameter %r)rÐ rÑ rj Údictrö r6 r rí rÙ r^ Ú CompileErrorrÚ ÚziprÄ r% r rþ ÚrequiredÚcallableÚeffective_valuer; )rß r r r rF rG rð Zhas_escaped_namesZorig_extractedÚ
|
ckbm_tupler° Zresolved_extractedÚpdr? rÌ Ú escaped_nameZ value_paramr rH r¢ r ) s¦
|
ÿ
|
ÿ
|
|
þÿý
|
|
þüÿý ÿ ÿýþüÿý z SQLCompiler.construct_paramsc s | j jjj fddi }| j}| jD ]F}||krHq:|jjrrfddtt |jj
|
D ||< q:|j||< q:|S )Nc sD | ¡ ¡}|d k r<d ks(|kr<d ks8|kr<|S d S d S rÝ )Ú_unwrapped_dialect_implZget_dbapi_type)ÚtypZdbtype)Údbapirc Ú exclude_typesÚ include_typesr r¢ Ú lookup_type´ s ÿþþýýz<SQLCompiler._get_set_input_sizes_lookup.<locals>.lookup_typec s g | ] } |qS r r )r rT )rX r r¢ r É s ÿz;SQLCompiler._get_set_input_sizes_lookup.<locals>.<listcomp>) rc Zinclude_set_input_sizesZexclude_set_input_sizesrU r× rÄ rÐ r= r r1 r> )rß Z
|
inputsizesr× r? r )rU rc rV rW rX r¢ Ú_get_set_input_sizes_lookup« s
|
|
þ z'SQLCompiler._get_set_input_sizes_lookupc C s | j ddS )zýReturn 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)rG r rÿ r r r¢ r Ò s zSQLCompiler.params)rö rñ rÜ c sÐ i }j }|dkrj}jr8g }j}|dkr@j}nd }}j}td|td|i }i i } d}
|
jr|dk r|} jrg }
|
n
|
j ¡ } j
|
} | D ]p | r²| ¡n } j }|j krð| krÜ| | ¡}j||d| < q|jkrü| kr| | }d}n0| ¡} | ||¡}|\}}|| | < || < |js| |¡ |jjr|dk snt| fddt|dD ¡ n| fdd|D ¡ |
|
dk rÊ|
|
d d |D ¡ n |dk rè| d
|
d |D ¡ d d |D | < q|dk r| ¡ qfd d}t j ||¡}|
|
dk r~|dk sDtfddt|
|
j D j fdd|¡}| |
|
¡ t |||||}|rÌ|_ |_|j _jrÀt!|jp¼dnd_|_"|S )a handle 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_valuec 3 s` | ]X\}}t |d D ]D\}} kr |d dk rd ||f |d fV qqdS )r Nú%s_%s_%s©Ú enumerate)r ÚiÚ tuple_elementÚjr° )rÌ Útuple_processorsr r¢ r N s ú þzBSQLCompiler._process_parameters_for_postcompile.<locals>.<genexpr>r c 3 s& | ] \}} kr| fV qd S rÝ r )r rþ r° )rÌ Úsingle_processorsr r¢ r Y s þc s s | ]\}}|V qd S rÝ r ©r rÌ r° r r r¢ r _ s c s s | ]\}}|V qd S rÝ r rd r r r¢ r f s c S s g | ] \}}|qS r r )r Z
|
expand_keyr° r r r¢ r g s zCSQLCompiler._process_parameters_for_postcompile.<locals>.<listcomp>c sb | d¡}| }| d¡r^| d¡ d¡}|d |d d fdd| d¡D ¡}|S )Nr r5 ú~~rå r¯ c 3 s | ]}d |f V qdS ©z%s%s%sNr )r Úexp©Úbe_leftÚbe_rightr r¢ r v s ÿz]SQLCompiler._process_parameters_for_postcompile.<locals>.process_expanding.<locals>.<genexpr>)ry Úsplitr~ )r rþ ÚexprÚtok)Úreplacement_expressionsrh r¢ Úprocess_expandingm s
|
|
þzJSQLCompiler._process_parameters_for_postcompile.<locals>.process_expandingc s i | ]\}}| j | qS r ©rÊ )r r6 rþ rÿ r r¢ rî s ÿ zCSQLCompiler._process_parameters_for_postcompile.<locals>.<dictcomp>c s | d¡ S r* r+ r, r- r r¢ r/ r0 zASQLCompiler._process_parameters_for_postcompile.<locals>.<lambda>r )#rÓ rR rò rÔ rú r@ r rÏ rÄ r3 rÙ r rà r× r< Úrender_literal_bindparamrØ Ú$_literal_execute_expanding_parameterÚliteral_executeÚupdaterÐ r= rj r^ Úextendr rä r Ú_post_compile_patternr4 r5 rô rõ r rÑ )rß rö rñ Zexpanded_parametersZpre_expanded_stringZnew_positiontupZpre_expanded_positiontuprø Znew_processorsZto_update_setsZnumeric_positiontupÚnamesZebnrR Ú parameterr; Ú to_updater3 Zleep_resÚreplacement_exprro rõ Zexpanded_stater )rÌ r. rn rß rc rb r¢ rþ ß sâ ÿ ÿ
|
|
|
|
|
þþÿ
|
|
ÿ
|
|
û
|
þ
|
|
ÿ
|
|
ÿ ÿ
|
|
ÿþ
|
ÿ
|
ûÿýz/SQLCompiler._process_parameters_for_postcompilezsqlalchemy.engine.cursorc C s t jj}|j | j¡S )z(utility method used for unit tests only.)r% Ú preloadedZ engine_cursorrT Z _create_description_match_maprU )rß Úcursorr r r¢ Ú_create_result_map¦ s ÿz SQLCompiler._create_result_mapÚ_BindNameForColProtocolÚ_get_bind_name_for_colzCallable[[Any], str]c C s
|
| j }|S rÝ )r )rß Úgetterr r r¢ Ú _within_exec_param_key_getter± s z)SQLCompiler._within_exec_param_key_getterzsqlalchemy.engine.resultc sÈ t jj}| j| jd k s t| jj}tr6t|t s6t|j
|
}fdd|j D d |j d k r j | jd ¡ | jkrfdd}|nd | dd |j D ¡ fdd}|S )Nc s" g | ]}t d |d¡|fqS )r N)ÚoperatorÚ methodcaller©r r )Úparam_key_getterr r¢ r Å s ÿzKSQLCompiler._inserted_primary_key_from_lastrowid_getter.<locals>.<listcomp>c s | | ¡}|d k r|S | S d S rÝ r )Ú lastrowidrö Z param_value)Ú autoinc_keyr r¢ Ú_autoinc_getterÚ s zPSQLCompiler._inserted_primary_key_from_lastrowid_getter.<locals>._autoinc_getterc S s g | ]
|
}|j qS r rë r r r r¢ r ì s c sN dk r dkr.fddD S fddD S dS )a given 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.
|
|
Nc 3 s | ]\}}| V qd S rÝ r ©r r r rü r r¢ r ù s zWSQLCompiler._inserted_primary_key_from_lastrowid_getter.<locals>.get.<locals>.<genexpr>c 3 s8 | ]0\}}| kr(d k r$q.n|V qd S rÝ r r )Ú autoinc_colÚautoinc_getterr rö r r¢ r û s þûÿ ýr ©r rö )r r ÚgettersÚlastrowid_processorÚrow_fnr r¢ r î s øzDSQLCompiler._inserted_primary_key_from_lastrowid_getter.<locals>.get)r% r{ Ú engine_resultr rì rj rõ r ri r@ r Ú primary_keyZ_autoincrement_columnrÐ Z_cached_result_processorrc rÃ Ú result_tuple)rß Úresultrõ r r r r )r r r r r r
r r¢ Ú+_inserted_primary_key_from_lastrowid_getter¶ s2
|
þ ÿ
|
z7SQLCompiler._inserted_primary_key_from_lastrowid_getterc s¸ t jrddlm} ntjj}| jd k s*t| jj }trDt
|
|t sDt| j |j }| j}|d k sbtdd t|D tdfdd|jD | dd |jD ¡ fd d
|
}|S ) Nr5 )r c S s i | ]\}}||qS r r )r Úidxr r r r¢ rî s zKSQLCompiler._inserted_primary_key_from_returning_getter.<locals>.<dictcomp>z'List[Tuple[Callable[[Any], Any], bool]]c s< g | ]4}|kr"t | ¡d fnt d |d¡dfqS )Tr NF)r Ú
|
itemgetterr r )r
Úretr r¢ r s ûÿþzKSQLCompiler._inserted_primary_key_from_returning_getter.<locals>.<listcomp>c S s g | ]
|
}|j qS r rë r r r r¢ r * s c s fddD S )Nc 3 s& | ] \}}|r|n| V qd S rÝ r )r r Zuse_row©rö Úrowr r¢ r - s ÿzWSQLCompiler._inserted_primary_key_from_returning_getter.<locals>.get.<locals>.<genexpr>r )r rö )r r r r¢ r , s þzDSQLCompiler._inserted_primary_key_from_returning_getter.<locals>.get)Útypingr Zenginer r% r{ r rì rj rõ ri r@ r r rÁ r^ r r r )rß r rõ r r r r )r r
r r r¢ Ú+_inserted_primary_key_from_returning_getter s* ùþ z7SQLCompiler._inserted_primary_key_from_returning_getterc C s dS )z´Called when a SELECT statement has no froms, and no FROM clause is
|
to be appended.
|
|
Gives Oracle a chance to tack on a ``FROM DUAL`` to the string output.
|
|
rQ r rÿ r r r¢ Ú default_from4 s zSQLCompiler.default_fromc K s d|j j| f| d S ©Nr² r³ ©r{ r
)rß ÚgroupingÚasfromr r r r¢ Úvisit_grouping= s zSQLCompiler.visit_groupingc K s d|j j| f| d S r r )rß r r r r r¢ Ú visit_select_statement_grouping@ s z+SQLCompiler.visit_select_statement_groupingc
|
K s¾ | j r¦| jjr¦ztd| j d d }W n. tk
|
rT } zt d¡|W 5 d }~X Y nX |j\}}}|rl|} n|} |jj }
|
|
|
d k r¦|
|
j
|
| kr¦|
|
| |
|
j
|
¡r¦|jj |d< | j |jfd|i|S )Nú'Union[SelectState, CompoundSelectState]r rì úECan't resolve label reference for ORDER BY / GROUP BY / DISTINCT etc.Úrender_label_as_labelÚwithin_columns_clause) rF rc Z supports_simple_order_by_labelr ÚKeyErrorr6 rK Ú_label_resolve_dictr{ Z_order_by_label_elementrÌ Zshares_lineagerk ) rß r{ r¦ r rì ÚkeÚ with_colsÚ
|
only_fromsÚ only_colsZ resolve_dictZ order_by_elemr r r¢ Úvisit_label_referenceC sP þÿý üÿþÿý þÿÿþýz!SQLCompiler.visit_label_referencec
|
K sê | j s| |j¡S ztd| j d d }W n8 tk
|
rb } ztj|jdtj |d W 5 d }~X Y nX |j
|
\}}}z |r||j } n
|
||j } W n8 tk
|
rÆ }
|
ztj|jdtj |
|
d W 5 d }
|
~
|
X Y n X | |d< | j| fd|i|S d S )Nr£ r rì r¤ )ÚextraZexc_clsr| r¥ r¦ ) rF rk Z _text_clauser r§ r Z_no_text_coercionr{ r6 rK r¨ ) rß r{ r¦ r rì r© rª r« r¬ r r| r r r¢ Ú visit_textual_label_referencer sD þù
|
ù
|
ÿÿÿz)SQLCompiler.visit_textual_label_referencec K sÊ |o| }||k} | s|r>t |jtjr8| d|j¡}
|
n|j}
|
|r|d k rj||
|
|j||
|
f|j | |j |jj| fddd|t t
|
j | j ||
|
¡ S | r®| j ||
|
¡S |jj| fddi|S d S )NÚcolidentT)r¦ Úwithin_label_clauser¦ F)ri rÌ r rC Ú_truncated_identifierr rÐ r{ r
Ú OPERATORSr Úas_rZ Ú format_label) rß r Úadd_to_result_mapr± r¦ r¥ Úresult_map_targetsr} Zrender_label_with_asZrender_label_onlyZ labelnamer r r¢ Ú visit_label sJ ÿüÿýüú ùÿ
|
ÿÿÿzSQLCompiler.visit_labelc C s t d¡d S )Nz:Cannot compile Column object until its 'name' is assigned.©r6 rK ©rß rg r r r¢ Ú_fallback_column_nameÐ s ÿz!SQLCompiler._fallback_column_namec K s |j }| j|f|S rÝ )Z _resolvedrk )rß r{ r} Z sql_elementr r r¢ Úvisit_lambda_elementÕ s z SQLCompiler.visit_lambda_elementúColumnClause[Any]z Optional[_ResultMapAppender]rÍ z Optional[_AmbiguousTableNameMap])rg r¶ Ú include_tabler· Úambiguous_table_name_mapr rÜ c K sB |j }}|d kr | |¡}|j} | s>t|tjr>| d|¡}|d k rx|||jf| }
|
|jrh|
|
|jf7 }
|
||||
|
|j | r|
|
|¡}n | j |¡}|j } | d ks¬|r¬| js°|S | j | ¡} | rÒ| j | ¡d } nd} trèt| tsèt| j }| s |r ||kr || }t|tjr&| d|¡}| | j |¡ d | S d S )Nr° rµ rQ Úalias)rÌ r» Ú
|
is_literalri r rC r² rþ Ú _tq_labelrÐ Úescape_literal_columnrZ Úquoter Znamed_with_columnÚschema_for_objectÚ quote_schemar rN rj )rß rg r¶ r¾ r· r¿ r rÌ Ú orig_namerÁ Útargetsr Úeffective_schemaZ schema_prefixZ tablenamer r r¢ Ú visit_columnÙ sF
|
|
ÿÿþý zSQLCompiler.visit_columnc K s | j |j¡S rÝ )rZ Úformat_collationÚ collation©rß r{ r} r r r¢ Úvisit_collation
|
s zSQLCompiler.visit_collationc K s |j S rÝ ©rÌ )rß Z
|
fromclauser r r r¢ Úvisit_fromclause
|
s z SQLCompiler.visit_fromclausec K s |j S rÝ rÏ )rß r8 r r r r¢ Ú visit_index
|
s zSQLCompiler.visit_indexc K s& ||d< | j |d< | jjj|jf|S )NÚtype_expressionrf )rZ rc Útype_compiler_instancerk rÐ )rß Ú
|
typeclauser} r r r¢ Úvisit_typeclause
|
s
|
ÿÿz SQLCompiler.visit_typeclausec C s | j jr| dd¡}|S ©Nr± ú%%©rZ Ú_double_percentsÚreplace©rß Útextr r r¢ Úpost_process_text$
|
s z SQLCompiler.post_process_textc C s | j jr| dd¡}|S rÖ rØ rÛ r r r¢ rà )
|
s z!SQLCompiler.escape_literal_columnc sR fdd}j s d_|r2|d d ftj t dd t | j¡¡¡S )Nc s: | d¡}|jkr(jj| f S j|f S d S r* )ry Z _bindparamsrk Úbindparam_string)r rÌ ©r} rß Ú
|
textclauser r¢ Ú do_bindparam/
|
s
|
|
z2SQLCompiler.visit_textclause.<locals>.do_bindparamTc S s
|
| d¡S r* r+ r, r r r¢ r/ A
|
r0 z.SQLCompiler.visit_textclause.<locals>.<lambda>) rF r r$ ÚNULLTYPEÚBIND_PARAMS_ESCr Ú BIND_PARAMSrÝ rÜ )rß rà r¶ r} rá r rß r¢ Úvisit_textclause.
|
s
|
ÿþz SQLCompiler.visit_textclausec K sú | j }|r| jn| j d }t t |d}| j |¡ |jrJ| ||¡ |pl|dkrb| dd¡pl| dd¡}|r²|j | _| _ |j ot
|
|j | _ |j D ]} | j | d| jd q| j |jf|}
|
| jrê|sÖt| j nd } | j| d |
|
}
|
| j d¡ |
|
S )
|
Nr ©ré rè r# r rï Frî T)r¦ r¶ ©Ú nesting_level)rF Ú_default_stack_entryr r Ú_independent_ctesÚ_dispatch_independent_ctesr rò rÍ rË rí Z column_argsrÎ rk Ú_add_to_result_mapr{ rÞ r& Ú_render_cte_clauser< ) rß ZtafÚcompound_indexr r} Útoplevelr Ú new_entryÚpopulate_result_mapr rÜ rè r r r¢ Úvisit_textual_selectG
|
sD ý
|
ý
|
ú þ
|
ÿ
|
ý z SQLCompiler.visit_textual_selectc K s dS ©NÚNULLr ©rß rl r} r r r¢ Ú
|
visit_null|
|
s zSQLCompiler.visit_nullc K s | j jr dS dS d S )Nr Ú1©rc Úsupports_native_booleanrõ r r r¢ Ú
|
visit_true
|
s zSQLCompiler.visit_truec K s | j jr dS dS d S )Nrt Ú0rø rõ r r r¢ Ú visit_false
|
s zSQLCompiler.visit_falsec s$ | dd fdd|D D ¡S )Nc s s | ]}|r|V qd S rÝ r ©r Úsr r r¢ r
|
s þz7SQLCompiler._generate_delimited_list.<locals>.<genexpr>c 3 s | ]}|j f V qd S rÝ r r ©r} rß r r¢ r
|
s ©r~ )rß r Ú separatorr} r rÿ r¢ Ú_generate_delimited_list
|
s
|
þz$SQLCompiler._generate_delimited_listc sl t j tjt jjt jj|¡\}}|dkr:|d jf S t tj }|
|
dd fdd|D D ¡S d S )Nr r c s s | ]}|r|V qd S rÝ r rý r r r¢ r
|
s þz;SQLCompiler._generate_delimited_and_list.<locals>.<genexpr>c 3 s | ]}|j f V qd S rÝ r r rÿ r r¢ r
|
s ) r ZBooleanClauseListZ _process_clauses_for_booleanr Úand_ZTrue_Z
|
_singletonZFalse_r
r³ r~ )rß Úclausesr} Zlccr r rÿ r¢ Ú _generate_delimited_and_list
|
s ü
|
|
þz(SQLCompiler._generate_delimited_and_listc K s d| j |f| S ©Nú(%s))Úvisit_clauselist)rß Ú
|
clauselistr} r r r¢ Ú visit_tuple¤
|
s zSQLCompiler.visit_tuplec K s0 |j }|d krd}n
|
t|j }| j|j|f|S ©Nr¸ )r r³ r r )rß r r} Úsepr r r¢ r §
|
s
|
|
z SQLCompiler.visit_clauselistc
|
K sz |j }| |dd ¡}|r&|||f|S z t| }W n0 tk
|
rb } zt | |¡|W 5 d }~X Y nX | j|j|f|S d S )NZexpression_clauselist)r Ú_get_operator_dispatchr³ r§ r6 ry r r )rß r r} Ú operator_ÚdispÚopstringr| r r r¢ Úvisit_expression_clauselist°
|
s$ ÿ ÿÿz'SQLCompiler.visit_expression_clauselistc K s d}|j d k r&||j j| f|d 7 }|jD ]4\}}|d|j| f| d |j| f| d 7 }q,|jd k r|d|jj| f| d 7 }|d7 }|S )NzCASE r¸ zWHEN z THEN zELSE ZEND)r; r
ZwhensZelse_)rß Úclauser r¡ Zcondr r r r¢ Ú
|
visit_caseÂ
|
s*
|
ÿþ ýüÿ
|
ÿzSQLCompiler.visit_casec K s |j j| f|S rÝ )Ztyped_expressionr
)rß Z type_coercer} r r r¢ Úvisit_type_coerceÕ
|
s z SQLCompiler.visit_type_coercec K s$ d|j j| f||jj| f|f S )NzCAST(%s AS %s))r r
rÔ )rß r r r r r¢ Ú
|
visit_castØ
|
s þzSQLCompiler.visit_castc K sä d|d t jkrdn\|d t jkr&dnJ|d dk rTd| jt t|d ¡f|f n d| jt |d ¡f|f |d t jkrdn\|d t jkrdnJ|d dk rÂd| jt t|d ¡f|f n d| jt |d ¡f|f f S ) Nz %s AND %sr zUNBOUNDED PRECEDINGz CURRENT ROWz %s PRECEDINGz %s FOLLOWINGr zUNBOUNDED FOLLOWING)r ZRANGE_UNBOUNDEDZ RANGE_CURRENTrk ÚliteralÚabs)rß Úrange_r} r r r¢ Ú_format_frame_clauseÞ
|
s0 ÿ ÿ
|
þ ÿÿ ÿ ÿ
|
þ ÿÿïz SQLCompiler._format_frame_clausec s |j jf }|jr,dj|jf }n |jrHdj|jf }nd }d|d fddd|jfd|jffD |r|gng ¡f S ) NzRANGE BETWEEN %szROWS BETWEEN %sz %s OVER (%s)r¸ c s6 g | ].\}}|d k rt |rd||jf f qS )Nz%s BY %s)r& r
)r Úwordr ©r rß r r¢ r s úÿz*SQLCompiler.visit_over.<locals>.<listcomp>Z PARTITIONÚORDER)r{ r
r r Úrowsr~ Z partition_byÚorder_by)rß Zoverr rÜ r r r r¢ Ú
|
visit_overõ
|
s4 ÿÿÿÿ þý ÷ÿþzSQLCompiler.visit_overc K s$ d|j j| f||jj| f|f S )Nz %s WITHIN GROUP (ORDER BY %s))r{ r
r )rß Z withingroupr r r r¢ Úvisit_withingroup s þz SQLCompiler.visit_withingroupc K s$ d|j j| f||jj| f|f S )Nz%s FILTER (WHERE %s))Úfuncr
Z criterion)rß Z
|
funcfilterr r r r¢ Úvisit_funcfilter s þz SQLCompiler.visit_funcfilterc K s* | j |j|j¡}d||jj| f|f S )NzEXTRACT(%s FROM %s))Ú extract_mapr Úfieldrl r
)rß Úextractr r$ r r r¢ Ú visit_extract s
|
þzSQLCompiler.visit_extractc K s* | j |jf|}| j|f|}d||f S )Nz(%s).%s)Úvisit_functionÚfnrÊ )rß r{ r} Z compiled_fnZ compiled_colr r r¢ Ú visit_scalar_function_column% s z(SQLCompiler.visit_scalar_function_columnz Function[Any])r! r¶ r rÜ c sæ |d k r ||j |j d|j td|j ¡ d }|rD||f|}nt | ¡ jd ¡ rj|jr d7 n6|j j
|
¡st t j rj ¡n d d fdd|jD g ¡dj|f|i }|jrâ|d7 }|S ) Nr z visit_%s_funcz%(expr)srµ c s4 g | ],}j |¡s t tjr,j |¡n|qS r )rZ Ú _requires_quotes_illegal_charsri r r/ rÄ )r rm ©rÌ rß r r¢ r H s ü
|
ÿ
|
þz.SQLCompiler.visit_function.<locals>.<listcomp>rl z WITH ORDINALITY)rÌ rÐ ÚgetattrÚlowerr· r Z _deannotateru Z _has_argsrZ r* ri r r/ rÄ r~ Z packagenamesÚfunction_argspecZ_with_ordinality)rß r! r¶ r r rÜ r r+ r¢ r' * s:
|
|
ÿ
|
þü ù ÷ÿ õ zSQLCompiler.visit_functionc K s | |j¡S rÝ )Úvisit_sequenceÚsequence)rß Z
|
next_valuer} r r r¢ Úvisit_next_value_funcX s z!SQLCompiler.visit_next_value_funcc K s t d| jj d S )Nz2Dialect '%s' does not support sequence increments.©r rc rÌ )rß r0 r} r r r¢ r/ [ s
|
ÿÿzSQLCompiler.visit_sequencec K s |j j| f|S rÝ )Z clause_exprr
)rß r! r r r r¢ r. a s z SQLCompiler.function_argspecc sb j }|j|f}|r(js(|_|j}|r8jnj d }|pV| oV| dd¡} |dkrh||d< j |d |d ||| d¡ |jr |¡ j |j
|
}
|
d |
|
d fd
|
d t |j D ¡} dd < | j|ftf d i7 } | j|f7 } |jr$| j|f7 } jrR|s<tj nd } j| dd| } j d¡ | S )Nr rï Fr rð ré rè )ré rè r# rì rï r¸ c 3 s* | ]"\}}|j f |d V qdS ))r rî Nr )r r_ r ©r r rß r r¢ r s ýÿ ÿÿz4SQLCompiler.visit_compound_select.<locals>.<genexpr>r¾ r T©rè Úinclude_following_stack)rF Ú_compile_state_factoryrì rõ ré r r rê rë Úcompound_keywordsÚkeywordr~ r^ ZselectsÚgroup_by_clauserJ Úorder_by_clauseÚ_has_row_limiting_clauseÚ_row_limit_clauserÞ r& rí r< ) rß Úcsr rî r rï rì Z compound_stmtr Zneed_result_mapr8 rÜ rè r r3 r¢ Úvisit_compound_selectd sX
|
|
þûÿ
|
üÿ þüÿ z!SQLCompiler.visit_compound_selectc K s* |j d k r| j|f|S | j|f|S d S rÝ )Ú _fetch_clauseÚ fetch_clauseÚ limit_clause)rß r= r r r r¢ r< ¥ s
|
z SQLCompiler._row_limit_clausec C s( d|j ||rd| ndf }t| |d S )Nz visit_%s_%s%sr° rQ )rÒ r, )rß r Z
|
qualifier1Z
|
qualifier2Úattrnamer r r¢ r « s ýz"SQLCompiler._get_operator_dispatchc K sÄ |d k r"||f7 }||d< ||d< |j rt|jr8t d¡| |j dd¡}|r\|||j f|S | j|t|j f|S nL|jr¶| |jdd¡}|r|||jf|S | j|t|j f|S n
|
t d¡d S )Nr¶ r· zFUnary expression does not support operator and modifier simultaneouslyÚunaryr Úmodifierz,Unary expression has no operator or modifier)r rD r6 rK r Ú _generate_generic_unary_operatorr³ Ú _generate_generic_unary_modifier)rß rC r¶ r· r} r r r r¢ Ú visit_unary³ sN
|
ÿ ÿ ÿÿ ÿ ÿÿÿzSQLCompiler.visit_unaryc K sx | j jrP| j|jf|d | jt |j|jjjt j
|
kr>|jjnt
|
¡ ¡f| S | j|jf|d | j|jf| S d S )Nú / ) rc Údiv_is_floordivrk r r ZCastr rÐ Ú_type_affinityr$ ZNumeric©rß rd r r} r r r¢ Úvisit_truediv_binaryÚ s, ÿÿ
|
üÿùüÿÿþÿz SQLCompiler.visit_truediv_binaryc K sh | j jr<|jjjtjkr<| j|jf|d | j|jf| S d| j|jf|d | j|jf| S d S )NrH z FLOOR(%s)) rc rI r rÐ rJ r$ ZIntegerrk r rK r r r¢ Úvisit_floordiv_binaryò s" ÿþÿþÿÿþÿz!SQLCompiler.visit_floordiv_binaryc K s6 |j s| jjr | j|jf|S d| j|jf| S d S )Nz%s = 1©Z_is_implicitly_booleanrc rù rk r{ ©rß r{ r r} r r r¢ Ú visit_is_true_unary_operator s ÿþz(SQLCompiler.visit_is_true_unary_operatorc K s: |j s| jjr"d| j|jf| S d| j|jf| S d S )NúNOT %sz%s = 0rN rO r r r¢ Ú visit_is_false_unary_operator s ÿþz)SQLCompiler.visit_is_false_unary_operatorc K s d| j |tjd S )NrQ )Úoverride_operator)Ú visit_binaryr Úmatch_oprK r r r¢ Úvisit_not_match_op_binary s ÿz%SQLCompiler.visit_not_match_op_binaryc K s d| j |t| f| S r )Ú_generate_generic_binaryr³ rK r r r¢ Úvisit_not_in_op_binary s ÿÿz"SQLCompiler.visit_not_in_op_binaryc K sv |t jkr4t|dkr.dd dd |D ¡ S dS n>|t jkrht|dkrbdd dd |D ¡ S d S n
|
| |¡S d S )
|
Nr z(%s)) OR (1 = 1r¯ c s s | ]
|
}d V qdS ©rô Nr ©r r{ r r r¢ r & s z6SQLCompiler.visit_empty_set_op_expr.<locals>.<genexpr>zNULL) OR (1 = 1z(%s)) AND (1 != 1c s s | ]
|
}d V qdS rY r rZ r r r¢ r - s zNULL) AND (1 != 1)r Ú not_in_opr& r~ Úin_opÚvisit_empty_set_expr)rß rÛ Ú expand_opr} r r r¢ Úvisit_empty_set_op_expr" s
|
ÿ
|
ÿz#SQLCompiler.visit_empty_set_op_exprc K s t d| jj d S )Nz3Dialect '%s' does not support empty set expression.r2 )rß Z element_typesr} r r r¢ r] 4 s
|
ÿÿz SQLCompiler.visit_empty_set_exprc sL j j¡}|sP|jr<jjr$dnd j jj¡ }n j gj¡}nô|js~|jr¼t |d t
|
j r¼t |d t t fs¼|jrtdjjrdndd fddt|D ¡ }n|r*j}| |¡}|rà| d¡sètd | d¡ d
|
¡}|d |d d fd d|D ¡}nd fdd|D ¡}d|fS )NúVALUES rQ r z?bind_expression() on TupleType not supported with literal_bindsr¯ c 3 s8 | ]0\}}d d fddt| jjD ¡ V qdS )r r¯ c 3 s | ]\}} ||¡V qd S rÝ rZ )r r; Z
|
param_typerÿ r r¢ r b s ÿz[SQLCompiler._literal_execute_expanding_parameter_literal_binds.<locals>.<genexpr>.<genexpr>N)r~ rL rÐ r> )r r_ r` ©rx rß r r¢ r _ s
|
÷ ÿþþzQSQLCompiler._literal_execute_expanding_parameter_literal_binds.<locals>.<genexpr>r5 ú)unexpected format for expanding parameterre r rå c 3 s& | ] }d |j¡f V qdS rf ©r[ rÐ ©r r; ©ri rj rx rß r r¢ r u s ú ýÿc 3 s | ]} | j¡V qd S rÝ rc rd ra r r¢ r s ÿr )rÐ rS rc r= Útuple_in_valuesr_ r> r^ Ú_isnullri Úcollections_abcr r ÚbytesÚ_has_bind_expressionr r~ r^ rv Úsearchry rj rk ) rß rx r3 Úbind_expression_templateÚtyp_dialect_implÚreplacement_expressionZpost_compile_patternr rm r re r¢ Ú2_literal_execute_expanding_parameter_literal_binds: s\ ÿþ ÿÿþýÿ
|
öþ
|
ÿþù
|
|
þz>SQLCompiler._literal_execute_expanding_parameter_literal_bindsc sX j r |¡S j}j |¡jr2jnjjjrZj rZfdd n fdd |sg j
|
r jj j ¡}n jgj ¡}n´j
|
sÐjr t|d tjr t|d ttfs jrÚtfddt|dD |jrüdnd d
|
fd d t|D ¡ }n0fd dt|dD d
|
fdd D ¡}|fS )Nc s j d| i ¡S ©NrÌ )Úrender_bind_castrÐ rÏ )Ú bind_templaterx rß rm r r¢ Ú_render_bindtemplate s
|
|
ýzNSQLCompiler._literal_execute_expanding_parameter.<locals>._render_bindtemplatec s d| i S rp r rÏ )rr r r¢ rs £ s r c s6 g | ].\}}t |d D ]\}}d ||f |fqqS )r r\ r] )r r_ r` ra r; rÏ r r¢ r ¸ s þzDSQLCompiler._literal_execute_expanding_parameter.<locals>.<listcomp>r r` rQ r¯ c 3 s8 | ]0\ d d fddtD ¡ V qdS )r r¯ c 3 s. | ]&\}} t | d V qdS )r N)r& )r ra r; )rs r_ ry r` r r¢ r à s ýÿzMSQLCompiler._literal_execute_expanding_parameter.<locals>.<genexpr>.<genexpr>N)r~ r^ )r )rs ry )r_ r` r¢ r À s
|
÷üþzCSQLCompiler._literal_execute_expanding_parameter.<locals>.<genexpr>c s g | ]\}}d |f |fqS )z%s_%sr )r r_ r; rÏ r r¢ r Í s ÿc 3 s | ]\}} |V qd S rÝ r r: )rs r r¢ r Ñ s )rs ro rc rÐ rS rÏ rÉ rÈ Ú_bind_typing_render_castsrq r= r_ r> r^ rg ri rh r r ri Z _is_arrayrj r^ rf r~ )rß rÌ rx r3 rc rn r )rs rr rÌ rx rß ry rm r¢ rr sd ÿ ÿþ ÿ ÿÿþý
|
|
þ
|
öþ
|
þÿz0SQLCompiler._literal_execute_expanding_parameterc
|
K s |rft |j¡rf|d k rJ|d }|j t |jj|g |j j|g ¡¡ n |j t |jj|j j¡¡ | j
|
rt |jt j rt |j t j rd|d< |p|j}| |dd ¡} | rº| ||f|S z t| }
|
W n0 tk
|
rö } zt | |¡| W 5 d } ~ X Y n X | j||
|
f||d|S d S )NÚenclosing_lateralTrs rd )Ú from_linterÚlateral_from_linter)r Z is_comparisonr r: rt r1 Úproductr r) r rÇ ri r rD r r³ r§ r6 ry rW ) rß rd rS Úeager_groupingrv rw r} ru r r r r| r r r¢ rT × sN þÿ ÿÿÿ þ ý
|
þüûzSQLCompiler.visit_binaryc K s | j |jf|S rÝ )rk Z sql_functionrO r r r¢ Ú&visit_function_as_comparison_op_binary
|
s z2SQLCompiler.visit_function_as_comparison_op_binaryc K sT | j jr,| j|jf|d | j|jf| S | j|jf|d | j|jf| S d S )Nz %% r )rZ rÙ rk r r rK r r r¢ Úvisit_mod_binary s ÿþÿÿþÿz SQLCompiler.visit_mod_binaryc K s* |j |d< | j|d| |j¡ d f|S )Nry r¸ )ry rW rà r rO r r r¢ Úvisit_custom_op_binary s
|
þýz"SQLCompiler.visit_custom_op_binaryc K s | j || |j¡d f|S r )rE rà r rO r r r¢ Ú visit_custom_op_unary_operator# s ÿÿz*SQLCompiler.visit_custom_op_unary_operatorc K s | j |d| |j¡ f|S r )rF rà r rO r r r¢ Ú visit_custom_op_unary_modifier( s ÿÿz*SQLCompiler.visit_custom_op_unary_modifierc K sf | dd¡}d|d< |j|d< |jj| fd|i|| |jj| fd|i| }|rb|rbd| }|S )NÚ
|
_in_binaryFTÚ
|
_binary_opry r )r r r r
r )rß rd r ry r} r rÜ r r r¢ rW - s0
|
ÿÿÿýÿÿÿüÿ
|
z$SQLCompiler._generate_generic_binaryc K s ||j j| f| S rÝ r ©rß rC r r} r r r¢ rE C s z,SQLCompiler._generate_generic_unary_operatorc K s |j j| f|| S rÝ r r r r r¢ rF F s z,SQLCompiler._generate_generic_unary_modifierc C s t jdtjdS )Nz'%')rÛ )r Zliteral_columnr$ Ú
|
STRINGTYPErÿ r r r¢ Ú_like_percent_literalI s z!SQLCompiler._like_percent_literalc K s d|j j| f| dS )Nzlower(r³ r rÍ r r r¢ Ú$visit_ilike_case_insensitive_operandM s z0SQLCompiler.visit_ilike_case_insensitive_operandc K s2 | ¡ }| j}| |j¡ |¡|_| j||f|S rÝ ©Ú_cloner Úconcatr Úvisit_like_op_binary©rß rd r r} Úpercentr r r¢ Úvisit_contains_op_binaryP s z$SQLCompiler.visit_contains_op_binaryc K s2 | ¡ }| j}| |j¡ |¡|_| j||f|S rÝ ©r r r r Úvisit_not_like_op_binaryr r r r¢ Ú visit_not_contains_op_binaryV s z(SQLCompiler.visit_not_contains_op_binaryc K sB | ¡ }| j}t|j|_| t|j¡ |¡|_| j||f|S rÝ ©r r r¨ r r r Úvisit_ilike_op_binaryr r r r¢ Úvisit_icontains_op_binary\ s ÿþz%SQLCompiler.visit_icontains_op_binaryc K sB | ¡ }| j}t|j|_| t|j¡ |¡|_| j||f|S rÝ ©r r r¨ r r r Úvisit_not_ilike_op_binaryr r r r¢ Ú visit_not_icontains_op_binarye s ÿþz)SQLCompiler.visit_not_icontains_op_binaryc K s, | ¡ }| j}| |j¡|_| j||f|S rÝ )r r Ú_rconcatr r r r r r¢ Úvisit_startswith_op_binaryn s z&SQLCompiler.visit_startswith_op_binaryc K s, | ¡ }| j}| |j¡|_| j||f|S rÝ )r r r r r r r r r¢ Ú visit_not_startswith_op_binaryt s z*SQLCompiler.visit_not_startswith_op_binaryc K s< | ¡ }| j}t|j|_| t|j¡|_| j||f|S rÝ )r r r¨ r r r r r r r r¢ Úvisit_istartswith_op_binaryz s
|
z'SQLCompiler.visit_istartswith_op_binaryc K s< | ¡ }| j}t|j|_| t|j¡|_| j||f|S rÝ )r r r¨ r r r r r r r r¢ Ú visit_not_istartswith_op_binary s
|
z+SQLCompiler.visit_not_istartswith_op_binaryc K s, | ¡ }| j}| |j¡|_| j||f|S rÝ r
r r r r¢ Úvisit_endswith_op_binary s z$SQLCompiler.visit_endswith_op_binaryc K s, | ¡ }| j}| |j¡|_| j||f|S rÝ r r r r r¢ Ú visit_not_endswith_op_binary s z(SQLCompiler.visit_not_endswith_op_binaryc K s< | ¡ }| j}t|j|_| t|j¡|_| j||f|S rÝ r r r r r¢ Úvisit_iendswith_op_binary s
|
z%SQLCompiler.visit_iendswith_op_binaryc K s< | ¡ }| j}t|j|_| t|j¡|_| j||f|S rÝ r r r r r¢ Ú visit_not_iendswith_op_binary s
|
z)SQLCompiler.visit_not_iendswith_op_binaryc K sL |j dd ¡}d|jj| f||jj| f|f |rFd| |tj¡ nd S )Nrå z
|
%s LIKE %sú ESCAPE rQ ©Ú modifiersr r r
r r[ r$ r ©rß rd r r} rå r r r¢ r ¢ s þÿúz SQLCompiler.visit_like_op_binaryc K sL |j dd ¡}d|jj| f||jj| f|f |rFd| |tj¡ nd S )Nrå z%s NOT LIKE %sr rQ r r¡ r r r¢ r ® s þÿúz$SQLCompiler.visit_not_like_op_binaryc K s: |t jkr*| ¡ }t|j|_t|j|_| j||f|S rÝ )r Zilike_opr r¨ r r r rK r r r¢ r ¹ s
|
|
z!SQLCompiler.visit_ilike_op_binaryc K s: |t jkr*| ¡ }t|j|_t|j|_| j||f|S rÝ )r Z not_ilike_opr r¨ r r r rK r r r¢ r  s
|
|
z%SQLCompiler.visit_not_ilike_op_binaryc K s& |j dd¡}| j||r dndf|S )Nr Fz BETWEEN SYMMETRIC z BETWEEN ©r r rW ©rß rd r r} r r r r¢ Úvisit_between_op_binaryË s
|
ÿÿz#SQLCompiler.visit_between_op_binaryc K s& |j dd¡}| j||r dndf|S )Nr Fz NOT BETWEEN SYMMETRIC z NOT BETWEEN r¢ r£ r r r¢ Úvisit_not_between_op_binaryÑ s
|
þýz'SQLCompiler.visit_not_between_op_binaryc K s t d| jj ¡d S ©Nz/%s dialect does not support regular expressions©r6 rK rc rÌ rK r r r¢ Ú visit_regexp_match_op_binaryÙ s
|
ÿÿz(SQLCompiler.visit_regexp_match_op_binaryc K s t d| jj ¡d S r¦ r§ rK r r r¢ Ú visit_not_regexp_match_op_binaryß s
|
ÿÿz,SQLCompiler.visit_not_regexp_match_op_binaryc K s t d| jj ¡d S )Nz;%s dialect does not support regular expression replacementsr§ rK r r r¢ Ú visit_regexp_replace_op_binaryå s
|
ÿÿz*SQLCompiler.visit_regexp_replace_op_binaryc K s® |s®|j | j¡}|jr®| |¡} | j| fd||o8|j ||d|}
|
|jrªt d|
|
¡} | sft dd|
|
d¡|
|
d¡|
|
d¡f }
|
|rª| j |fd|
|
d |} d
|
| S |
|
S |sÒ|pÄ|j pÄ|oÄ| j }|pÎ|j} nd } |r| j |fd di|} |jrd
|
| } | S | |¡}|| jkrØ| j| }||k rØ|js@|jrp|j |j¡sp|j |j¡spt d | ¡nh|j|jkrt d|f ¡nH|js |jrØ|jr¼|jr¼t d¡n t d|j d|j d¡| | j|j< | j|< | j}|r4|\}}|jD ]*}|j|kr||j }|| |¡ q|jrBd| _| r||rTd| _ |rl| j |hO _ n| j |hO _ | j |f| |j|j d|} |jrªd
|
| } | S )NT)Úskip_bind_expressionr¦ Ú literal_bindsrs Úrender_postcompilez&^(.*)\(__\[POSTCOMPILE_(\S+?)\]\)(.*)$rb z$(__[POSTCOMPILE_%s~~%s~~REPL~~%s~~])r5 r rå )r¦ rl r Fr¦ zIBind parameter '%s' conflicts with unique bind parameter of the same namea Can'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Ú expandingÚbindparam_type) rÐ Ú dialect_implrc rj Úbind_expressionrk r¯ rä Úmatchrj ry rq rs rÇ Ú_truncate_bindparamrà r r¢ Ú intersectionZ _cloned_setr6 rK Z_is_crudrþ rÚ r Z
|
isoutparamÚhas_out_parametersrÐ r× rØ rÞ )rß r? r¦ r¬ r« rs r r Úimplr² Úwrappedr r r® rÌ ÚexistingrP r rÿ ZbpÚcbr r r¢ Úvisit_bindparamë sî
|
|
ÿ
|
úù ÿ ýÿýüÿý ÿÿÿ
|
|
|
ÿÿÿþÿû ÿÿûÿÿ ÿ
|
|
|
ÿüûzSQLCompiler.visit_bindparamc C s
|
t d S rÝ r )rß rÛ Z
|
dbapi_typeÚsqltextr r r¢ rq s z SQLCompiler.render_bind_castc
|
K s |t k r|}nZ|jd krb|jd krb| dd ¡}|rR|tjtjfkrRt d|j f¡ | j
|
t j f|S |j }|jr| j}||||d\}} | S | ||j¡S d S )Nr zBound parameter '%s' rendering literal NULL in a SQL expression; comparisons to NULL should not use operators outside of 'is' or 'is not')rl )r- r; rN r r Úis_Úis_notr% Z warn_limitedrþ rk r$ râ rO r¯ ro r[ rÐ )
|
rß r? r[ rl r} r; ÚopZleepry rz r r r¢ rq s( üý
|
z$SQLCompiler.render_literal_bindparamc
|
C s | | j¡}|r`z
|
||W S tk
|
r\ } z$t dt |¡ d| d¡|W 5 d}~X Y q|X n t dt |¡ d| ¡dS )a Render 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.
|
|
z Could not render literal value "z" with datatype z); see parent stack trace for more detail.Nz:No literal value renderer is available for literal value ")Z_cached_literal_processorrc r r6 rK Úsql_utilZ_repr_single_value)rß r; rÛ Ú processorÚer r r¢ r[ ³ s
|
ÿú ÿz SQLCompiler.render_literal_valuec C s@ || j kr| j | S |j}t|tjr2| d|¡}|| j |< |S )Nr? )rÄ rþ ri r rC r² )rß r? r7 r r r¢ r´ Ò s
|
|
|
z SQLCompiler._truncate_bindparamrC )Ú ident_classrÌ rÜ c C s ||f| j kr | j ||f S | | j¡}t|| jd kr| j |d¡}|dt| jd d
d t|dd
}|d | j|< n|}|| j ||f< |S )Né r r r° r5 ) rú Ú apply_maprù r& r÷ rû r ÚmaxÚhex)rß rà rÌ ZanonnameÚcounterZ truncnamer r r¢ r² ß s ÿþÿz!SQLCompiler._truncated_identifier)rÌ rÜ c C s
|
|| j S rÝ ©rù ©rß rÌ r r r¢ Ú
|
_anonymizeô s zSQLCompiler._anonymizezOptional[TypeEngine[Any]]zOptional[Set[str]]) rÌ r® r¯ Ú escaped_fromr° Úaccumulate_bind_namesÚvisited_bindparamr} rÜ c s |d k r| |¡ |d k r$| |¡ |sR j |¡rR j fdd|¡} |}| }|rh j ||i¡ _|r¨d| }
|
|r||
|
S |d k r¤| j¡} | j r¤
|
|| |
|
¡}
|
|
|
S j t j krÄ jd|i }
|
n jd|i }
|
|d k r jjr| j¡} | j
|
r
|
|| |
|
¡}
|
|
|
S )Nc s j | d¡ S )Nr )r» ry r, rÿ r r¢ r/ r0 z.SQLCompiler.bindparam_string.<locals>.<lambda>z__[POSTCOMPILE_%s]rÌ )Úaddr rº rk r rÙ r rS rc Zrender_literal_castrq rS r+ r, rÉ rÈ rt ) rß rÌ r® r¯ rÌ r° rÍ rÎ r} Únew_namer Z type_implr rÿ r¢ rÞ ÷ sL
|
|
|
þÿÿ ÿþ z SQLCompiler.bindparam_stringc C sF | ¡ }| dd ¡ t|j|jD ] \}}|j| fd|i| q"d S )NÚcte_opts)Úcopyr< rL rê Z_independent_ctes_optsr
)rß Ústmtr} Zlocal_kwÚcteÚoptr r r¢ rë < s ÿ z&SQLCompiler._dispatch_independent_ctesrL zOptional[_FromHintsType]z Optional[CTE]zOptional[FromLinter]zselectable._CTEOpts) rÔ r ÚashintÚ fromhintsÚ visiting_cterv rÑ r rÜ c sÞ ¡ } | jkst||d< |j}
|
t|
|
tjr< d|
|
¡}
|
d} d} | ¡ } |j pV|j }| j
|
krð j
|
| \}}}||
|
ks~t||
|
f} j | }|j rî|j r¦t d¡||
|
f}|r¼t jnd}||
|
f }} j |= | j |< ||f j
|
| < n6|rþt jnd}||
|
f}| j kr" j | }nd }|d k rÌ||k} ||jksN||krTd} nx||jkr| |= | ¡ }|| ks|t||kst j
|
|= n8|jd k s¬|jd k r¾| |¡r¾d} nt d|
|
¡|sÜ| sÜd S |jd k r|j}|jj}t|tjr d|¡}n|}d }| r\| j |< ||f j
|
| < | jkrT j|f| |s\|| kr\|jrrd _ j ||
|
¡}|jrÂ|j}dd | d¡D }|d
|
d fd d |D ¡ 7 }| dd¡dksØt jsø|jj fd|i|S j ||j f|} |jj fddi|} |d| | f 7 }|j rT|d j ||j f| 7 }|| |< |rÚ|rr|
|
|j!|< | s| r j ||
|
¡S |rÌ j ||¡} j "|
|
¡rº j #|
|
¡}
|
| $|
|
¡7 }|S j ||
|
¡S d S )NrØ rÀ TFz6CTE is stated as 'nest_here' in more than one locationr z5Multiple, unrelated CTEs found with the same name: %rc S s" g | ]\}}}}}|s|p |qS r r )r r° Ú
|
proxy_nameÚfallback_label_namer Úrepeatedr r r¢ r Ê s øz)SQLCompiler.visit_cte.<locals>.<listcomp>r r¯ c 3 s | ]} j j| jd V qdS )rÉ N)rZ Úformat_label_namerù )r Úidentrÿ r r¢ r Û s
|
ý ÿz(SQLCompiler.visit_cte.<locals>.<genexpr>Úsubqueryr z AS %s
|
(%s)r¸ )%r rÞ rj rÌ ri r rC r² Ú_get_reference_cteÚnestingrà rß r6 rK r& rF Z _restatesZ _is_clone_ofÚcompareZ
|
_cte_aliasÚ visit_cteÚ recursiverá rZ Ú format_aliasr{ Ú _generate_columns_plus_namesr~ r r
Ú_generate_prefixesÚ _prefixesÚ _suffixesr9 Ú_requires_quotesrÄ Úget_render_as_alias_suffix) rß rÔ r rÖ r× rØ rv rÑ r Z self_ctesÚcte_nameZ
|
is_new_cteZ embedded_in_current_named_cteZ_reference_cterà Ú cte_levelr° Zexisting_cte_optsZcte_level_nameZ existing_cteZold_level_nameZnew_level_nameZexisting_cte_reference_cteZ pre_alias_cteZcte_pre_alias_namerÜ Z
|
col_sourceZ
|
recur_colsÚprefixesr| r rÿ r¢ râ D s
|
ÿ
|
|
ÿ
|
ÿ
|
|
ÿþýÿÿ ÿ
|
ÿ ôüÿ ÿÿÿ ÿÿÿÿÿ ÿÿ
|
zSQLCompiler.visit_ctec K s4 |j rd |d< |jr"| j|f|S | j|f|S d S )Nrv )Zjoins_implicitlyÚ _is_lateralÚ visit_lateralÚ visit_aliasrÍ r r r¢ Úvisit_table_valued_alias s
|
z$SQLCompiler.visit_table_valued_aliasc K s | j |f|S rÝ )rÊ rÍ r r r¢ Úvisit_table_valued_column s z%SQLCompiler.visit_table_valued_columnc
|
s¢ |r:dkr j st d< | r:dkr:dkr:| d< |d k r|j kr jjf||||| d} |r|sz|rd| f } | S }d< |s|rÀt jtjrº d j¡} n j} |rÒj
|
| ¡S |r| ræ| | j < jjfd|d} |rd| f } | j
|
| ¡¡ } j r^ jr^| dd fd
|
d jD ¡ 7 } |r |kr | | |¡} | S jjfd |iS d S ) Nru rw )r rÖ Úiscrudr× ÚlateralÚenclosing_aliasr rõ rÀ T)r rô r¯ c 3 sB | ]:}d j |j¡ jr2djjj|jf ndf V qdS )z%s%sú %srQ N)rZ rÄ rÌ Z_render_derived_w_typesrc rÓ rk rÐ r ©rÀ r rß r r¢ r b s ö üÿÿÿùÿz*SQLCompiler.visit_alias.<locals>.<genexpr>rô )rî rj r{ r
ri rÌ r rC r² rZ rä r9 rê Z_supports_derived_columnsZ_render_derivedr~ r Úformat_from_hint_text)rß rÀ r rÖ ró r× rÞ rô rõ rv r r| Z
|
alias_namer r r÷ r¢ rð s
|
ÿþýÿùø
|
|
|
ÿ ÿÿ
|
ÿ õÿ ÿÿÿÿzSQLCompiler.visit_aliasc K s d|d< | j |f|S )NTrÞ ©rð )rß rÞ r} r r r¢ Úvisit_subquery} s zSQLCompiler.visit_subqueryc K s d|d< d| j |f| S )NTrô z
|
LATERAL %srù )rß Zlateral_r} r r r¢ rï s zSQLCompiler.visit_lateralc K sR d| j |fddi|| ¡ j| f|f }|jd k rN|d|jj| f| 7 }|S )Nz%s TABLESAMPLE %sr Tz REPEATABLE (%s))rð Z _get_methodr
Úseed)rß Z tablesampler r} rÜ r r r¢ Úvisit_tablesample
s þ
|
ÿz SQLCompiler.visit_tablesamplec s6 d j¡ d fdd jD ¡}d| S )Nr¬ r¯ c 3 s8 | ]0}|D ]&}j tj|d ji ¡ fV q
|
qdS )r> N)rk r r Z _column_typesr¥ )r ÚchunkÚelem©r{ r} rß r r¢ r s ùÿÿÿüz-SQLCompiler._render_values.<locals>.<genexpr>r` )Ú
|
setdefaultr¬ r~ Ú_data)rß r{ r} Ztuplesr rÿ r¢ Ú_render_values s
|
ù
|
zSQLCompiler._render_valuesc s¸ j |f }|jrd }n$t|jtjr8 d|j¡}n|j}|jrJd}nd}|r´|rl|d k rb|nd|j|< |r¨d|| j
|
|¡¡d fdd|j D ¡f }n d ||f }|S )
|
Nr3 zLATERAL rQ z(unnamed VALUES element)z %s(%s)%s (%s)r¯ c 3 s$ | ] }|j fd di V qdS )r¾ FNr r rÿ r r¢ r » s ýÿÿÿz+SQLCompiler.visit_values.<locals>.<genexpr>z%s(%s))r Z_unnamedri rÌ r rC r² rî r9 rê rZ rÄ r~ Úcolumns)rß r{ r rv r} r rÌ rô r rÿ r¢ Ú visit_values s0 ÿüû zSQLCompiler.visit_valuesc K s d| j |f| dS r )r rÍ r r r¢ Úvisit_scalar_valuesÇ s z SQLCompiler.visit_scalar_valuesc C s d| S )Nr° r )rß Zalias_name_textr r r¢ rê Ê s z&SQLCompiler.get_render_as_alias_suffixrÏ rÙ rÚ c C sF |d ks|dkr d| _ d| _|jr,t d¡| j t||||¡ d S )NÚ*FTzxMost backends don't support SELECTing from a tuple() object. If this is an ORM query, consider using the Bundle object.)rÍ rÌ r= r6 rK rU r rÊ rÞ r r r¢ rì Í s ÿ ÿz SQLCompiler._add_to_result_mapc K s" | j d||d|dkri n|f|S )aL Render 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)rß rÓ rg rñ Úcolumn_clause_argsr} r r r¢ Ú_label_returning_columná s ûúz#SQLCompiler._label_returning_columnc sÌ j | j¡} | jr(| s |r(| ¡}n}|rh| j}|
|
rL| fdd}ql|k rl| fdd}nd}| sxtdttj rª|k r¢t
|
|j j fd}n|}n|rÔ|dk s¾tdt
|
|||j fd}nÚ|k râd}n~ttjr |oj ojdk }nTttjr d }n@ttjr<jp8|}n$ttjs\jdkr\d}nd }|rª|s||
|
rvtj}t|tjst |¡n|}t
|
|||fd}n|}|j| || d
|
|j| f|S ) z.produce labeled columns present in a select().c s | |d| d S )Nr r ©rË rÌ rÎ rÛ )rì r r¢ r¶ s z;SQLCompiler._label_select_column.<locals>.add_to_result_mapc s | |f| | d S rÝ r r ©rì rg r r¢ r¶ $ s ÿNzX_label_select_column is only relevant within the columns clause of a SELECT or RETURNING)r z*proxy_name is required if 'name' is passedTF)r¦ r¶ r¾ )rÐ r± rc Z_has_column_expressionZcolumn_expressionrì rj ri r rG r rÌ r{ r rE rÁ r Z
|
TextClauseZUnaryExpressionZwraps_column_expressionZ NamedColumnZ_non_anon_labelZ_anon_name_labelrC rt r
)rß r rg rñ r r rÌ rÙ rÚ r¦ Úcolumn_is_repeatedÚneed_column_expressionsr¾ r· Zcol_exprr¶ Z result_exprZrender_with_labelr r r¢ r ö s¢ ÿÿ ÿ ÿÿþùýÿý
|
ü ô
|
ÿÿû ÿýz SQLCompiler._label_select_columnc C s | ||¡}|r |d| 7 }|S r )Úget_from_hint_text)rß r¼ r Úhintró Úhinttextr r r¢ rø s z!SQLCompiler.format_from_hint_textc C s d S rÝ r )rß Zbyfromsr r r¢ Úget_select_hint_text s z SQLCompiler.get_select_hint_textc C s d S rÝ r ©rß r rÜ r r r¢ r £ s z SQLCompiler.get_from_hint_textc C s d S rÝ r r r r r¢ Úget_crud_hint_text¦ s z SQLCompiler.get_crud_hint_textc C s
|
d |¡S r r )rß Z
|
hint_textsr r r¢ Úget_statement_hint_text© s z#SQLCompiler.get_statement_hint_textrë ré ré rè c K sh | j }|r| jn| j d }| || ¡}|d }|d } |rV|sV|j| | ¡dd}
|
n|j|| d}
|
|
|
S )Nr ré rè r ©Zexplicit_correlate_fromsZimplicit_correlate_froms)rF ré r6 Ú_get_display_fromsÚ
|
difference) rß Ú select_stmtr rô r} rï r rì ré rè r9 r r r¢ Ú_display_froms_for_select³ s" ÿüþz%SQLCompiler._display_froms_for_selectÚtranslate_select_structurec
|
s¼ |d kst dd| d< jf| }
|
|
|
j| d< |
|
jj } | rPjsP|
|
_|d k pZ|} jr¢jfd i| } | k r¢|
|
}}| jf| }
|
|
|
j| r¬jnjd }| pÐ| dd¡pÐ| dd¡ |rÞdsðd | krð| d = |
|
| ||¡}|
|
¡ ddd
|
¡ d }j rJ ¡\}}|rN||d 7 }nd }jrb | ¡ jr|jjf| 7 }|jf| 7 }d d fdd|
|
jD D }r|d k rttdd |
|
jD dd |jD fddjD _ ||
|
|||| | ¡}jrRfddjD }|rR|d |¡ 7 }jr| rf| r| svtjnd }j |d| }j r¬|d jj f| 7 }j d¡ |S )NzpSQLAlchemy 1.4 requires use of the translate_select_structure hook for structural translations of SELECT objectsFr¦ r¿ r r rï rî r¶ )r± r¦ zSELECT r¸ c S s g | ]}|d k r|qS rÝ r r r r r¢ r D s êz,SQLCompiler.visit_select.<locals>.<listcomp>c s4 g | ],\}}}}}j | ||||d
|
qS ))rÌ rÙ rÚ r r r ©r rÌ rÙ rÚ rg rÛ )r r r rñ r rß r r¢ r F s$ ïöc S s g | ]\}}}}}|qS r r ©r rþ rÙ rÚ rÌ rÛ r r r¢ r d s úc S s g | ]\}}}}}|qS r r r r r r¢ r n s úc s4 g | ],\}}}}t ||t fd d|D |qS )c 3 s | ]} ||¡V qd S rÝ r )r Úo©Ú translater r¢ r } s z6SQLCompiler.visit_select.<locals>.<listcomp>.<genexpr>)rÊ r )r rþ rÌ r rÛ r r r¢ r { s
|
ý ÿc s$ g | ] \}}|d j jfkr|qS ©r ©rc rÌ )r Ú dialect_nameÚhtrÿ r r¢ r s þrç ) rj r6 Z_ambiguous_table_name_maprõ rF rì r ré r Ú_setup_select_stackrÒ rt Ú_hintsÚ_setup_select_hintsrê rë rç ræ Úget_select_precolumnsÚcolumns_plus_namesrJ rL rU Ú_compose_select_bodyZ_statement_hintsr rÞ r& rí rè r< )rß r r Ú insert_intor× rî Zselect_wraps_forrô rv r rì rï Zis_embedded_selectZnew_select_stmtZcompile_state_wraps_forr r9 rÜ Ú hint_textÚbyfromÚ inner_columnsZ per_dialectrè r )r r r rñ r rß r r¢ Ú visit_select× sö
|
ÿ ÿÿþÿ
|
ÿÿÿ ÿÿ
|
ÿ
|
ý ÿÿ ÿÿíþø
|
øõÿ
|
üø
|
þ ÿÿ zSQLCompiler.visit_selectrñ zTuple[str, _FromHintsType])r rÜ c s* fdd|j ¡ D } |¡}||fS )Nc s< i | ]4\\}}}|d j jfkr||d|j ddi qS )r rÌ T)rÖ ©rc rÌ r
)r rJ rc r rÿ r r¢ rî § s
|
ý ÿz3SQLCompiler._setup_select_hints.<locals>.<dictcomp>)r& r% r )rß r r- r, r rÿ r¢ r' ¤ s
|
|
ý
|
z SQLCompiler._setup_select_hintsc C sÆ |d }|d }|dkr"||d< nD|rf|d } t | j}
|
t |j|
|
krft dd|
|
|d t |jf ¡|r|s|j| |¡dd} n|j||d} tt| } | |¡} | | ||d }| j
|
|¡ | S )
|
Nré rè r rð z}All selectables passed to CompoundSelect must have identical numbers of columns; select #%d has %d columns, select #%d has %dr r r )rè ré r# rì ) r& r r) r6 rK r r r r) r rF r )rß r rì r r rô rî ré rè rð Znumcolsr9 Znew_correlate_fromsZall_correlate_fromsrð r r r¢ r% ° sJ
|
|
üüÿ ÿüþ
|
ü z SQLCompiler._setup_select_stackc s |d |¡7 }jt@ r:ti t jt@ } |rB_nd d} |sN| ¡ }|r¦|d7 }|jr|d fdd|D ¡7 }q²|d fdd|D ¡7 }n | ¡ 7 }|j
|
ràj |j
|
fdi}
|
|
|
rà|d|
|
7 }| rød k sðt ¡ |jr|j|f7 }|jr<j |jf}
|
|
|
r<|d |
|
7 }|jrV|j|f7 }|jrp|j|f7 }|jd k r|j|f7 }|S )
|
Nr¯ Fz
|
FROM c s& g | ] }|j fd dqS )T)r r× rv r ©r Úf©r- rv r rß r r¢ r s ùÿüûz4SQLCompiler._compose_select_body.<locals>.<listcomp>c s$ g | ] }|j fd dqS )T©r rv r r1 )rv r rß r r¢ r s úÿýürv z
|
WHERE z
|
HAVING )r~ rê r1 r4 r r2 rv Úrstripr& r Ú_where_criteriar rj rL Ú_group_by_clausesr9 Z_having_criteriaÚ_order_by_clausesr: r; r< Z_for_update_argÚfor_update_clause) rß rÜ r rì r. r9 r- rï r Ú warn_lintingÚtr r3 r¢ r* ä sl
|
|
øÿ ùÿ ÿÿÿ ÿÿ z SQLCompiler._compose_select_bodyc s* d fdd|D ¡}|r&|d7 }|S )Nr¸ c 3 s4 | ],\}}|d ks |j jkr|jf V qdS ))Nr Nr0 )r Úprefixr# rÿ r r¢ r D s þz1SQLCompiler._generate_prefixes.<locals>.<genexpr>r )rß rÓ rí r} r r rÿ r¢ ræ C s þz SQLCompiler._generate_prefixesc C s0 | j s
|
dS |r|dkrt ¡ }t| j ¡ D ]T}| j| ¡ \}}}|jpN|j}||kpf|of||d k} |r,| srq,| j | ||< q,n| j }|sdS tdd |D }
|
| |
|
¡d } | d
|
dd | ¡ D ¡7 } | d7 } |r,|dkr,t| ¡ D ]8}| j| ¡ \}}}| j |= | j ||f= | j| ¡ = qò| 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.
|
rQ r c S s g | ]
|
}|j qS r )rã )r rÔ r r r¢ r q s z2SQLCompiler._render_cte_clause.<locals>.<listcomp>r¸ ú,
|
c S s g | ]}|qS r r )r Útxtr r r¢ r t s z
|
) rÞ r% r r Úkeysrà rß rà r` Úget_cte_preambler~ r3 rß ) rß rè r5 rÞ rÔ rì rë rÑ rà Zis_rendered_levelrá Zcte_textr r r¢ rí M s> ÿ
|
ÿ ÿ
|
z SQLCompiler._render_cte_clausec C s |rdS dS d S )NzWITH RECURSIVEZWITHr )rß rã r r r¢ r@ s z SQLCompiler.get_cte_preamblec K s" |j rtjddd |jr dS dS )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.4©Úversionr± rQ )Z _distinct_onr% Úwarn_deprecatedZ _distinct©rß r r} r r r¢ r( s úz!SQLCompiler.get_select_precolumnsc K s, | j |jttj f|}|r$d| S dS dS )z5allow dialects to customize how GROUP BY is rendered.z
|
GROUP BY rQ N)r r7 r³ r Úcomma_op)rß r r} Zgroup_byr r r¢ r9 s ÿÿzSQLCompiler.group_by_clausec K s, | j |jttj f|}|r$d| S dS dS )z5allow dialects to customize how ORDER BY is rendered.z
|
ORDER BY rQ N)r r8 r³ r rE )rß r r} r r r r¢ r: £ s ÿÿzSQLCompiler.order_by_clausec K s dS )Nz FOR UPDATEr rD r r r¢ r9 ¯ s z SQLCompiler.for_update_clauserA ú Sequence[ColumnElement[Any]]©rÓ Úreturning_colsrñ r} rÜ c s6 fddj dt |¡dD }dd |¡ S )Nc s6 g | ].\}}}}}j |f||||d qS ))rÚ r rÌ rÙ )r
|
r ©r} rñ rß rÓ r r¢ r » s$ ñýùøz0SQLCompiler.returning_clause.<locals>.<listcomp>T)Úcolsú
|
RETURNING r¯ )rå r Ú_select_iterablesr~ ©rß rÓ rH rñ r} r r rI r¢ Úreturning_clause² s ÿïz SQLCompiler.returning_clausec K s^ d}|j d k r&|d| j|j f| 7 }|jd k rZ|j d krB|d7 }|d| j|jf| 7 }|S )NrQ z
|
LIMIT z
|
|
LIMIT -1z OFFSET )Z _limit_clauserk Ú_offset_clause)rß r r} rÜ r r r¢ rA Ó s
|
|
|
zSQLCompiler.limit_clausec
|
K sÈ |d kr|j }|j}n
|
ddd}d}|jd k rf|j}|rJ| |¡rJ| ¡ }| j|f|} |d| 7 }n |rr|d7 }|d k rÄ|r| |¡r| ¡ }|d| j|f||d r¬dnd|d rºd
|
nd f 7 }|S ) NF)r Ú with_tiesrQ z
|
OFFSET %s ROWSz
|
OFFSET 0 ROWSz
|
FETCH FIRST %s%s ROWS %sr z PERCENTrP z WITH TIESZONLY)r? Z_fetch_clause_optionsrO Z_simple_int_clauseZrender_literal_executerk )
|
rß r r@ Zrequire_offsetZ"use_literal_execute_for_simple_intr} Zfetch_clause_optionsrÜ Z offset_clauseZ
|
offset_strr r r¢ r@ Ý s8
|
|
ÿþÿþ ýzSQLCompiler.fetch_clausec K s |r|j |j|< |s|rº| j |¡}
|
|rL|
|
rL| j |
|
¡d | j |j¡ } nJ| j |j¡} |
|
s|r|j|kr| d||j ¡} | | | j d | ¡¡ } |r¶||kr¶|
|
| ||| |¡} | S dS d S )Nrµ rÀ rQ ) Úfullnamer9 rZ rÅ rÆ rÄ rÌ r² rê rä rø ) rß r r ró rÖ r× Ú
|
use_schemarv r¿ r rÉ r Z anon_namer r r¢ Ú visit_table sD
|
ÿ þÿÿþý ÿ ÿ ÿzSQLCompiler.visit_tablec K s |r |j t |jj|jj¡¡ |jr,d}n|jr8d}nd}|jj | fd|d|| |jj | fd|d| d |j
|
j | fd|i| S )Nz FULL OUTER JOIN z LEFT OUTER JOIN z JOIN Tr4 z ON rv ) r: rt r1 rx r r) r rx Zisouterr
Zonclause)rß r~ r rv r Z join_typer r r¢ Ú
|
visit_join6 sT ÿÿÿ ÿÿýÿ ÿÿüù ÿÿÿ÷ÿzSQLCompiler.visit_joinc sB fdd|j ¡ D }|j|kr: ||j||j d¡}||fS )Nc s* i | ]"\\}}}|d j jfkr||qS r! r" )r r rc r, rÿ r r¢ rî T s
|
þ z1SQLCompiler._setup_crud_hints.<locals>.<dictcomp>T)r& r% r rø )rß rÓ Ú
|
table_textÚ dialect_hintsr rÿ r¢ Ú_setup_crud_hintsS s
|
þ
|
ÿz SQLCompiler._setup_crud_hintsrI r )r rÜ c C s~ | j j}|j}|j}|dkr dS |jr8| j |jd¡}n| j |jd¡}||@ rT|S |j rzt
|
d|d d| j j d¡dS )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.
|
|
Nr zColumn 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.) rc Ú"insertmanyvalues_implicit_sentinelZ _sentinel_column_characteristicsr Z
|
is_autoincÚ _sentinel_col_autoinc_lookupr Zdefault_characterizationÚ _sentinel_col_non_autoinc_lookupZ is_explicitr6 r rÌ )rß r Z sentinel_optsZsentinel_characteristicsZ sent_colsZbitmaskr r r¢ Ú _get_sentinel_column_for_table s* ÿ ÿÿz*SQLCompiler._get_sentinel_column_for_tablerW r r z Iterator[_InsertManyValuesBatch])rõ rö Úgeneric_setinputsizesr r rÜ c * # sÔ
|
j }|d k stt }|jr2
|
jjs2d}d} n4
|
jjrT|r^
|
jr^|jd ksT|j r^d}d} nd}d} |r¤t
|
t d dD ]$\}
|
t |g||
|
||| V qzd S d|j d} | | d¡}
|
jj} | røt
|
j} t|j}| | }t|| | | }t }d }d}
|
|| || r dnd }|j}|d k s6td
|
jsà
|
jrV
|
jni t d }
|
fd d
|
|jrd }nd }dd fdd|D ¡ | d}| fdd|D ¡} fdd| |¡D }d nØd }t }i }|jrd|j dnd|j dt |jD ]} |d ¡ q r
|
j }|d k sPt fddt
|
|D }t|t |d t| kst
|
j r¸t
|
j!¡} t "| dd¡|rÐt d|d|
} g |d|
< rdd fd dt#t| D D }
|
jr,|j$} | t| d kr4d } } | }!n4| d d
} | d d
} fd d| D }!|jrd fd dt
|
| D ¡d d!
}"nt| d d!
}"
|
j r| dkr| rÆtd }#| t| |# }$t%
|
fd"dt#|#|$D }%|"|% }"| d|"¡}&t%t&j' (|!¡}'| |' | }'n~g }(| )¡ }'t
|
| D ]V\| d#t*¡})|jrp|) d$t*¡})|( +|)¡ |' fd%d|D ¡ q@| dd |(¡¡}&t |&|'|| ||
|
||d V |
|
d7 }
|
q¸d S )&NTFr r r² r³ Z__EXECMANY_TOKEN__r c s@ | D ]6} ||¡}| jd|i jd| di ¡}q|S )NrÌ Z__EXECMANY_INDEX__)r rÚ rÈ )r? Ú formattedrþ )rÙ rß r r¢ Úapply_placeholders$ s ÿþzISQLCompiler._deliver_insertmanyvalues_batches.<locals>.apply_placeholdersz, _IMV_VALUES_COUNTERrQ r¯ c 3 s | ]\}}}} ||V qd S rÝ r )r r° r] Ú bind_keys)r^ r r¢ r 2 s
|
ÿz@SQLCompiler._deliver_insertmanyvalues_batches.<locals>.<genexpr>c 3 s, | ]$\}}}}|D ]} ||¡V qqd S rÝ r )r r° r_ rþ )rÙ r r¢ r 7 s
|
þc s i | ]}| d | qS )r r rý rü r r¢ rî < s ÿ zASQLCompiler._deliver_insertmanyvalues_batches.<locals>.<dictcomp>z, _IMV_VALUES_COUNTER), z), rå c s h | ]\}}| kr|qS r r )r r rÌ )Úall_names_we_will_expandr r¢ r£ Y s þz@SQLCompiler._deliver_insertmanyvalues_batches.<locals>.<setcomp>z\d+r rØ c S s g | ]\}}}|||fqS r r )r Znew_keyÚlen_rT r r r¢ r s s ÿzASQLCompiler._deliver_insertmanyvalues_batches.<locals>.<listcomp>c 3 s2 | ]*} D ] \}}}| d | ||fV q
|
qdS )r° Nr )r r8 rþ ra rT )r\ r r¢ r u s þr c 3 s | ]}|
V qd S rÝ r rì )Úexpand_pos_lower_indexÚexpand_pos_upper_indexr r¢ r s ÿc 3 s" | ]\}} d t|¡V qdS )Ú_IMV_VALUES_COUNTERN)rÚ r ©r r_ r° )Úexecutemany_values_w_commar r¢ r s
|
ý ÿéþÿÿÿc 3 s | ]} j | V qd S rÝ rp ©r r_ rÿ r r¢ r « s ÿZEXECMANY_INDEX__rd c s i | ]}| d | qS )Ú__r rý )r_ Úparamr r¢ rî Í s ),rÕ rj r& r rc Úsupports_default_metavalueÚsupports_multivalues_insertrU r r r^ r r r rÚ Z insertmanyvalues_max_parametersrÄ r
|
Úminr rò rÙ r r r~ rµ r rt rú rÆ rÏ rä rå rÊ r Úranger r r1 r2 Ú from_iterablerÒ r r )*rß rõ rö r\ r r rB Z lenparamsZuse_row_at_a_timeZ
|
downgradedr Zexecutemany_valuesZ
|
max_paramsZtotal_num_of_paramsZnum_params_per_batchZnum_params_outside_of_batchZbatchesr r r
|
Zall_keysZimv_values_counterZformatted_values_clauseZkeys_to_replaceZbase_parametersrþ rú Zall_expand_positionsÚescapedr Znum_ins_paramsZextra_params_leftZextra_params_rightZbatch_iteratorZexpanded_values_stringrC rr r r r Zreplaced_values_clausesZfmvr ) r` r^ rÙ rf rb rc r\ r_ rj rö rß r¢ Ú!_deliver_insertmanyvalues_batches½ sz ÿþýý ÿ ÷
|
|
ÿÿýÿ
|
þýþ
|
þ ÿ
|
|
þ ÿÿ ÿ
|
|
þþ
|
þüÿù
|
|
ÿþ
|
|
þ ÿ
|
ÿÿþÿ ÿ
|
ÿþ÷ z-SQLCompiler._deliver_insertmanyvalues_batchesc s° |j | f|}|j} j }|r@d _ js4| _ js@| _ j t t |d¡ d}d } jrvd|k}|svg }t j
|
|||fd|i|} jrÎ|d k rÎt |} j rÎ j d k rÈ j |7 _ n| _ |j} | s
|
jjs
|
jjs
|
jjs
|
t d jj ¡|jrZ jjs0t d jj ¡n" js@|jrR|jrRt d¡|j} n|j} j}
|
jj} d } |j r| j ||j f|7 } | d
|
7 } |
|
|j ¡} |j r¼ !|| ¡\}} |j"rÐ #||¡ | | 7 } | sä| s | d d $d d | D ¡ 7 } |j%}d }d }d} jp |j}|r|j&}|d k râ|s@t'dd | D }g }|D ]F}||krnd } q (|¡}||| krd } q| |¡ qV|d krÒ jj)t*j+@ r¾d}n|d j,rÒt'dt-|t-| } j.|||d} j/r | d| 7 } nd }|j0d k r j1 jd d fddi|} j2rz jj3rz|sZt jnd }| d j4|dd|f 7 } n | d| 7 } n| sä| rä| d7 } |r t5d jj6t7d | ||j|j8d k ||rÔt |nd|d _9n<|jr| d d $d d |j:D ¡f 7 } nd $d!d t7d | D ¡}|r|r¾ jj)t*j;@ r¾|j<s¾d} jj)t*j=@ } d $d"d t>| D ¡} | rd $ fd#d t>| D ¡} n| } | d$| d%| d&| d'7 } nd}| d(| d)7 } t5d|t7d | ||j|j8d k ||rþt |nd|||d* _9n| d(| d)7 } |j8d k rN j1|j8f|} | rN| d| 7 } |rh j/sh| d| 7 } j2r jj3s |st jnd } j4|dd| } j ?d¡ | S )+NTræ r rØ rÎ zWThe '%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)r¯ c S s g | ]\}}}}|qS r r )r r° rl r r r¢ r V s
|
z,SQLCompiler.visit_insert.<locals>.<listcomp>Fc S s i | ]\}}}}||qS r r )r r r° Z param_namesr r r¢ rî p s
|
ÿ z,SQLCompiler.visit_insert.<locals>.<dictcomp>zTsentinel selection rules should have prevented us from getting here for this dialect©rñ r¸ r rò r+ z %s%sr4 rö z DEFAULT VALUESr )r r r r r z
|
VALUES %sc s s& | ] }d d dd |D ¡ V qdS )r r¯ c s s | ]\}}}}|V qd S rÝ r ©r r° r; r r r¢ r Ú s
|
z5SQLCompiler.visit_insert.<locals>.<genexpr>.<genexpr>Nr )r Zcrud_param_setr r r¢ r Ø s þÿz+SQLCompiler.visit_insert.<locals>.<genexpr>c S s g | ]\}}}}|qS r r rt r r r¢ r à s
|
ÿc s s | ]\}}d | V qdS ©ÚpNr re r r r¢ r s c 3 s6 | ].\}^}} |j|j j¡d | ¡V qdS ru )rq rÐ rS rc )r r_ r r° rÿ r r¢ r s
|
û ýz SELECT z FROM (VALUES (z)) AS imp_sen(z#, sen_counter) ORDER BY sen_counterz VALUES (r³ ) r r r
|
r r r r r r r r )@r6 rõ rF r½ r\ rì r r rò r Ú_get_crud_paramsr& rÏ rÛ Ú single_paramsrc Úsupports_default_valuesrk Zsupports_empty_insertr6 rK rÌ Z_has_multi_parametersrl rÁ Ú
|
_returningZ_sort_by_parameter_orderrZ rç ræ Ú format_tabler r& rW rê rë r~ Úuse_insertmanyvaluesZuse_sentinel_columnsrj r rX r r' Z_insert_sentinelr rN rÅ r rk rÞ Zcte_follows_insertrí r Zdefault_metavalue_tokenr Z_post_values_clauserÕ Zall_multi_paramsr) Zis_default_metavalue_onlyr* r^ r< ) rß Z insert_stmtrÎ r} rì rï Zcounted_bindparamZhas_visiting_cteÚcrud_params_structZcrud_params_singlerZ ry rÜ rU r° r| Znamed_sentinel_paramsZadd_sentinel_colsr rH Z_params_by_colZ_add_sentinel_colÚ
|
param_namerN Z select_textrè r Zembed_sentinel_valueZrender_bind_castsZcolnamesZcolnames_w_castZpost_values_clauser rÿ r¢ Ú visit_insertâ sþ ÿÿýÿüûú
|
ÿþýüþÿ
|
þÿÿÿþÿ ÿÿ ÿ
|
|
þ
|
ÿ
|
ÿÿÿý ÿÿÿþû
|
ÿÿ ï
|
ýÿ þþÿ
|
ÿÿýøÿÿ
|
ÿú
|
ÿ þÿ ì
|
ÿÿ þüÿ zSQLCompiler.visit_insertc C s dS )z3Provide a hook for MySQL to add LIMIT to the UPDATENr )rß Ú update_stmtr r r¢ Úupdate_limit_clauseU s z SQLCompiler.update_limit_clausec K s d|d< |j | fddi|S )z|Provide a hook to override the initial table clause
|
in an UPDATE statement.
|
|
MySQL overrides this.
|
|
Tr ró r )rß r Ú
|
from_tableÚ extra_fromsr} r r r¢ Úupdate_tables_clauseY s z SQLCompiler.update_tables_clausec K s t ddS )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 UPDATENr ©rß r r r Ú
|
from_hintsr} r r r¢ Úupdate_from_clausec s ÿz SQLCompiler.update_from_clausec sÜ |j || f|}|j}| j }|r@d| _| js4|| _| js@|| _| jt@ rlti t }| jt
|
@ }|rt|| _ nd }d}|j }t |}|r²t t|j fdd|D } |¡}
|
n g } |jh}
|
| j |
|
|
|
|d¡ d} |jrò| | j||jf|7 } | j||j| fd|i|} tj| |||f|} | j}|jrB| || ¡\}} nd }|jrZ| ||¡ | | 7 } | d7 } | d d
|
d t d |D ¡7 } | j s|j rÂ| j rÂ| d | j!|| j p¶|j |d 7 } |rø| j"||j| |fd|i|}|rø| d | 7 } |j#r*| j$|j#fd|i|}|r*| d| 7 } | %|¡}|rF| d | 7 } | j sV|j r| j s| d | j!|| j pt|j |d 7 } | j&r¬|st'| jnd }| j(|d| } |rÌ|d k sÀt)|j*dd | j +d¡ | S )NTFc s g | ]}| kr|qS r r r1 ©Z
|
main_fromsr r¢ r s z,SQLCompiler.visit_update.<locals>.<listcomp>ræ zUPDATE rv z SET r¯ c s s" | ]\}}}}|d | V qdS )ú=Nr )r r° rl r; r r r¢ r ¿ s
|
ÿz+SQLCompiler.visit_update.<locals>.<genexpr>z List[Tuple[Any, str, str, Any]]r¸ rs ú WHERE rç ZUPDATE©rK r ),r6 rõ rF r¾ r\ rì rê r1 r4 r r2 rv Ú _extra_fromsrí r) r r r rç ræ r r rw rx r& rW rê rë r~ r rÁ rz rÅ rN r r6 r r rÞ r& rí rj rL r< )rß r r} rì rï rv r: r Z is_multitableZrender_extra_fromsré rÜ rU r} Z crud_paramsrV Úextra_from_textr; rA rè r r r¢ Ú visit_updateq s ÿÿ
|
|
|
ÿ ýÿ ÿÿýüû ÿÿ ÿ
|
ÿþ
|
ý
|
üûú ÿÿÿ
|
ÿÿþ ý
|
zSQLCompiler.visit_updatec K s t ddS )zÀProvide 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 DELETENr r
r r r¢ Údelete_extra_from_clauseú s ÿz$SQLCompiler.delete_extra_from_clausec K s |j | fddd|S )NT)r ró r )rß Ú delete_stmtr r r} r r r¢ Údelete_table_clause
|
s ÿ ÿÿz SQLCompiler.delete_table_clausec K s |j || f|}|j}| j }|r@d| _| js4|| _| js@|| _| jt@ rlti t }| jt
|
@ }|rt|| _ nd }d}|j }|j h |¡}| j |||d¡ d} |jr¼| | j||jf|7 } | d7 } z| j||j ||d}
|
W n< tk
|
r | ||j |¡}
|
|r| j|j |d} Y nX tj| |||f| |jrH| ||
|
¡\} }
|
nd } |jr`| ||¡ | |
|
7 } | jsx|j r¢| j r¢| d| j || jp|j |d 7 } |rØ| j ||j || fd |i|} | rØ| d| 7 } |j r
|
| j!|j fd |i|}|r
|
| d
|
| 7 } | js|j rD| j sD| d| j || jp8|j |d 7 } | j"rp|s\t#| jnd }| j$|d | } |r|d k st%|j&d d | j 'd¡ | S )NTFræ zDELETE úFROM )rv r¸ rs rv r rç ÚDELETEr r )(r6 rõ rF r¼ r\ rì rê r1 r4 r r2 rv r r r r rç ræ r Ú TypeErrorrk r rw r& rW rê rë rÁ rz rÅ rN r r6 r rÞ r& rí rj rL r< )rß r r} rì rï rv r: r ré rÜ rU r° rV r r; rè r r r¢ Ú visit_delete sè ÿÿ
|
|
ýÿ ÿÿü
|
ÿ ÿ
|
ÿÿþ ý
|
üûú ÿÿÿ ÿÿþ ý
|
zSQLCompiler.visit_deletec K s d| j |¡ S )Nz SAVEPOINT %s©rZ Úformat_savepoint©rß Zsavepoint_stmtr} r r r¢ Úvisit_savepoint s zSQLCompiler.visit_savepointc K s d| j |¡ S )NzROLLBACK TO SAVEPOINT %sr r r r r¢ Úvisit_rollback_to_savepoint s ÿz'SQLCompiler.visit_rollback_to_savepointc K s d| j |¡ S )NzRELEASE SAVEPOINT %sr r r r r¢ Úvisit_release_savepoint s ÿz#SQLCompiler.visit_release_savepoint)NT)NNTNTF)F)F)F)F)NFFNr )NTr N)N)NF)N)FN)Nr )N)NFNN)F)FFFFF)FFNNNN)FFFNFFNN)F)FN)N)NNNTFFT)F)FFNNNFN)NF)NFF)FFFNTNN)FN)N)ùrÒ rÓ rÔ rÕ Ú EXTRACT_MAPr# r% r r¹ rÖ r ÚCOMPOUND_KEYWORDSr7 r¼ r½ r¾ r¿ rÀ rÁ r rÅ rÆ rÇ rË rÌ rÍ rÎ rÏ rÐ rÑ rÓ rÔ rÕ rÖ Ú frozensetr× rØ r rÙ r¶ Zpostfetch_lastrowidrÚ rú rÛ rÜ rÝ rä ræ rv r5 Úpatternr r ro rã r0 rn r r Zro_memoized_propertyr r r r Úmemoized_propertyr Zmemoized_instancemethodr Ú
|
contextlibÚcontextmanagerr rý rü r@ rC rD r rE r rY r rþ Úpreload_moduler} r r r r r¡ r¢ r r¯ r¸ r» r¼ rÊ rÎ rÐ rÑ rÕ rÝ rà rå rò rö rú rü r r r
|
r r r r r r r r r" r& r) r' r1 r/ r. r> r< r rG rL rM rP rR rV rX r_ r] ro rr rT rz r{ r| r} r~ rW rE rF r r r r r r r r r r r r r r r r r r r¤ r¥ r¨ r© rª r» rq r- rq r[ r´ r² rË rÞ rë r# Z_CTEOptsrâ rñ rò rð rú rï rü r r r rê rì r
|
r rø r r r r r r ré r r r/ r' r% r* ræ rí r@ r( r9 r: r9 rN rA r@ rS rT rW r+ Z
|
CLIENTSIDEr r( ZSENTINEL_DEFAULTÚNONEr% r& rZ r r$ rY r[ rq r r r r r r r r r r r r r r r¢ r« s
|
øÿþ
|
+
|
õ
|
|
|
ÿ
|
|
ù
|
|
"
|
|
ES
|
ý ù
|
&
|
ý H
|
P * ÿ
|
0ÿ
|
0 ù
|
1 ú ; ÿ
|
5 ý. ÿ
|
A ÿ
|
'
|
ÿL T ú3 ÿ ù % ü! ø*E ø0 L öc ' ÿ ó % ÿÿ
|
÷ N 4 _ ý5 ! û, ÷0 òÿþÿ>& ' u
|
|
z r« c s e Zd ZdZdd Ze d¡ fddZdd Zd d
|
Z d d Z
|
d d Z ddddddddZ dd Z dd Zdd Zd d Zd d Zd!d" Zd#d$ Z ZS )%ÚStrSQLCompilera A :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`
|
|
c C s dS )Nz<name unknown>r rº r r r¢ r» « s z$StrSQLCompiler._fallback_column_namezsqlalchemy.engine.urlc sT |j dkrFtjj}|j |j ¡ ¡ }| |d ¡}t|t sF|
|
|¡S t ||¡S )Nrn ) Zstringify_dialectr% r{ Z
|
engine_urlÚURLri Ú get_dialectÚstatement_compilerri r¥ rk rp r~ )rß r{ r| r} Úurlrc Úcompilerrt r r¢ r~ ® s
|
|
|
z,StrSQLCompiler.visit_unsupported_compilationc K s$ d| j |jf|| j |jf|f S )Nz%s[%s])rk r r rK r r r¢ Úvisit_getitem_binaryº s þz#StrSQLCompiler.visit_getitem_binaryc K s | j ||f|S rÝ ©r« rK r r r¢ Ú visit_json_getitem_op_binaryÀ s z+StrSQLCompiler.visit_json_getitem_op_binaryc K s | j ||f|S rÝ r¬ rK r r r¢ Ú!visit_json_path_getitem_op_binaryà s z0StrSQLCompiler.visit_json_path_getitem_op_binaryc K s d| j |¡ S )Nz<next sequence value: %s>)rZ Úformat_sequence)rß Úseqr} r r r¢ r/ Æ s z StrSQLCompiler.visit_sequencerA rF rí r r rG c s& fddt |¡D }dd |¡ S )Nc s g | ]} d |ddi ¡qS )NTFr r rÿ r r¢ r Ñ s ÿz3StrSQLCompiler.returning_clause.<locals>.<listcomp>rK r¯ )r rL r~ rM r rÿ r¢ rN É s
|
þz StrSQLCompiler.returning_clausec s( dd< dd fdd|D ¡ S )NTr r r¯ c 3 s$ | ] }|j fd iV qdS ©r× Nr ©r r; ©r r} rß r r¢ r Û s ÿz4StrSQLCompiler.update_from_clause.<locals>.<genexpr>r r
r r³ r¢ r × s þz!StrSQLCompiler.update_from_clausec s( dd< dd fdd|D ¡ S )NTr r¯ c 3 s$ | ] }|j fd iV qdS r± r r² r³ r r¢ r ä s ÿz:StrSQLCompiler.delete_extra_from_clause.<locals>.<genexpr>r r
r r³ r¢ r à s þz'StrSQLCompiler.delete_extra_from_clausec K s dS )NzSELECT 1 WHERE 1!=1r r r r r¢ r] é s z#StrSQLCompiler.visit_empty_set_exprc C s d| S )Nz[%s]r r r r r¢ r ì s z!StrSQLCompiler.get_from_hint_textc K s | j |df|S )Nz
|
<regexp> ©rW rK r r r¢ r¨ ï s z+StrSQLCompiler.visit_regexp_match_op_binaryc K s | j |df|S )Nz <not regexp> r´ rK r r r¢ r© ò s z/StrSQLCompiler.visit_not_regexp_match_op_binaryc K s: |j d }d|jj| f||jj| f||j| f|f S )NÚ replacementz <regexp replace>(%s, %s, %s))r r r
r )rß rd r r} rµ r r r¢ rª õ s
|
ýz-StrSQLCompiler.visit_regexp_replace_op_binary)rÒ rÓ rÔ rÕ r» r% r£ r~ r« r r® r/ rN r r r] r r¨ r© rª r r r rt r¢ r¥ s r¥ c @ s¨ e Zd ZdZer(dgddddddd d
|
Zejd d Zejd d Z dhdddddddZ
|
dd Z dd Z dd Z d d Zdid d Zdjd!d"Zd#d$ Zd%d& Zd'd( Zdkd)d*Zd+d, Zdld-d.Zd/d0 Zd1d2 Zd3d4 Zd5d6 Zd7d8 Zd9d: Z d;d< Z d=d> Z dmd?d@Z dAdB Z dCdD Z!dEdF Z"dGdH Z#dIdJ Z$dKdL Z%dMdN Z&dOdP Z'dQdR Z(dSdT Z)dUdV Z*dWdX Z+dYdZ Z,d[d\ Z-d]d^ Z.d_d` Z/dadb Z0dcdd Z1dedf Z2dS )nÚ DDLCompilerT.r\ r? rV rí ra rb c C s d S rÝ r rm r r r¢ rn s zDDLCompiler.__init__c C s | j j| j d | jdS )N©rW )rc r¨ rW rÿ r r r¢ r s
|
ÿzDDLCompiler.sql_compilerc C s | j jS rÝ )rc rÓ rÿ r r r¢ Ú type_compiler s zDDLCompiler.type_compilerNr r r r c C s d S rÝ r r r r r¢ r s z DDLCompiler.construct_paramsc K s |j }t|jtjr| ¡ }| j}| |j¡}t|dkrJ|d d }}n|d |d }}| d|¡ | d|¡ | d|
|
|j¡¡ | j |j | ¡S )Nr r rQ r r r" rQ )Úcontextri Útargetr" rI rÒ rZ Úformat_table_seqr& r r{ r rÝ rõ )rß Úddlr r¹ rZ Úpathr Zschr r r¢ Ú visit_ddl s zDDLCompiler.visit_ddlc K s$ d}|j r|d7 }|| j |j¡ S )NzCREATE SCHEMA úIF NOT EXISTS )Ú if_not_existsrZ Ú format_schemar{ )rß ri r} rÜ r r r¢ Úvisit_create_schema2 s z DDLCompiler.visit_create_schemac K s6 d}|j r|d7 }|| j |j¡7 }|jr2|d7 }|S )Nz DROP SCHEMA ú
|
IF EXISTS ú CASCADE)Ú if_existsrZ rÁ r{ Úcascade©rß Údropr} rÜ r r r¢ Úvisit_drop_schema8 s z DDLCompiler.visit_drop_schemac K sV |j }| j}d}|jr*|d |j¡d 7 }|d7 }|jr@|d7 }|| |¡d 7 }| |¡}|rl||d 7 }|d7 }d}d}|jD ]} | j }
|
zD| j| |
|
j o| d} | d k rÄ||7 }d }|d
|
| 7 }|
|
j rÎd }W q t
|
j k
|
r } z$t
|
d |j |
|
j | jd f ¡| W 5 d } ~ X Y qX q| j||jd} | r@||d
|
| 7 }|d| |¡ 7 }|S )Nz
|
CREATE r¸ zTABLE r¿ r² Ú
|
F©Úfirst_pkr= ú Tz (in table '%s', column '%s'): %sr )Ú _include_foreign_key_constraintsz
|
)%s
|
|
)r{ rZ rç r~ rÀ r{ Úcreate_table_suffixr rk r r6 rK Ú descriptionrÌ ÚargsÚcreate_table_constraintsZ include_foreign_key_constraintsÚpost_create_table)rß ri r} r rZ rÜ rÏ r rÌ Z create_columnrg Ú processedZceÚconstr r r¢ Úvisit_create_tableA sX
|
|
|
ÿ ÿÿýþz DDLCompiler.visit_create_tableFc sL |j }|jrd S j||d}d fdd|jD ¡}|rH|d| 7 }|S )NrË r¸ c 3 s | ]} |¡V qd S rÝ )rk ©r rh rÿ r r¢ r | s z2DDLCompiler.visit_create_column.<locals>.<genexpr>)r{ ÚsystemÚget_column_specificationr~ Ú constraints)rß ri rÌ r} rg rÜ rÕ r rÿ r¢ Úvisit_create_columnu s ÿ z DDLCompiler.visit_create_columnc st g }j r| j ¡ j}|d k r0| |¡ nt | fddjD ¡ d dd fdd|D D ¡S )Nc s" g | ]}|j k r| kr|qS r )r r )Ú omit_fkcsr r r¢ r s
|
þz8DDLCompiler.create_table_constraints.<locals>.<listcomp>z,
|
c s s | ]}|d k r|V qd S rÝ r )r rv r r r¢ r s öz7DDLCompiler.create_table_constraints.<locals>.<genexpr>c 3 s6 | ].}| ¡r jjr$t|d ds |¡V qdS )Z use_alterFN)Z_should_create_for_compilerrc Zsupports_alterr, rk r× rÿ r r¢ r s
|
|
û)r r Zforeign_key_constraintsr r ru Z_sorted_constraintsr~ )rß r rÎ r} rÚ Zall_fkcsr )rÜ rß r r¢ rÒ s" þÿ
|
|
þþz$DDLCompiler.create_table_constraintsc K s$ d}|j r|d7 }|| j |j¡ S )Nz
|
DROP TABLE rà )rÅ rZ r{ r{ rÇ r r r¢ Úvisit_drop_tableª s z DDLCompiler.visit_drop_tablec K s d| j |j¡ S )Nz
|
DROP VIEW ©rZ r{ r{ ©rß rÈ r} r r r¢ Úvisit_drop_view° s zDDLCompiler.visit_drop_viewc C s |j d krt d|j ¡d S )Nz,Index '%s' is not associated with any table.)r r6 rK rÌ ©rß r8 r r r¢ Ú_verify_index_table³ s
|
ÿz DDLCompiler._verify_index_tablec s |j } |¡ j}d}|jr(|d7 }|jd kr<t d¡|d7 }|jrR|d7 }|d j||d|j |j
|
|dd fd
|
d |j D ¡f 7 }|S ) NzCREATE zUNIQUE z0CREATE INDEX requires that the index have a namezINDEX r¿ z %s ON %s (%s)©Úinclude_schema©rR r¯ c 3 s | ]} j j|d ddV qdS )FT©r¾ r¬ N)r rk )r rl rÿ r r¢ r Ð s ý ÿz1DDLCompiler.visit_create_index.<locals>.<genexpr>) r{ râ rZ r rÌ r6 rK rÀ Ú_prepared_index_namer{ r r~ Z expressions)rß ri rä Zinclude_table_schemar} r8 rZ rÜ r rÿ r¢ Úvisit_create_index¹ s0
|
|
ÿ ÿüû z DDLCompiler.visit_create_indexc K s> |j }|jd krt d¡d}|jr,|d7 }|| j|dd S )Nz.DROP INDEX requires that the index have a namez
|
DROP INDEX rà Trã )r{ rÌ r6 rK rÅ rç )rß rÈ r} r8 rÜ r r r¢ Úvisit_drop_indexÙ s
|
ÿz DDLCompiler.visit_drop_indexc C sX |j d k r| j |j ¡}nd }|r4|r4| j |¡}nd }| j |¡}|rT|d | }|S ©Nrµ )r rZ rÅ rÆ Ú format_index)rß r8 rä rÉ Z schema_nameZ
|
index_namer r r¢ rç æ s
|
z DDLCompiler._prepared_index_namec K s d| j |jj¡| |j¡f S )NzALTER TABLE %s ADD %s)rZ r{ r{ r rk ©rß ri r} r r r¢ Úvisit_add_constraintö s
|
þz DDLCompiler.visit_add_constraintc K s( d| j |j¡| j |jjt ¡ ¡f S )NzCOMMENT ON TABLE %s IS %s)rZ r{ r{ r r[ Úcommentr$ ÚStringrì r r r¢ Úvisit_set_table_commentü s ÿþz#DDLCompiler.visit_set_table_commentc K s d| j |j¡ S )NzCOMMENT ON TABLE %s IS NULLrÞ rß r r r¢ Úvisit_drop_table_comment s ÿz$DDLCompiler.visit_drop_table_commentc K s. d| j j|jddd| j |jjt ¡ ¡f S )NzCOMMENT ON COLUMN %s IS %sT)Ú use_tablerR )rZ Ú format_columnr{ r r[ rî r$ rï rì r r r¢ Úvisit_set_column_comment s ÿ ÿüz$DDLCompiler.visit_set_column_commentc K s d| j j|jdd S )Nz COMMENT ON COLUMN %s IS NULLT)rò )rZ ró r{ rß r r r¢ Úvisit_drop_column_comment s ÿz%DDLCompiler.visit_drop_column_commentc K s t | t|¡d S rÝ rx rì r r r¢ Ú visit_set_constraint_comment s z(DDLCompiler.visit_set_constraint_commentc K s t | t|¡d S rÝ rx rß r r r¢ Ú visit_drop_constraint_comment s z)DDLCompiler.visit_drop_constraint_commentc C sô g }|j d k r | d|j ¡ |jd k r8| d|j ¡ |jd k rR| d|j ¡ |jd k rl| d|j ¡ |jd k r| d¡ |jd k r| d¡ |jd k r®| d|j ¡ |jd k rÌ| |jrÆdnd ¡ |j d k rê| |j räd
|
nd ¡ d
|
|¡S ) NzINCREMENT BY %dz START WITH %dz MINVALUE %dz MAXVALUE %dz NO MINVALUEz NO MAXVALUEzCACHE %dr zNO ORDERZCYCLEzNO CYCLEr¸ ) Ú incrementr rC ZminvalueZmaxvalueZ
|
nominvalueZ
|
nomaxvalueÚcacher Úcycler~ )rß Zidentity_optionsrÜ r r r¢ Úget_identity_options s(
|
|
|
|
|
|
|
|
|
|
|
z DDLCompiler.get_identity_optionsc K sP d}|j r|d7 }|| j |j¡7 }|r0||7 }| |j¡}|rL|d| 7 }|S )NzCREATE SEQUENCE r¿ r¸ )rÀ rZ r¯ r{ rû )rß ri r< r} rÜ Úoptionsr r r¢ Úvisit_create_sequence4 s z!DDLCompiler.visit_create_sequencec K s$ d}|j r|d7 }|| j |j¡ S )NzDROP SEQUENCE rà )rÅ rZ r¯ r{ rÇ r r r¢ Úvisit_drop_sequenceA s z DDLCompiler.visit_drop_sequencec K sj |j }|jd k r | j |¡}nd }|d kr:t d|j ¡d| j |j j¡|jrTdnd||j rbdndf S )Nz<Can't emit DROP CONSTRAINT for constraint %r; it has no namez%ALTER TABLE %s DROP CONSTRAINT %s%s%srà rQ rÄ )
|
r{ rÌ rZ Úformat_constraintr6 rK r{ r rÅ rÆ )rß rÈ r} rh Úformatted_namer r r¢ Úvisit_drop_constraintG s
|
ÿÿ üz!DDLCompiler.visit_drop_constraintc K s¦ | j |¡d | jjj|j|d }| |¡}|d k rB|d| 7 }|jd k r`|d| |j¡ 7 }|jd k r| jj r|d| |j¡ 7 }|j
|
s¢|jr| jj s¢|d7 }|S )Nr¸ )rÒ z DEFAULT z NOT NULL) rZ ró rc rÓ rk rÐ Úget_column_default_stringZcomputedÚidentityZsupports_identity_columnsZnullable)rß rg r Zcolspecrn r r r¢ rÙ Z s4
|
ÿ ÿþÿ
|
|
ÿþÿÿz$DDLCompiler.get_column_specificationc C s dS ©NrQ r ©rß r r r r¢ rÏ u s z DDLCompiler.create_table_suffixc C s dS r r r r r r¢ rÓ x s z DDLCompiler.post_create_tablec C s$ t |jtjr | |jj¡S d S d S rÝ )ri Zserver_defaultr" Z DefaultClauseÚrender_default_stringÚargrº r r r¢ r { s z%DDLCompiler.get_column_default_stringc C s. t |tr| j |tj¡S | jj|ddS d S )NT)r¬ )ri r r r[ r$ r rk )rß rn r r r¢ r s
|
ÿz!DDLCompiler.render_default_stringc K s |j r| |¡S | |¡S d S rÝ )Zis_column_levelÚ visit_column_check_constraintÚvisit_check_constraint)rß rh r} r r r¢ Ú&visit_table_or_column_check_constraint s
|
z2DDLCompiler.visit_table_or_column_check_constraintc K s\ d}|j d k r.| j |¡}|d k r.|d| 7 }|d| jj|jddd 7 }|| |¡7 }|S ©NrQ úCONSTRAINT %s z
|
CHECK (%s)FTræ ©rÌ rZ rÿ r rk r¼ Ú define_constraint_deferrability©rß rh r} rÜ r r r r¢ r s
|
|
ÿ
|
z"DDLCompiler.visit_check_constraintc K s\ d}|j d k r.| j |¡}|d k r.|d| 7 }|d| jj|jddd 7 }|| |¡7 }|S r r r r r r¢ r s
|
|
ÿ
|
z)DDLCompiler.visit_column_check_constraintc s t |dkrdS d}|jd k r> j |¡}|d k r>|d| 7 }|d7 }|dd fdd|jrd|jn|jD ¡ 7 }| |¡7 }|S ) Nr rQ r z PRIMARY KEY r r¯ c 3 s | ]} j |j¡V qd S rÝ ©rZ rÄ rÌ r rÿ r r¢ r ° s ÿz;DDLCompiler.visit_primary_key_constraint.<locals>.<genexpr>) r& rÌ rZ rÿ r~ Z_implicit_generatedZcolumns_autoinc_firstr r r r rÿ r¢ Ú visit_primary_key_constraint§ s
|
ÿû z(DDLCompiler.visit_primary_key_constraintc s¼ | j d}|jd k r4| j |¡}|d k r4|d| 7 }t|jd jj}|dd fdd|jD ¡| || ¡d fdd|jD ¡f 7 }|| |¡7 }||
|
|¡7 }|| |¡7 }|S ) NrQ r r z"FOREIGN KEY(%s) REFERENCES %s (%s)r¯ c 3 s | ]} |jj¡V qd S rÝ )rÄ ÚparentrÌ r1 ©rZ r r¢ r Ä s z;DDLCompiler.visit_foreign_key_constraint.<locals>.<genexpr>c 3 s | ]} |jj¡V qd S rÝ )rÄ rg rÌ r1 r r r¢ r Ê s ) rZ rÌ rÿ r r rg r r~ Ú define_constraint_remote_tableÚdefine_constraint_matchÚdefine_constraint_cascadesr )rß rh r} rÜ r Z remote_tabler r r¢ Ú visit_foreign_key_constraint» s0
|
ÿ ÿÿù z(DDLCompiler.visit_foreign_key_constraintc C s
|
| |¡S )z=Format the remote table clause of a CREATE CONSTRAINT clause.)r{ )rß rh r rZ r r r¢ r Ó s z*DDLCompiler.define_constraint_remote_tablec sp t |dkrdS d}|jd k r> j |¡}|d k r>|d| 7 }|dd fdd|D ¡ 7 }| |¡7 }|S )Nr rQ r z UNIQUE (%s)r¯ c 3 s | ]} j |j¡V qd S rÝ r r rÿ r r¢ r á s z6DDLCompiler.visit_unique_constraint.<locals>.<genexpr>)r& rÌ rZ rÿ r~ r r r rÿ r¢ Úvisit_unique_constraintØ s
|
ÿz#DDLCompiler.visit_unique_constraintc C sL d}|j d k r&|d| j |j t¡ 7 }|jd k rH|d| j |jt¡ 7 }|S )NrQ z ON DELETE %sz ON UPDATE %s)ZondeleterZ Úvalidate_sql_phraseÚ FK_ON_DELETEZonupdateÚ FK_ON_UPDATE©rß rh rÜ r r r¢ r æ s
|
|
ÿ
|
|
ÿz&DDLCompiler.define_constraint_cascadesc C sL d}|j d k r&|j r |d7 }n|d7 }|jd k rH|d| j |jt¡ 7 }|S )NrQ z DEFERRABLEz NOT DEFERRABLEz INITIALLY %s)ro r{ rZ r Ú FK_INITIALLYr r r r¢ r ò s
|
|
|
|
ÿz+DDLCompiler.define_constraint_deferrabilityc C s d}|j d k r |d|j 7 }|S )NrQ z MATCH %s)r³ r r r r¢ r ÿ s
|
z#DDLCompiler.define_constraint_matchc K sB d| j j|jddd }|jdkr,|d7 }n|jdkr>|d7 }|S )NzGENERATED ALWAYS AS (%s)FTræ z STOREDz VIRTUAL)r rk r¼ Z persisted)rß Ú generatedr} rÜ r r r¢ Úvisit_computed_column s ÿ
|
|
|
z!DDLCompiler.visit_computed_columnc K s2 d|j r dndf }| |¡}|r.|d| 7 }|S )NzGENERATED %s AS IDENTITYZALWAYSz
|
BY DEFAULTrr )Úalwaysrû )rß r r} rÜ rü r r r¢ Úvisit_identity_column s ÿ
|
z!DDLCompiler.visit_identity_column)...)NNT)F)N)FT)F)N)3rÒ rÓ rÔ r r rn r% r r r¸ r r¾ r rÉ rÖ rÛ rÒ rÝ rà râ rè ré rç rí rð rñ rô rõ rö r÷ rû rý rþ r rÙ rÏ rÓ r r r
|
r r r r r r r r r r r! r r r r¢ r¶ þ sr ú
|
|
|
ü 4
|
ÿ
|
& ÿ
|
|
|
|
|
r¶ c @ s~ e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd d Zd d Z dd Z
|
dd Z dd Z dd Z dd Zdd Zdd Zd d Zd^d d!Zd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd,d- Zd.d/ Zd0d1 Zd2d3 Zd4d5 Z d6d7 Z d8d9 Z d:d; Z d<d= Z d>d? Z!d@dA Z"dBdC Z#dDdE Z$dFdG Z%dHdI Z&dJdK Z'dLdM Z(dNdO Z)dPdQ Z*dRdS Z+dTdU Z,dVdW Z-dXdY Z.dZd[ Z/d\d] Z0d S )_ÚGenericTypeCompilerc K s dS )NÚFLOATr r r r r¢ Ú visit_FLOAT s z GenericTypeCompiler.visit_FLOATc K s dS )NÚDOUBLEr r r r r¢ Ú visit_DOUBLE s z GenericTypeCompiler.visit_DOUBLEc K s dS )NzDOUBLE PRECISIONr r r r r¢ Úvisit_DOUBLE_PRECISION s z*GenericTypeCompiler.visit_DOUBLE_PRECISIONc K s dS )NZREALr r r r r¢ Ú
|
visit_REAL# s z GenericTypeCompiler.visit_REALc K s< |j d krdS |jd kr&dd|j i S d|j |jd S d S )NZNUMERICzNUMERIC(%(precision)s)Ú precisionz!NUMERIC(%(precision)s, %(scale)s)©r) Zscaler* r r r r¢ Ú visit_NUMERIC& s
|
|
þz!GenericTypeCompiler.visit_NUMERICc K s< |j d krdS |jd kr&dd|j i S d|j |jd S d S )NZDECIMALzDECIMAL(%(precision)s)r) z!DECIMAL(%(precision)s, %(scale)s)r* r* r r r r¢ Ú visit_DECIMAL1 s
|
|
þz!GenericTypeCompiler.visit_DECIMALc K s dS )NZINTEGERr r r r r¢ Ú visit_INTEGER< s z!GenericTypeCompiler.visit_INTEGERc K s dS )NZSMALLINTr r r r r¢ Úvisit_SMALLINT? s z"GenericTypeCompiler.visit_SMALLINTc K s dS )NZBIGINTr r r r r¢ Ú visit_BIGINTB s z GenericTypeCompiler.visit_BIGINTc K s dS )NÚ TIMESTAMPr r r r r¢ Úvisit_TIMESTAMPE s z#GenericTypeCompiler.visit_TIMESTAMPc K s dS )NZDATETIMEr r r r r¢ Úvisit_DATETIMEH s z"GenericTypeCompiler.visit_DATETIMEc K s dS )NZDATEr r r r r¢ Ú
|
visit_DATEK s z GenericTypeCompiler.visit_DATEc K s dS )NZTIMEr r r r r¢ Ú
|
visit_TIMEN s z GenericTypeCompiler.visit_TIMEc K s dS )NZCLOBr r r r r¢ Ú
|
visit_CLOBQ s z GenericTypeCompiler.visit_CLOBc K s dS )NZNCLOBr r r r r¢ Ú visit_NCLOBT s z GenericTypeCompiler.visit_NCLOBNc C sB |}|r|d| 7 }n|j r*|d|j 7 }|jr>|d|j 7 }|S )Nú(%d)z COLLATE "%s")ÚlengthrÌ )rß rÛ rÌ Úlength_overriderÜ r r r¢ Ú_render_string_typeW s z'GenericTypeCompiler._render_string_typec K s | |d¡S )NÚCHAR©r: r r r r¢ Ú
|
visit_CHARb s z GenericTypeCompiler.visit_CHARc K s | |d¡S )NZNCHARr< r r r r¢ Ú visit_NCHARe s z GenericTypeCompiler.visit_NCHARc K s | |d¡S )NZVARCHARr< r r r r¢ Ú visit_VARCHARh s z!GenericTypeCompiler.visit_VARCHARc K s | |d¡S )NZNVARCHARr< r r r r¢ Úvisit_NVARCHARk s z"GenericTypeCompiler.visit_NVARCHARc K s | |d¡S )NZTEXTr< r r r r¢ Ú
|
visit_TEXTn s z GenericTypeCompiler.visit_TEXTc K s dS )NZBLOBr r r r r¢ Ú
|
visit_BLOBq s z GenericTypeCompiler.visit_BLOBc K s d|j rd|j pd S )NÚBINARYr7 rQ ©r8 r r r r¢ Ú visit_BINARYt s z GenericTypeCompiler.visit_BINARYc K s d|j rd|j pd S )NZ VARBINARYr7 rQ rD r r r r¢ Úvisit_VARBINARYw s z#GenericTypeCompiler.visit_VARBINARYc K s dS )NÚBOOLEANr r r r r¢ Ú visit_BOOLEANz s z!GenericTypeCompiler.visit_BOOLEANc K s | j |dddS )Nr; é )r9 r< r r r r¢ Ú
|
visit_uuid} s z GenericTypeCompiler.visit_uuidc K s | j |f|S rÝ )rB r r r r¢ Úvisit_large_binary s z&GenericTypeCompiler.visit_large_binaryc K s | j |f|S rÝ )rH r r r r¢ Ú visit_boolean s z!GenericTypeCompiler.visit_booleanc K s | j |f|S rÝ )r4 r r r r¢ Ú
|
visit_time s z GenericTypeCompiler.visit_timec K s | j |f|S rÝ )r2 r r r r¢ Úvisit_datetime s z"GenericTypeCompiler.visit_datetimec K s | j |f|S rÝ )r3 r r r r¢ Ú
|
visit_date s z GenericTypeCompiler.visit_datec K s | j |f|S rÝ )r/ r r r r¢ Úvisit_big_integer s z%GenericTypeCompiler.visit_big_integerc K s | j |f|S rÝ )r. r r r r¢ Úvisit_small_integer s z'GenericTypeCompiler.visit_small_integerc K s | j |f|S rÝ )r- r r r r¢ Ú visit_integer s z!GenericTypeCompiler.visit_integerc K s | j |f|S rÝ )r( r r r r¢ Ú
|
visit_real s z GenericTypeCompiler.visit_realc K s | j |f|S rÝ )r$ r r r r¢ Ú visit_float s z GenericTypeCompiler.visit_floatc K s | j |f|S rÝ )r& r r r r¢ Ú visit_double s z GenericTypeCompiler.visit_doublec K s | j |f|S rÝ )r+ r r r r¢ Ú visit_numeric¡ s z!GenericTypeCompiler.visit_numericc K s | j |f|S rÝ ©r? r r r r¢ Ú visit_string¤ s z GenericTypeCompiler.visit_stringc K s | j |f|S rÝ rW r r r r¢ Ú visit_unicode§ s z!GenericTypeCompiler.visit_unicodec K s | j |f|S rÝ ©rA r r r r¢ Ú
|
visit_textª s z GenericTypeCompiler.visit_textc K s | j |f|S rÝ rZ r r r r¢ Úvisit_unicode_text s z&GenericTypeCompiler.visit_unicode_textc K s | j |f|S rÝ rW r r r r¢ Ú
|
visit_enum° s z GenericTypeCompiler.visit_enumc K s t d| ¡d S )NzKCan't generate DDL for %r; did you forget to specify a type on this Column?r¹ r r r r¢ rö ³ s
|
þÿz GenericTypeCompiler.visit_nullc K s | j | | j¡f|S rÝ )rk Z type_enginerc r r r r¢ Úvisit_type_decoratorº s z(GenericTypeCompiler.visit_type_decoratorc K s |j f |S rÝ )Ú get_col_specr r r r¢ Úvisit_user_defined½ s z&GenericTypeCompiler.visit_user_defined)N)1rÒ rÓ rÔ r$ r& r' r( r+ r, r- r. r/ r1 r2 r3 r4 r5 r6 r: r= r> r? r@ rA rB rE rF rH rJ rK rL rM rN rO rP rQ rR rS rT rU rV rX rY r[ r\ r] rö r^ r` r r r r¢ r" s\
|
r" c @ s4 e Zd Zdd Zdd Zdd Zdd Zd d
|
Zd S ) ÚStrSQLTypeCompilerc K s> z
|
|j }W n" tk
|
r, | j|f| Y S X || f|S d S rÝ )r
ÚAttributeErrorÚ_visit_unknown)rß rÛ r} r
r r r¢ rk  s
|
|
zStrSQLTypeCompiler.processc C s | d¡r| jS t|d S )NZvisit_)rô rc rb )rß rþ r r r¢ Ú __getattr__Ê s
|
z StrSQLTypeCompiler.__getattr__c K s( |j j|j j ¡ kr |j jS t|S d S rÝ )ru rÒ ÚupperÚreprr r r r¢ rc Ð s z!StrSQLTypeCompiler._visit_unknownc K s dS ró r r r r r¢ rö Ö s z StrSQLTypeCompiler.visit_nullc K s6 z
|
|j }W n tk
|
r& t| Y S X |f |S d S rÝ )r_ rb rf )rß rÛ r} r_ r r r¢ r` Ù s
|
|
z%StrSQLTypeCompiler.visit_user_definedN)rÒ rÓ rÔ rk rd rc rö r` r r r r¢ ra Á s
|
ra c @ s e Zd ZdddddZdS )Ú_SchemaForObjectCallabler r )r rÜ c C s d S rÝ r )rß r r r r¢ rà ã s z!_SchemaForObjectCallable.__call__Nrá r r r r¢ rg â s rg c @ s e Zd ZdddddZdS )r~ r½ r )r rÜ c C s d S rÝ r )rß r r r r¢ rà è s z _BindNameForColProtocol.__call__Nrá r r r r¢ r~ ç s r~ c @ s e Zd ZU dZeZeZeZ de
|
d< de
|
d< de
|
d< e d¡Z de
|
d < dQddZdd Zdd ZdddddZdddddZdd Zddddd Zdd dd d Zd d! ZdRdd"dd#d$d%ZdSdd"dd&d'd(Zd)d* ZdTd+d,ZdUd-d.dd/d0d1ZdVd2d.dd3d4d5Z dWd6d7Z e d8¡dXd9d:Z dYd;d<Z!dZd=d>Z"d?d@ Z#dAdB Z$d[dCdDZ%dEdF Z&d\dGdHZ'd]dIdJZ(d^dKdLZ)e j*dMdN Z+dOdP Z,d S )_rY z@Handle quoting and case-folding of identifiers based on options.r Ú initial_quoteÚ final_quotezMutableMapping[str, str]Ú_stringsr" rg rÅ rI NTFc C sN || _ || _|p| j| _|| _| jd | _|| _|| _i | _| j jdk| _ dS )as Construct 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.
|
r5 )r© r§ N)
|
rc rh ri Ú escape_quoteÚescape_to_quoteÚ omit_schemaÚ quote_case_sensitive_collationsrj ró rÙ )rß rc rh ri rk rn rm r r r¢ rn s zIdentifierPreparer.__init__c s2 | j | j ¡}|j | j¡ fdd}||_|S )Nc sX | j }| krN| jrN|d k r:d|ks,d|kr:t d| ¡td|pDd ddS | j S d S )Nr¶ r· zJSquare bracket characters ([]) not supported in schema translate name '%s'z __[SCHEMA_%s]Ú_noneF©rÄ )r" Z_use_schema_mapr6 rK r/ )r rÌ r· r r¢ Ú symbol_getter/ s ÿÿ
|
ÿz@IdentifierPreparer._with_schema_translate.<locals>.symbol_getter)ru Ú__new__Ú__dict__rt rÅ )rß rW Úpreprq r r· r¢ rg + s
|
z)IdentifierPreparer._with_schema_translatec s4 | d kr d d< fdd}t d||¡S )Nro c s6 | d¡} | }|s,jj}|s,t d¡ |¡S )Nr5 zLDialect has no default schema name; can't use None as dynamic schema target.)ry rc Zdefault_schema_namer6 rK rÆ )r rÌ rÉ ©Údrß r r¢ rÚ E s
|
ÿz=IdentifierPreparer._render_schema_translates.<locals>.replacez(__\[SCHEMA_([^\]]+)\]))rä r )rß rõ rW rÚ r ru r¢ rl @ s
|
z,IdentifierPreparer._render_schema_translates)r; rÜ c C s& | | j| j¡}| jr"| dd¡}|S )zEscape an identifier.
|
|
Subclasses should override this to provide database-dependent
|
escaping behavior.
|
r± r× )rÚ rk rl rÙ ©rß r; r r r¢ Ú_escape_identifierT s z%IdentifierPreparer._escape_identifierc C s | | j| j¡S )z±Canonicalize an escaped identifier.
|
|
Subclasses should override this to provide database-dependent
|
unescaping behavior that reverses _escape_identifier.
|
)rÚ rl rk rw r r r¢ Ú_unescape_identifier` s z'IdentifierPreparer._unescape_identifierc C s* |dk r&| |¡s&t d||jf ¡|S )zýkeyword 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))r³ r6 rK r )rß r{ rç r r r¢ r i s ÿÿz&IdentifierPreparer.validate_sql_phrasec C s | j | |¡ | j S )z~Quote an identifier.
|
|
Subclasses should override this to provide database-dependent
|
quoting behavior.
|
)rh rx ri rw r r r¢ Úquote_identifier{ s ÿþÿz#IdentifierPreparer.quote_identifierrí c C s: | ¡ }|| jkp8|d | jkp8| j t|¡ p8||kS )z5Return True if the given identifier requires quoting.r )r- Úreserved_wordsÚillegal_initial_charactersÚlegal_charactersr³ r )rß r; Zlc_valuer r r¢ ré s
|
ÿþüz#IdentifierPreparer._requires_quotesc C s | j t|¡ S )zjReturn True if the given identifier requires quoting, but
|
not taking case convention into account.)r} r³ r rw r r r¢ r* s z1IdentifierPreparer._requires_quotes_illegal_charsr )r" ÚforcerÜ c C s |dk rt jddd | |¡S )a Conditionally 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`.
|
|
NzÚThe 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.9rA )r% rC rÄ )rß r" r~ r r r¢ rÆ s ù
|
z IdentifierPreparer.quote_schema)rÝ r~ rÜ c C s |dk rt jddd t|dd}|dkrp|| jkr>| j| S | |¡rZ| |¡| j|< n
|
|| j|< | j| S n|r~| |¡S |S dS )a Conditionally 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`.
|
|
NzÓThe 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().r rA rÄ )r% rC r, rj ré rz )rß rÝ r~ r r r¢ rÄ ¾ s ù
|
|
|
|
|
|
zIdentifierPreparer.quotec C s | j r| |¡S |S d S rÝ )rn rÄ )rß Zcollation_namer r r¢ rË ò s
|
z#IdentifierPreparer.format_collationc C s> | |j¡}| |¡}| js:|r:|d k r:| |¡d | }|S rê )rÄ rÌ rÅ rm rÆ )rß r0 rR rÌ rÉ r r r¢ r¯ ø s
|
ÿþýz"IdentifierPreparer.format_sequencez
|
Label[Any]rÒ )r rÌ rÜ c C s | |p |j¡S rÝ )rÄ rÌ )rß r rÌ r r r¢ rµ s z IdentifierPreparer.format_labelz Optional[AliasedReturnsRows])rÀ rÌ rÜ c C s. |d kr |d k st | |j¡S | |¡S d S rÝ )rj rÄ rÌ )rß rÀ rÌ r r r¢ rä
|
s z IdentifierPreparer.format_aliasc C s" |p|j }| |¡r | |¡}|S rÝ )rÝ ré rz )rß Z savepointrÌ rÝ r r r¢ r s
|
|
|
z#IdentifierPreparer.format_savepointzsqlalchemy.sql.namingc C s^ t jj}|jtkr.| ||j¡}|d kr4d S n|j}|jdkrL| j||dS | j ||dS d S )Nr8 )Ú_alembic_quote)
|
r% r{ Z
|
sql_namingrÌ r* Z_constraint_name_for_tabler r¦ Ú truncate_and_render_index_nameÚ#truncate_and_render_constraint_name)rß rh r ZnamingrÌ r r r¢ rÿ s$
|
ÿ
|
ÿ ÿz$IdentifierPreparer.format_constraintc C s | j jp| j j}| |||¡S rÝ )rc Zmax_index_name_lengthrø Ú _truncate_and_render_maxlen_name©rß rÌ r Úmax_r r r¢ r 3 s þ ÿz1IdentifierPreparer.truncate_and_render_index_namec C s | j jp| j j}| |||¡S rÝ )rc Zmax_constraint_name_lengthrø r r r r r¢ r ? s þ ÿz6IdentifierPreparer.truncate_and_render_constraint_namec C sb t |tjr@t||krL|d|d
d t |¡dd
}n | j |¡ |sT|S | |¡S d S )Nr r! r° éüÿÿÿ) ri r rC r& r% Zmd5_hexrc Zvalidate_identifierrÄ )rß rÌ r
r r r r¢ r K s ( z3IdentifierPreparer._truncate_and_render_maxlen_namec C s
|
| |¡S rÝ )rÿ rá r r r¢ rë W s z IdentifierPreparer.format_indexc C sF |dkr|j }| |¡}| |¡}| jsB|rB|rB| |¡d | }|S )z'Prepare a quoted table and schema name.Nrµ )rÌ rÄ rÅ rm rÆ )rß r rR rÌ r rÉ r r r¢ r{ Z s
|
|
z IdentifierPreparer.format_tablec C s
|
| |¡S )z Prepare a quoted schema name.rp rÊ r r r¢ rÁ h s z IdentifierPreparer.format_schemac C s( |dk r t |tjr | |¡}| |¡S )ú Prepare a quoted column name.N)ri r rC rÅ rÄ )rß rÌ rù r r r¢ rÜ m s
|
ÿ
|
z$IdentifierPreparer.format_label_namec C s |dkr|j }|dk r,t|tjr,| |¡}t|ddsh|r\| j|j||dd | |¡ S | |¡S n"|r| j|j||dd | S |S dS )r NrÁ F)rR rÌ rµ ) rÌ ri r rC rÅ r, r{ r rÄ )rß rg rò rÌ Z
|
table_namerR rù r r r¢ ró { s@
|
ÿ
|
ÿýüÿ ÿýüÿz IdentifierPreparer.format_columnc C sD | |¡}| js0|r0|r0| |¡| j|ddfS | j|ddfS dS )z(Format table name and schema as a tuple.Frå N)rÅ rm rÆ r{ )rß r rR rÉ r r r¢ r» ¨ s
|
þz#IdentifierPreparer.format_table_seqc C s@ dd | j | j| | j¡fD \}}}t d|||d ¡}|S )Nc s s | ]}t |¡V qd S rÝ )rä rå rý r r r¢ r » s ÿz4IdentifierPreparer._r_identifiers.<locals>.<genexpr>zM(?:(?:%(initial)s((?:%(escaped)s|[^%(final)s])+)%(final)s|([^\.]+))(?=\.|$))+)ÚinitialÚfinalrp )rh ri rx rä ræ )rß r r Z escaped_finalÚrr r r¢ Ú_r_identifiers¹ s
|
ýþ
|
ýÿz!IdentifierPreparer._r_identifiersc s( j } fdddd | |¡D D S )z:Unpack 'schema.table.column'-like strings into components.c s g | ]} |¡qS r )ry rh rÿ r r¢ r Ï s ÿz;IdentifierPreparer.unformat_identifiers.<locals>.<listcomp>c S s g | ]\}}|p|qS r r )r Úarí r r r¢ r Ñ s )r Úfindall)rß Z identifiersr r rÿ r¢ Úunformat_identifiersË s
|
þz'IdentifierPreparer.unformat_identifiers)rI NrI TF)N)N)T)N)N)N)T)T)T)TN)N)FNNFN)T)-rÒ rÓ rÔ rÕ ÚRESERVED_WORDSr{ ÚLEGAL_CHARACTERSr} ÚILLEGAL_INITIAL_CHARACTERSr| rÖ r Ú
|
attrgetterrÅ rn rg rl rx ry r rz ré r* rÆ rÄ rË r¯ rµ rä r r% r£ rÿ r r r rë r{ rÁ rÜ ró r» r r r r r r r¢ rY ì sf
|
ù
|
$
|
'4
|
ÿ ÿ
|
|
|
|
ý
|
ù
|
-
|
|
rY )ërÕ Ú
|
__future__r r= Úcollections.abcÚabcrh r¡ Úenumr r1 r rä Útimer r r r r r r r
|
r r r r r r r r r r r r r r r rQ r r r r r r r! r" r# r$ r% rÀ Ú_typingr' r( r) r* r+ r, r- r. r/ r0 r1 Ztype_apir2 Zvisitorsr3 r4 r6 r7 Z util.typingr8 r9 r: Ú
|
annotationr; r< r= r^ r> r¼ r? Zdmlr@ rA rB rC rD rE rF rG rH rI rJ rK rL rM rN rO rP rQ rR rS Z engine.cursorrT Zengine.interfacesrU rV rW rX rY rZ r[ r\ r] r Z_FromHintsTyper ræ ÚIr ZLEGAL_CHARACTERS_PLUS_SPACErn r r r r r ÚUNICODErä rã rõ rö r Úor_rÏ Úmulr ÚmodÚnegÚltÚleÚneÚgtÚgeÚeqZis_distinct_fromZis_not_distinct_fromZ concat_oprU Z not_match_opr\ r[ rE rJ r´ r½ r¾ rf ÚexistsZ distinct_opÚinvZany_opZall_opZdesc_opZasc_opZnulls_first_opZ nulls_last_opZbitwise_xor_opZ bitwise_or_opZbitwise_and_opZbitwise_not_opZbitwise_lshift_opZbitwise_rshift_opr³ r³ rj rk rl rm r r r´ rµ r r ZcubeZrollupZ grouping_setsr· rÖ r Z_CompoundSelectKeywordrÇ Z UNION_ALLrÈ Z
|
EXCEPT_ALLrÉ Z INTERSECT_ALLr rÊ r× râ rã rä ræ rç rë rô r r r r+ r/ r r0 r1 r2 r3 Ú
|
namedtupler4 rO Z EnsureKWArgr ZBinaryElementRoleZCompilerColumnElementr r¨ r« r¥ r¶ r" ra rg r~ rY r r r r¢ Ú<module> sp ¢a ÿ ÿú Ó1 òñ ú
|
=sÿ (C M ÿ ÿ& 9g )!
|
