Package twisted :: Package persisted :: Package journal :: Module rowjournal :: Class RowJournal
[show private | hide private]
[frames | no frames]

Class RowJournal

Journal --+
          |
         RowJournal


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.
Method Summary
  __init__(self, log, journaledService, reflector)
  deleteRow(self, obj)
Mark on object for deleting when sync()ing.
  executeCommand(self, command)
Log and execute a command. (inherited from Journal)
  getLastSnapshot(self)
Return command index of last snapshot.
  insertRow(self, obj)
Mark on object for inserting when sync()ing.
  loadObjectsFrom(self, tableName, parentRow, data, whereClause, forceChildren)
Flush all objects to the database and then load objects.
  sync(self)
Commit changes to database.
  updateFromLog(self)
Run all commands from log that haven't been run yet. (inherited from Journal)
  updateRow(self, obj)
Mark on object for updating when sync()ing.
  _reallyExecute(self, index, command, runTime)
Callback called when logging command is done. (inherited from Journal)
  _sync(self, txn, index, commands)
Do the actual database synchronization.
  _syncDone(self, result)

Method Details

deleteRow(self, obj)

Mark on object for deleting when sync()ing.

getLastSnapshot(self)

Return command index of last snapshot.
Overrides:
twisted.persisted.journal.base.Journal.getLastSnapshot

insertRow(self, obj)

Mark on object for inserting when sync()ing.

loadObjectsFrom(self, tableName, parentRow=None, data=None, whereClause=None, forceChildren=0)

Flush all objects to the database and then load objects.

sync(self)

Commit changes to database.
Overrides:
twisted.persisted.journal.base.Journal.sync

updateRow(self, obj)

Mark on object for updating when sync()ing.

_sync(self, txn, index, commands)

Do the actual database synchronization.

Generated by Epydoc 1.2 prerelease on Wed Jan 29 06:28:21 2003 http://epydoc.sf.net