Package org.opennms.features.distributed.kvstore.json.postgres

Class PostgresJsonStore

java.lang.Object

org.opennms.features.distributed.kvstore.api.AbstractKeyValueStore<T>

org.opennms.features.distributed.kvstore.api.AbstractAsyncKeyValueStore<T>

org.opennms.features.distributed.kvstore.pgshared.AbstractPostgresKeyValueStore<String,String>

org.opennms.features.distributed.kvstore.json.postgres.PostgresJsonStore

All Implemented Interfaces:

JsonStore, KeyValueStore<String>

public class PostgresJsonStore
extends AbstractPostgresKeyValueStore<String,String>
implements JsonStore

Constructor Summary

Constructors

Constructor	Description
PostgresJsonStore(DataSource dataSource)

Method Summary

Modifier and Type	Method	Description
protected String	getPkConstraintName()
protected String	getTableName()
protected String	getValueStatementPlaceholder()	Sub classes should override this to add additional specificity to the SQL placeholder in the prepared statements if necessary.
protected String	getValueTypeFromSQLType(ResultSet resultSet, String columnName)	Sub classes must override this method to provide handling for converting from the JDBC result to type T.

Methods inherited from class org.opennms.features.distributed.kvstore.pgshared.AbstractPostgresKeyValueStore

delete, enumerateContext, get, getIfStale, getLastUpdated, getName, getSQLTypeFromValueType, put, truncateContext

Methods inherited from class org.opennms.features.distributed.kvstore.api.AbstractAsyncKeyValueStore

deleteAsync, enumerateContextAsync, getAsync, getIfStaleAsync, getLastUpdatedAsync, putAsync, truncateContextAsync

Methods inherited from class org.opennms.features.distributed.kvstore.api.AbstractKeyValueStore

put, putAsync

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.opennms.features.distributed.kvstore.api.KeyValueStore

delete, deleteAsync, enumerateContext, enumerateContextAsync, get, getAsync, getIfStale, getIfStaleAsync, getLastUpdated, getLastUpdatedAsync, getName, put, put, putAsync, putAsync, truncateContext, truncateContextAsync

Constructor Detail

PostgresJsonStore

public PostgresJsonStore(DataSource dataSource)

Method Detail

getTableName

protected String getTableName()

Specified by:

getTableName in class AbstractPostgresKeyValueStore<String,String>

Returns:

the name of the table for this store

getValueStatementPlaceholder

protected String getValueStatementPlaceholder()

Description copied from class: AbstractPostgresKeyValueStore

Sub classes should override this to add additional specificity to the SQL placeholder in the prepared statements if necessary.

Overrides:

getValueStatementPlaceholder in class AbstractPostgresKeyValueStore<String,String>

getValueTypeFromSQLType

protected String getValueTypeFromSQLType(ResultSet resultSet,
                                         String columnName)
                                  throws SQLException

Description copied from class: AbstractPostgresKeyValueStore

Sub classes must override this method to provide handling for converting from the JDBC result to type T.

Specified by:

getValueTypeFromSQLType in class AbstractPostgresKeyValueStore<String,String>

Throws:

SQLException

getPkConstraintName

protected String getPkConstraintName()

Specified by:

getPkConstraintName in class AbstractPostgresKeyValueStore<String,String>

Returns:

the name of the primary key constraint for the table this store persists to