Package es.bsc.dataclay.dbhandler.sql

Class SQLHandler<T extends DBHandlerConf>

java.lang.Object

es.bsc.dataclay.dbhandler.sql.SQLHandler<T>

All Implemented Interfaces:

DBHandler

Direct Known Subclasses:

SQLiteHandler

public abstract class SQLHandler<T extends DBHandlerConf>
extends Object
implements DBHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected T	configuration	Configuration of the connection.
protected SQLiteDataSource	dataSource	Data sources.
protected static boolean	DEBUG_ENABLED	Indicates if debug is enabled.

Constructor Summary

Constructors

Constructor	Description
SQLHandler(T connConfig)	Constructor.

Method Summary

Modifier and Type	Method	Description
boolean	close()	Close the database
int	count()	Count number of objects in DB
abstract void	createDatabase()
void	createTables()	Initialize database
abstract boolean	databaseExists()
void	delete(ObjectID objectID)	Deletes and object from the database.
abstract void	dropAllDatabases()	Drop all databases.
boolean	exists(ObjectID objectID)	Check if object with ID provided exists.
byte[]	get(ObjectID objectID)	Get serialized object identified by ObjectID
T	getConfiguration()
SQLiteDataSource	getDataSource()
protected abstract void	initDataSource()
boolean	isClosed()	Verify if database is closed.
void	open()	Open database.
void	store(ObjectID objectID, byte[] bytes)	Store the object.
void	update(ObjectID objectID, byte[] newbytes)	Updates an object identified by the ID provided with the new values provided.
void	vacuum()	Vacuum database.

Methods inherited from class java.lang.Object

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

Field Detail

DEBUG_ENABLED

protected static final boolean DEBUG_ENABLED

Indicates if debug is enabled.

dataSource

protected SQLiteDataSource dataSource

Data sources.

configuration

protected final T extends DBHandlerConf configuration

Configuration of the connection.

Constructor Detail

SQLHandler

public SQLHandler(T connConfig)

Constructor.

Parameters:

connConfig - Configuration.

Method Detail

open

public void open()

Open database.

Specified by:

open in interface DBHandler

initDataSource

protected abstract void initDataSource()

databaseExists

public abstract boolean databaseExists()

createDatabase

public abstract void createDatabase()

dropAllDatabases

public abstract void dropAllDatabases()

Drop all databases. FOR TESTING PURPOSES.

createTables

public void createTables()

Initialize database

getConfiguration

public T getConfiguration()

store

public void store(ObjectID objectID,
                  byte[] bytes)

Description copied from interface: DBHandler

Store the object.

Specified by:

store in interface DBHandler

Parameters:

objectID - ID of the object

bytes - Bytes of the object

get

public byte[] get(ObjectID objectID)

Description copied from interface: DBHandler

Get serialized object identified by ObjectID

Specified by:

get in interface DBHandler

Parameters:

objectID - ID of the object

Returns:

Bytes of the serialized object with ID provided.

exists

public boolean exists(ObjectID objectID)

Description copied from interface: DBHandler

Check if object with ID provided exists.

Specified by:

exists in interface DBHandler

Parameters:

objectID - ID of the object

Returns:

TRUE if object exists.

count

public int count()

Description copied from interface: DBHandler

Count number of objects in DB

Specified by:

count in interface DBHandler

Returns:

number of objects in DB

update

public void update(ObjectID objectID,
                   byte[] newbytes)

Description copied from interface: DBHandler

Updates an object identified by the ID provided with the new values provided.

Specified by:

update in interface DBHandler

Parameters:

objectID - ID of the object.

newbytes - New byte values

delete

public void delete(ObjectID objectID)

Description copied from interface: DBHandler

Deletes and object from the database.

Specified by:

delete in interface DBHandler

Parameters:

objectID - ID of the object to delete

vacuum

public void vacuum()

Description copied from interface: DBHandler

Vacuum database.

Specified by:

vacuum in interface DBHandler

isClosed

public boolean isClosed()

Description copied from interface: DBHandler

Verify if database is closed.

Specified by:

isClosed in interface DBHandler

Returns:

TRUE if database is closed. FALSE, otherwise.

close

public boolean close()

Description copied from interface: DBHandler

Close the database

Specified by:

close in interface DBHandler

Returns:

TRUE if database was closed successfully. FALSE otherwise.

getDataSource

public SQLiteDataSource getDataSource()