R6�Ws
� @ 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_tables�peeweec @ 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)�db�models�
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�_meta�databaser 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_type�exc_val�exc_tb�ir 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)�queries�logging�Handlerr )r �args�kwargsr
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_select�count)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* �logger�setLevelr! �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)�.0�qr
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