H`Tc@sdZddlmZmZddlmZmZddlZddlZyddl m Z dZ Wne k rdZ nXydd l m Z Wn'e k rd efd YZ nXd e fd YZy!ddlmZejeWne k r nXdefdYZdefdYZdefdYZdefdYZdefdYZdefdYZdS(sSDefine result set constructs including :class:`.ResultProxy` and :class:`.RowProxy.i(texctutil(t expressiontsqltypesiN(tsafe_rowproxy_reconstructorcCs t||S(N(R(tclststate((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pytrowproxy_reconstructorscCs |j|}|j||S(N(t__new__t __setstate__(RRtobj((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs (t BaseRowProxyR cBsMeZd ZdZdZdZdZdZd Zd Z RS( t_parentt_rowt _processorst_keymapcCs(||_||_||_||_dS(s8RowProxy objects are constructed by ResultProxy objects.N(R R RR(tselftparenttrowt processorstkeymap((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__init__*s   cCst|j|jffS(N(Rt __class__t __getstate__(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt __reduce__2scCs t|S(s9Return the values represented by this RowProxy as a list.(tlist(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pytvalues6sccsIxBt|j|jD]+\}}|dkr6|Vq||VqWdS(N(tzipRR tNone(Rt processortvalue((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__iter__:s" cCs t|jS(N(tlenR (R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__len__AscCs&y|j|\}}}Wntk rH|jj|\}}}ntk rt|trg}xZt|j||j |D];\}}|dkr|j |q|j ||qWt |SnX|dkrt jd|n|dk r||j |S|j |SdS(NsVAmbiguous column name '%s' in result set! try 'use_labels' option on select statement.(RtKeyErrorR t _key_fallbackt TypeErrort isinstancetsliceRRR RtappendttupleRtInvalidRequestError(RtkeyRR tindextlR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt __getitem__Ds*       cCs9y ||SWn&tk r4}t|jdnXdS(Ni(R"tAttributeErrortargs(Rtnamete((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt __getattr__^s (s_parents_rows _processorss_keymap( t__name__t __module__t __slots__RRRRR!R-R2(((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR 's      tRowProxycBseZdZdZdZdZdZdZdZ dZ dZ dZ dZ d Zd Zd Zd Zd ZdZdZdZRS(sxProxy values from a single cursor row. Mostly follows "ordered dictionary" behavior, mapping result values to the string-based column name, the integer position of the result in the row, as well as Column instances which can be mapped to the original Columns that produced this result set (for results that correspond to constructed SQL expressions). cCs|jj|j|S(N(R t_has_keyR (RR*((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt __contains__pscCsi|jd6t|d6S(NR R (R R((R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRss cCs:|d|_}|d|_|j|_|j|_dS(NR R (R R RR(RRR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR ys  cCs;t|tr(|t|t|S|t||S(N(R%R6R((Rtothertop((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt_ops(cCs|j|tjS(N(R;toperatortlt(RR9((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__lt__scCs|j|tjS(N(R;R<tle(RR9((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__le__scCs|j|tjS(N(R;R<tge(RR9((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__ge__scCs|j|tjS(N(R;R<tgt(RR9((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__gt__scCs|j|tjS(N(R;R<teq(RR9((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__eq__scCs|j|tjS(N(R;R<tne(RR9((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__ne__scCstt|S(N(treprR((R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt__repr__scCs|jj|j|S(s4Return True if this RowProxy contains the given key.(R R7R (RR*((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pythas_keyscCs'g|jD]}|||f^q S(s@Return a list of tuples, each tuple containing a key/value pair.(tkeys(RR*((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pytitemsscCs |jjS(s@Return the list of keys as strings represented by this RowProxy.(R RL(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRLscCst|jjS(N(titerR RL(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pytiterkeysscCs t|S(N(RN(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt itervaluess(N(R3R4t__doc__R5R8RR Rt__hash__R;R>R@RBRDRFRHRJRKRMRLRORP(((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR6es&               (tSequencetResultMetaDatacBsYeZdZdZejdddZedZdZ dZ dZ RS( sRHandle cursor.description, applying additional info from an execution context.cCsg|_}i|_}g|_|j}|j}|j}|j}|j|_i} xt|D]\} } | d} | d} |j r|j | } n|r|| \} }n|j r|j | } n|j rIy/|j |jr| n | j\}}}Wqltk rE| d|j| tj}}}qlXn#| d|j| tj}}}|j|| | }|j|||| f} | | | <| j|jr|n |j| | k rd|df| |jr|n |j<} n|jj| |r7x|D]}| ||s(RRRLtcontexttdialecttdbapi_type_mapt_translate_colnametcase_sensitivet enumeratetdescription_encodingt_description_decodertrequires_name_normalizetnormalize_namet result_maptlowerR"RtgetRtNULLTYPEtget_result_processorR't setdefaulttupdatet_echotenginetloggertdebugR((RRtmetadataRRRWRXttypemapttranslate_colnametprimary_keymaptitrectcolnametcoltypet untranslatedR0R ttype_Rto((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRsZ             ) *#    /    s0.8s,sqlite dialect uses _translate_colname() nowcCsg|j|jr|n |j}\}}}|jj|||k rc||df|j| '     cCs-||jkrtS|j|tdk SdS(N(RtTrueR#tFalseR(RRR*((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR7RscCs8itd|jjDd6|jd6|jd6S(NcssC|]9\}\}}}t|tjtjr||fVqdS(N(R%RRyt int_types(RUR*RR R+((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pys [st_pickled_keymapRLR[(tdictRRMRLR[(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRXs  cCsgtt|dD] }d^q|_i|_}x1|djD]\}}dd|f||Statement is not an insert() or update() expression construct.(RWRRR)RRtpostfetch_cols(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs   cCsT|jjstjdn,|jj rJ|jj rJtjdn|jjS(sLReturn ``prefetch_cols()`` from the underlying :class:`.ExecutionContext`. See :class:`.ExecutionContext` for details. Raises :class:`~sqlalchemy.exc.InvalidRequestError` if the executed statement is not a compiled expression construct or is not an insert() or update() construct. s1Statement is not a compiled expression construct.s>Statement is not an insert() or update() expression construct.(RWRRR)RRt prefetch_cols(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs   cCs |jjS(sxReturn ``supports_sane_rowcount`` from the dialect. See :attr:`.ResultProxy.rowcount` for background. (RXtsupports_sane_rowcount(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRscCs |jjS(s~Return ``supports_sane_multi_rowcount`` from the dialect. See :attr:`.ResultProxy.rowcount` for background. (RXtsupports_sane_multi_rowcount(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRscCs3y|jjSWntk r.|jnXdS(N(RRR.t _non_result(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt_fetchone_impls cCsOy-|dkr|jjS|jj|SWntk rJ|jnXdS(N(RRt fetchmanyR.R(Rtsize((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt_fetchmany_impls    cCs3y|jjSWntk r.|jnXdS(N(RtfetchallR.R(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt_fetchall_impls cCs4|jdkr!tjdntjddS(NsJThis result object does not return rows. It has been closed automatically.sThis result object is closed.(RRRtResourceClosedError(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs c Cs|j}|j}|j}|j}|jr|jjjj}g}x7|D]/}|d||j |||||qLW|Sg|D]}|||||^qSdS(NsRow %r( t _process_rowRRRRhRWRiRjRkR'( Rtrowst process_rowRlRRtlogR,R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt process_rowss        cCscy'|j|j}|j|SWn5tk r^}|jj|dd|j|jnXdS(s7Fetch all rows, just like DB-API ``cursor.fetchall()``.N( RRRRRRRRRW(RR,R1((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR s   cCs{y?|j|j|}t|dkr:|jn|SWn5tk rv}|jj|dd|j|j nXdS(sFetch many rows, just like DB-API ``cursor.fetchmany(size=cursor.arraysize)``. If rows are present, the cursor remains open after this is called. Else the cursor is automatically closed and an empty list is returned. iN( RRR RRRRRRRW(RRR,R1((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs    cCszy>|j}|dk r/|j|gdS|jdSWn5tk ru}|jj|dd|j|jnXdS(sFetch one row, just like DB-API ``cursor.fetchone()``. If a row is present, the cursor remains open after this is called. Else the cursor is automatically closed and None is returned. iN( RRRRRRRRRW(RRR1((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR(s     cCs|jdkr|jny|j}Wn5tk rc}|jj|dd|j|jnXz(|dk r|j |gdSdSWd|j XdS(sxFetch the first row and then close the result set unconditionally. Returns None if no row is present. iN( RRRRRRRRRWRR(RRR1((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pytfirst;s    cCs(|j}|dk r |dSdSdS(sxFetch the first column of the first row, and close the result set. Returns None if no row is present. iN(RR(RR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pytscalarSs  N(+R3R4RQR6RRtout_parametersRt_can_close_connectionRRRRLRtmemoized_propertyRtpropertyRRRRRRRRRRRRRRRRRRRRRRRRRR(((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRqsD  /    +          tBufferedRowResultProxycBs|eZdZdZidd6dd6dd6dd6dd6dd6d d6d d 6Zd Zd Zdd ZdZ RS(sZA ResultProxy with row buffering behavior. ``ResultProxy`` that buffers the contents of a selection of rows before ``fetchone()`` is called. This is to allow the results of ``cursor.description`` to be available immediately, when interfacing with a DB-API that requires rows to be consumed before this information is available (currently psycopg2, when used with server-side cursors). The pre-fetching behavior fetches only one row initially, and then grows its buffer size by a fixed amount with each successive need for additional rows up to a size of 100. cCs!|jtt|jdS(N(t$_BufferedRowResultProxy__buffer_rowstsuperRR(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRos iii ii2idiiicCsLt|dd}tj|jj||_|jj|||_dS(Nt_bufsizei( tgetattrt collectionstdequeRRt"_BufferedRowResultProxy__rowbuffert size_growthRcR(RR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyt __buffer_rowsscCs=|jr dS|js0|j|js0dSn|jjS(N(RRRRtpopleft(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs    cCsc|dkr|jSg}x@td|D]/}|j}|dkrNPn|j|q,W|S(Ni(RRRRR'(RRRRVR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs    cCs5|jj|jj|j}tj|_|S(N(RtextendRRRR(Rtret((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs N( R3R4RQRRRRRRR(((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyR`s     tFullyBufferedResultProxycBs>eZdZdZdZdZddZdZRS(sA result proxy that buffers rows fully upon creation. Used for operations where a result is to be delivered after the database conversation can not be continued, such as MSSQL INSERT...OUTPUT after an autocommit. cCs&tt|j|j|_dS(N(RRRt _buffer_rowst$_FullyBufferedResultProxy__rowbuffer(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRscCstj|jjS(N(RRRR(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRscCs|jr|jjSdSdS(N(RRR(R((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs  cCsc|dkr|jSg}x@td|D]/}|j}|dkrNPn|j|q,W|S(Ni(RRRRR'(RRRRVR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs    cCs|j}tj|_|S(N(RRR(RR((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs N( R3R4RQRRRRRR(((s^/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/sqlalchemy/engine/result.pyRs     tBufferedColumnRowcBseZdZRS(cCst|}d}x>|jD]3}|dk rE||||||_i}x9|j j D](\}\}}}d||f|| s4      >K B'