Module Expr Str ImportFrom alias ImportFrom alias Import alias Assign TupleStore NameStore NameStore NameStore Call NameLoad Num ClassDef bases AttributeLoad NameLoad attr body Expr Str FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr Num Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Str Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults NameLoad NameLoad NameLoad Num body Expr Str Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Lambda arguments args NameParam defaults Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad keyword NameLoad keyword NameLoad keyword NameLoad keyword NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str If AttributeLoad NameLoad attr body Raise NameLoad Str Assign NameStore Dict NameLoad NameLoad NameLoad AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore ListLoad For TupleStore NameStore NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Call SubscriptLoad NameLoad Index NameLoad NameLoad Assign AttributeStore NameLoad attr ListLoad If NameLoad body Assign AttributeStore NameLoad attr Num Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Return NameLoad orelse Return Call AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr BinOpMod Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr Num Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Str Assign NameStore Call AttributeLoad AttributeLoad AttributeLoad NameLoad attr attr attr Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr Str Return SubscriptLoad SubscriptLoad Call AttributeLoad NameLoad attr Index Num Index Num decorator_list decorator_list
N/A N/A Journal using twisted.enterprise.row RDBMS support.

You're going to need the following table in your database::

    | CREATE TABLE journalinfo
    | (
    |   commandIndex int
    | );
    | INSERT INTO journalinfo VALUES (0);

 __future__ nested_scopes twisted.internet defer N/A base N/A N/A INSERT DELETE UPDATE N/A range 3 RowJournal N/A N/A base Journal N/A N/A Journal that stores data 'snapshot' in using twisted.enterprise.row.

    Use this as the reflector instead of the original reflector.

    It may block on creation, if it has to run recovery.
     __init__ N/A N/A self log journaledService reflector N/A N/A N/A N/A self reflector reflector N/A N/A self commands N/A N/A N/A self syncing 0 N/A N/A N/A N/A base Journal __init__ self log journaledService N/A updateRow N/A N/A self obj N/A N/A N/A Mark on object for updating when sync()ing. N/A N/A N/A N/A self commands append N/A UPDATE obj N/A insertRow N/A N/A self obj N/A N/A N/A Mark on object for inserting when sync()ing. N/A N/A N/A N/A self commands append N/A INSERT obj N/A deleteRow N/A N/A self obj N/A N/A N/A Mark on object for deleting when sync()ing. N/A N/A N/A N/A self commands append N/A DELETE obj N/A loadObjectsFrom N/A N/A self tableName parentRow data whereClause forceChildren N/A None None None 0 N/A N/A Flush all objects to the database and then load objects. N/A d N/A N/A self sync N/A N/A N/A d addCallback N/A N/A N/A result N/A N/A N/A N/A self reflector loadObjectsFrom tableName parentRow parentRow data data whereClause whereClause forceChildren forceChildren N/A d N/A sync N/A N/A self N/A N/A N/A Commit changes to database. N/A N/A self syncing N/A N/A ValueError sync already in progress N/A comandMap N/A INSERT UPDATE DELETE N/A N/A self reflector insertRowSQL N/A N/A self reflector updateRowSQL N/A N/A self reflector deleteRowSQL N/A sqlCommands N/A N/A N/A kind obj N/A self commands N/A N/A N/A N/A sqlCommands append N/A N/A comandMap N/A kind obj N/A N/A self commands N/A N/A sqlCommands N/A N/A N/A self syncing 1 N/A d N/A N/A N/A N/A self reflector dbpool runInteraction N/A self _sync N/A self latestIndex sqlCommands N/A N/A N/A d addCallback N/A self _syncDone N/A d N/A N/A N/A N/A defer succeed 1 N/A _sync N/A N/A self txn index commands N/A N/A N/A Do the actual database synchronization. N/A c commands N/A N/A N/A N/A txn execute c N/A N/A N/A txn update N/A UPDATE journalinfo SET commandIndex = %d index N/A _syncDone N/A N/A self result N/A N/A N/A N/A self syncing 0 N/A result N/A getLastSnapshot N/A N/A self N/A N/A N/A Return command index of last snapshot. N/A conn N/A N/A N/A N/A self reflector dbpool connect N/A cursor N/A N/A conn cursor N/A N/A N/A cursor execute SELECT commandIndex FROM journalinfo N/A N/A N/A N/A N/A cursor fetchall N/A 0 N/A 0 N/A N/A