G`Tc@shdZddlmZmZddlZddlZddlZddlZddlZddl Z ddl m Z ddlm Z ddl mZmZddlmZddlmZdd lmZdd l mZmZdd lmZdd lmZdd lmZddlm Z ddl!m"Z"m#Z#ddl$m%Z%m&Z&m'Z'm(Z(ej)dkrsej*Z+n ejZ+yddl m,Z,Wne-k rdZ,nXdZ/e,peZ0ej1dZ2eZ3e3j4dZ5e3j4dZ6dZ7dZ8dZ9dZ:de;fdYZ<dZ=defdYZ>d e?fd!YZ@d"e?fd#YZAd$e?fd%YZBd&ZCd'e?fd(YZDd)ejEfd*YZFd+e?fd,YZGd-ZHd.e?fd/YZId0ZJd1e#fd2YZKd3ZLd4e?fd5YZMd6e?fd7YZNd8e?fd9YZOdS(:s flaskext.sqlalchemy ~~~~~~~~~~~~~~~~~~~ Adds basic SQLAlchemy support to your application. :copyright: (c) 2014 by Armin Ronacher, Daniel Neuhäuser. :license: BSD, see LICENSE for more details. i(twith_statementtabsolute_importN(tceil(tpartial(t_request_ctx_stacktabort(t Namespace(t itemgetter(tLock(tormtevent(tUnmappedClassError(tSession(tlisten(tmake_url(tdeclarative_basetDeclarativeMeta(t iteritemst itervaluestxranget string_typestwin32(t_app_ctx_stacks2.0s([A-Z]+)(?=[a-z0-9])smodels-committedsbefore-models-committedcsfd}|S(Ncst|dkrFt|djrF|djf|d}n|jddp[i}|jdd||d|if}nt|dn||S(Ntbackrefi(R)RR(R"R#R*(tfn(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytnewfnMs   (t functoolstwraps(R+R,((R+s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt_wrap_with_default_query_classLs cCsxVttjfD]E}x<|jD]1}t||s t||t||q q WqWt||_t|j |_ t|j |_ t|j |_ t |_ dS(N( R R t__all__thasattrtsetattrtgetattrR%R!R/t relationshiptrelationtdynamic_loaderR (tobjtmoduletkey((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt_include_sqlalchemyYs$t_DebugQueryTuplecBszeZeedZeedZeedZeedZeedZedZ dZ RS(iiiiicCs|j|jS(N(tend_timet start_time(tself((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytdurationmscCsd|j|j|jfS(Ns3(t statementt parametersR?(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt__repr__qs( t__name__t __module__tpropertyRR@RAR=R<tcontextR?RB(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR;fscCstjd}xy|jdk r|jjd}|r~||ksX|j|dr~|jj}d|jj |j |fS|j}qWdS(NiRCt.s %s:%s (%s)s ( tsyst _getframetf_backRt f_globalstgett startswithtf_codetco_namet co_filenametf_lineno(tapp_pathtfrmtnametfuncname((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt_calling_contextys%   tSignallingSessioncBs)eZdZeedZddZRS(s8The signalling session is the default session that Flask-SQLAlchemy uses. It extends the default session system with bind selection and modification tracking. If you want to use a different session you can override the :meth:`SQLAlchemy.create_session` function. .. versionadded:: 2.0 c Ks~|j|_i|_|jjd|_|jddpC|j}tj |d|d|d|d|j |j|dS(NtSQLALCHEMY_TRACK_MODIFICATIONStbindt autocommitt autoflushtbinds( tget_apptappt_model_changestconfigtemit_modification_signalsRRtenginet SessionBaset__init__t get_binds(R>R$RZR[toptionsRY((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRds cCsz|dk rgt|jdi}|jd}|dk rgt|j}|jj|jd|Sntj |||S(NRRRY( RR3t mapped_tableRLt get_stateR^R$t get_engineRctget_bind(R>tmappertclauseRRtstate((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRjs  N(RCRDt__doc__tFalsetTrueRdRRj(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRWs t_SessionSignalEventscBs>eZdZedZedZedZRS(cCs=ttd|jttd|jttd|jdS(Nt before_committ after_committafter_rollback(R Rctsession_signal_before_committsession_signal_after_committsession_signal_after_rollback(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytregisterscCsEt|tsdS|j}|rAtj|jd|jndS(Ntchanges(RRWR_tbefore_models_committedtsendR^tvalues(tsessionR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRus  cCsUt|tsdS|j}|rQtj|jdt|j|jndS(NRy( RRWR_tmodels_committedR{R^tlistR|tclear(R}R(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRvs  "cCs$t|tsdS|jjdS(N(RRWR_R(R}((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRws(RCRDRxt staticmethodRuRvRw(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRqs  t_MapperSignalEventscBsDeZdZdZdZdZdZedZRS(cCs ||_dS(N(Rk(R>Rk((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRdscCsFt|jd|jt|jd|jt|jd|jdS(Nt after_deletet after_insertt after_update(R Rktmapper_signal_after_deletetmapper_signal_after_inserttmapper_signal_after_update(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRxscCs|j||ddS(Ntdelete(t_record(R>Rkt connectionttarget((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRscCs|j||ddS(Ntinsert(R(R>RkRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRscCs|j||ddS(Ntupdate(R(R>RkRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRscCsVtj|}t|trR|jrRt|j|}||f|j|Rbt import_name((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRds cCs0t|jd|jt|jd|jdS(Ntbefore_cursor_executetafter_cursor_execute(R RbRR(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRxscCs"tjdk rt|_ndS(N(tconnection_stackttopRt_timert_query_start_time(R>tconntcursorR@RARFt executemany((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRsc Cstj}|dk rt|dd}|dkrLg}t|d|n|jt|||jtt |j fndS(Ntsqlalchemy_queries( RRRR3R2tappendR;RRRVR( R>RRR@RARFRtctxtqueries((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs    (RCRDRnRdRxRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs    cCsttjdgS(sIn debug mode Flask-SQLAlchemy will log all the SQL queries sent to the database. This information is available until the end of request which makes it possible to easily ensure that the SQL generated is the one expected on errors or in unittesting. If you don't want to enable the DEBUG mode for your unittests you can also enable the query recording by setting the ``'SQLALCHEMY_RECORD_QUERIES'`` config variable to `True`. This is automatically enabled if Flask is in testing mode. The value returned will be a list of named tuples with the following attributes: `statement` The SQL statement issued `parameters` The parameters for the SQL statement `start_time` / `end_time` Time the query started / the results arrived. Please keep in mind that the timer function used depends on your platform. These values are only useful for sorting or comparing. They do not necessarily represent an absolute timestamp. `duration` Time the query took in seconds `context` A string giving a rough estimation of where in your application query was issued. The exact format is undefined so don't try to reconstruct filename or function name. R(R3RR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytget_debug_queriess t PaginationcBseZdZdZedZedZedZedZ edZ edZ edZ d d d d d Z RS( s>Internal helper class returned by :meth:`BaseQuery.paginate`. You can also construct it from any other SQLAlchemy query object if you are working with other libraries. Additionally it is possible to pass `None` as query object in which case the :meth:`prev` and :meth:`next` will no longer work. cCs1||_||_||_||_||_dS(N(tquerytpagetper_pagettotaltitems(R>RRRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRd0s     cCs>|jdkrd}n"tt|jt|j}|S(sThe total number of pagesi(RtintRRtfloat(R>tpages((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR=s "cCs;|jdk std|jj|jd|j|S(s;Returns a :class:`Pagination` object for the previous page.s2a query object is required for this method to workiN(RRtAssertionErrortpaginateRR(R>t error_out((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytprevFscCs |jdS(sNumber of the previous page.i(R(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytprev_numLscCs |jdkS(sTrue if a previous page existsi(R(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pythas_prevQscCs;|jdk std|jj|jd|j|S(s7Returns a :class:`Pagination` object for the next page.s2a query object is required for this method to workiN(RRRRRR(R>R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytnextVscCs|j|jkS(sTrue if a next page exists.(RR(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pythas_next\scCs |jdS(sNumber of the next pagei(R(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytnext_numasiiccsd}xtd|jdD]u}||ksl||j|dkrY||j|ksl||j|kr|d|krdVn|V|}qqWdS(sIterates over the page numbers in the pagination. The four parameters control the thresholds how many numbers should be produced from the sides. Skipped page numbers are represented as `None`. This is how you could render such a pagination in the templates: .. sourcecode:: html+jinja {% macro render_pagination(pagination, endpoint) %} {% endmacro %} iiN(RRRR(R>t left_edget left_currentt right_currentt right_edgetlasttnum((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt iter_pagesfs (RCRDRnRdRERRoRRRRRRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR(s   R'cBs/eZdZdZdZdedZRS(shThe default query object used for models, and exposed as :attr:`~SQLAlchemy.Query`. This can be subclassed and replaced for individual models by setting the :attr:`~Model.query_class` attribute. This is a subclass of a standard SQLAlchemy :class:`~sqlalchemy.orm.query.Query` class and has all the methods of a standard query as well. cCs,|j|}|dkr(tdn|S(s_Like :meth:`get` but aborts with 404 if not found instead of returning `None`. iN(RLRR(R>tidenttrv((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt get_or_404s  cCs)|j}|dkr%tdn|S(saLike :meth:`first` but aborts with 404 if not found instead of returning `None`. iN(tfirstRR(R>R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt first_or_404s   ic Cs|r|dkrtdn|j|j|d|j}| rk|dkrk|rktdn|dkrt||krt|}n|jdj}t|||||S(sReturns `per_page` items from page `page`. By default it will abort with 404 if no items were found and the page was larger than 1. This behavor can be disabled by setting `error_out` to `False`. Returns an :class:`Pagination` object. iiN( RtlimittoffsettallRtorder_byRtcountR(R>RRRRR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs & (RCRDRnRRRpR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR's t_QueryPropertycBseZdZdZRS(cCs ||_dS(N(tsa(R>R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRdscCsNy5tj|}|r4|j|d|jjSWntk rIdSXdS(NR}(R t class_mapperR&RR}R R(R>R7ttypeRk((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt__get__s   (RCRDRdR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs cCs@|jr tS|jd}|dk r*|St|jjdS(NtSQLALCHEMY_RECORD_QUERIEStTESTING(tdebugRpR`RtboolRL(R^trq((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt_record_queriess    t_EngineConnectorcBs&eZddZdZdZRS(cCs=||_||_d|_d|_||_t|_dS(N(t_sat_appRt_enginet_connected_fort_bindRt_lock(R>RR^RY((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRds      cCse|jdkr|jjdS|jjjdp5d}|j|ksZtd|j||jS(NtSQLALCHEMY_DATABASE_URItSQLALCHEMY_BINDSsPBind %r is not specified. Set it in the SQLALCHEMY_BINDS configuration variable((RRRR`RLR(R>R\((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytget_uris cCs|j|j}|jjd}||f|jkrB|jSt|}itd6}|jj |j||jj |j|||rt|dturiRRRfR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRis"      N(RCRDRRdRRi(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs  cCstdt|DS(sAFigures out if the given dictionary defines a primary key column.css0|]&\}}t|tjr|jVqdS(N(RR Rt primary_key(t.0tktv((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pys s (tanyR(R(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt_defines_primary_keyst_BoundDeclarativeMetacBseZdZdZRS(cCsx|jd}| rb|jddkrbt|rbd}tj||jd|dRTRR(R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRds (RCRDRRd(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs cCs&d|jkstd|jdS(s"Gets the state for the applicationR ssThe sqlalchemy extension was not registered to the current application. Please make sure to call init_app() first.(t extensionsR(R^((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRhs t_SQLAlchemyStatecBseZdZdZRS(s0Remembers configuration for the (db, app) tuple.cCs||_||_i|_dS(N(R$R^t connectors(R>R$R^((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRd(s  (RCRDRnRd(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR%stModelcBseZdZeZdZRS(s!Baseclass for custom user models.N(RCRDRnR'R&RR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR.st SQLAlchemycBseZdZdeddZedZddZdZ dZ dZ dZ dZ ed Zdd Zdd Zdd Zdd ZddZedZdddZdddZdddZdZRS(sThis class is used to control the SQLAlchemy integration to one or more Flask applications. Depending on how you initialize the object it is usable right away or will attach as needed to a Flask application. There are two usage modes which work very similar. One is binding the instance to a very specific Flask application:: app = Flask(__name__) db = SQLAlchemy(app) The second possibility is to create the object once and configure the application later to support it:: db = SQLAlchemy() def create_app(): app = Flask(__name__) db.init_app(app) return app The difference between the two is that in the first case methods like :meth:`create_all` and :meth:`drop_all` will work all the time but in the second case a :meth:`flask.Flask.app_context` has to exist. By default Flask-SQLAlchemy will apply some backend-specific settings to improve your experience with them. As of SQLAlchemy 0.6 SQLAlchemy will probe the library for native unicode support. If it detects unicode it will let the library handle that, otherwise do that itself. Sometimes this detection can fail in which case you might want to set `use_native_unicode` (or the ``SQLALCHEMY_NATIVE_UNICODE`` configuration key) to `False`. Note that the configuration key overrides the value you pass to the constructor. This class also provides access to all the SQLAlchemy functions and classes from the :mod:`sqlalchemy` and :mod:`sqlalchemy.orm` modules. So you can declare models like this:: class User(db.Model): username = db.Column(db.String(80), unique=True) pw_hash = db.Column(db.String(80)) You can still use :mod:`sqlalchemy` and :mod:`sqlalchemy.orm` directly, but note that Flask-SQLAlchemy customizations are available only through an instance of this :class:`SQLAlchemy` class. Query classes default to :class:`BaseQuery` for `db.Query`, `db.Model.query_class`, and the default query_class for `db.relationship` and `db.backref`. If you use these interfaces through :mod:`sqlalchemy` and :mod:`sqlalchemy.orm` directly, the default query class will be that of :mod:`sqlalchemy`. .. admonition:: Check types carefully Don't perform type or `isinstance` checks against `db.Table`, which emulates `Table` behavior but is not a class. `db.Table` exposes the `Table` interface, but is a function which allows omission of metadata. You may also define your own SessionExtension instances as well when defining your SQLAlchemy class instance. You may pass your custom instances to the `session_extensions` keyword. This can be either a single SessionExtension instance, or a list of SessionExtension instances. In the following use case we use the VersionedListener from the SQLAlchemy versioning examples.:: from history_meta import VersionedMeta, VersionedListener app = Flask(__name__) db = SQLAlchemy(app, session_extensions=[VersionedListener()]) class User(db.Model): __metaclass__ = VersionedMeta username = db.Column(db.String(80), unique=True) pw_hash = db.Column(db.String(80)) The `session_options` parameter can be used to override session options. If provided it's a dict of parameters passed to the session's constructor. .. versionadded:: 0.10 The `session_options` parameter was added. .. versionadded:: 0.16 `scopefunc` is now accepted on `session_options`. It allows specifying a custom function which will define the SQLAlchemy session's scoping. cCs||_|dkri}n|jdtj|j||_|j|_t |_ |dk r||_ |j |n d|_ t |t|jjtjt|_dS(Nt scopefunc(tuse_native_unicodeRRRt__ident_func__tcreate_scoped_sessionR}tmake_declarative_baseRRt _engine_lockR^tinit_appR:RRkRxRqR'tQuery(R>R^Rtsession_options((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRds           cCs |jjS(sReturns the metadata(RR(R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRscCsF|dkri}n|jdd}tjt|j|d|S(srHelper factory method that creates a scoped session. It internally calls :meth:`create_session`. RN(RRR tscoped_sessionRtcreate_session(R>RfR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs   cCs t||S(sCreates the session. The default implementation returns a :class:`SignallingSession`. .. versionadded:: 2.0 (RW(R>Rf((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR scCs.tdtdddt}t||_|S(sCreates the declarative base.RRTRt metaclass(RRRRR(R>tbase((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs csyjjddjjddjjddjjdtjjddjjddjjddjjd djjd djjd tjjd ttd si_ntjd= 0.7cs=jdr,|dkr,jjq,njj|S(NR(R`RR}tcommittremove(tresponse_or_exc(R>R^(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytshutdown_sessions    N( R`RRRoRpR1RRRRt RuntimeErrort after_request(R>R^tteardownR((R>R^s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs,     csJfd}|dd|dd|dd|dd dS( Ncs*j|}|dk r&||R^RfR ((R^Rfs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs    cCs:|jjdrZ|jjdd|jdkr|jdd|jddqn|jd kr|jd}t}|jdkrt}|d krt d qn#|sd dl m }||dR^RRfR!tdetected_in_memoryR*tunu((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRs,   $   cCs|j|jS(sUGives access to the engine. If the database configuration is bound to a specific application (initialized with an application) this will always return a database connection. If however the current application is used this might raise a :exc:`RuntimeError` if no application is active at the moment. (RiR](R>((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRb(scCst|||S(s1Creates the connector for a given state and bind.(R(R>R^RY((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytmake_connector2scCsj|j[t|}|jj|}|dkrV|j||}||j|R^RYRmt connector((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRi6s   cCsR|dk r|S|jdk r&|jStj}|dk rB|jStddS(sKHelper method that implements the logic to look up an application. sUapplication not registered on db instance and no application bound to current contextN(RR^RRR(R>t reference_appR((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR]Cs   cCsRg}xEt|jjjD].}|jjd|kr|j|qqW|S(s1Returns a list of all tables relevant for a bind.R(RRRttablesRRLR(R>RYtresultttable((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pytget_tables_for_bindQs cs|j|}dgt|jjdp-d}i}xR|D]J}|j|||j|}|jtfd|DqAW|S(sReturns a dictionary with a table->engine mapping. This is suitable for use of sessionmaker(binds=db.get_binds(app)). Rc3s|]}|fVqdS(N((RR:(Rb(s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pys dsN(( R]RRR`RLRiR;Rtdict(R>R^R\tretvalRYR8((Rbs_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyReYs% 'c Cs|j|}|dkrCdgt|jjdp9d}n-t|ts^|dkrj|g}n|}xg|D]_}i}|s|j|}||dR^RYRt skip_tablesR\textraR8top((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt_execute_for_all_tablesgs (   R0cCs|j||ddS(s_Creates all tables. .. versionchanged:: 0.12 Parameters were added t create_allN(RA(R>RYR^((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRByscCs|j||ddS(s]Drops all tables. .. versionchanged:: 0.12 Parameters were added tdrop_allN(RA(R>RYR^((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRCscCs|j||ddtdS(snReflects tables from the database. .. versionchanged:: 0.12 Parameters were added treflectR>N(RARp(R>RYR^((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRDscCsid}|jdk r!|j}n!tj}|dk rB|j}nd|jj|ra|jdpddfS(Ns<%s engine=%r>R(RR^RRt __class__RCR`(R>R^R((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyRBs     N(RCRDRnRRpRdRERRR RRRRRbR5RiR]R;ReRoRARBRCRDRB(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyR:s,T    * +     (PRnt __future__RRR/treRHttimeR-R tmathRRtflaskRRt flask.signalsRtoperatorRt threadingRR R tsqlalchemy.orm.excR tsqlalchemy.orm.sessionR Rctsqlalchemy.eventR tsqlalchemy.engine.urlRtsqlalchemy.ext.declarativeRRtflask.ext.sqlalchemy._compatRRRRtplatformtclockRRt ImportErrorRt __version__RtcompileRt_signalstsignalR~RzR%R)R/R:RR;RVRWtobjectRqRRRRRR'RRRRRRhRRR(((s_/var/www/send.findwatt.com/datamanager/lib/python2.7/site-packages/flask_sqlalchemy/__init__.pyt sn      "         % #c2 '