o y\1@spddlZddlZddlZddlmZddlmZddlmZddlmZd7z compound.not_..csr(r r))r,skiprrrr.8r/r$)rr'rrrnot_5s z compound.not_cCs |tjSr )enabled_for_configr_currentrrrrenabled<s zcompound.enabledcCs&|j|jD] }||rdSqdS)NFTr unionr)rrrrrrr2@s zcompound.enabled_for_configcsfdd|j|jDS)Ncsg|] }|r|qSr _as_string)r,rrrr Hs z4compound.matching_config_reasons..r5rrrrrmatching_config_reasonsGs  z compound.matching_config_reasonscCs$t|j| o| p|j|Sr )boolr intersection)r include_tags exclude_tagsrrr include_testNszcompound.include_testcCs.|j|j|j|j|j|jdSr )r r%rrr rrr_extendTszcompound._extendcs<t|dr |j|Stfdd}||}|_|S)N_sa_exclusion_extendcsjtj|g|Ri|Sr )_dorr3)fnargskwrrrdecorate^sz#compound.__call__..decorate)hasattrrBrAr)rrDrG decoratedrrr__call__Ys  zcompound.__call__c csnt}|j|j|jzdVWnty.}z|tj|WYd}~dSd}~ww| tjdSr ) r rr%r r6 Exception_expect_failurerr3_expect_success)r all_failsexrrrfail_iffs zcompound.fail_ifc Os|jD]}||rd|j||f}t|qz ||i|}Wnty>}z|j|||jdWYd}~dSd}~ww|j||jd|S)Nz '%s' : %s)name)r __name__r8r skip_testrKrLrM) rcfgrDrErFr0msg return_valuerOrrrrCrs   z compound._doblockcCsD|jD]}||rtd|||t|fdSqt|dS)Nz%s failed as expected (%s): %s )rprintr8strrraise_from_cause)rrrOrQr-rrrrLs  zcompound._expect_failurecsJ|jsdS|jD] }|sdSqtd|dfdd|jDf)Nz Unexpected success for '%s' (%s) and c3s|]}|VqdSr r7r+rrrr.s  z+compound._expect_success..)rAssertionErrorjoin)rrrQr-rrrrMs zcompound._expect_successN)rW)rR __module__ __qualname__rr"rr1propertyr4r2r;r@rArJ contextlibcontextmanagerrPrCrLrMrrrrr !s"     r cCs t|gSr )r)tagnamerrr requires_tagr#rdcCst}|j||Sr )r rr%)tagnamescomprrrrs rcCt|}tt||Sr )r rr*rrrrronly_ifricCrgr )r rr*rhrrr succeeds_ifrjrkc@s.eZdZed ddZd ddZd ddZdS) PredicateNcs t|tr |j|St|tr|r|jdur||_|St|ttfr0tfdd|D|St|t r9t |St|t j rut d|}|sMtd||d}|d}|drkt dd |dd Dnd}t ||||d St |rt||SJd |)Ncsg|]}|qSr) as_predicate)r,rclsrrr9z*Predicate.as_predicate..z.([\+\w]+)\s*(?:(>=|==|!=|<=|<|>)\s*([\d\.]+))?z(Couldn't locate DB name in predicate: %rrrcsr(r )int)r,drrrr.r/z)Predicate.as_predicate...) descriptionFzunknown predicate type: %s) isinstancer rmr2rlrulistr OrPredicatetuple SpecPredicater string_typesrematch ValueErrorgroupsplitcallableLambdaPredicate)rorrutokensdbopspecrrnrrms<          zPredicate.as_predicateFcCs\||}|r | }|j|r|jjnd|r|jjnd|r!dnd|r)ddSddS)Nz z zdoesn't supportz does support)driverdatabasedoesnt_support does_support)rururlget_driver_nameget_backend_name)rrnegatebool_rrr_format_descriptions zPredicate._format_descriptioncCstr )NotImplementedErrorrrrrrrr8zPredicate._as_stringr F)NF)rRr^r_ classmethodrmrr8rrrrrls   #rlc@(eZdZd ddZddZd ddZdS) BooleanPredicateNcCs||_|pd||_dS)Nz boolean %s)valueru)rrrurrrrszBooleanPredicate.__init__cCs|jSr )rr:rrrrJrzBooleanPredicate.__call__FcCs|j||dS)Nrrrrrrr8zBooleanPredicate._as_stringr rrRr^r_rrJr8rrrrr rc @sPeZdZd ddZejejejejej ej ej dddZ ddZ d d d ZdS)rzNcCs||_||_||_||_dSr )rrrru)rrrrrurrrrs zSpecPredicate.__init__cCs||dko ||dkS)Nrrr)valpairrrrzSpecPredicate.)<>z==z!=z<=z>=inbetweencCs|j}d|jvr|jd\}}n|jd}}|r |j|kr dS|dur+|j|kr+dS|jdurQ|dus8Jdt|}t|jdrE|jpJ|j|j}|||jSdS)N+Fz%DBAPI version specs not supported yetrJT) rrrQrr_server_versionrH_opsr)rrenginedialectrversionoperrrrrJ s    zSpecPredicate.__call__FcCsb|jdur ||S|jdur|rd|jSd|jS|r'd|j|j|jfSd|j|j|jfS)Nznot %sz%sz not %s %s %sz%s %s %s)rurrrrrrrrr8!s     zSpecPredicate._as_stringNNNr)rRr^r_roperatorltgteqnelegecontainsrrJr8rrrrrzs  rzc@r) rNcsdt}|dsfdd|_n|_|pd|_|pi|_|r$||_dSjr-j|_dSd|_dS)NrcsSr r)rlambda_rrr4sz*LambdaPredicate.__init__..rzcustom function)rrrErFru__doc__)rrrurErFrrrrr1s     zLambdaPredicate.__init__cCrr rr:rrrrJ@r#zLambdaPredicate.__call__FcCrr rrrrrr8Cr#zLambdaPredicate._as_stringrrrrrrrr0s rc@r) r*NcC||_||_dSr )rru)rrrurrrrH zNotPredicate.__init__cCs || Sr )rr:rrrrJLs zNotPredicate.__call__FcCs$|jr ||| S|j|| Sr )rurrr8rrrrr8OszNotPredicate._as_stringr rrrrrrr*Grr*c@s:eZdZd ddZddZdddZd d Zdd d ZdS)rxNcCrr ) predicatesru)rrrurrrrWrzOrPredicate.__init__cCs|jD] }||r dSqdS)NTF)r)rrrrrrrJ[s zOrPredicate.__call__Fcs*rd}nd}|fdd|jDS)Nr[z or c3s|] }|jdVqdS)rNr7)r,prrrrr.fs z(OrPredicate._eval_str..)r]r)rrr conjunctionrrr _eval_stras zOrPredicate._eval_strcCs&|jdur d||S|j|ddS)NzNot Tr)rurrr:rrr _negation_strjs zOrPredicate._negation_strcCs,|r||S|jdur||S||Sr )rrurrrrrrr8ps     zOrPredicate._as_stringr r)rRr^r_rrJrrr8rrrrrxVs    rxcCst|||tjSr )rzrr3)rrrrrr _is_excluded}rcCs.|}t|jdd}|durd}||S)z#Return a server_version_info tuple.server_version_infoNr)connectgetattrrclose)rconnrrrrrs rcGstdd|DS)NcSg|]}t|qSrrlrmr,rrrrr9rpzdb_spec..rxdbsrrrdb_specrrcCttddS)NFzmark as executerrrrrropenrrcCr)NTzmarked as skiprrrrrclosedrrcCsttd|pdS)NTzexpected to fail)rrrrrrrrrcGstt|dS)NzFuture feature)rr)rDargrrrfuturesrcC t||Sr )rrrrrrfails_onr#rcGsttdd|DS)NcSrrrrrrrr9rpz.fails_on_everything_except..)rkrxrrrrfails_on_everything_exceptsrcCrr )rrrrrr0r#r0cs ttfddt|DS)Ncsg|]}t|qSrrrrrrr9rzonly_on..)rirxrto_list)rrrrronly_ons rcCstt||||Sr )rrz)rrrrrrrexcluderrcGs"|sJdtdd|D|S)Nzno queries sent!cSrrr)r,queryrrrr9rpzagainst..r)rqueriesrrragainsts rr )&rarr|rrr util.compatrrrobjectr rdrrirkrlrrzrr*rxrmr rrrrrrrrrr0rrrrrrrsF      ~  8 9$