org.rvpf.store.server.the.sql.dialect

Class DialectSupport.Abstract

Object

DialectSupport.Abstract

All Implemented Interfaces:

DialectSupport

Direct Known Subclasses:

DerbyDialect, GenericDialect, H2Dialect, HSQLDialect, MariaDBDialect, PostgreSQLDialect

Enclosing interface:

DialectSupport

public abstract static class DialectSupport.Abstract
extends Object
implements DialectSupport

Abstract dialect support.

Nested Class Summary

Nested classes/interfaces inherited from interface DialectSupport

DialectSupport.Abstract

Field Summary

Fields inherited from interface DialectSupport

ARCHIVE_TABLE_PROPERTY, CATALOG_PROPERTY, DEFAULT_ARCHIVE_TABLE_NAME, DEFAULT_CATALOG_NAME, DEFAULT_POINT_COLUMN, DEFAULT_SCHEMA_NAME, DEFAULT_SNAPSHOT_TABLE_NAME, DEFAULT_STAMP_COLUMN, DEFAULT_STATE_COLUMN, DEFAULT_VALUE_COLUMN, DEFAULT_VERSION_COLUMN, POINT_COLUMN_PROPERTY, SCHEMA_PROPERTY, SNAPSHOT_TABLE_PROPERTY, STAMP_COLUMN_PROPERTY, STATE_COLUMN_PROPERTY, TABLE_PROPERTY, VALUE_COLUMN_PROPERTY, VERSION_COLUMN_PROPERTY

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Abstract(String dialectName) Constructs an instance.

Method Summary

Modifier and Type	Method and Description
Optional<String>	getCatalogName() Gets the catalog name.
protected String	getCatalogSchemaTable() Gets the catalog schema table name.
List<String>	getCreateTableSQL() Gets the SQL for statements that create the table.
protected String	getDefaultCatalogName() Gets the default catalog name.
ClassDefImpl	getDefaultClientDriverClassDef() Gets the default client driver class definition.
protected Optional<ClassDefImpl>	getDefaultDriverClassDef() Gets the default driver class definition.
protected String	getDefaultSchemaName() Gets the default schema name.
protected String	getDefaultTableName() Gets the default table name.
StringBuilder	getDeleteSQL(boolean purge) Gets the SQL for a DELETE statement.
String	getDialectName() Gets the dialect name.
StringBuilder	getInsertSQL() Gets the SQL for an INSERT statement.
protected String	getPointColumn() Gets the point column name.
String	getSchemaName() Gets the schema name.
StringBuilder	getSelectSQL(StoreCursor cursor) Gets the SQL for a SELECT statement.
protected String	getStampColumn() Gets the stamp column name.
protected String	getStateColumn() Gets the state column name.
String	getTableName() Gets the table name.
protected Logger	getThisLogger() Gets the logger.
StringBuilder	getUpdateSQL() Gets the SQL for an UPDATE statement.
protected String	getValueColumn() Gets the value column name.
protected String	getVersionColumn() Gets the version column name.
protected boolean	isPullDisabled() Asks if pull is disabled.
protected boolean	isSnapshot() Asks for the snapshot indicator.
void	onFirstConnection(TheStoreConnection connection) Called on the first connection.
Class<? extends Driver>	registerDriver(ClassDef driverClassDef) Registers the JDBC driver.
int	setDeleteStatement(PreparedStatement statement, byte[] point, long startStamp, long finishStamp) Sets a DELETE statement.
int	setInsertStatement(PreparedStatement statement, byte[] point, long stamp, long version, byte[] state, byte[] value) Sets an INSERT statement according to the PointValue.
int	setSelectStatement(PreparedStatement statement, StoreCursor cursor) Sets a SELECT statement according to the Request and request type.
protected static void	setSystemProperty(String key, String value) Sets a system property.
boolean	setUp(Optional<StoreServiceAppImpl> storeAppImpl, File storeDataDir, String storeEntityName) Sets up the basic informations for dialect support.
int	setUpdateStatement(PreparedStatement statement, byte[] point, long stamp, long version, Optional<byte[]> state, Optional<byte[]> value) Sets an UPDATE statement according to the PointValue.
void	tearDown() Tears down what has been set up.

Methods inherited from class Object

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

Methods inherited from interface DialectSupport

getDefaultConnectionOptions, getDefaultConnectionPassword, getDefaultConnectionShared, getDefaultConnectionURL, getDefaultConnectionUser

Constructor Detail

Abstract

protected Abstract(@Nonnull
                   String dialectName)

Constructs an instance.

Parameters:

dialectName - The dialect name.

Method Detail

getCatalogName

public Optional<String> getCatalogName()

Gets the catalog name.

Specified by:

getCatalogName in interface DialectSupport

Returns:

The catalog name.

getCreateTableSQL

public List<String> getCreateTableSQL()

Gets the SQL for statements that create the table.

Specified by:

getCreateTableSQL in interface DialectSupport

Returns:

The SQL.

getDefaultClientDriverClassDef

public ClassDefImpl getDefaultClientDriverClassDef()

Gets the default client driver class definition.

Specified by:

getDefaultClientDriverClassDef in interface DialectSupport

Returns:

The default client driver class definition.

getDeleteSQL

public StringBuilder getDeleteSQL(boolean purge)

Gets the SQL for a DELETE statement.

Specified by:

getDeleteSQL in interface DialectSupport

Parameters:

purge - True when the operation is a purge.

Returns:

The SQL.

getDialectName

public final String getDialectName()

Gets the dialect name.

Specified by:

getDialectName in interface DialectSupport

Returns:

The dialect name.

getInsertSQL

public StringBuilder getInsertSQL()

Gets the SQL for an INSERT statement.

Specified by:

getInsertSQL in interface DialectSupport

Returns:

The SQL.

getSchemaName

public final String getSchemaName()

Gets the schema name.

Specified by:

getSchemaName in interface DialectSupport

Returns:

The schema name.

getSelectSQL

public StringBuilder getSelectSQL(StoreCursor cursor)

Gets the SQL for a SELECT statement.

Specified by:

getSelectSQL in interface DialectSupport

Parameters:

cursor - The store cursor.

Returns:

The SQL.

getTableName

public final String getTableName()

Gets the table name.

Specified by:

getTableName in interface DialectSupport

Returns:

The table name.

getUpdateSQL

public StringBuilder getUpdateSQL()

Gets the SQL for an UPDATE statement.

Specified by:

getUpdateSQL in interface DialectSupport

Returns:

The SQL.

onFirstConnection

public void onFirstConnection(TheStoreConnection connection)

Called on the first connection.

Specified by:

onFirstConnection in interface DialectSupport

Parameters:

connection - The newly established connection.

registerDriver

public final Class<? extends Driver> registerDriver(ClassDef driverClassDef)

Registers the JDBC driver.

Specified by:

registerDriver in interface DialectSupport

Parameters:

driverClassDef - The driver class definition.

Returns:

The driver class (null on failure).

setDeleteStatement

public int setDeleteStatement(PreparedStatement statement,
                              byte[] point,
                              long startStamp,
                              long finishStamp)
                       throws SQLException

Sets a DELETE statement.

Specified by:

setDeleteStatement in interface DialectSupport

Parameters:

statement - The Statement prepared from DialectSupport.getDeleteSQL(boolean).

point - The bytes of the Point's UUID.

startStamp - The raw value of the start time stamp.

finishStamp - The raw value of the finish time stamp.

Returns:

The number of columns set.

Throws:

SQLException - From java.sql.

setInsertStatement

public int setInsertStatement(PreparedStatement statement,
                              byte[] point,
                              long stamp,
                              long version,
                              byte[] state,
                              byte[] value)
                       throws SQLException

Sets an INSERT statement according to the PointValue.

Specified by:

setInsertStatement in interface DialectSupport

Parameters:

statement - The Statement prepared from DialectSupport.getInsertSQL().

point - The bytes of the Point's UUID.

stamp - The raw value of the Point's time stamp.

version - The raw value of the version stamp.

state - The value's state.

value - The Point's serialized value.

Returns:

The number of columns set.

Throws:

SQLException - From java.sql.

setSelectStatement

public int setSelectStatement(PreparedStatement statement,
                              StoreCursor cursor)
                       throws SQLException

Sets a SELECT statement according to the Request and request type.

Specified by:

setSelectStatement in interface DialectSupport

Parameters:

statement - The statement prepared from DialectSupport.getInsertSQL().

cursor - The store cursor for which the statement has been prepared.

Returns:

The number of columns set.

Throws:

SQLException - From java.sql.

setUp

public boolean setUp(Optional<StoreServiceAppImpl> storeAppImpl,
                     File storeDataDir,
                     String storeEntityName)

Sets up the basic informations for dialect support.

Specified by:

setUp in interface DialectSupport

Parameters:

storeAppImpl - The optional store application implementation.

storeDataDir - The store data directory.

storeEntityName - The store entity name.

Returns:

True on success.

setUpdateStatement

public int setUpdateStatement(PreparedStatement statement,
                              byte[] point,
                              long stamp,
                              long version,
                              Optional<byte[]> state,
                              Optional<byte[]> value)
                       throws SQLException

Sets an UPDATE statement according to the PointValue.

Specified by:

setUpdateStatement in interface DialectSupport

Parameters:

statement - The Statement prepared from DialectSupport.getUpdateSQL().

point - The bytes of the Point's UUID.

stamp - The raw value of the Point's time stamp.

version - The raw value of the version stamp.

state - The value's serialized state.

value - The Point's serialized value.

Returns:

The number of columns set.

Throws:

SQLException - From java.sql.

tearDown

public void tearDown()

Tears down what has been set up.

Specified by:

tearDown in interface DialectSupport

setSystemProperty

protected static void setSystemProperty(@Nonnull
                                        String key,
                                        @Nonnull
                                        String value)

Sets a system property.

Parameters:

key - The property key.

value - The property value.

getCatalogSchemaTable

@Nonnull
 @CheckReturnValue
protected final String getCatalogSchemaTable()

Gets the catalog schema table name.

Returns:

The catalog schema table name.

getDefaultCatalogName

protected String getDefaultCatalogName()

Gets the default catalog name.

Returns:

The default catalog name.

getDefaultDriverClassDef

@Nonnull
 @CheckReturnValue
protected Optional<ClassDefImpl> getDefaultDriverClassDef()

Gets the default driver class definition.

Returns:

The optional default driver class definition.

getDefaultSchemaName

protected String getDefaultSchemaName()

Gets the default schema name.

Returns:

The default schema name.

getDefaultTableName

@Nonnull
 @CheckReturnValue
protected String getDefaultTableName()

Gets the default table name.

Returns:

The default table name.

getPointColumn

@Nonnull
 @CheckReturnValue
protected final String getPointColumn()

Gets the point column name.

Returns:

The point column name.

getStampColumn

@Nonnull
 @CheckReturnValue
protected final String getStampColumn()

Gets the stamp column name.

Returns:

The stamp column name.

getStateColumn

@Nonnull
 @CheckReturnValue
protected final String getStateColumn()

Gets the state column name.

Returns:

The state column name.

getThisLogger

@Nonnull
 @CheckReturnValue
protected final Logger getThisLogger()

Gets the logger.

Returns:

The logger.

getValueColumn

@Nonnull
 @CheckReturnValue
protected final String getValueColumn()

Gets the value column name.

Returns:

The value column name.

getVersionColumn

@Nonnull
 @CheckReturnValue
protected final String getVersionColumn()

Gets the version column name.

Returns:

The version column name.

isPullDisabled

@CheckReturnValue
protected final boolean isPullDisabled()

Asks if pull is disabled.

Returns:

True if pull is disabled.

isSnapshot

@CheckReturnValue
protected final boolean isSnapshot()

Asks for the snapshot indicator.

Returns:

The snapshot indicator.