Class DBPersistenceManager

java.lang.Object

org.jgroups.persistence.DBPersistenceManager

All Implemented Interfaces:

PersistenceManager

public class DBPersistenceManager
extends Object
implements PersistenceManager

Class will be utilized

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.commons.logging.Log	log

Constructor Summary

Constructors

Constructor	Description
DBPersistenceManager(InputStream input)	Duplicate constructor allowing inputstream
DBPersistenceManager(String filename)	Default construct

Method Summary

Modifier and Type	Method	Description
void	clear()	Clears the key-cache as well as all entries
protected void	init(InputStream in)	used to intitiailize complete DB access.
Serializable	remove(Serializable key)	Removes existing entry.
Map	retrieveAll()	Used to retrieve the persisted map back to its last known state
void	save(Serializable key, Serializable val)	Saves NV pair as serializable object; creates if new, stores new state if already exists.
void	saveAll(Map map)	Saves all row entries for the map to DB.
void	shutDown()	Shutting down the database cleanly

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

log

protected final org.apache.commons.logging.Log log

Constructor Details

DBPersistenceManager

public DBPersistenceManager(String filename)
                     throws Exception

Default construct

Parameters:

filename - absolute filepath

Throws:

Exception

DBPersistenceManager

public DBPersistenceManager(InputStream input)
                     throws Exception

Duplicate constructor allowing inputstream

Parameters:

input -

Throws:

Exception

Method Details

init

protected void init(InputStream in)
             throws Exception

used to intitiailize complete DB access. THis method will use existing database to create schema (if it doesnt exist) and get PersistenceManager in usable condition

Parameters:

in -

Throws:

Exception

save

public void save(Serializable key,
 Serializable val)
          throws CannotPersistException

Saves NV pair as serializable object; creates if new, stores new state if already exists.

Specified by:

save in interface PersistenceManager

Parameters:

key -

val -

Throws:

CannotPersistException

remove

public Serializable remove(Serializable key)
                    throws CannotRemoveException

Removes existing entry.

Specified by:

remove in interface PersistenceManager

Parameters:

key -

Returns:

Serializable; gives back the value

Throws:

CannotRemoveException

saveAll

public void saveAll(Map map)
             throws CannotPersistException

Saves all row entries for the map to DB.

Specified by:

saveAll in interface PersistenceManager

Parameters:

map -

Throws:

CannotPersistException

retrieveAll

public Map retrieveAll()
                throws CannotRetrieveException

Used to retrieve the persisted map back to its last known state

Specified by:

retrieveAll in interface PersistenceManager

Returns:

Map;

Throws:

CannotRetrieveException

clear

public void clear()
           throws CannotRemoveException

Clears the key-cache as well as all entries

Specified by:

clear in interface PersistenceManager

Throws:

CannotRemoveException

shutDown

public void shutDown()

Shutting down the database cleanly

Specified by:

shutDown in interface PersistenceManager