Package fr.dyade.aaa.util

Class DBRepository

java.lang.Object

fr.dyade.aaa.util.DBRepository

All Implemented Interfaces:

Repository

public final class DBRepository
extends Object
implements Repository

This class allows to use a database through JDBC as repository with the NTransaction module.

See Also:

NTransaction, Repository

Field Summary

Fields

Modifier and Type	Field	Description
private int	baddeleted
(package private) Connection	conn
(package private) String	connurl
(package private) PreparedStatement	deleteStmt
(package private) File	dir
(package private) String	driver
(package private) PreparedStatement	insertStmt
private int	nbdeleted
private int	nbloaded
private int	nbsaved
(package private) PreparedStatement	updateStmt

Constructor Summary

Constructors

Constructor	Description
DBRepository()

Method Summary

Modifier and Type	Method	Description
void	backup(BackupFile backup)	Backups the repository (may be unimplemented).
void	close()	Closes the repository.
void	commit()	Commits all changes to the repository.
void	delete(String dirName, String name)	Deletes the corresponding objects in repository.
int	getNbBadDeletedObjects()	Returns the number of useless delete operation on repository.
int	getNbDeletedObjects()	Returns the number of delete operation on repository.
int	getNbLoadedObjects()	Returns the number of load operation from repository.
int	getNbSavedObjects()	Returns the number of save operation to repository.
void	init(Transaction transaction, File dir)	Initializes the repository.
String[]	list(String prefix)	Gets a list of persistent objects that name corresponds to prefix.
byte[]	load(String dirName, String name)	Loads the byte array.
void	save(String dirName, String name, byte[] content)	Save the corresponding bytes array.

Methods inherited from class java.lang.Object

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

Field Detail

driver

String driver

connurl

String connurl

dir

File dir

nbsaved

private int nbsaved

nbdeleted

private int nbdeleted

baddeleted

private int baddeleted

nbloaded

private int nbloaded

conn

Connection conn

insertStmt

PreparedStatement insertStmt

updateStmt

PreparedStatement updateStmt

deleteStmt

PreparedStatement deleteStmt

Constructor Detail

DBRepository

public DBRepository()

Method Detail

getNbSavedObjects

public int getNbSavedObjects()

Returns the number of save operation to repository.

Specified by:

getNbSavedObjects in interface Repository

Returns:

The number of save operation to repository.

getNbDeletedObjects

public int getNbDeletedObjects()

Returns the number of delete operation on repository.

Specified by:

getNbDeletedObjects in interface Repository

Returns:

The number of delete operation on repository.

getNbBadDeletedObjects

public int getNbBadDeletedObjects()

Returns the number of useless delete operation on repository.

Specified by:

getNbBadDeletedObjects in interface Repository

Returns:

The number of useless delete operation on repository.

getNbLoadedObjects

public int getNbLoadedObjects()

Returns the number of load operation from repository.

Specified by:

getNbLoadedObjects in interface Repository

Returns:

The number of load operation from repository.

init

public void init(Transaction transaction,
                 File dir)
          throws IOException

Initializes the repository. Opens the connection, evntually creates the database and tables.

Specified by:

init in interface Repository

Parameters:

transaction - the transaction object.

dir - the directory.

Throws:

IOException - an error occurs.

list

public String[] list(String prefix)
              throws IOException

Gets a list of persistent objects that name corresponds to prefix.

Specified by:

list in interface Repository

Parameters:

prefix - the prefix.

Returns:

The list of corresponding names.

Throws:

IOException - an error occurs.

save

public void save(String dirName,
                 String name,
                 byte[] content)
          throws IOException

Save the corresponding bytes array.

Specified by:

save in interface Repository

Parameters:

dirName - the directory.

name - the object name.

content - the serialized object view.

Throws:

IOException - an error occurs.

load

public byte[] load(String dirName,
                   String name)
            throws IOException

Loads the byte array.

Specified by:

load in interface Repository

Parameters:

dirName - the directory.

name - the object name.

Returns:

The loaded bytes array.

Throws:

IOException - an error occurs.

delete

public void delete(String dirName,
                   String name)
            throws IOException

Deletes the corresponding objects in repository.

Specified by:

delete in interface Repository

Parameters:

dirName - the directory.

name - the object name.

Throws:

IOException - an error occurs.

commit

public void commit()
            throws IOException

Commits all changes to the repository.

Specified by:

commit in interface Repository

Throws:

IOException - an error occurs.

backup

public void backup(BackupFile backup)
            throws IOException

Description copied from interface: Repository

Backups the repository (may be unimplemented).

Specified by:

backup in interface Repository

Parameters:

backup - The backup file.

Throws:

IOException

close

public void close()
           throws IOException

Closes the repository.

Specified by:

close in interface Repository

Throws:

IOException - an error occurs.