U
    r\j4                     @   st  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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   T/root/pica-gateway/venv/lib/python3.8/site-packages/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_tagsZ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:   r9   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_testrB   rC   __name__rD   )	r   cfgr<   r=   r>   r*   msgZreturn_valuerE   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   rE   rG   r(   Zstr_exr   r   r   rC      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   rG   r(   r   r   r   rD      s    
zcompound._expect_successN)rK   )rK   )rH   
__module____qualname__r   r   r!   r   r+   propertyr.   r,   r5   r8   r9   rA   
contextlibcontextmanagerrF   r;   rC   rD   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    ra   c                 C   s   t | } tt| |S r	   )r   r   r%   r`   r   r   r   succeeds_if   s    rb   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
   rd   r,   rc   rk   listr   OrPredicatetupleSpecPredicater   string_typesrematch
ValueErrorgroupsplitcallableLambdaPredicaterV   )rf   r   rk   tokensdbopspecr   re   r   rd      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)rk   rz   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)rH   rX   rY   classmethodrd   r   r2   r   r   r   r   rc      s   #
rc   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)valuerk   )r   r   rk   r   r   r   r      s    zBooleanPredicate.__init__c                 C   s   | j S r	   )r   r4   r   r   r   rA      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rH   rX   rY   r   rA   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 )rp   Nc                 C   s   || _ || _|| _|| _d S r	   )rz   r{   r|   rk   )r   rz   r{   r|   rk   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 yetrA   T)
rz   rv   rG   r}   r{   rV   _server_versionr@   _opsr|   )r   r   enginedialectr}   versionoperr   r   r   rA     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)rk   r   r{   rz   r|   r   r   r   r   r2   4  s    



zSpecPredicate._as_string)NNN)F)rH   rX   rY   r   operatorltgteqnelegecontainsr   rA   r2   r   r   r   r   rp     s   
rp   c                   @   s(   e Zd Zd	ddZdd Zd
ddZdS )rx   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   )rz   lambda_r   r   r   G  r   z*LambdaPredicate.__init__.<locals>.<lambda>r   zcustom function)r   r   r=   r>   rk   __doc__)r   r   rk   r=   r>   r|   r   r   r   r   D  s    


zLambdaPredicate.__init__c                 C   s
   |  |S r	   r   r4   r   r   r   rA   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   rx   C  s   
rx   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   rk   )r   r   rk   r   r   r   r   [  s    zNotPredicate.__init__c                 C   s   |  | S r	   )r   r4   r   r   r   rA   _  s    zNotPredicate.__call__Fc                 C   s(   | j r| || S | j|| S d S r	   )rk   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 )rn   Nc                 C   s   || _ || _d S r	   )
predicatesrk   )r   r   rk   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   rA   n  s    
zOrPredicate.__call__Fc                    s*   r
d}nd}|  fdd| jD S )NrU   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>)rW   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   )rk   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   rk   r   r   r   r   r   r   r2     s
    


zOrPredicate._as_string)N)F)F)rH   rX   rY   r   rA   r   r   r2   r   r   r   r   rn   i  s
   

	rn   c                 C   s   t | ||tjS r	   )rp   r   r-   )rz   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   rc   rd   r'   rz   r   r   r   r3     s     zdb_spec.<locals>.<listcomp>)rn   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                   C   s   t tddS )NTzFuture featurer   r   r   r   r   future  s    r   c                 C   s
   t | |S r	   )r   rz   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>)rb   rn   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>)ra   rn   r   Zto_list)r   r   r   r   r   only_on  s
    r   c                 C   s   t t| |||S r	   )r   rp   )rz   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>)rV   rn   )r   Zqueriesr   r   r   against  s    r   )N)N)N)N)N)N)N)N)N)'r[   r   rr   rS    r   r   r   Zutil.compatr   r   r   objectr
   r^   r   ra   rb   rc   r   rp   rx   r%   rn   rd   r   r   r   r   r   r   r   r   r   r   r*   r   r   r   r   r   r   r   <module>	   sF   

 

8<$




