R6Ws
@ s d d l m Z d d l Z d d l m Z d d l m Z e j d Z Gd d d e Z Gd d d e j
Z Gd
d d e Z Gd d
d
e Z
d S) )wrapsN)create_model_tables)drop_model_tablespeeweec @ s= e Z d Z d d d d d Z d d Z d d Z d S)
test_databaseTFc C s1 | | _ | | _ | | _ | | _ | | _ d S)N)dbmodels
create_tables drop_tables
fail_silently)selfr r r r
r r
/test_utils.py__init__ s
ztest_database.__init__c C se g | _ x6 | j D]+ } | j j | j j | j | j _ q W| j ra t | j d | j d S)Nr ) origr append_metadatabaser r r r )r mr
r
r __enter__ s ztest_database.__enter__c C s_ | j r( | j r( t | j d | j x0 t | j D] \ } } | j | | j _ q8 Wd S)Nr ) r r
r r r enumerater r r )r exc_typeexc_valexc_tbir r
r
r __exit__ s ztest_database.__exit__N)__name__
__module__ __qualname__r r r r
r
r
r r
s r c @ s( e Z d Z d d Z d d Z d S)_QueryLogHandlerc O s# g | _ t j j | | | d S)N)queriesloggingHandlerr )r argskwargsr
r
r r # s z_QueryLogHandler.__init__c C s | j j | d S)N)r r )r recordr
r
r emit' s z_QueryLogHandler.emitN)r r r r r& r
r
r
r r " s r c @ sC e Z d Z d d d Z d d Z d d Z d d Z d
S)
count_queriesFc C s | | _ d | _ d S)Nr ) only_selectcount)r r( r
r
r r , s zcount_queries.__init__c C s
| j j S)N)_handlerr )r r
r
r get_queries0 s zcount_queries.get_queriesc C s0 t | _ t j t j t j | j | S)N)r r* loggersetLevelr! DEBUG
addHandler)r r
r
r r 3 s zcount_queries.__enter__c C sW t j | j | j r> t d d | j j D | _ n t | j j | _ d S)Nc S s, g | ]" } | j d j d r | q S)r zSELECT )msg
startswith).0qr
r
r
<listcomp>< s z*count_queries.__exit__.<locals>.<listcomp>)r,
removeHandlerr* r( lenr r) )r r r r r
r
r r 9 s %zcount_queries.__exit__N)r r r r r+ r r r
r
r
r r' + s r' c sO e Z d Z d f d d Z d d Z d d Z f d d Z S)
assert_query_countFc s& t t | j d | | | _ d S)Nr( )superr7 r expected)r r9 r( ) __class__r
r r C s zassert_query_count.__init__c s% t f d d } | S)Nc
s+ | | } Wd QRX j | S)N)
_assert_count)r# kwdsZret)fr r
r decoratedH s
z.assert_query_count.__call__.<locals>.decorated)r )r r= r> r
)r= r r __call__G s !zassert_query_count.__call__c C s8 d | j | j f } | j | j k s4 t | d S)Nz%s != %s)r) r9 AssertionError)r Z error_msgr
r
r r; R s z assert_query_count._assert_countc s* t t | j | | | | j d S)N)r8 r7 r r; )r r r r )r: r
r r V s zassert_query_count.__exit__)r r r r r? r; r r
r
)r: r r7 B s r7 ) functoolsr r! r r r getLoggerr, objectr r" r r' r7 r
r
r
r <module> s