Package com.gigaspaces.internal.server.space.redolog.storage

Class SqliteStorageLayer<T extends IReplicationOrderedPacket>

java.lang.Object

com.gigaspaces.internal.server.space.redolog.storage.SqliteStorageLayer<T>

Direct Known Subclasses:

SqliteRedoLogFileStorage

public abstract class SqliteStorageLayer<T extends IReplicationOrderedPacket>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	SqliteStorageLayer.RDBMSRedoLogIterator

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<String>	COLUMN_NAMES
protected Connection	connection
protected final org.slf4j.Logger	logger
protected final int	OPERATION_TYPE_COLUMN_INDEX
protected final int	PACKET_COLUMN_INDEX
protected final int	PACKET_COUNT_COLUMN_INDEX
protected final int	PACKET_WEIGHT_COLUMN_INDEX
protected final int	REDO_KEY_COLUMN_INDEX
protected static final String	TABLE_NAME
protected final int	TYPE_NAME_COLUMN_INDEX
protected final int	UID_COLUMN_INDEX

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	SqliteStorageLayer(DBSwapRedoLogFileConfig<T> config)

Method Summary

Modifier and Type	Method	Description
void	deleteDataFile()
protected T	deserializePacket(ResultSet resultSet)
protected void	dropTable()
protected void	executeCreateTable(String sqlQuery)
protected long	executeDelete(String sqlQuery)
protected long	executeInsert(PreparedStatement statement)
protected ResultSet	executeQuery(String sqlQuery)
protected int	getPacketCount(T packet)
protected String	getPacketOperationTypeName(T packet)
protected String	getPacketTypeName(T packet)
protected String	getPacketUID(T packet)
protected int	getPacketWeight(T packet)
protected long	getStorageRedoLogSize()
protected byte[]	serializePacket(T packet)

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.slf4j.Logger logger

TABLE_NAME

protected static final String TABLE_NAME

See Also:

• Constant Field Values

connection

protected Connection connection

COLUMN_NAMES

protected final List<String> COLUMN_NAMES

REDO_KEY_COLUMN_INDEX

protected final int REDO_KEY_COLUMN_INDEX

See Also:

• Constant Field Values

TYPE_NAME_COLUMN_INDEX

protected final int TYPE_NAME_COLUMN_INDEX

See Also:

• Constant Field Values

OPERATION_TYPE_COLUMN_INDEX

protected final int OPERATION_TYPE_COLUMN_INDEX

See Also:

• Constant Field Values

UID_COLUMN_INDEX

protected final int UID_COLUMN_INDEX

See Also:

• Constant Field Values

PACKET_COUNT_COLUMN_INDEX

protected final int PACKET_COUNT_COLUMN_INDEX

See Also:

• Constant Field Values

PACKET_WEIGHT_COLUMN_INDEX

protected final int PACKET_WEIGHT_COLUMN_INDEX

See Also:

• Constant Field Values

PACKET_COLUMN_INDEX

protected final int PACKET_COLUMN_INDEX

See Also:

• Constant Field Values

Constructor Details

SqliteStorageLayer

protected SqliteStorageLayer(DBSwapRedoLogFileConfig<T> config)

Method Details

getStorageRedoLogSize

protected long getStorageRedoLogSize()

executeCreateTable

protected void executeCreateTable(String sqlQuery)
                           throws SQLException

Throws:

SQLException

executeInsert

protected long executeInsert(PreparedStatement statement)
                      throws SQLException

Throws:

SQLException

executeQuery

protected ResultSet executeQuery(String sqlQuery)
                          throws SQLException

Throws:

SQLException

executeDelete

protected long executeDelete(String sqlQuery)
                      throws SQLException

Throws:

SQLException

serializePacket

protected byte[] serializePacket(T packet)

deserializePacket

protected T deserializePacket(ResultSet resultSet)

dropTable

protected void dropTable()
                  throws SQLException

Throws:

SQLException

deleteDataFile

public void deleteDataFile()

getPacketCount

protected int getPacketCount(T packet)

getPacketTypeName

protected String getPacketTypeName(T packet)

getPacketUID

protected String getPacketUID(T packet)

getPacketWeight

protected int getPacketWeight(T packet)

getPacketOperationTypeName

protected String getPacketOperationTypeName(T packet)