U
S��W�
� @ s| d dl mZ d dlZd dlmZ d dlmZ e�d�ZG dd� de�Z G dd � d ej
�Z G d
d � d e�Z G d d
� d
e �Z
dS )� ��wrapsN)�create_model_tables)�drop_model_tables�peeweec @ s& e Zd Zd
dd�Zdd� Zdd� Zd S ) �
test_databaseTFc C s> t |tttf�s td| ��|| _|| _|| _|| _|| _ d S )Nz%r must be a list or tuple.)
�
isinstance�list�tuple�set�
ValueError�db�models�
create_tables� drop_tables�
fail_silently)�selfr
r r r r � r �/test_utils.py�__init__ s ztest_database.__init__c C sF g | _ | jD ] }| j �|jj� | j|j_q | jrBt| j| jd� d S �N)r ) �origr �append�_meta�databaser
r r r )r �mr r r � __enter__ s
ztest_database.__enter__c C sB | j r | jr t| j| jd� t| j�D ]\}}| j| |j_q&d S r ) 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)TTF)�__name__�
__module__� __qualname__r r r" r r r r r
s
�
r c @ s e Zd Zdd� Zdd� ZdS )�_QueryLogHandlerc O s g | _ tjj| f|�|� d S �N)�queries�logging�Handlerr )r �args�kwargsr r r r % s z_QueryLogHandler.__init__c C s | j �|� d S r' )r( r )r �recordr r r �emit) s z_QueryLogHandler.emitN)r# r$ r% r r. r r r r r& $ s r& c @ s. e Zd Zd dd�Zdd� Zdd� Zdd � Zd
S ) �
count_queriesFc C s || _ d| _d S )Nr )� only_select�count)r r0 r r r r . s zcount_queries.__init__c C s | j jS r' )�_handlerr( �r r r r � get_queries2 s zcount_queries.get_queriesc C s$ t � | _t�tj� t�| j� | S r' )r& r2 �loggerZsetLevelr) �DEBUGZ
addHandlerr3 r r r r 5 s zcount_queries.__enter__c C s> t �| j� | jr,tdd� | jjD ��| _nt| jj�| _d S )Nc S s g | ]}|j d �d�r|�qS )r zSELECT )�msg�
startswith)�.0�qr r r �
<listcomp>> s �z*count_queries.__exit__.<locals>.<listcomp>)r5 Z
removeHandlerr2 r0 �lenr( r1 �r r r r r r r r" ; s zcount_queries.__exit__N)F)r# r$ r% r r4 r r" r r r r r/ - s
r/ c s: e Zd Zd
� fdd� Zdd� Zdd� Z� fdd �Z� ZS ) �assert_query_countFc s t t| �j|d� || _d S )N)r0 )�superr> r �expected)r r@ r0 �� __class__r r r E s zassert_query_count.__init__c s t � �� �fdd��}|S )Nc s& �� � | |�}W 5 Q R X �� � |S r' )�
_assert_count)r+ �kwdsZret��fr r r � decoratedJ s z.assert_query_count.__call__.<locals>.decoratedr )r rF rG r rE r �__call__I s zassert_query_count.__call__c C s( d| j | jf }| j | jks$t|��d S )Nz%s != %s)r1 r@ �AssertionError)r Z error_msgr r r rC T s z assert_query_count._assert_countc s t t| ��|||� | �� d S r' )r? r> r" rC r= rA r r r" X s zassert_query_count.__exit__)F)r# r$ r% r rH rC r" �
__classcell__r r rA r r> D s r> )� functoolsr r) r r r Z getLoggerr5 �objectr r* r& r/ r> r r r r �<module> s