mirror of
https://github.com/CCOSTAN/Home-AssistantConfig.git
synced 2026-02-15 07:50:29 +00:00
77 lines
12 KiB
Plaintext
77 lines
12 KiB
Plaintext
|
<EFBFBD>
|
|||
|
|
}<7D><>W<EFBFBD>$ <00> @ sw d d l m Z d d l Z d d l m Z d d l m Z d d l m Z m Z d d l Z d d l
|
|||
|
|
Z
|
|||
|
|
Gd d <00> d e <00> Z e <00> Z
d
|
|||
|
|
d <00> Z e d d
<00> <00> Z e d d <00> <00> Z e d d <00> <00> Z e d d <00> <00> Z d d d <00> Z Gd d <00> d e <00> Z d d d d <00> Z d d d d <00> Z d d d <00> Z Gd d <00> d e <00> Z Gd d! <00> d! e <00> Z e e d" d# <00> Z d S)$<24> )<01>absolute_importN<74> )<01>config)<01> decorator<6F> )<02>event<6E>poolc @ s<> e Z d Z d d <00> Z d d <00> Z d d <00> Z d d <00> Z d d
|
|||
|
|
<00> Z d d <00> Z d
d <00> Z d d <00> Z
|
|||
|
|
d d <00> Z d d <00> Z d d <00> Z
d d <00> Z d d <00> Z d S) <1C>ConnectionKillerc C s. t j <00> | _ t j <00> | _ t <00> | _ d S)N)<06>weakref<65>WeakKeyDictionary<72>
|
|||
|
|
proxy_refs<EFBFBD>testing_engines<65>set<65>conns)<01>self<6C> r <00>@/tmp/pip-build-zkr322cu/sqlalchemy/sqlalchemy/testing/engines.py<70>__init__ s zConnectionKiller.__init__c C s d | j | <d S)NT)r
)r <00>enginer r r <00>
|
|||
|
|
add_engine s zConnectionKiller.add_enginec C s | j j | | f <00> d S)N)r <00>add)r Z
|
|||
|
|
dbapi_conn<EFBFBD>
|
|||
|
|
con_recordr r r <00>connect s zConnectionKiller.connectc C s d | j | <d S)NT)r )r <00> dbapi_conr Z con_proxyr r r <00>checkout s zConnectionKiller.checkoutc C s | j j | | f <00> d S)N)r <00>discard)r r r <00> exceptionr r r <00>
|
|||
|
|
invalidate" s zConnectionKiller.invalidatec C sH y | <00> Wn6 t k
|
|||
|
|
rC } z t j d | <16> WYd d } ~ Xn Xd S)Nz5testing_reaper couldn't rollback/close connection: %s)<03> Exception<6F>warnings<67>warn)r <00>fn<66>er r r <00>_safe% s zConnectionKiller._safec C sF x? t | j <00> D]. } | d k r | j r | j | j <00> q q Wd S)N)<05>listr <00>is_validr# <00>rollback)r <00>recr r r <00> rollback_all- s z ConnectionKiller.rollback_allc C sF x? t | j <00> D]. } | d k r | j r | j | j <00> q q Wd S)N)r$ r r% r# Z_close)r r' r r r <00> close_all2 s zConnectionKiller.close_allc C s4 x- t | j <00> D] \ } } | j | j <00> q Wd S)N)r$ r r# r& )r <00>connr' r r r <00>_after_test_ctx7 s z ConnectionKiller._after_test_ctxc C s' t j j r | j <00> n
|
|||
|
|
| j <00> d S)N)r <00>optionsZlow_connections<6E>_stop_test_ctx_minimal<61>_stop_test_ctx_aggressive)r r r r <00>_stop_test_ctx@ s
z ConnectionKiller._stop_test_ctxc C sP | j <00> t <00> | _ x3 t | j <00> D]" } | t j k r& | j <00> q& q& Wd S)N)r) r r r$ r
r <00>db<64>dispose)r r' r r r r- F s
|
|||
|
|
|
|||
|
|
z'ConnectionKiller._stop_test_ctx_minimalc C sw | j <00> x6 t | j <00> D]% \ } } | j | j <00> d | _ q Wt <00> | _ x! t | j <00> D] } | j <00> q_ Wd S)N) r) r$ r r# <00>close<73>
|
|||
|
|
connectionr r
r1 )r r* r' r r r r. O s
|
|||
|
|
z*ConnectionKiller._stop_test_ctx_aggressivec C s0 x) | j D] } | j r
|
|||
|
|
d s( t <00> q
|
|||
|
|
q
|
|||
|
|
Wd S)NF)r r% <00>AssertionError)r r' r r r <00>assert_all_closedY s z"ConnectionKiller.assert_all_closedN)<10>__name__<5F>
|
|||
|
|
__module__<EFBFBD> __qualname__r r r r r r# r( r) r+ r/ r- r. r5 r r r r r s
|
|||
|
|
r c C s<> t j <00> t | d <00> r& | j <00> n t j j j sq d d l m } | j
|
|||
|
|
d d d <00><01> | j | <00> Wd QXn
| j | <00> d S)Nr2 r )<01>
|
|||
|
|
assertionszCan't sort tablesZassert_F) <0C>testing_reaperr) <00>hasattrr2 r r0 <00>dialectZsupports_alter<65> r9 Zexpect_warningsZdrop_all)<03>metadata<74>bindr9 r r r <00>drop_all_tablesa s
|
|||
|
|
r@ c
|
|||
|
|
O s# z | | | <00> Wd t j <00> Xd S)N)r: r5 )r! <00>args<67>kwr r r <00>assert_conns_closedo s rC c
|
|||
|
|
O s# z | | | <00> Wd t j <00> Xd S)zBDecorator that rolls back all open connections after fn execution.N)r: r( )r! rA rB r r r <00>rollback_open_connectionsw s rD c O s t j <00> | | | <00> d S)z:Decorator that closes all connections before fn execution.N)r: r) )r! rA rB r r r <00> close_first<73> s
|
|||
|
|
rE c
|
|||
|
|
O s# z | | | <00> Wd t j <00> Xd S)z9Decorator that closes all connections after fn execution.N)r: r) )r! rA rB r r r <00>close_open_connections<6E> s rF c c s<> d d l j } xk | j D]` } | r7 | | k r7 q n t | | d <00> } | sn t t d | <16> j | <00> } n | j <00> Vq Wd S)Nr zsqlalchemy.databases.%s)Zsqlalchemy.databasesZ databases<65>__all__<5F>getattr<74>
|
|||
|
|
__import__r< )<04>exclude<64>d<>name<6D>modr r r <00> all_dialects<74> s rN c @ sL e Z d Z d d <00> Z d d <00> Z d d <00> Z d d <00> Z d d
|
|||
|
|
<00> Z d S) <0C>ReconnectFixturec C s | | _ g | _ d S)N)<02>dbapi<70> connections)r rP r r r r <00> s zReconnectFixture.__init__c C s t | j | <00> S)N)rH rP )r <00>keyr r r <00> __getattr__<5F> s z ReconnectFixture.__getattr__c O s) | j j | | <00> } | j j | <00> | S)N)rP r rQ <00>append)r rA <00>kwargsr* r r r r <00> s zReconnectFixture.connectc C sH y | <00> Wn6 t k
|
|||
|
|
rC } z t j d | <16> WYd d } ~ Xn Xd S)Nz.ReconnectFixture couldn't close connection: %s)r r r )r r! r" r r r r# <00> s zReconnectFixture._safec C s7 x' t | j <00> D] } | j | j <00> q Wg | _ d S)N)r$ rQ r# r2 )r <00>cr r r <00>shutdown<77> s zReconnectFixture.shutdownN)r6 r7 r8 r rS r r# rW r r r r rO <00> s
|
|||
|
|
rO c s<> | p t j j } t j j j } | s0 i } n t | <00> | d <t | | <00> <00> <00> j <00> <00> <00> f d d <00> } <00> j j j <00> _ | <00> _ <00> S)N<>modulec s <00> j j j <00> <01> <00> d S)N)r< rP rW r )<02>_disposer r r r1 <00> s z$reconnecting_engine.<locals>.dispose)
|
|||
|
|
r r0 <00>urlr< rP rO <00>testing_enginer1 rW Z
test_shutdown)rZ r, rP r1 r )rY r r <00>reconnecting_engine<6E> s r\ c C sT d d l m } d d l m } | s/ d } n | j d d <00> } | pP t j j } | | <00> } | d k r<> t j d k s<> | j t j j j k r<> t j } q<> i } n | | | <00> } d | _
|
|||
|
|
t | j t j
<00> r<> d | j _ d | j _ n | rPt j | j d t j <00> t j | j d t j <00> t j | j d t j <00> t j | <00> n | S)
|
|||
|
|
zBProduce an engine configured by --options with optional overrides.r )<01>
create_engine)<01>make_urlT<6C>
|
|||
|
|
use_reaperNr r r )<17>
|
|||
|
|
sqlalchemyr] Zsqlalchemy.engine.urlr^ <00>popr r0 rZ Z
|
|||
|
|
drivernameZdb_optsZ _has_events<74>
|
|||
|
|
isinstancer Z QueuePool<6F>_timeoutZ
_max_overflowr <00>listenr: r r r r )rZ r, r] r^ r_ r r r r r[ <00> s, ' r[ c s<> d d l m } | s% t j j } n g <00> <00> f d d <00> } <00> f d d <00> } <00> f d d <00> } | | d d
|
|||
|
|
d d | <00><02> t <00> d <00> s<> t <00> <00> <00> _ | <00> _ | <00> _ <00> S)
a' Provides a mocking engine based on the current testing.db.
|
|||
|
|
|
|||
|
|
This is normally used to test DDL generation flow as emitted
|
|||
|
|
by an Engine.
|
|||
|
|
|
|||
|
|
It should not be used in other cases, as assert_compile() and
|
|||
|
|
assert_sql_execution() are much better choices with fewer
|
|||
|
|
moving parts.
|
|||
|
|
|
|||
|
|
r )r] c s <00> j | <00> d S)N)rT )Zsql<71>arB )<01>bufferr r <00>executor s z mock_engine.<locals>.executorc s/ d d <00> <00> D<> } | | k s+ t | <00> <00> d S)Nc S s+ g | ]! } t j d d t | <00> <00> <00> q S)z[\n\t]r= )<03>re<72>sub<75>str)<02>.0<EFBFBD>sr r r <00>
|
|||
|
|
<listcomp> s z3mock_engine.<locals>.assert_sql.<locals>.<listcomp>)r4 )Zstmts<74>recv)rf r r <00>
|
|||
|
|
assert_sql s z mock_engine.<locals>.assert_sqlc s, <00> j <00> d j <00> f d d <00> <00> j D<> <00> S)N<>
|
|||
|
|
c 3 s' | ] } t | j d <00> <00> <01> Vq d S)r< N)rj <00>compile)rk rl )rK r r <00> <genexpr> s z1mock_engine.<locals>.print_sql.<locals>.<genexpr>)r< <00>join<69>mockr )r )rK r <00> print_sql s z mock_engine.<locals>.print_sqlz://Zstrategyrt rg )
|
|||
|
|
r` r] r r0 rL r; r4 rt ro ru )Z dialect_namer] rg ro ru r )rf r r <00> mock_engine<6E> s
rv c @ sI e Z d Z d Z d d <00> Z d d d <00> Z d d <00> Z d d
|
|||
|
|
<00> Z d S) <0B>DBAPIProxyCursorzuProxy a DBAPI cursor.
|
|||
|
|
|
|||
|
|
Tests can provide subclasses of this to intercept
|
|||
|
|
DBAPI-level cursor operations.
|
|||
|
|
|
|||
|
|
c O s+ | | _ | | _ | j | | <00> | _ d S)N)r r3 <00>cursor)r r r* rA rU r r r r ' s zDBAPIProxyCursor.__init__Nc K s3 | r | j j | | | <00> S| j j | | <00> Sd S)N)rx <00>execute)r <00>stmtZ
|
|||
|
|
parametersrB r r r ry , s zDBAPIProxyCursor.executec K s | j j | | | <00> S)N)rx <00> executemany)r rz <00>paramsrB r r r r{ 2 s z DBAPIProxyCursor.executemanyc C s t | j | <00> S)N)rH rx )r rR r r r rS 5 s z DBAPIProxyCursor.__getattr__)r6 r7 r8 <00>__doc__r ry r{ rS r r r r rw s
|
|||
|
|
rw c @ sF e Z d Z d Z d d <00> Z d d <00> Z d d <00> Z d d <00> Z d
|
|||
|
|
S) <0B>DBAPIProxyConnectionz}Proxy a DBAPI connection.
|
|||
|
|
|
|||
|
|
Tests can provide subclasses of this to intercept
|
|||
|
|
DBAPI-level connection operations.
|
|||
|
|
|
|||
|
|
c C s/ | j j <00> | _ | _ | | _ | | _ d S)N)r Z_creatorr* Z _sqla_unwrapr <00>
|
|||
|
|
cursor_cls)r r r r r r r A s z DBAPIProxyConnection.__init__c O s | j | j | j | | <00> S)N)r r r* )r rA rU r r r rx F s zDBAPIProxyConnection.cursorc C s | j j <00> d S)N)r* r2 )r r r r r2 I s zDBAPIProxyConnection.closec C s t | j | <00> S)N)rH r* )r rR r r r rS L s z DBAPIProxyConnection.__getattr__N)r6 r7 r8 r} r rx r2 rS r r r r r~ 9 s
|
|||
|
|
r~ c s) <00> <00> f d d <00> } t d i | d 6<> S)zIProduce an engine that provides proxy hooks for
|
|||
|
|
common methods.
|
|||
|
|
|
|||
|
|
c s <00> t j <00> <00> S)N)r r0 r )<02>conn_clsr r r <00> mock_connV s z"proxying_engine.<locals>.mock_connr, Zcreator)r[ )r<> r r<> r )r<> r r <00>proxying_engineP s r<> )<1B>
|
|||
|
|
__future__r r
|
|||
|
|
r= r <00>utilr r r rh r <00>objectr r: r@ rC rD rE rF rN rO r\ r[ rv rw r~ r<> r r r r <00><module> s, L
|
|||
|
|
!#*
|