U
    [h4                     @   sx  d dl Z d dlZd dlZd dlZddlmZ ddlmZ ddlmZ ddlm	Z	 d<dd	Z
d=d
dZG dd deZdd Zdd Zd>ddZd?ddZG dd deZG dd deZG dd deZG dd deZG dd deZG d d! d!eZejZd"d# Zd$d% Zd&d' Zd(d) Zd*d+ Zd@d,d-Zed.d/ Z dAd0d1Z!d2d3 Z"dBd4d5Z#dCd6d7Z$dDd8d9Z%d:d; Z&dS )E    N   config   )util)	decorator)inspect_getfullargspecc                 C   s    t  }t| |}|j| |S N)compound_as_predicateskipsadd	predicatereasonrulepred r   A/tmp/pip-unpacked-wheel-joqu7d3y/sqlalchemy/testing/exclusions.pyskip_if   s    
r   c                 C   s    t  }t| |}|j| |S r	   )r
   r   failsr   r   r   r   r   fails_if   s    
r   c                   @   s   e Zd Zdd Zdd Zdd Zdd Zd	d
 Zedd Z	dd Z
dd Zdd Zdd Zdd Zejdd Zdd Zd!ddZd"ddZd S )#r
   c                 C   s   t  | _t  | _t  | _d S r	   )setr   r   tagsselfr   r   r   __init__#   s    zcompound.__init__c                 C   s
   |  |S r	   )r   r   otherr   r   r   __add__(   s    zcompound.__add__c                 C   s4   t  }|j| j |j| j |j| j |S r	   )r
   r   updater   r   )r   r   r   r   r   as_skips+   s
    zcompound.as_skipsc                 G   sh   t  }|j| j |j| j |j| j |D ].}|j|j |j|j |j|j q4|S r	   r
   r   r    r   r   )r   Zotherscopyr   r   r   r   r   2   s    zcompound.addc                 C   sH   t  }|jdd | jD  |jdd | jD  |j| j |S )Nc                 s   s   | ]}t |V  qd S r	   NotPredicate.0failr   r   r   	<genexpr>?   s     z compound.not_.<locals>.<genexpr>c                 s   s   | ]}t |V  qd S r	   r$   )r'   skipr   r   r   r)   @   s     r"   )r   r#   r   r   r   not_=   s
    zcompound.not_c                 C   s   |  tjS r	   )enabled_for_configr   _currentr   r   r   r   enabledD   s    zcompound.enabledc                 C   s&   | j | jD ]}||r dS qdS )NFTr   unionr   )r   r   r   r   r   r   r,   H   s    zcompound.enabled_for_configc                    s    fdd| j | jD S )Nc                    s   g | ]}| r|  qS r   
_as_string)r'   r   r   r   r   
<listcomp>P   s   z4compound.matching_config_reasons.<locals>.<listcomp>r/   r   r   r   r   r   matching_config_reasonsO   s    
z compound.matching_config_reasonsc                 C   s$   t | j| o | p | j|S r	   )boolr   intersection)r   Zinclude_tagsexclude_tagsr   r   r   include_testV   s    zcompound.include_testc                 C   s.   | j |j  | j|j | j|j d S r	   )r   r    r   r   r   r   r   r   _extend\   s    zcompound._extendc                    s<   t |dr|j  |S t fdd}||} |_|S )N_sa_exclusion_extendc                    s    j tj| f||S r	   )_dor   r-   )fnargskwr   r   r   decoratef   s    z#compound.__call__.<locals>.decorate)hasattrr;   r:   r   )r   r=   r@   Z	decoratedr   r   r   __call__a   s    
zcompound.__call__c              
   c   sh   t  }|j| j| j z
d V  W n0 tk
rV } z|tj| W 5 d }~X Y nX |	tj d S r	   )
r
   r   r    r   r0   	Exception_expect_failurer   r-   _expect_success)r   Z	all_failsexr   r   r   fail_ifn   s    
 zcompound.fail_ifc           	   
   O   s   | j D ],}||rdt ||f }t| qz|||}W n4 tk
rv } z| j|||jd W 5 d }~X Y nX | j||jd |S d S )Nz	'%s' : %s)name)	r   r   Zget_current_test_namer2   Z	skip_testrC   rD   __name__rE   )	r   cfgr=   r>   r?   r*   msgZreturn_valuerF   r   r   r   r<   z   s    
$zcompound._doblockc                 C   sl   | j D ]J}||rtjr,t|jddd}nt|}td||||f   qhqtj|t	
 d d d S )Nzutf-8ignore)errorsz%s failed as expected (%s): %s r   )with_traceback)r   r   Zpy2kunicodeencodestrprintr2   Zraise_sysexc_info)r   r   rF   rH   r(   Zstr_exr   r   r   rD      s    
 zcompound._expect_failurec              	      sH   | j s
d S | j D ]2}| rtd|d fdd| j D f qd S )Nz Unexpected success for '%s' (%s) and c                 3   s   | ]}|  V  qd S r	   r1   r&   r   r   r   r)      s    z+compound._expect_success.<locals>.<genexpr>)r   AssertionErrorjoin)r   r   rH   r(   r   r   r   rE      s    
zcompound._expect_successN)rL   )rL   )rI   
__module____qualname__r   r   r!   r   r+   propertyr.   r,   r5   r9   r:   rB   
contextlibcontextmanagerrG   r<   rD   rE   r   r   r   r   r
   "   s"   


r
   c                 C   s
   t | gS r	   )r   )tagnamer   r   r   requires_tag   s    r_   c                 C   s   t  }|j|  |S r	   )r
   r   r    )Ztagnamescompr   r   r   r      s    r   c                 C   s   t | } tt| |S r	   )r   r   r%   r   r   r   r   r   only_if   s    rb   c                 C   s   t | } tt| |S r	   )r   r   r%   ra   r   r   r   succeeds_if   s    rc   c                   @   s.   e Zd Zed	ddZd
ddZdddZdS )	PredicateNc                    s  t |tr |j|S t |tr:|r6|jd kr6||_|S t |ttfr`t fdd|D |S t |t	rrt
| S t |tjrtd|}|std| |d}|d}|drt	dd	 |dd
D nd }t
||||dS t| rt||S dstd| d S )Nc                    s   g | ]}  |qS r   )as_predicate)r'   r   clsr   r   r3      s     z*Predicate.as_predicate.<locals>.<listcomp>z.([\+\w]+)\s*(?:(>=|==|!=|<=|<|>)\s*([\d\.]+))?z(Couldn't locate DB name in predicate: %rr   r      c                 s   s   | ]}t |V  qd S r	   )int)r'   dr   r   r   r)      s     z)Predicate.as_predicate.<locals>.<genexpr>.)descriptionFzunknown predicate type: %s)
isinstancer
   re   r,   rd   rl   listr   OrPredicatetupleSpecPredicater   string_typesrematch
ValueErrorgroupsplitcallableLambdaPredicaterW   )rg   r   rl   tokensdbopspecr   rf   r   re      s@    

 
 

 

zPredicate.as_predicateFc                 C   sV   | |}|r| }| j |r&|jj nd|r8|jj nd|rBdnd|rLdndd S )Nz<no driver>z<no database>zdoesn't supportzdoes support)driverZdatabaseZdoesnt_supportZdoes_support)rl   r{   urlZget_driver_nameZget_backend_name)r   r   negateZbool_r   r   r   _format_description   s    

zPredicate._format_descriptionc                 C   s
   t  d S r	   )NotImplementedErrorr   r   r   r   r   r   r2      s    zPredicate._as_string)N)F)NF)rI   rY   rZ   classmethodre   r   r2   r   r   r   r   rd      s   #
rd   c                   @   s(   e Zd Zd	ddZdd Zd
ddZdS )BooleanPredicateNc                 C   s   || _ |pd| | _d S )Nz
boolean %s)valuerl   )r   r   rl   r   r   r   r      s    zBooleanPredicate.__init__c                 C   s   | j S r	   )r   r4   r   r   r   rB      s    zBooleanPredicate.__call__Fc                 C   s   | j ||dS )Nr   r   r   r   r   r   r2     s    zBooleanPredicate._as_string)N)FrI   rY   rZ   r   rB   r2   r   r   r   r   r      s   
r   c                	   @   sP   e Zd ZdddZejejejejej	ej
ejdd dZdd Zdd
dZdS )rq   Nc                 C   s   || _ || _|| _|| _d S r	   )r{   r|   r}   rl   )r   r{   r|   r}   rl   r   r   r   r     s    zSpecPredicate.__init__c                 C   s   | |d ko| |d kS )Nr   r   r   )valpairr   r   r   <lambda>      zSpecPredicate.<lambda>)<>z==z!=z<=z>=inZbetweenc                 C   s   |d krdS |j }d| j kr.| j d\}}n| j d  }}|rL|j|krLdS |d k	rb|j|krbdS | jd k	r|d ks|tdt|}t| jdr| jp| j| j }||| j	S dS d S )NF+z%DBAPI version specs not supported yetrB   T)
r{   rw   rH   r~   r|   rW   _server_versionrA   _opsr}   )r   r   enginedialectr~   versionoperr   r   r   rB     s"    

zSpecPredicate.__call__Fc                 C   sh   | j d k	r| |S | jd kr8|r,d| j S d| j S n,|rPd| j| j| jf S d| j| j| jf S d S )Nznot %sz%sznot %s %s %sz%s %s %s)rl   r   r|   r{   r}   r   r   r   r   r2   4  s    



zSpecPredicate._as_string)NNN)F)rI   rY   rZ   r   operatorltgteqnelegecontainsr   rB   r2   r   r   r   r   rq     s   
rq   c                   @   s(   e Zd Zd	ddZdd Zd
ddZdS )ry   Nc                    s`   t  }|d s  fdd| _n | _|p,d| _|p6i | _|rF|| _n jrV j| _nd| _d S )Nr   c                    s     S r	   r   )r{   lambda_r   r   r   G  r   z*LambdaPredicate.__init__.<locals>.<lambda>r   zcustom function)r   r   r>   r?   rl   __doc__)r   r   rl   r>   r?   r}   r   r   r   r   D  s    


zLambdaPredicate.__init__c                 C   s
   |  |S r	   r   r4   r   r   r   rB   S  s    zLambdaPredicate.__call__Fc                 C   s
   |  |S r	   r   r   r   r   r   r2   V  s    zLambdaPredicate._as_string)NNN)Fr   r   r   r   r   ry   C  s   
ry   c                   @   s(   e Zd Zd	ddZdd Zd
ddZdS )r%   Nc                 C   s   || _ || _d S r	   )r   rl   )r   r   rl   r   r   r   r   [  s    zNotPredicate.__init__c                 C   s   |  | S r	   )r   r4   r   r   r   rB   _  s    zNotPredicate.__call__Fc                 C   s(   | j r| || S | j|| S d S r	   )rl   r   r   r2   r   r   r   r   r2   b  s    zNotPredicate._as_string)N)Fr   r   r   r   r   r%   Z  s   
r%   c                   @   s:   e Zd ZdddZdd ZdddZd	d
 ZdddZdS )ro   Nc                 C   s   || _ || _d S r	   )
predicatesrl   )r   r   rl   r   r   r   r   j  s    zOrPredicate.__init__c                 C   s   | j D ]}||r dS qdS )NTF)r   )r   r   r   r   r   r   rB   n  s    
zOrPredicate.__call__Fc                    s*   r
d}nd}|  fdd| jD S )NrV   z or c                 3   s   | ]}|j  d V  qdS )r   Nr1   )r'   pr   r   r   r   r)   y  s    z(OrPredicate._eval_str.<locals>.<genexpr>)rX   r   )r   r   r   Zconjunctionr   r   r   	_eval_strt  s    zOrPredicate._eval_strc                 C   s*   | j d k	rd| | S | j|ddS d S )NzNot Tr   )rl   r   r   r4   r   r   r   _negation_str}  s    
zOrPredicate._negation_strc                 C   s0   |r|  |S | jd k	r"| |S | |S d S r	   )r   rl   r   r   r   r   r   r   r2     s
    


zOrPredicate._as_string)N)F)F)rI   rY   rZ   r   rB   r   r   r2   r   r   r   r   ro   i  s
   

	ro   c                 C   s   t | ||tjS r	   )rq   r   r-   )r{   r|   r}   r   r   r   _is_excluded  s    r   c                 C   s.   |   }t| jdd}|dkr"d}|  |S )z#Return a server_version_info tuple.Zserver_version_infoNr   )connectgetattrr   close)r   connr   r   r   r   r     s    r   c                  G   s   t dd | D S )Nc                 S   s   g | ]}t |qS r   rd   re   r'   r{   r   r   r   r3     s     zdb_spec.<locals>.<listcomp>)ro   dbsr   r   r   db_spec  s    r   c                   C   s   t tddS )NFzmark as executer   r   r   r   r   r   open  s    r   c                   C   s   t tddS )NTzmarked as skipr   r   r   r   r   closed  s    r   c                 C   s   t td| pdS )NTzexpected to fail)r   r   r   r   r   r   r     s    r   c                 G   s   t t| dS )NzFuture feature)r   ry   )r=   argr   r   r   future  s    r   c                 C   s
   t | |S r	   )r   r{   r   r   r   r   fails_on  s    r   c                  G   s   t tdd | D S )Nc                 S   s   g | ]}t |qS r   r   r   r   r   r   r3     s     z.fails_on_everything_except.<locals>.<listcomp>)rc   ro   r   r   r   r   fails_on_everything_except  s    r   c                 C   s
   t | |S r	   )r   r   r   r   r   r*     s    r*   c                    s    t t fddt| D S )Nc                    s   g | ]}t | qS r   r   r   r   r   r   r3     s     zonly_on.<locals>.<listcomp>)rb   ro   r   Zto_list)r   r   r   r   r   only_on  s
    r   c                 C   s   t t| |||S r	   )r   rq   )r{   r|   r}   r   r   r   r   exclude  s    r   c                 G   s"   |st dtdd |D | S )Nzno queries sent!c                 S   s   g | ]}t |qS r   r   )r'   queryr   r   r   r3     s     zagainst.<locals>.<listcomp>)rW   ro   )r   Zqueriesr   r   r   against  s    r   )N)N)N)N)N)N)N)N)N)'r\   r   rs   rT    r   r   r   Zutil.compatr   r   r   objectr
   r_   r   rb   rc   rd   r   rq   ry   r%   ro   re   r   r   r   r   r   r   r   r   r   r   r*   r   r   r   r   r   r   r   <module>	   sH   

 

8<$





