ó H`¾Tc@@sóddlmZddlmZddlmZmZmZddlm Z m Z m Z ddlm Z ddlmZddlmZmZdd lZdd lZdd lmZdd lmZmZdd lmZdd lmZddlmZdd lZejd„ƒZd„Zd„Z d„Z!ejd„ƒZ"d„Z#da$d„Z%d d„Z'd d„Z(d d„Z)d d„Z*d d„Z+d„Z,d„Z-de.fd„ƒYZ/de.fd „ƒYZ0d!e.fd"„ƒYZ1d S(#i(tabsolute_importi(tutil(tpooltormR(tdefaultt create_engineturl(texc(t decorator(ttypestschemaN(t resetwarnings(tdb_spect _is_excluded(t assertsql(tconfig(tfailcg@stdddtjƒg}|sC|jtdddtjƒƒn|jd„|Dƒƒx|D]}tj|qaWz dVWdtƒXdS(s;Context manager to expect warnings with the given messages.tactiontignoretcategorycs@s-|]#}tddd|dtjƒVqdS(RRtmessageRN(tdicttsa_exct SAWarning(t.0R((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pys $sN( RRtSAPendingDeprecationWarningtappendRtextendtwarningstfilterwarningsR (tmessagestfilterstf((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytexpect_warningss     c@st‡fd†ƒ}|S(sâMark a test as emitting a warning. With no arguments, squelches all SAWarning failures. Or pass one or more strings; these will be matched to the root of the warning description by warnings.filterwarnings(). c@s$tˆŒ|||ŽSWdQXdS(N(R!(tfntargstkw(R(sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytdecorate7s (R(RR%((Rsc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyt emits_warning0sc@s+tˆƒ‰t‡‡‡fd†ƒ}|S(søMark a test as emitting a warning on a specific dialect. With no arguments, squelches all SAWarning failures. Or pass one or more strings; these will be matched to the root of the warning description by warnings.filterwarnings(). c@sŒtˆtjƒrPˆtjƒs.|||ŽStˆŒ|ƒ}|||ŽSn8tˆŒsi|||ŽStˆŒ|ƒ}|||ŽSdS(N(t isinstanceRt string_typesRt_currentR&R (R"R#R$twrapped(Rtdbtspec(sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyR%Gs   (R R(R+RR%((RR+R,sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytemits_warning_on>s c@st‡fd†ƒ}|S(sÎMark a test as immune from fatal deprecation warnings. With no arguments, squelches all SADeprecationWarning failures. Or pass one or more strings; these will be matched to the root of the warning description by warnings.filterwarnings(). As a special case, you may pass a function name prefixed with // and it will be re-written as needed to match the standard warning verbiage emitted by the sqlalchemy.util.deprecated decorator. c@s$tˆŒ|||ŽSWdQXdS(N(texpect_deprecated(R"R#R$(R(sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyR%ds (R(RR%((Rsc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytuses_deprecatedXs c g@sátdddtjƒg}|sC|jtdddtjƒƒnh|jgg|D])}|jdƒrvd|dpy|^qSD]$}tddd|dtjƒ^q€ƒx|D]}tj|q²Wz dVWdt ƒXdS(NRRRs//sCall to deprecated function iR( RRRRtSADeprecationWarningRt startswithRRR (RRtmRR ((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyR.ks \  cC@s tƒdS(sÛCheck things that have to be finalized at the end of a test suite. Hardcoded at the moment, a modular system can be built here to support things like PG prepared transactions, tables all dropped, etc. N(t!_assert_no_stray_pool_connections(((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytglobal_cleanup_assertions…scC@s«tjƒtjr<td7adttjƒGHtjƒntjr€ttjƒ}tjjƒdats§t d|ƒ‚n'tdkr§tsžt dƒ‚dandS(Nis2Encountered a stray connection in test cleanup: %sis8Stray connection refused to leave after gc.collect(): %si s*Encountered more than 10 stray connections( ttestutiltlazy_gcRt_refst_STRAY_CONNECTION_FAILUREStstrt gc_collecttcleartFalsetAssertionError(terr((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyR3’s         cC@s,||ks(t|p"d||fƒ‚dS(s.Assert a == b, with repr messaging on failure.s%r != %rN(R=(tatbtmsg((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyteq_¹scC@s,||ks(t|p"d||fƒ‚dS(s.Assert a != b, with repr messaging on failure.s%r == %rN(R=(R?R@RA((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytne_¾scC@s,||ks(t|p"d||fƒ‚dS(s.Assert a is b, with repr messaging on failure.s %r is not %rN(R=(R?R@RA((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytis_ÃscC@s,||k s(t|p"d||fƒ‚dS(s2Assert a is not b, with repr messaging on failure.s%r is %rN(R=(R?R@RA((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytis_not_ÈscC@s/|j|ƒs+t|p%d||fƒ‚dS(s>Assert a.startswith(fragment), with repr messaging on failure.s%r does not start with %rN(R1R=(R?tfragmentRA((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyt startswith_ÍscO@sGy|||Žt}Wn|k r0t}nX|sCtdƒ‚dS(Ns#Callable did not raise an exception(R<tTrueR=(t except_clst callable_R#R$tsuccess((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyt assert_raisesÓs     cO@s‹y#|||Žts"tdƒ‚Wna|k r†}tj|tj|ƒtjƒsltd||fƒ‚tj|ƒjdƒGHnXdS(Ns#Callable did not raise an exceptions%r !~ %ssutf-8(R<R=tretsearchRt text_typetUNICODEtencode(RIRARJR#tkwargste((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytassert_raises_messageÞs 1tAssertsCompiledSQLcB@s&eZddddeeed„ZRS(c C@sp|rtjƒ}n“|r$d}n„|dkrEt|ddƒ}n|dkr`tjj}nH|dkr{tjƒ}n-t|tj ƒr¨t j |ƒj ƒƒ}ni} i} |dk rÓt |ƒ| dyss#Unexpected type "%s", expected "%s"s+Unexpected object count "%s", expected "%s"c@sŒx…|jƒD]w\}}t|tƒrhy(ˆjt||ƒ|d|dŒWq„tk rdtSXq t||ˆƒ|kr tSq WtS(Nii(R£R'Rntassert_unordered_resultR`R=R<RH(tobjR,R¦R§(RptNOVALUE(sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyt _compare_item„s" s2Expected %s instance with attributes %s not found.( RRt IdentitySetR‹titertools_filterfalseRR†R~RtobjecttremoveRiRH( RpRrR¬texpectedR¨tfoundRStwrongR±t expected_itemt found_item((RpR°R¬sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyR®ks*%     cG@s=tjj|ƒz|ƒtjjƒWdtjjƒXdS(N(Rtassertert add_ruleststatement_completet clear_rules(RpR+RJtrules((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytassert_sql_executionœs c C@sÀ|dk r$tjjjr$|}n|}g}xv|D]n}t|tƒr‰tjg|j ƒD]\}} tj || ƒ^q_Œ} ntj |Œ} |j | ƒq7W|j |||ŒdS(N( R_RR+RZtsupports_sequencesR'RRtAllOfR£tExactSQLRRÀ( RpR+RJtlist_twith_sequencesR¿tnewrulestruletktvtnewrule((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyt assert_sql¤s   7cC@s |j||tj|ƒƒdS(N(RÀRtCountStatements(RpR+RJtcount((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytassert_sql_count·scg@s;tjj|ƒzdVtjjƒWdtjjƒXdS(N(RR»R¼R½R¾(RpR¿((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytassert_execution»s cC@s|jtj|ƒƒS(N(RÏRRÌ(RpRÍ((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pytassert_statement_countÄsN(R~RRRšR R®RÀR_RËRÎt contextlibtcontextmanagerRÏRÐ(((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyR™Ps    1    (2t __future__RR]RR5t sqlalchemyRRtsqlalchemy.engineRRRRRtsqlalchemy.utilRR RˆR RRMR t exclusionsR R RRRRÑRÒR!R&R-R/R.R4R8R3R_RBRCRDRERGRLRTR´RUR€R™(((sc/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/testing/assertions.pyts@        '      B&