org.rvpf.store.server.the.sql

Class SQLBackEnd

Object

SQLBackEnd

All Implemented Interfaces:

BackEnd

public class SQLBackEnd
extends Object
implements BackEnd

SQL back-end.

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_DIALECT_NAME Default dialect name.
static ElapsedTime	DEFAULT_RESPONDER_KEEP Default responder keep time.
static int	DEFAULT_SELECT_STATEMENTS_LIMIT Default select statements limit.
static String	DIALECT_CLASS_PROPERTY Names the class to use for the database specific SQL dialect.
static ClassDef	GENERIC_DIALECT Generic dialect (used if the default dialect is unknown).
static String	RESPONDER_KEEP_PROPERTY Responder keep property.
static String	SQL_CONNECTION_PROPERTIES Properties group used to configure the JDBC connection.
static String	SQL_CREATE_PROPERTY The database table will be created if necessary.
static String	STATEMENTS_PROPERTY Statements property.

Constructor Summary

Constructors

Constructor and Description
SQLBackEnd()

Method Summary

Modifier and Type	Method and Description
void	beginUpdates() Begins updates.
void	close() Closes.
void	commit() Commits.
StoreValues	createResponse(StoreValuesQuery query, Optional<Identity> identity) Creates store values for a store query.
int	delete(VersionedValue versionedValue) Deletes a point value.
void	endUpdates() Ends updates.
void	open() Opens.
int	purge(UUID[] pointUUIDs, TimeInterval timeInterval) Purges points values.
void	rollback() Rolls back.
boolean	setUp(TheStoreServiceAppImpl theStoreAppImpl) Sets up the back end.
boolean	supportsCount() Asks if the back end supports count.
boolean	supportsPurge() Asks if the back end supports purge.
void	tearDown() Tears down what has been set up.
void	update(VersionedValue versionedValue) Updates a point value.

Methods inherited from class Object

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

Methods inherited from interface BackEnd

newArchiver

Field Detail

DEFAULT_DIALECT_NAME

public static final String DEFAULT_DIALECT_NAME

Default dialect name.

See Also:

Constant Field Values

DEFAULT_RESPONDER_KEEP

public static final ElapsedTime DEFAULT_RESPONDER_KEEP

Default responder keep time.

DEFAULT_SELECT_STATEMENTS_LIMIT

public static final int DEFAULT_SELECT_STATEMENTS_LIMIT

Default select statements limit.

See Also:

Constant Field Values

DIALECT_CLASS_PROPERTY

public static final String DIALECT_CLASS_PROPERTY

Names the class to use for the database specific SQL dialect.

See Also:

Constant Field Values

GENERIC_DIALECT

public static final ClassDef GENERIC_DIALECT

Generic dialect (used if the default dialect is unknown).

RESPONDER_KEEP_PROPERTY

public static final String RESPONDER_KEEP_PROPERTY

Responder keep property.

See Also:

Constant Field Values

SQL_CONNECTION_PROPERTIES

public static final String SQL_CONNECTION_PROPERTIES

Properties group used to configure the JDBC connection.

See Also:

Constant Field Values

SQL_CREATE_PROPERTY

public static final String SQL_CREATE_PROPERTY

The database table will be created if necessary.

See Also:

Constant Field Values

STATEMENTS_PROPERTY

public static final String STATEMENTS_PROPERTY

Statements property.

See Also:

Constant Field Values

Constructor Detail

SQLBackEnd

public SQLBackEnd()

Method Detail

beginUpdates

public void beginUpdates()

Begins updates.

Specified by:

beginUpdates in interface BackEnd

close

public void close()

Closes.

Specified by:

close in interface BackEnd

commit

public void commit()

Commits.

Specified by:

commit in interface BackEnd

createResponse

public StoreValues createResponse(StoreValuesQuery query,
                                  Optional<Identity> identity)

Creates store values for a store query.

Specified by:

createResponse in interface BackEnd

Parameters:

query - The store query.

identity - The optional requesting identity.

Returns:

The store values.

delete

public int delete(VersionedValue versionedValue)

Deletes a point value.

Specified by:

delete in interface BackEnd

Parameters:

versionedValue - The point value to delete.

Returns:

The number of deleted values (0 .. 2).

endUpdates

public void endUpdates()

Ends updates.

Specified by:

endUpdates in interface BackEnd

open

public void open()
          throws ServiceNotAvailableException

Opens.

Specified by:

open in interface BackEnd

Throws:

ServiceNotAvailableException - On failure.

purge

public int purge(UUID[] pointUUIDs,
                 TimeInterval timeInterval)

Purges points values.

Specified by:

purge in interface BackEnd

Parameters:

pointUUIDs - The UUID of the points to purge.

timeInterval - A time interval.

Returns:

The number of values purged.

rollback

public void rollback()

Rolls back.

Specified by:

rollback in interface BackEnd

setUp

public boolean setUp(TheStoreServiceAppImpl theStoreAppImpl)

Sets up the back end.

Specified by:

setUp in interface BackEnd

Parameters:

theStoreAppImpl - The TheStore application instance.

Returns:

True on success.

supportsCount

public boolean supportsCount()

Asks if the back end supports count.

Specified by:

supportsCount in interface BackEnd

Returns:

True if count is supported.

supportsPurge

public boolean supportsPurge()

Asks if the back end supports purge.

Specified by:

supportsPurge in interface BackEnd

Returns:

True if purge is supported.

tearDown

public void tearDown()

Tears down what has been set up.

Specified by:

tearDown in interface BackEnd

update

public void update(VersionedValue versionedValue)

Updates a point value.

Specified by:

update in interface BackEnd

Parameters:

versionedValue - The point value to update.