fume-manage-python.git

U  
¸ý°d´Nã@sädZddlmZddlZddlZddlZddlZddlmZddl    Z    ddl    m
Z
ddl    mZddl    mZddl    m Z dd    l    mZdd
l    mZddl    mZddl    mZdd l    mZddl    mZddl    mZddl    mZddl    mZddl    mZddl    mZddlZddlmZddlmZddlmZddlm Z ddlm!Z!ddlm"Z"ddlm#Z#ddlm$Z$ddlm%Z%ddl&m'Z'ddl&m(Z(d d!lm)Z)d d"lm*Z*d d#lm+Z+d d$lm,Z,d d%l-m.Z.d d&l-m/Z/d d'l-m0Z0d d(l-m1Z1d d)l2m3Z3d d*l4m5Z5d d+l6m7Z7d d,l6m8Z8d d-l6m9Z9d d.l:m;Z;d d/l<m=Z=d d0l<m>Z>e    jrdd1l?m@Z@dd2lmAZAdd3lmBZBdd4lmCZCdd5lmDZDdd6lmEZEdd7lmFZFdd8lmGZGdd9lmHZHdd:lmIZIdd;lmJZJdd<lKmLZLdd=lMmNZNd d>l)mOZOd d?l+mPZPd d@l+mQZQd dAl-mRZRd dBl6mSZSd dCl6mTZTd dDl6mUZUd dElVmWZWd dFlVmXZXd dGl:mYZYd dHlZm[Z[d dIl\m]Z]d dJl\m^Z^e _dKej`ejaB¡Zbece!\ZdZeZfZgZhGdLdMdMe#ZiGdNdOdOeiZjGdPdQdQe%Zkekei_ldS)RaDefault implementations of per-dialect sqlalchemy.engine classes.
 
These are semi-private implementation classes which are only of importance
to database dialect authors; dialects will usually use the classes here
as the base class for their own corresponding classes.
 
é)ÚannotationsN)Úperf_counter)ÚAny)ÚCallable)Úcast)ÚDict)ÚList)ÚMapping)ÚMutableMapping)ÚMutableSequence)ÚOptional)ÚSequence)ÚSet)ÚTuple)ÚType)Ú TYPE_CHECKING)ÚUnioné)Úcharacteristics)Úcursor)Ú
interfaces)Ú
Connection)Ú
CacheStats)ÚDBAPICursor)ÚDialect)ÚExecuteStyle)ÚExecutionContext)Ú
ObjectKind)ÚObjectScopeé)Úevent)Úexc)Úpool)Úutil)Úcompiler)Údml)Ú
expression)Útype_api)Ú is_tuple_type)Ú_NoArg)ÚDDLCompiler)ÚInsertmanyvaluesSentinelOpts)ÚSQLCompiler)Úquoted_name)ÚFinal)ÚLiteral)Ú
ModuleType)ÚEngine)Ú_CoreMultiExecuteParams)Ú_CoreSingleExecuteParams)Ú_DBAPICursorDescription)Ú_DBAPIMultiExecuteParams)Ú_ExecuteOptions)Ú_MutableCoreSingleExecuteParams)Ú_ParamStyle)ÚDBAPIConnection)ÚIsolationLevel)ÚRow)ÚURL)Ú_ListenerFnType)ÚPool)ÚPoolProxiedConnection)Ú
Executable)ÚCompiled)ÚLinting)ÚResultColumnsEntry)ÚDMLState)Ú
UpdateBase)Ú BindParameter)ÚColumn)Ú_BindProcessorType)Ú
TypeEnginez    \s*SELECTc@sÀeZdZUdZejZejZej    Z
ejZdZ dZdZdZdZdZejjZdZded<dZded<dZeZdZdZdZdZ dZ!dZ"dZ#dZ$dZ%dZ&dZ'dZ(dZ)dZ*dZ+dZ,dZ-dZ.dZ/dZ0dZ1dZ2e3 4d    e5 6¡i¡Z7e3 4e3j8e3 9d
¡e3 9d
¡e3j8e3j8e3j8e3j:d¡Z;ded <dZ<dZ=dZ>dZ?ded<dZ@ded    <dZAded<dZBded<dZCdZDiZEded<dZFdZGdZHdZIdZJdZKdZLded<dZMded<eNjOZPded<dZQded <d!ZRdZSdZTdZUdZVdZWdZXded"<dZYdZZdZ[d#Z\e3j]d$d%d&ddddddde^j_de`ejadfd'd(d)d*d+ddd,d+d-dd.d/d0d1Zbece3 dd2d3¡d4d5Zee3jfd6d7Zge3jfd8d9ZhdZidZje3jfd:d;d<d=Zke3jfd>d?Zld@dAZme3jfdBdCZne3jfdDdEZoecdFdGZpecdHdIZqerdJdKdLdMdNZsdJdKdLdOdPZterdQdRZudSd;dTdUZvdVdWZwdXdYZxdZd[Zyd\d]Zzd^d_Z{d½d`daZ|dbdcd.ddddedfZ}dgdhZ~didjZdkdlZdmddndodpdqZdbddndrdsdtZdudvZdwdxZdydzZd{d|Zd}d~ZddZddZe3jfddZdddddZdddddZddZddZddZddZddZd¾ddZd¿ddZdÀddZddZe3jddZdd Zd¡d¢Zd£d¤Zd¥d¦Zd§d¨Zd©dªZd«d¬Zdd®Zd¯d°Z d±d²Z¡d³d´Z¢dµd¶Z£d·d¸Z¤d¹dºZ¥d»d¼Z¦dS)ÁÚDefaultDialectz!Default implementation of DialectTFNzOptional[Set[Any]]Úinclude_set_input_sizesÚexclude_set_input_sizesrÚisolation_levelÚdebug)Úpool_timeoutZechoZ    echo_poolZpool_recycleZ    pool_sizeZmax_overflowÚfutureúMapping[str, Any]Úengine_config_typesÚdefaulti'z Optional[int]Ú#_user_defined_max_identifier_lengthz Optional[str]Úmax_index_name_lengthÚmax_constraint_name_lengthz<MutableMapping[Type[TypeEngine[Any]], Type[TypeEngine[Any]]]ÚcolspecsÚnamedÚDEFAULTÚboolÚuse_insertmanyvaluesÚ!use_insertmanyvalues_wo_returningr+Ú"insertmanyvalues_implicit_sentinelièÚintÚinsertmanyvalues_page_sizei¼Údefault_schema_namezutf-8)ú1.4aThe :paramref:`_sa.create_engine.empty_in_strategy` keyword is deprecated, and no longer has any effect.  All IN expressions are now rendered using the "expanding parameter" strategy which renders a set of boundexpressions, or an "empty set" SELECT, at statement executiontime.)razÑThe :paramref:`_sa.create_engine.server_side_cursors` parameter is deprecated and will be removed in a future release.  Please use the :paramref:`_engine.Connection.execution_options.stream_results` parameter.)Zempty_in_strategyÚserver_side_cursorszOptional[_ParamStyle]zOptional[IsolationLevel]zOptional[ModuleType]z Literal[True]zOptional[bool]zUnion[_NoArg, int]rBr)Ú
paramstylerMÚdbapiÚimplicit_returningÚsupports_native_booleanÚmax_identifier_lengthÚlabel_lengthr_r[Úcompiler_lintingrbÚkwargscKs4|r |jst d|¡nd|_t|ddrBt dd¡tjj    |_
d|_d|_||_ |dk    rd||_n|j dk    rz|j j|_n|j|_|jdk|_| |¡|_||_t|dd} | dk    rÈtttj|j}n|j}|||_|_|dk    rì||_||_|jr|j|_||_|
|_|    dk    r|    |_|t j!k    r0||_"dS)    Nz/Dialect %s does not support server side cursorsTZuse_setinputsizesFzoThe dialect-level use_setinputsizes attribute is deprecated.  Please use bind_typing = BindTyping.SETINPUTSIZESú2.0)ZqmarkÚformatÚnumericZnumeric_dollarÚ type_compiler)#Úsupports_server_side_cursorsr!Ú ArgumentErrorrbÚgetattrr#Zwarn_deprecatedrÚ
BindTypingZ SETINPUTSIZESÚbind_typingÚ
positionalZ_ischemardrcÚdefault_paramstyleÚpreparerÚidentifier_preparerÚ_on_connect_isolation_levelrrr$ÚGenericTypeCompilerrnÚtype_compiler_clsZtype_compiler_instancerfrTrgrhrir[r)ÚNO_ARGr_)ÚselfrcrMrdrerfrgrhr_r[rirbrjZlegacy_tt_callableZtt_callable©r}úPd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\sqlalchemy/engine/default.pyÚ__init__
sV$ÿü
 
þÿ
zDefaultDialect.__init__rkz]full_returning is deprecated, please use insert_returning, update_returning, delete_returningcCs|jo|jo|jS©N)Úinsert_returningÚupdate_returningÚdelete_returning©r|r}r}r~Úfull_returningos
ÿýzDefaultDialect.full_returningcCs|jo
|jS)aôDefault implementation for insert_executemany_returning, if not
        otherwise overridden by the specific dialect.
 
        The default dialect determines "insert_executemany_returning" is
        available if the dialect in use has opted into using the
        "use_insertmanyvalues" feature. If they haven't opted into that, then
        this attribute is False, unless the dialect in question overrides this
        and provides some other implementation (such as the Oracle dialect).
 
        ©rr[rr}r}r~Úinsert_executemany_returning|sz+DefaultDialect.insert_executemany_returningcCs|jo
|jS)aÚDefault implementation for
        insert_executemany_returning_deterministic_order, if not otherwise
        overridden by the specific dialect.
 
        The default dialect determines "insert_executemany_returning" can have
        deterministic order only if the dialect in use has opted into using the
        "use_insertmanyvalues" feature, which implements deterministic ordering
        using client side sentinel columns only by default.  The
        "insertmanyvalues" feature also features alternate forms that can
        use server-generated PK values as "sentinels", but those are only
        used if the :attr:`.Dialect.insertmanyvalues_implicit_sentinel`
        bitflag enables those alternate SQL forms, which are disabled
        by default.
 
        If the dialect in use hasn't opted into that, then this attribute is
        False, unless the dialect in question overrides this and provides some
        other implementation (such as the Oracle dialect).
 
        rrr}r}r~Ú4insert_executemany_returning_sort_by_parameter_orderszCDefaultDialect.insert_executemany_returning_sort_by_parameter_orderr0©ÚreturncCs"|jdkrt d|d¡|jS)NúDialect z\ does not have a Python DBAPI established and cannot be used for actual database interaction)rdr!ÚInvalidRequestErrorrr}r}r~Úloaded_dbapi¤s
 
 
ÿzDefaultDialect.loaded_dbapicCs|jtjjkSr)rsrrrZRENDER_CASTSrr}r}r~Ú_bind_typing_render_castssz(DefaultDialect._bind_typing_render_castscCs$t|ts t dtt|f¡dS)NzáThe argument passed to Dialect.has_table() should be a %s, got %s. Additionally, the Dialect.has_table() method is for internal dialect use only; please use ``inspect(some_engine).has_table(<tablename>>)`` for public API use.)Ú
isinstancerr!rpÚtype)r|Úargr}r}r~Ú_ensure_has_table_connection±s
 
úÿz+DefaultDialect._ensure_has_table_connectioncCs:|jj dd¡}|dkr2tjd|j|jfddt|S)NÚsupports_statement_cacheaíDialect %s:%s will not make use of SQL compilation caching as it does not set the 'supports_statement_cache' attribute to ``True``.  This can have significant performance implications including some performance degradations in comparison to prior SQLAlchemy versions.  Dialect maintainers should seek to set this attribute to True after appropriate development and testing for SQLAlchemy 1.4 caching support.   Alternatively, this attribute may be set to False which will disable this warning.Zcprf)Úcode)Ú    __class__Ú__dict__Úgetr#ÚwarnÚnameÚdriverrZ)r|Zsscr}r}r~Ú_supports_statement_cache¾s    
÷
õz(DefaultDialect._supports_statement_cachecCst ¡Sr)ÚweakrefÚWeakKeyDictionaryrr}r}r~Ú_type_memosÒszDefaultDialect._type_memoscCs|jd|jS)Nú+)rrrr}r}r~Údialect_descriptionÖsz"DefaultDialect.dialect_descriptioncCs|jS)zÊTrue if this dialect supports sane rowcount even if RETURNING is
        in use.
 
        For dialects that don't support RETURNING, this is synonymous with
        ``supports_sane_rowcount``.
 
        )Úsupports_sane_rowcountrr}r}r~Ú supports_sane_rowcount_returningÚs    z/DefaultDialect.supports_sane_rowcount_returningr<z
Type[Pool])ÚurlrcCst|dtjS)NZ    poolclass)rqr"Z    QueuePool)Úclsr£r}r}r~Úget_pool_classåszDefaultDialect.get_pool_classcCs
| |¡Sr)r¥)r|r£r}r}r~Úget_dialect_pool_classész%DefaultDialect.get_dialect_pool_classcCsDd |j d¡dd¡}zt|dWntk
r>YnXdS)NÚ.réÿÿÿÿz
.provision)ÚjoinÚ
__module__ÚsplitÚ
__import__ÚImportError)r¤Úpackager}r}r~Úload_provisioningìs
z DefaultDialect.load_provisioningzOptional[_ListenerFnType]cs"jdk    rfdd}|SdSdS)Ncs |j¡dSr)Ú_assert_and_set_isolation_levelrx)Ú
dbapi_connZconn_recrr}r~Úbuiltin_connect÷sÿz:DefaultDialect._builtin_onconnect.<locals>.builtin_connect)rx)r|r²r}rr~Ú_builtin_onconnectôs
z!DefaultDialect._builtin_onconnectcCsÎz| |¡|_Wntk
r*d|_YnXz| |¡|_Wntk
rVd|_YnXz| |jj¡|_Wntk
rd|_YnX|j    s¢| 
|¡}|r¢||_|jrÊ|j|jkrÊt  d|j|jf¡dS)NzQLabel length of %d is greater than this dialect's maximum identifier length of %d)Z_get_server_version_infoÚserver_version_infoÚNotImplementedErrorZ_get_default_schema_namer`Úget_default_isolation_levelÚ
connectionÚdbapi_connectionÚdefault_isolation_levelrTÚ_check_max_identifier_lengthrgrhr!rp)r|r·Zmax_ident_lengthr}r}r~Ú
initializes>ÿ
ÿ
ÿ
 
ÿ
þ
þÿzDefaultDialect.initializecCsdSrr}rr}r}r~Ú
on_connect$szDefaultDialect.on_connectcCsdS)zôPerform a connection / server version specific check to determine
        the max_identifier_length.
 
        If the dialect's class level max_identifier_length should be used,
        can return None.
 
        .. versionadded:: 1.3.9
 
        Nr}©r|r·r}r}r~rº(s
z+DefaultDialect._check_max_identifier_lengthcCs
| |¡S)aÕGiven a DBAPI connection, return its isolation level, or
        a default isolation level if one cannot be retrieved.
 
        May be overridden by subclasses in order to provide a
        "fallback" isolation level for databases that cannot reliably
        retrieve the actual isolation level.
 
        By default, calls the :meth:`_engine.Interfaces.get_isolation_level`
        method, propagating any exceptions raised.
 
        .. versionadded:: 1.3.22
 
        )Zget_isolation_level©r|r±r}r}r~r¶4sz*DefaultDialect.get_default_isolation_levelcCst ||j¡S)a)Provide a database-specific :class:`.TypeEngine` object, given
        the generic object which comes from the types module.
 
        This method looks for a dictionary called
        ``colspecs`` as a class or instance-level variable,
        and passes on to :func:`_types.adapt_type`.
 
        )r'Z
adapt_typerW)r|Ztypeobjr}r}r~Útype_descriptorDs    zDefaultDialect.type_descriptorcKsP|j||fd|i|sdS|j||fd|i|D]}|d|kr4dSq4dS)NÚschemaFrT)Z    has_tableÚget_indexes)r|r·Z
table_nameZ
index_namerÀÚkwÚidxr}r}r~Ú    has_indexOsÿÿÿ
zDefaultDialect.has_indexrÚstr)r·Úschema_namerÂrcKs||j|f|kSr)Zget_schema_names)r|r·rÆrÂr}r}r~Ú
has_schemaZszDefaultDialect.has_schemacCs&t||jkr"t d||jf¡dS)Nz7Identifier '%s' exceeds maximum length of %d characters)Úlenrgr!ZIdentifierError)r|Úidentr}r}r~Úvalidate_identifier_sÿÿz"DefaultDialect.validate_identifiercOs|jj||Sr)rÚconnect)r|ZcargsZcparamsr}r}r~rËfszDefaultDialect.connectcCs| ¡}| |j¡g|gSr)Ztranslate_connect_argsÚupdateÚquery)r|r£Úoptsr}r}r~Úcreate_connect_argsjsz"DefaultDialect.create_connect_argsr1ÚNone)ÚenginerÎrcsJtj ¡}|rFt fdd|D¡t |d¡fdd}dS)Nc3s|]}||fVqdSrr}©Ú.0r©rÎr}r~Ú    <genexpr>wsz>DefaultDialect.set_engine_execution_options.<locals>.<genexpr>Zengine_connectcs |¡dSr)Ú_set_connection_characteristics)r·)rr|r}r~Úset_connection_characteristics{sÿzSDefaultDialect.set_engine_execution_options.<locals>.set_connection_characteristics)ÚsetÚconnection_characteristicsÚintersectionr#Ú immutabledictr Zlistens_for)r|rÑrÎÚsupported_namesr×r})rrÎr|r~Úset_engine_execution_optionsps
ÿÿ
z+DefaultDialect.set_engine_execution_options)r·rÎrcs<t|j ¡}|r8t fdd|D¡}| ||¡dS)Nc3s|]}||fVqdSrr}rÒrÔr}r~rÕszBDefaultDialect.set_connection_execution_options.<locals>.<genexpr>)rØrÙrÚr#rÛrÖ)r|r·rÎrÜrr}rÔr~Ú set_connection_execution_optionss
ÿÿz/DefaultDialect.set_connection_execution_optionsc    sfdd| ¡D}| ¡rNdd|D}|rNt dd dd|D¡¡|jj}|D]\}}}| ||¡qZ|jjj     
t j |¡¡dS)Ncs g|]\}}|j||fqSr})rÙ)rÓrÚvaluerr}r~Ú
<listcomp>sÿzBDefaultDialect._set_connection_characteristics.<locals>.<listcomp>cSs g|]\}}}|jr||fqSr})Z transactional)rÓrÚobjrßr}r}r~ràsþz¨This connection has already initialized a SQLAlchemy Transaction() object via begin() or autobegin; %s may not be altered unless rollback() or commit() is called first.ú, css|]\}}|VqdSrr})rÓrrár}r}r~rÕ szADefaultDialect._set_connection_characteristics.<locals>.<genexpr>)ÚitemsZin_transactionr!rr©r·r¸Zset_characteristicZ_connection_recordZfinalize_callbackÚappendÚ    functoolsÚpartialÚ_reset_characteristics)    r|r·rZcharacteristic_valuesZ
trans_objsr¸rÚcharacteristicrßr}rr~rÖs&
þþüÿ
ÿz.DefaultDialect._set_connection_characteristicscCs$|D]}|j|}| ||¡qdSr)rÙZreset_characteristic)r|rr¸Zcharacteristic_namerèr}r}r~rçªs
ÿz%DefaultDialect._reset_characteristicscCsdSrr}©r|r¸r}r}r~Údo_begin±szDefaultDialect.do_begincCs| ¡dSr)Úrollbackrér}r}r~Údo_rollback´szDefaultDialect.do_rollbackcCs| ¡dSr)Úcommitrér}r}r~Ú    do_commit·szDefaultDialect.do_commitcCs| |¡dSr)Údo_closerér}r}r~Údo_terminateºszDefaultDialect.do_terminatecCs| ¡dSr)Úcloserér}r}r~rï½szDefaultDialect.do_closecCstt d¡j|dS)Nr©Údialect)rÅr&ÚselectÚcompilerr}r}r~Ú_dialect_specific_select_oneÀsz+DefaultDialect._dialect_specific_select_oner9)r¸rc Cs z| |¡WS|jjk
r}zl| ||d¡}|jrzztj|||dddWn*tjk
rx}z
|j    }W5d}~XYnX|rWY¢
dSW5d}~XYnXdS)NFT)Ú is_disconnectZinvalidate_pool_on_disconnectZis_pre_ping)
Údo_pingrÚErrorr÷Ú_has_eventsrZ$_handle_dbapi_exception_noconnectionr!ZStatementErrorZconnection_invalidated)r|r¸Úerrr÷Znew_errr}r}r~Ú_do_ping_w_eventÄs$û
 
zDefaultDialect._do_ping_w_eventcCs,d}| ¡}z| |j¡W5| ¡XdS)NT)rrñÚexecuterö)r|r¸rr}r}r~røÛs
zDefaultDialect.do_pingcCsdt ddd¡S)z¼Create a random two-phase transaction ID.
 
        This id will be passed to do_begin_twophase(), do_rollback_twophase(),
        do_commit_twophase().  Its format is unspecified.
        z    _sa_%032xrré)ÚrandomÚrandintrr}r}r~Ú
create_xidåszDefaultDialect.create_xidcCs| t |¡¡dSr)rýr&ZSavepointClause©r|r·rr}r}r~Údo_savepointîszDefaultDialect.do_savepointcCs| t |¡¡dSr)rýr&ZRollbackToSavepointClauserr}r}r~Údo_rollback_to_savepointñsz'DefaultDialect.do_rollback_to_savepointcCs| t |¡¡dSr)rýr&ZReleaseSavepointClauserr}r}r~Údo_release_savepointôsz#DefaultDialect.do_release_savepointc#sHtt|}tt|j}|jdk    s(tt|j}|j     d|j
¡}d|rhg}    |    |_j}
j rp|jnd}
d}    | |||||
¡D]¾}|V|r| |¡}|    dk    s¨tj r8|js8j dk} jrê| rÐt|     t|t d¡d¡qjsôt| rj fdd|Dndd|Dtt|jkrXt d    t|jd
td¡z| rrfdd |jD}nfdd |jD}nRjdrÔdrÔdfdd |jD}nfdd |jD}Wn>tk
r*}zt d|jdd¡|W5d}~XYnX|     |¡q|     |¡qdS)Nr_Frr¨)Úkeycs i|]}t|d|qSr)Útuple©rÓÚrow)Ú_nscr}r~Ú
<dictcomp>6szDDefaultDialect._deliver_insertmanyvalues_batches.<locals>.<dictcomp>cSsi|]}|d|qS)r¨r}rr}r}r~r:szASentinel-keyed result set did not produce correct number of rows z; produced zP.  Please ensure the sentinel column is fully unique and populated in all cases.cs.g|]&tfddtjDqS)c3s*|]"\}}|r||n|VqdSrr})rÓZ    _resolverÚ_spk©Ú
parametersr}r~rÕOsþÿúNDefaultDialect._deliver_insertmanyvalues_batches.<locals>.<listcomp>.<genexpr>)rÚzipÚsentinel_param_keys©rÓ)ÚimvÚrows_by_sentinelÚsentinel_value_resolversr r~ràMsõþüÿzDDefaultDialect._deliver_insertmanyvalues_batches.<locals>.<listcomp>cs(g|] tfddjDqS)c3s|]}|VqdSrr})rÓrr r}r~rÕ`sÿr)rrr)rrr r~rà^súþÿrcsg|]}|qSr}r}©rÓr)Ú_sentinel_param_keyÚ_sentinel_value_resolverrr}r~ràqsûÿÿcsg|]}|qSr}r}r)rrr}r~rà{sýÿzACan't match sentinel values in result set to parameter sets; key z³ was not found. There may be a mismatch between the datatype passed to the DBAPI driver vs. that which it returns in a result row.  Try using a different datatype, such as integer)rÚDefaultExecutionContextr,ÚcompiledÚ_insertmanyvaluesÚAssertionErrorrZÚeffective_returningÚexecution_optionsrr_Ú_insertmanyvalues_rowsÚsort_by_parameter_orderÚnum_sentinel_columnsZ_imv_sentinel_value_resolversÚ!_deliver_insertmanyvalues_batchesÚfetchall_for_returningZ is_downgradedZimplicit_sentinelÚextendÚsortedÚoperatorÚ
itemgetterrrÈÚbatchr!rÚKeyErrorÚargs)r|rÚ    statementrZgeneric_setinputsizesÚcontextrZis_returningZ
batch_sizeÚresultr Z    imv_batchÚrowsZcomposite_sentinelZordered_rowsZker})r
rrrrrr~r"÷s
 
ÿÿû
 
 
ÿ
 
ÿÿ    ôù
 
ÿþÿú
ü
ÿø
z0DefaultDialect._deliver_insertmanyvalues_batchescCs| ||¡dSr)Úexecutemany©r|rr+rr,r}r}r~Údo_executemanyszDefaultDialect.do_executemanycCs| ||¡dSr©rýr0r}r}r~Ú
do_executeszDefaultDialect.do_executecCs| |¡dSrr2)r|rr+r,r}r}r~Údo_execute_no_paramssz#DefaultDialect.do_execute_no_paramscCsdS)NFr})r|Úer·rr}r}r~r÷szDefaultDialect.is_disconnectcCspzt| |¡}Wntk
r(YdSXdd|D}||krdtd|jdtt| |¡t|SdS)NcSsg|]}| dd¡ ¡qS)Ú_ú )ÚreplaceÚupper)rÓÚlevelr}r}r~rà¨sz@DefaultDialect._gen_allowed_isolation_levels.<locals>.<listcomp>rzi get_isolation_level_values() method should return names as UPPERCASE using spaces, not underscores; got )    ÚlistZget_isolation_level_valuesrµÚ
ValueErrorrr%rØÚ
differencer)r|r±Z
raw_levelsZnormalized_levelsr}r}r~Ú_gen_allowed_isolation_levels sÿÿz,DefaultDialect._gen_allowed_isolation_levelsc
CsZ| dd¡ ¡}| |¡}|rJ||krJt d|d|jdd |¡¡| ||¡dS)Nr6r7zInvalid value z1 for isolation_level. Valid isolation levels for z are râ)r8r9r>r!rprr©Zset_isolation_level)r|r±r:Z_allowed_isolation_levelsr}r}r~r°´sÿÿþÿz.DefaultDialect._assert_and_set_isolation_levelcCs| ||j¡dSr)r°r¹r¾r}r}r~Úreset_isolation_levelÆsÿz$DefaultDialect.reset_isolation_levelcCs\|dkrdS| ¡}| ¡}||kr(|S||kr@|j |¡s@|S||krTt|ddS|SdS)NT)Úquote)Úlowerr9rwÚ_requires_quotesr-©r|rZ
name_lowerZ
name_upperr}r}r~Únormalize_nameÎsÿþzDefaultDialect.normalize_namecCsD|dkrdS| ¡}| ¡}||kr(|S||kr@|j |¡s@|}|Sr)rAr9rwrBrCr}r}r~Údenormalize_nameèsÿþzDefaultDialect.denormalize_namecCs|Srr}r½r}r}r~Úget_driver_connectionùsz$DefaultDialect.get_driver_connectioncCstt||jtt|jk    Sr)rqrÚ__code__rJ)r|Úmethodr}r}r~Ú_overrides_defaultüs
ÿÿz!DefaultDialect._overrides_defaultcks¤g}g}    tj|kr*| |j¡|     |j¡tj|krL| |j¡|     |j¡tj|krb| |j    ¡| 
di¡}
|r|tjkr|tjkr|}nrg}d|i|}g} tj |kr´|  |¡tj|krÈ|  |    ¡| D]0}z| ||f|¡WqÌtk
rúYqÌXqÌ|rt|}|D]}|r$||kr||f}z ||||fd|i|fVWnNtjk
r}z||
krt||
|<W5d}~XYntjk
rYnXqdS)NÚ unreflectablerÀ)rZTABLEräZget_table_namesZget_temp_table_namesZVIEWZget_view_namesZget_temp_view_namesZMATERIALIZED_VIEWZget_materialized_view_namesÚpoprÚANYrYr$Ú    TEMPORARYrµrØr!ZUnreflectableTableErrorZNoSuchTableError)r|Zsingle_tbl_methodr·ÚkindrÀZfilter_namesZscoperÂZ    names_fnsZtemp_names_fnsrJÚnamesZname_kwÚfnsÚfnÚtablerrûr}r}r~Ú_default_multi_reflectsf
 
 
ÿþý
 
 
 
ÿÿÿþ
 
z%DefaultDialect._default_multi_reflectcKs|j|j|f|Sr)rSZget_table_options©r|r·rÂr}r}r~Úget_multi_table_optionsLsÿÿz&DefaultDialect.get_multi_table_optionscKs|j|j|f|Sr)rSZget_columnsrTr}r}r~Úget_multi_columnsQsz DefaultDialect.get_multi_columnscKs|j|j|f|Sr)rSZget_pk_constraintrTr}r}r~Úget_multi_pk_constraintTsÿÿz&DefaultDialect.get_multi_pk_constraintcKs|j|j|f|Sr)rSZget_foreign_keysrTr}r}r~Úget_multi_foreign_keysYsÿÿz%DefaultDialect.get_multi_foreign_keyscKs|j|j|f|Sr)rSrÁrTr}r}r~Úget_multi_indexes^sz DefaultDialect.get_multi_indexescKs|j|j|f|Sr)rSZget_unique_constraintsrTr}r}r~Úget_multi_unique_constraintsasÿÿz+DefaultDialect.get_multi_unique_constraintscKs|j|j|f|Sr)rSZget_check_constraintsrTr}r}r~Úget_multi_check_constraintsfsÿÿz*DefaultDialect.get_multi_check_constraintscKs|j|j|f|Sr)rSZget_table_commentrTr}r}r~Úget_multi_table_commentksÿÿz&DefaultDialect.get_multi_table_comment)N)N)N)N)§Ú__name__rªÚ__qualname__Ú__doc__r$r,Ústatement_compilerr*Úddl_compilerryrzÚIdentifierPreparerrvZsupports_alterZsupports_commentsZsupports_constraint_commentsZinline_commentsrZdiv_is_floordivrrrÚNONErsrKÚ__annotations__rLZdefault_sequence_baserÚexecute_sequence_formatZsupports_schemasZsupports_viewsÚsupports_sequencesÚsequences_optionalÚ"preexecute_autoincrement_sequencesÚsupports_identity_columnsÚpostfetch_lastrowidZfavor_returning_over_lastrowidZ#insert_null_pk_still_autoincrementsrrZupdate_returning_multifromZdelete_returning_multifromrZcte_follows_insertZsupports_native_enumrfZsupports_native_uuidZreturns_native_bytesZ#non_native_boolean_check_constraintÚsupports_simple_order_by_labelZtuple_in_valuesr#rÛrZIsolationLevelCharacteristicrÙZasintZbool_or_strZasboolrRZsupports_native_decimalrrgrTrMrUrVr¡Úsupports_sane_multi_rowcountrWruZsupports_default_valuesZsupports_default_metavalueZdefault_metavalue_tokenZsupports_empty_insertÚsupports_multivalues_insertr[r\r+Z NOT_SUPPORTEDr]r_Zinsertmanyvalues_max_parametersZsupports_is_distinct_fromrorbZsupports_for_update_ofr´r`Zrequires_name_normalizeZis_asyncZ has_terminateZ$_legacy_binary_type_literal_encodingZdeprecated_paramsr)r{r^Z
NO_LINTINGrÚpropertyÚ
deprecatedrÚmemoized_propertyrrÚupdate_executemany_returningÚdelete_executemany_returningrrrrrr r¢Úclassmethodr¥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ørrrrr"r1r3r4r÷Zmemoized_instancemethodr>r°r?rDrErFrIrSrUrVrWrXrYrZr[r\r}r}r}r~rJpsh
 
ÿùÿÿ
    öò(Rþ
 
 
 
 
 
 
 
 
$
 
 
    
 
 
 
JrJc@sPeZdZejZejZejZ    ej
ZdZdZ dZdZdZdZdZdZdZdZdZdS)ÚStrCompileDialectTFN)r]rªr^r$ZStrSQLCompilerr`r*raZStrSQLTypeCompilerrzrbrvrrrrrirfrgrhrfrmrkr}r}r}r~rtqsrtc @s$eZdZUdZdZdZdZdZdZe    j
Zded<dZ ded<dZded<dZd    ed
<ejZded<ejZdZd ed<dZdZdZdZdZdZdZded<e ¡Zded<e Z!ded<ded<ded<ded<ded<ded<ded <d!ed"<e"d#ejZ#dZ$d$ed%<d&Z%d'ed(<e&ddddd)d*d+d,d-Z'e&e(j)fddddd.d/d0d!d1d*d2
d3d4Z*e&ddddddd*d5d6d7Z+e&ddddd*d8d9d:Z,dd;d<d=Z-e.d>d?Z/ej0d@dAZ1ej0dBdCZ2ej0dDd;dEdFZ3ej0dDd;dGdHZ4ej0dIdJZ5ddKdLZ6ej0dMdNZ7dOdPZ8dQdRZ9dSdTZ:dUdVZ;dWdXZ<dYdZZ=d[d\Z>d]d^Z?d_d`Z@dadbZAdcddZBejCd'd;dedfZDdgdhZEdidjZFdkdlZGdmdnZHdodpZIej0dqdrZJdsdtZKdudvZLdwdxZMdydzZNd{d;d|d}ZOd~dZPddZQdZRded<dddZSddZTddZUddZVdS)rFrÚ execute_styleNzOptional[Compiled]rzAOptional[Tuple[List[ResultColumnsEntry], bool, bool, bool, bool]]Úresult_column_structzOptional[Sequence[Row[Any]]]Úreturned_default_rowsr6rzOptional[Executable]Úinvoked_statementzOptional[Callable[[str], str]]Ú_translate_colnamezMapping[str, List[str]]Ú_expanded_parametersrÚroot_connectionr?Ú_dbapi_connectionrrórÅÚunicode_statementrrz%List[_MutableCoreSingleExecuteParams]Úcompiled_parametersr5rz&Optional[Sequence[BindParameter[Any]]]Úextracted_parametersrQzOptional[List[Tuple[Any, ...]]]rrr^Ú_num_sentinel_colsr*r)rór·r¸rÚcompiled_ddlrc
Cs¢| |¡}||_||_|j|_||_}d|_||_t||_|j    rh|j 
di¡}|jj}    |    |j||_|j|_ | ¡|_g|_|jr| ¡g|_n
|jg|_|S)zKInitialize execution context for an ExecutableDDLElement
        construct.TÚschema_translate_map)Ú__new__r{r|rórÚisddlrrÅr}rrrvÚ_render_schema_translatesr+Ú create_cursorrr~rtrerÚ_empty_dict_params)
r¤rór·r¸rrr|rrÚrstr}r}r~Ú    _init_ddlÅs2
 
 
ÿÿ
 
z!DefaultExecutionContext._init_ddlr,r2r@r)
rór·r¸rrrrxrÚ    cache_hitrc
sØ| |¡}
||
_||
_|j|
_|
_||
_|
_|    |
_||
_j    j
jjj f|
_j|
_}j|
_}j|
_} j|
_|s|s| rÈjj}trªt|tsªtd|
_t|j|
_}tj|
_}|rà|j ràd|
_!|rì|rìt|sö|rÈj"rÈ|r&|
jj#s&t$ %d|
jj&d¡n¢|rV|j'rV|
jj(sVt$ %d|
jj&d¡nr|rz|
jj)rzj*szt$ %d¡nN|r¢|
jj+s¢t$ %d|
jj&d¡n&| rÈ|
jj,sÈt$ %d|
jj&d¡|sâj-dd    g|
_.ndfd
dt/|D|
_.t0|dkrF|
jr>j*r>t1j2|
_3j*}|j4d k    rF|j5|
_6nt1j7|
_3j8|
_9|
 :¡|
_;|
jj<sl|
jj=rt|
 >¡j?}|j@sjArÜ|
jBr t$ %d¡ C|
j.d¡}|j|
_9|jD|
_EtF| G|jH¡|jI}njJrî|
jjI}nd }jKr|
j Ldi¡}jMjN}||
j9||
_9|
j9|
_jJrzg}|d k    s@t|
j.D]*fdd|D}| O| P|¡¡qF||
_QnZg}jR|
j.D]Br¬fddD}nfddD}| O|¡q||
_Q|
S)z6Initialize execution context for a Compiled construct.Trz] with current server capabilities does not support INSERT..RETURNING when executemany is usedz} with current server capabilities does not support INSERT..RETURNING with deterministic row ordering when executemany is usedznStatement does not have "insertmanyvalues" enabled, can't use INSERT..RETURNING with executemany in this case.z] with current server capabilities does not support UPDATE..RETURNING when executemany is usedz] with current server capabilities does not support DELETE..RETURNING when executemany is usedF)rÚescape_namescs"g|]\}}j|d|dqS)F)rZ _group_numberr)Úconstruct_params)rÓÚgrpÚm)rrr}r~ràYsúüz:DefaultExecutionContext._init_compiled.<locals>.<listcomp>rNzL'literal_execute' or 'expanding' parameters can't be used with executemany()rrcs,g|]$}|kr ||n|qSr}r}©rÓr©Úcompiled_paramsÚflattened_processorsr}r~rà§sþÿcs6i|].} ||¡|kr*||n|qSr})rr)rÚ escaped_namesrr}r~r¾sû
ýÿz:DefaultExecutionContext._init_compiled.<locals>.<dictcomp>cs.i|]&}||kr"||n|qSr}r}rrr}r~rÇs
ýÿ)Srr{r|rórrxrrrZ_result_columnsZ_ordered_columnsZ_textual_ordered_columnsZ_ad_hoc_textualZ_loose_column_name_matchingrvÚisinsertÚisupdateÚisdeleteZisplaintextÚis_textÚ compile_stater+rrrErÚis_crudrZZ
_returningÚ_is_explicit_returningreÚ_is_implicit_returningZ_supplemental_returningÚ_is_supplemental_returningZfor_executemanyrr!rr Z_sort_by_parameter_orderrr[rrqrrrr~Ú    enumeraterÈrÚINSERTMANYVALUESruZsentinel_columnsr!rÚEXECUTEMANYÚstringr}rrÚinsert_prefetchÚupdate_prefetchÚ_process_execute_defaultsÚ_bind_processorsÚliteral_execute_paramsZpost_compile_paramsr/Z#_process_parameters_for_postcompileZparameter_expansionrzÚdictrÌÚ
processorsÚpositiontuprtrrrvrrärerÚescaped_bind_names)r¤rór·r¸rrrrxrrr|ÚiiÚiuZid_Z dml_statementZierZiirrr§Zexpanded_stater¨rrZcore_positional_parametersZl_paramZcore_dict_parametersZd_paramr})rrrrrr~Ú_init_compiledòs
ûÿ
 
ÿÿþýÿÿþýÿÿÿþÿù
 
 
þÿÿ
ÿÿ
üÿ
ú    üz&DefaultExecutionContext._init_compiled)rór·r¸rr+rrcsÀ| |¡}||_||_|j|_d|_||_|sP|jjrD ¡g|_q|j    g|_nBt
|djrh||_n*t
|dtr~||_nfdd|D|_t|dkr¦t j|_||_|_| ¡|_|S)z8Initialize execution context for a string SQL statement.Trcsg|]} |¡qSr})re)rÓÚpròr}r~ràòsz;DefaultExecutionContext._init_statement.<locals>.<listcomp>r)rr{r|rórrrtrerrrr¦rÈrrrur+r}rr)r¤rór·r¸rr+rr|r}ròr~Ú_init_statementÔs,
 
ÿ
z'DefaultExecutionContext._init_statement)rór·r¸rrcCs2| |¡}||_||_|j|_||_| ¡|_|S)z;Initialize execution context for a ColumnDefault construct.)rr{r|rórrr)r¤rór·r¸rr|r}r}r~Ú _init_defaultþs
 
 
z%DefaultExecutionContext._init_defaultrcCs°|jdkrdSt}|j}|jj}|dk    s.t|tkrDd||fS|tkrZd||fS|tkrpd||fS|tkrd||fS|t    kr¨d|j
j|j
j||fSdSdS)Nzraw sqlzno key %.5fszcached since %.4gs agozgenerated in %.5fszcaching disabled %.5fsz,dialect %s+%s does not support caching %.5fsÚunknown) rrrZ    _gen_timerÚNO_CACHE_KEYÚ    CACHE_HITÚ
CACHE_MISSÚCACHING_DISABLEDÚNO_DIALECT_SUPPORTrórr)r|ÚnowÚchZgen_timer}r}r~Ú_get_cache_statss*
ýz(DefaultExecutionContext._get_cache_statscCs|jtjtjfkSr)rurrrrr}r}r~r/.sþz#DefaultExecutionContext.executemanycCs8|jr|jjSd|jkr,|jj |jd¡S|jjSdS)Nr)rrvrrórwZ_with_schema_translaterr}r}r~rw5s
ÿz+DefaultExecutionContext.identifier_preparercCs|jjSr)r{rÑrr}r}r~rÑ@szDefaultExecutionContext.enginezOptional[Sequence[Column[Any]]]cCstrt|jtst|jjSr)rrrr,rÚ    postfetchrr}r}r~Úpostfetch_colsDsz&DefaultExecutionContext.postfetch_colscCs8trt|jtst|jr"|jjS|jr0|jjSdSdS)Nr})    rrrr,rrr¡rr¢rr}r}r~Ú prefetch_colsJsz%DefaultExecutionContext.prefetch_colscCs|j dd¡S)NÚ no_parametersF)rrrr}r}r~r¼Usz%DefaultExecutionContext.no_parametersc
Cs²|j}d|jkr0|j di¡}|jj}|||}|sL|jjrH|j ¡}ni}|j|j    |||d|j     
¡}|dk    r||d}nd}|dk    r®| |j|j    jdd¡}    |    r®|    |S|S)aExecute a string statement on the current cursor, returning a
        scalar result.
 
        Used to fire off sequences, default phrases, and "select lastrowid"
        types of statements individually or in the context of a parent INSERT
        or UPDATE statement.
 
        r)r,Nrr) r{rrrwrrórtreZ_cursor_executerZfetchoneÚ_cached_result_processorÚdescription)
r|ZstmtÚtype_rÚconnrrr    ÚrÚprocr}r}r~Ú_execute_scalarYs2
 
ÿ
 
 
ÿz'DefaultExecutionContext._execute_scalarcCs|jSr)r{rr}r}r~r·sz"DefaultExecutionContext.connectioncCsv|jjsdS|jjrd|j dd¡o`|jr8t|jjtj    p`|jsPt|jjtj
o`|jo`t  |j¡}n|j dd¡}|S)NFÚstream_resultsT)rórorbrrrrr+r&Z
SelectableZ
TextClauser}ÚSERVER_SIDE_CURSOR_REÚmatch)r|Zuse_server_sider}r}r~Ú_use_server_side_cursors2ÿÿÿþú
óÿz/DefaultExecutionContext._use_server_side_cursorcCsF|jjr4|j dd¡s&|jjr4| ¡r4d|_| ¡Sd|_| ¡SdS)NrÄFT)    rórorrrbrÇÚ_is_server_sideÚcreate_server_side_cursorÚcreate_default_cursorrr}r}r~r£sþüúùz%DefaultExecutionContext.create_cursorcCs| ¡Sr)Zfetchall)r|rr}r}r~r#µsz.DefaultExecutionContext.fetchall_for_returningcCs
|j ¡Sr)r|rrr}r}r~rÊ¸sz-DefaultExecutionContext.create_default_cursorcCs
tdSr©rµrr}r}r~rÉ»sz1DefaultExecutionContext.create_server_side_cursorcCsdSrr}rr}r}r~Úpre_exec¾sz DefaultExecutionContext.pre_execcCstddS)Nz,This dialect does not support OUT parametersrË)r|rOr}r}r~Úget_out_parameter_valuesÁsÿz0DefaultExecutionContext.get_out_parameter_valuescCsdSrr}rr}r}r~Ú    post_execÆsz!DefaultExecutionContext.post_execcCs| |j|¡S)zÚReturn a 'result processor' for a given type as present in
        cursor.description.
 
        This has a default implementation that dialects can override
        for context-sensitive result type handling.
 
        )r½ró)r|r¿ZcolnameZcoltyper}r}r~Úget_result_processorÉsz,DefaultExecutionContext.get_result_processorcCs|jjS)a return self.cursor.lastrowid, or equivalent, after an INSERT.
 
        This may involve calling special cursor functions, issuing a new SELECT
        on the cursor (or a new one), or returning a stored value that was
        calculated within post_exec().
 
        This function will only be called for dialects which support "implicit"
        primary key generation, keep preexecute_autoincrement_sequences set to
        False, and when no explicit id value was bound to the statement.
 
        The function is called once for an INSERT statement that would need to
        return the last inserted primary key for those dialects that make use
        of the lastrowid concept.  In these cases, it is called directly after
        :meth:`.ExecutionContext.post_exec`.
 
        )rÚ    lastrowidrr}r}r~Ú get_lastrowidÓsz%DefaultExecutionContext.get_lastrowidcCsdSrr})r|r5r}r}r~Úhandle_dbapi_exceptionæsz.DefaultExecutionContext.handle_dbapi_exceptioncCs|jjSr)rÚrowcountrr}r}r~rÓész DefaultExecutionContext.rowcountcCs|jjSr)rór¡rr}r}r~r¡ísz.DefaultExecutionContext.supports_sane_rowcountcCs|jjSr)rórlrr}r}r~rlðsz4DefaultExecutionContext.supports_sane_multi_rowcountcCsÐ|j}|js|jr$| ¡}d}}nl| dd¡}|jp@| dd¡}|j}|rf|tjkrft     |j
|j¡}|jpr|j
j}|dkrtj }t |||¡}|j}|r¶|js¶tt|jr¶| |¡|j|_|rÌ| |¡}|S)NFÚ    yield_perrÄ)rrrÚ_setup_dml_or_text_resultrrÈÚcursor_fetch_strategyÚ_cursorÚ_DEFAULT_FETCHÚBufferedRowCursorFetchStrategyrÚalternate_cursor_descriptionr¾Z_NO_CURSOR_DQLÚCursorResultrrrr,Zhas_out_parametersÚ_setup_out_parametersÚ_soft_closedrÔ)r|Zexec_optr-ZypÚsrÚstrategyÚcursor_descriptionrr}r}r~Ú_setup_result_proxyós<
ÿþÿþ
ý
 
z+DefaultExecutionContext._setup_result_proxycCs¤tt|j}dd|j ¡D}i}tdd|D| dd|D¡D]P\}}|j}| |j    ¡}| 
|j    j¡}    | |j    |    ¡}
|
dk    r|
|}|||j <qH||_dS)NcSsg|]\}}|jr||fqSr})Z
isoutparam©rÓÚparamrr}r}r~ràsþzADefaultExecutionContext._setup_out_parameters.<locals>.<listcomp>cSsg|]\}}|qSr}r}râr}r}r~rà%scSsg|]\}}|qSr}r}râr}r}r~rà's)rr,rÚ
bind_namesrãrrÍrZdialect_implróZget_dbapi_typerÚresult_processorrÚout_parameters)r|r-rZout_bindparamsræÚ    bindparamZ    raw_valuer¿Z    impl_typeZ
dbapi_typerår}r}r~rÜs,þÿþÿz-DefaultExecutionContext._setup_out_parameterscCsÂtt|j}|j}|jrP|jtjkr@|jr@t    j
|j|j|j d}|jrP| ¡|_|jrp|t    jkrpt     |j|j¡}|j p||jj}|dkrt    j}n&|jr´|jtjks¤t|d|j}t     |||¡}|jr*|jr| ¡}||_| ||¡|_|jjsút|j r| !|¡n| "¡n|j#s¾| "¡n|jr| ¡}|rF||_t$||_%d|_&|j rj| !|¡n| "¡|jjs¾tn<|jjs¢|j%d|_&| "¡n|j's²|j(r¾|j%d|_&|S)N)Zinitial_bufferZalternate_descriptionrT))rr,rrÖrrurrrr×Z FullyBufferedCursorFetchStrategyrrrÚrjÚ_setup_ins_pk_from_lastrowidÚinserted_primary_key_rowsrÈrØrÙrr¾Z_NO_CURSOR_DMLrrrÛrÚallrwÚ%_setup_ins_pk_from_implicit_returningÚ    _metadataZreturns_rowsrÚ_rewindZ_soft_closerrÈrÓÚ _has_rowcountrr)r|rrßràr-r.r}r}r~rÕ7s
ÿþú
ÿÿÿÿÿ
ÿ
 
 
 
 
z1DefaultExecutionContext._setup_dml_or_text_resultcCs| ¡Sr)Ú_setup_ins_pk_from_emptyrr}r}r~ré¤sz1DefaultExecutionContext.inserted_primary_key_rowscCs(tt|jj}| ¡}|||jdgS)Nr)rr,rÚ+_inserted_primary_key_from_lastrowid_getterrÑr~)r|ÚgetterrÐr}r}r~rè«sÿz4DefaultExecutionContext._setup_ins_pk_from_lastrowidcs"tt|jjfdd|jDS)Ncsg|]}d|qSrr})rÓrã©rñr}r~rà¶szDDefaultExecutionContext._setup_ins_pk_from_empty.<locals>.<listcomp>)rr,rrðr~rr}ròr~rï²s
ÿz0DefaultExecutionContext._setup_ins_pk_from_emptycs4|sgStt|jj|j}fddt||DS)Ncsg|]\}}||qSr}r})rÓr    rãròr}r~ràÂszQDefaultExecutionContext._setup_ins_pk_from_implicit_returning.<locals>.<listcomp>)rr,rZ+_inserted_primary_key_from_returning_getterr~r)r|r-r.rr}ròr~rë¸sÿ
ÿz=DefaultExecutionContext._setup_ins_pk_from_implicit_returningcCs|js|jottt|jjSr)rrrZrr,rr¹rr}r}r~Úlastrow_has_defaultsÆsÿz,DefaultExecutionContext.lastrow_has_defaultsz0Optional[List[Tuple[str, Any, TypeEngine[Any]]]]cs|js|jrdStt|j ¡}|dkr0dS|j}|jr^t|}|j     
||j|j|j |¡jrljnd|jrfddjpdD}nddj ¡D}g}|D]Ò\}jkrÀq¬||jkrFtjrtjj|| fddt|j|D¡n.| d¡| fdd|j|D¡q¬| d¡dk    rh ||¡n|}| |jf¡q¬|S)    aGiven a cursor and ClauseParameters, prepare arguments
        in order to call the appropriate
        style of ``setinputsizes()`` on the cursor, using DB-API types
        from the bind parameter's ``TypeEngine`` objects.
 
        This method only called by those dialects which set
        the :attr:`.Dialect.bind_typing` attribute to
        :attr:`.BindTyping.SETINPUTSIZES`.   cx_Oracle is the only DBAPI
        that requires setinputsizes(), pyodbc offers it as an option.
 
        Prior to SQLAlchemy 2.0, the setinputsizes() approach was also used
        for pg8000 and asyncpg, which has been changed to inline rendering
        of casts.
 
        Ncsg|]}|j|fqSr})Zbindsr)rr}r~rà÷sÿzDDefaultExecutionContext._prepare_set_input_sizes.<locals>.<listcomp>r}cSsg|]\}}||fqSr}r})rÓrçrr}r}r~ràüsÿc3sD|]<\}}dk    r ||¡n||jj|fVqdSr)rrÚtypes)rÓrÃÚ    paramname)rçÚdbtypesr©Únumr}r~rÕ
s
úÿ
ùzCDefaultExecutionContext._prepare_set_input_sizes.<locals>.<genexpr>c3s.|]&}dk    r ||¡n|jfVqdSr)rr)rÓrõ)rçÚdbtyper©r}r~rÕs
úÿù)rrrr,rZ_get_set_input_sizes_lookuprórúr¦ÚdispatchZdo_setinputsizesrr+rr©rtr¨rärãr¥rzr(rrÈrôr$rrrä)r|Z
inputsizesrórãZgeneric_inputsizesrZescaped_namer})rçrrørör©r÷r~Ú_prepare_set_input_sizesËshÿ
þþ
 
ÿö
 
ö
 ÿý
ÿz0DefaultExecutionContext._prepare_set_input_sizescCsF|jr| ||¡S|jr(||_| |¡S|jr<| |||¡S|jSdSr)Zis_sequenceZ fire_sequenceÚis_callableÚcurrent_columnrZis_clause_elementÚ_exec_default_clause_element)r|ÚcolumnrSr¿r}r}r~Ú _exec_default5s
z%DefaultExecutionContext._exec_defaultcs|jst |j|¡}n|j}t |¡j|jd}| ¡|j|j    rh|j 
fdd|jp^dD¡}nfddD}|jt |||dS)Nròcs,g|]$}|kr ||n|qSr}r}r©rr§r}r~ràUsþÿzHDefaultExecutionContext._exec_default_clause_element.<locals>.<listcomp>r}cs.i|]&}||kr"||n|qSr}r}rrr}r~r]s
ýÿzHDefaultExecutionContext._exec_default_clause_element.<locals>.<dictcomp>r )Z _arg_is_typedr&Ztype_coercerrôrõrórr¤rtrer¨rÃrÅ)r|rþrSr¿Zdefault_argrrr}rr~rýDs(üÿ    üÿz4DefaultExecutionContext._exec_default_clause_elementz"Optional[_CoreSingleExecuteParams]Úcurrent_parametersTcsòz|j|j}Wntk
r.t d¡YnX|dk    s<tdk    sHttdtt|jj    }|dk    sht|rêt
 |¡rê|jrê|j r |jd|jj|ji}n|j|ji}d|jdk    sÂt|j ¡}| fdd|D¡|SSdS)aiReturn a dictionary of parameters applied to the current row.
 
        This method can only be used in the context of a user-defined default
        generation function, e.g. as described at
        :ref:`context_default_functions`. When invoked, a dictionary is
        returned which includes entries for each column/value pair that is part
        of the INSERT or UPDATE statement. The keys of the dictionary will be
        the key value of each :class:`_schema.Column`,
        which is usually synonymous
        with the name.
 
        :param isolate_multiinsert_groups=True: indicates that multi-valued
         INSERT constructs created using :meth:`_expression.Insert.values`
         should be
         handled by returning only the subset of parameters that are local
         to the current column default invocation.   When ``False``, the
         raw parameters of the statement are returned including the
         naming convention used in the case of multi-valued INSERT.
 
        .. versionadded:: 1.2  added
           :meth:`.DefaultExecutionContext.get_current_parameters`
           which provides more functionality over the existing
           :attr:`.DefaultExecutionContext.current_parameters`
           attribute.
 
        .. seealso::
 
            :attr:`.DefaultExecutionContext.current_parameters`
 
            :ref:`context_default_functions`
 
        zdget_current_parameters() can only be invoked in the context of a Python side column default functionNrDrrc3s"|]}|d|ffVqdS)z%s_m%dNr}r©Úindexrr}r~rÕ½szADefaultExecutionContext.get_current_parameters.<locals>.<genexpr>)rrüÚAttributeErrorr!rrrr,rrr%rZ_has_multi_parametersZ_is_multiparam_columnrÚoriginalrZ_dict_parametersÚkeysrÌ)r|Zisolate_multiinsert_groupsrþrÚdrr}rr~Úget_current_parameterss@!
ÿ
ÿÿþý
 
ÿz.DefaultExecutionContext.get_current_parameterscCs$|jdkrdS| ||j|j¡SdSr)rSrÿr©r|rþr}r}r~Úget_insert_defaultÄs
z*DefaultExecutionContext.get_insert_defaultcCs$|jdkrdS| ||j|j¡SdSr)Zonupdaterÿrr    r}r}r~Úget_update_defaultÊs
z*DefaultExecutionContext.get_update_defaultc sÞttj}|jd}|jr4fdd|jD}n"|jrRfdd|jD}ng}jD]x}|_|D]h\}}\}}}    }
}|
r|||<|d7}qj|r¢|||<qj|    rº|_|||<qj||}|dk    rj|||<qjq\`dS)Nrcs g|]}|||jjfqSr})Z_default_description_tupler
©rÓÚc©Z
key_getterr|r}r~ràØsûüzEDefaultExecutionContext._process_execute_defaults.<locals>.<listcomp>cs g|]}|||jjfqSr})Z_onupdate_description_tuplerrrr}r~ràâsûür)    rr,rZ_within_exec_param_key_getterr¡r¢r~rrü) r|rZsentinel_counterZ prefetch_recsrãr Z    param_keyrZ    is_scalarrûZis_sentinelÚfallbackÚvalr}rr~r£Ðs@ù    ù
 
û
 
 
z1DefaultExecutionContext._process_execute_defaults)N)T)Wr]rªr^rrrrrrrZEXECUTErurdrrvrwr#Ú
EMPTY_DICTrr×rØrÖrxrrrrÈrÝrîryrÛrzr±rrrrrrsrrr´r¬r®r¯r¸rnr/rprwrÑrºr»r¼rÃr·rÇrr#rÊrÉrÌrÍrÎrÏrÑrÒZnon_memoized_propertyrÓr¡rlrárÜrÕrérèrïrërórúrÿrýrrr
rr£r}r}r}r~rs¸
þ
,ö$b)
 
 
 
 
 
 
)
 
'm
j#
Dr)mr_Ú
__future__rrår&rÿÚreÚtimerÚtypingrrrrrr    r
rrr rrrrrrÚrrr×rÚbaserrrrrrZ
reflectionrrr r!r"r#Zsqlr$r%r&r'Zsql._typingr(Zsql.baser)Zsql.compilerr*r+r,Zsql.elementsr-Zutil.typingr.r/rôr0r1r2r3r4r5r6r7r8r9r:r    r;r£r<r=r>r?r@rArBrCZsql.dmlrDrErFZ
sql.schemarGZsql.type_apirHrIrõÚIÚUNICODErÅr;r²r³r´r±rµrJrtrZexecution_ctx_clsr}r}r}r~Ú<module>    sÔ    ú