ó H`¾Tc@sdZddlmZmZddlmZmZddlmZmZddl m Z ddl m Z dd l mZmZmZmZmZmZmZdd lmZmZmZmZdd lmZejjejd ƒZdd l m!Z!m"Z"m#Z#ddl m$Z$ddl%m&Z&d„Z'd„Z(e)e)e)e)e)d„Z*d„Z+d„Z,d„Z-d„Z.d„Z/d„Z0de1fd„ƒYZ2d„Z3d%d„Z5d„Z6d%d%e)d„Z7de1fd „ƒYZ8d!ej9fd"„ƒYZ:d#e:fd$„ƒYZ;d%S(&s;High level utilities which build upon other modules here. i(texctutili(t _from_objectst ColumnSet(t operatorstvisitorsiÿÿÿÿ(tchain(tdeque(t BindParametert ColumnClauset ColumnElementtNulltUnaryExpressiontliteral_columntLabel(t ScalarSelecttJoint FromClauset FromGrouping(tColumns.sql.util.join_condition(t_shallow_annotatet_deep_annotatet_deep_deannotate(t _find_columns(t sort_tablescCsatt|ƒƒ}xHt|ƒD]6\}}x'|D]}|j|ƒr2||fSq2WqWdSdS(s”Given a list of FROM clauses and a selectable, return the first index and element from the list of clauses which can be joined against the selectable. returns None, None if no match is found. e.g.:: clause1 = table1.join(table2) clause2 = table4.join(table5) join_to = table2.join(table3) find_join_source([clause1, clause2], join_to) == clause1 N(NN(tlistRt enumeratetis_derived_fromtNone(tclausestjoin_tot selectablestitfts((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytfind_join_source!s  cs/g‰‡‡‡fd†‰tˆ|ƒƒdS(sýProduce a traversal of the given expression, delivering column comparisons to the given function. The function is of the form:: def my_fn(binary, left, right) For each binary expression located which has a comparison operator, the product of "left" and "right" will be delivered to that function, in terms of that binary. Hence an expression like:: and_( (a + b) == q + func.sum(e + f), j == r ) would have the traversal:: a q a e a f b q b e b f j r That is, every combination of "left" and "right" that doesn't further contain a binary comparison is passed as pairs. c3st|tƒr|Vnô|jdkrÁtj|jƒrÁˆjd|ƒxEˆ|jƒD]4}x+ˆ|jƒD]}ˆˆd||ƒqnWqXWˆj dƒxk|j ƒD]}ˆ|ƒqªWnJt|t ƒrØ|Vnx0|j ƒD]"}xˆ|ƒD] }|VqøWqåWdS(Ntbinaryi( t isinstanceRt__visit_name__Rt is_comparisontoperatortinserttlefttrighttpopt get_childrenR (telementtltrtelemte(tvisittstacktfn(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR3`s  N(R(R5texpr((R3R4R5sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytvisit_binary_product;s#csÏg‰i}|r*ˆj|d<|dŠsR)tupdatetdeletecsˆj|jƒdS(N(R<R=(tcolumn(R?(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt visit_columnsRCR=tcolumn_collections(R<RttraversetFalse(tclauset check_columnstinclude_aliasest include_joinstinclude_selectst include_crudt _visitorsRD((R?sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt find_tablesws &  cCsžtjƒ}t|gƒ}x||r™|jƒ}t|tƒrrt|tƒ sbtj|j ƒ rr|j |ƒqx!|j ƒD]}|j |ƒqWqW|S(sqBreak up an 'order by' expression into individual column-expressions, without DESC/ASC/NULLS FIRST/NULLS LAST( Rt column_setRtpopleftR%R R Rtis_ordering_modifiertmodifiertaddR-R<(RHtcolsR4tttc((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytunwrap_order_by—s   cCs/x(t|ƒD]}||kr tSq WtSdS(sÐGiven a target clause and a second to search within, return True if the target is plainly present in the search without any subqueries or aliases involved. Basically descends through Joins. N(tsurface_selectablestTrueRG(RHtsearchR1((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytclause_is_present«s  ccsx|g}xh|rs|jƒ}|Vt|tƒrN|j|j|jfƒq t|tƒr |j|jƒq q WdS(N( R,R%RtextendR*R+RR<R.(RHR4R1((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRY»s   cCs%ttt|ƒƒjt|ƒƒƒS(s:Return True if left/right have some overlapping selectable(tbooltsetRYt intersection(R*R+((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytselectables_overlapÆscs3g‰‡fd†}tj|ii|d6ƒˆS(sÑReturn an ordered list of "bound" values in the given clause. E.g.:: >>> expr = and_( ... table.c.foo==5, table.c.foo==7 ... ) >>> bind_values(expr) [5, 7] csˆj|jƒdS(N(R<teffective_value(tbind(tv(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytvisit_bindparamÞst bindparam(RRF(RHRe((RdsY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt bind_valuesÐs cCs:t|tjƒr,|jddƒ}d|St|ƒSdS(Nt's''s'%s'(R%Rt string_typestreplacetrepr(R.((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt_quote_ddl_expråst _repr_paramscBs eZdZd„Zd„ZRS(snA string view of bound parameters, truncating display to the given number of 'multi' parameter sets. cCs||_||_dS(N(tparamstbatches(tselfRnRo((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt__init__ós cCs¾t|jttfƒr­t|jƒ|jkr­t|jdtttfƒr­d}djt|j|jd ƒdd!||jt|jƒft|jdƒdfƒSt|jƒSdS(Nis8 ... displaying %i of %i total bound parameter sets ... t iiÿÿÿÿiþÿÿÿi( R%RnRttupletlenRotdictR:Rk(Rptmsg((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt__repr__÷s(t__name__t __module__t__doc__RqRw(((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRmís cs)‡fd†}tj|ii|d6ƒS(sWgiven criterion containing bind params, convert selected elements to IS NULL. cs¦t|jtƒrW|jjˆkrW|j|_tƒ|_tj|_tj |_ nKt|jtƒr¢|jjˆkr¢tƒ|_tj|_tj |_ ndS(N( R%R*Rt_identifying_keyR+R Rtis_R(tisnottnegate(R$(tnulls(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt visit_binary s     R$(Rtcloned_traverse(tcritRR€((RsY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytadapt_criterion_to_nullscCsï|dkr|S|dfg}t|ƒ}d}x·|rê|jƒ\}}t|tƒr«||k r«|jƒ}|jƒ|j|jƒ|_|j |j |fƒn|j|ƒ}|dk rÒ||_ n|dkr4|}q4q4W|S(N( Rt ClauseAdapterR,R%Rt_clonet_reset_exportedRFtonclauseR<R*(R*R+tstop_onR4tadaptertrett prevright((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt splice_joinss$         c sœ|jdtƒ}|jdtƒ‰tjˆƒ‰tjƒ‰xïˆD]ç}xÞtg|jD]}|j^q\ŒD]·}x®ˆD]¦}||kr—qny |j}WnEt j k rÉ|rÃqqì‚n#t j k rë|råqqì‚nX|j |ƒrˆ s|j |j krˆj|ƒPqqWqrWqFW|r‰‡‡‡fd†}x:|D]/} | dk rStj| ii|d6ƒqSqSWntˆjˆƒƒS(sCgiven a list of columns, return a 'reduced' set based on natural equivalents. the set is reduced to the smallest list of columns which have no natural equivalent present in the list. A "natural equivalent" means that two columns will ultimately represent the same value because they are related by a foreign key. \*clauses is an optional list of join clauses which will be traversed to further identify columns that are "equivalent". \**kw may specify 'ignore_nonexistent_tables' to ignore foreign keys whose tables are not yet configured, or columns that aren't yet present. This function is primarily used to determine the most minimal "primary key" from a selectable, by reducing the set of primary key columns present in the selectable to just those that are not repeated. tignore_nonexistent_tablest only_synonymscsÄ|jtjkrÀtjtgˆjˆƒD]}|j^q+Œƒ}|j|krÀ|j |krÀxVt ˆƒD]E}|j |j ƒrqˆ s¥|j |jj krqˆj |ƒPqqqqWqÀndS(N(R(RteqRRPRt differencet proxy_setR*R+treversedtshares_lineagetnameRT(R$RWRU(RŽtomittcolumns(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR€ks. R$N(R,RGRtordered_column_setRPRR‘t foreign_keysRCRtNoReferencedColumnErrortNoReferencedTableErrorR“R”RTRRRFRR( R–RtkwRtcolRWtfktfk_colR€RH((RŽR•R–sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytreduce_columns5s<  ,      $csfˆrˆrtjdƒ‚nd„‰‡‡‡‡‡fd†}g‰tj|ii|d6ƒˆS(s9traverse an expression and locate binary criterion pairs.sSCan only specify one of 'consider_as_foreign_keys' or 'consider_as_referenced_keys'cSs |j|ƒS(N(tcompare(tatb((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytcol_is†sc s"ˆ r|jtjk rdSt|jtƒ sCt|jtƒ rGdSˆrî|jˆkrœˆ|j|jƒs€|jˆkrœˆj|j|jfƒq|jˆkrˆ|j|jƒsÏ|jˆkrˆj|j|jfƒqn0ˆr•|jˆkrCˆ|j|jƒs'|jˆkrCˆj|j|jfƒq|jˆkrˆ|j|jƒsv|jˆkrˆj|j|jfƒqn‰t|jtƒrt|jtƒr|jj |jƒrêˆj|j|jfƒq|jj |jƒrˆj|j|jfƒqndS(N( R(RRR%R*R R+R<Rt references(R$(tpairsR£t any_operatortconsider_as_foreign_keystconsider_as_referenced_keys(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR€Šs:R$(Rt ArgumentErrorRRF(t expressionR§R¨R¦R€((R¥R£R¦R§R¨sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytcriterion_as_pairs}s   t AliasedRowcBs;eZdZd„Zd„Zd„Zd„Zd„ZRS(sˆWrap a RowProxy with a translation map. This object allows a set of keys to be translated to those present in a RowProxy. cCs4t|tƒr|j|_n ||_||_dS(N(R%R¬trowtmap(RpR­R®((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRq·s cCs|j||jkS(N(R®R­(Rptkey((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt __contains__ÀscCs ||kS(N((RpR¯((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pythas_keyÃscCs|j|j|S(N(R­R®(RpR¯((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt __getitem__ÆscCs |jjƒS(N(R­tkeys(Rp((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR³És(RxRyRzRqR°R±R²R³(((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR¬¯s    R„cBsGeZdZddddded„Zejd„ZeZ d„Z RS(s5Clones and modifies clauses based on column correspondence. E.g.:: table1 = Table('sometable', metadata, Column('col1', Integer), Column('col2', Integer) ) table2 = Table('someothertable', metadata, Column('col1', Integer), Column('col2', Integer) ) condition = table1.c.col1 == table2.c.col1 make an alias of table1:: s = table1.alias('foo') calling ``ClauseAdapter(s).traverse(condition)`` converts condition to read:: s.c.col1 == table2.c.col1 cs£i|gd6|_||_ˆrD| s/t‚‡fd†|_n ||_ˆru| s`t‚‡fd†|_n ||_tj|piƒ|_||_dS(NRˆcs |ˆkS(N((R2(tinclude(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR@ðscs |ˆkS(N((R2(texclude(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR@õs( t__traverse_options__t selectabletAssertionErrort include_fnt exclude_fnRt column_dictt equivalentstadapt_on_names(RpR·R¼R´RµR¹RºR½((RµR´sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRqès     c CsÅ|jj|d|ƒ}|dkr‘||jkr‘||kr‘xO|j|D]=}|j|d|d|j|gƒƒ}|dk rM|SqMWn|jrÁ|dkrÁ|jjj|j ƒ}n|S(Ntrequire_embeddedt_seen( R·tcorresponding_columnRR¼t_corresponding_columntunionR½RWtgetR”(RpRœR¾R¿tnewcoltequiv((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRÁûs  '   cCs’|j r2t|tƒr2|jj|ƒr2|jSt|tƒsEdS|jrb|j|ƒ rbdS|jr~|j|ƒr~dS|j |t ƒSdS(N( t magic_flagR%RR·RR RR¹RºRÁRZ(RpRœ((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRj sN( RxRyRzRRGRqRt EMPTY_SETRÁRÆRj(((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyR„Ís t ColumnAdaptercBsneZdZdddded„Zd„ZejZ ej Z d„Z d„Z d„Zd„Zd„ZRS( sñExtends ClauseAdapter with extra utility functions. Provides the ability to "wrap" this ClauseAdapter around another, a columns dictionary which returns adapted elements given an original, and an adapted_row() factory. cCsQtj|||||ƒ|r/|j|ƒntj|jƒ|_||_dS(N(R„RqRRtpopulate_column_dictt _locate_colR–tadapt_required(RpR·R¼tchain_toR´RµRË((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRq%s  cCs‘|jj|jƒ}|jjƒ|_|j|j|jƒ|_|j|j|jƒ|_|j|j|jƒ|_tj |jƒ|_ |S(N( t __class__t__new__t__dict__tcopyt_wrapRÊt adapt_clauset adapt_listRRÉR–(RpR‰tac((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytwrap/scs‡‡fd†}|S(Ncsˆ|ƒ}ˆ|ƒS(N((Rœ(twrappedtlocal(sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pytlocate<s ((RpR×RÖRØ((RÖR×sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRÑ;scCsn|j|tƒ}|dkrQ|j|ƒ}t|tƒrQ|jdƒ}qQn|jrj||krjdS|S(N(RÁRZRRÒR%RtlabelRË(RpRœRW((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRÊAs cCst||jƒS(N(R¬R–(RpR­((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt adapted_rowTscCs|jjƒ}|d=|S(NR–(RÏRÐ(Rptd((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt __getstate__WscCs)|jj|ƒtj|jƒ|_dS(N(RÏRARt PopulateDictRÊR–(Rptstate((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt __setstate__\sN(RxRyRzRRGRqRÕR„RFRÒtcopy_and_processRÓRÑRÊRÚRÜRß(((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyRÈs      N(<RztRRtbaseRRRRt itertoolsRt collectionsRtelementsRR R R R R RR·RRRRtschemaRt langhelperstpublic_factoryt_join_conditiontjoin_conditiont annotationRRRRtddlRR#R7RGRORXR\RYRaRgRltobjectRmRƒRRŒRŸR«R¬tReplacingCloningVisitorR„RÈ(((sY/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/sql/util.pyt sD4"    <       H1N