Node Director
|
SyncDB passes on any append/replace/whatever requests to a
wrapped DB connection. More...
Classes | |
class | WrapAccessor |
Public Member Functions | |
SyncDB () | |
SyncDB (String url) | |
void | setURL (String url) throws DirectorException |
set URL of the RemoteFile used for input/output | |
Enumeration | search (final String expr, Options searchopt) throws DirectorException |
void | append (DBObject dbo) throws DirectorException |
void | truncate () throws DirectorException |
DBAccessor | get (DN dn) throws DirectorException |
void | replace (DBObject dbo) throws DirectorException |
void | remove (DBObject dbo) throws DirectorException |
void | modify (DBObject dbo, Vector attrs) throws DirectorException |
void | close () throws DirectorException |
boolean | isInScope (DBObject dbo) |
returns true if the argument is an object covered by this SyncDB instance. | |
Public Member Functions inherited from sfi.director.repository.DBConnection | |
void | setCredentials (Credentials cred) |
String | getURL () |
void | setContext (RemoteJob context) |
void | setOption (String option) |
void | setOption (String option, String val) |
void | setOption (Options opt) |
void | setOption (SURL url) |
String | getOption (String option) |
void | setError (Exception e) |
Exception | getError () |
DN | completeDN (DN dn) |
Enumeration | search (String expr) throws DirectorException |
abstract Enumeration | search (String expr, Options searchopt) throws DirectorException |
Additional Inherited Members | |
Static Public Member Functions inherited from sfi.director.repository.DBConnection | |
static Enumeration | unwrap (final Enumeration wrapped) |
Given an Enumeration of DBAccessor objects as returned by the search() method, returns an Enumeration of DBObject objects. | |
static String | escapeSearchval (String val) |
Static Public Attributes inherited from sfi.director.repository.DBConnection | |
static final String | SEARCH_BASEDN = "BaseDN" |
used in conjunction with the search() method to set the base DN of the subtree we are about to search (option) | |
static final String | SEARCH_NOSUB = "Sub" |
static final String | SEARCH_WITHSTRUCT = "WithStruct" |
static final String | SEARCH_SORT = "Sort" |
static final String | SEARCH_SCHEMA = "Schema" |
Protected Attributes inherited from sfi.director.repository.DBConnection | |
String | url |
RemoteJob | context |
Options | options = new Options() |
Exception | error = null |
SyncDB passes on any append/replace/whatever requests to a
wrapped DB connection.
If somewhen during the transmission the truncate() method was called SyncDB will delete any record not touched between truncate() and close() on close. Thus after a SyncDB connection closed only the newly appended/replaced records will be left in the target database.
sfi.director.repository.SyncDB.SyncDB | ( | ) |
sfi.director.repository.SyncDB.SyncDB | ( | String | url | ) |
url |
References sfi.director.repository.SyncDB.setURL().
|
virtual |
*
DirectorException |
dbo |
Implements sfi.director.repository.DBConnection.
References sfi.director.repository.DBConnection.append(), and sfi.director.repository.DBConnection.replace().
void sfi.director.repository.SyncDB.close | ( | ) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.DBConnection.close(), sfi.director.repository.DBObject.getDN(), sfi.director.repository.SyncDB.isInScope(), sfi.director.repository.DBConnection.remove(), sfi.director.repository.SyncDB.search(), and sfi.director.repository.DBConnection.unwrap().
DBAccessor sfi.director.repository.SyncDB.get | ( | DN | dn | ) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.DBConnection.get().
boolean sfi.director.repository.SyncDB.isInScope | ( | DBObject | dbo | ) |
returns true if the argument is an object covered by this SyncDB instance.
After truncation only objects in the target database that are "in scope" are to be removed. The SyncDB default is that every object is "in scope". Inherited classes might override this.
Reimplemented in sfi.director.repository.SyncPartialDB.
Referenced by sfi.director.repository.SyncDB.close().
void sfi.director.repository.SyncDB.modify | ( | DBObject | dbo, |
Vector | attrs | ||
) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.DBConnection.modify().
void sfi.director.repository.SyncDB.remove | ( | DBObject | dbo | ) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.DBConnection.remove().
void sfi.director.repository.SyncDB.replace | ( | DBObject | dbo | ) | throws DirectorException |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.DBConnection.replace().
Enumeration sfi.director.repository.SyncDB.search | ( | final String | expr, |
Options | searchopt | ||
) | throws DirectorException |
References sfi.director.repository.DBConnection.search().
Referenced by sfi.director.repository.SyncDB.close().
void sfi.director.repository.SyncDB.setURL | ( | String | url | ) | throws DirectorException |
set URL of the RemoteFile used for input/output
DirectorException |
url |
Reimplemented from sfi.director.repository.DBConnection.
References sfi.director.repository.DBManager.getConnection(), and sfi.director.repository.DBConnection.url.
Referenced by sfi.director.repository.SyncDB.SyncDB().
|
virtual |
Implements sfi.director.repository.DBConnection.