com.caplin.transformer.persistence

Class JdbcPersistorImpl

java.lang.Object

com.caplin.transformer.persistence.JdbcPersistorImpl

All Implemented Interfaces:

Persistor

public class JdbcPersistorImpl
extends Object
implements Persistor

A basic JDBC Implementation of a Persistor. This implementation expects the user to provide the following configuration in Transformers persistence.conf configuration file

 persistence.conf
     persistence-classid com/caplin/transformer/persistence/JdbcPersistorImpl
          add-database-params
              init-string    <jdbc url>
              driver-name    <jdbc driver - must be explicitly added to transformers jvm-global-classpath>
              username       <db user>
              password       <db password>
              table-name     <name of the table to be used>
              columns        <key_column, value_column>
              extra-params   <SLF4J_log_level, num_pooled_connections>
          end-database-params
     
 

 java.conf
     jvm-global-classpath <path_to_jdbc_driver>
      end-database-params
     
 

Constructor Summary

Constructors

Constructor and Description
JdbcPersistorImpl(PersistorConfiguration configuration)

Method Summary

Methods

Modifier and Type	Method and Description
void	onDelete(String key) Delete a row with the provided key from the Database
PersistedValue	onGet(String key) Retrieve a row from the Database
void	onInsert(PersistedValue persistedValue) Implement this method to handle Insert/Put callbacks.
PersistedValue[]	onQuery(String query) A Query is a prefix match for all keys in the database.
void	onShutdown() When transformer unloads the module, usually a shutdown.

Methods inherited from class java.lang.Object

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

Constructor Detail

JdbcPersistorImpl

public JdbcPersistorImpl(PersistorConfiguration configuration)
                  throws Exception

Throws:

Exception

Method Detail

onInsert

public void onInsert(PersistedValue persistedValue)

Description copied from interface: Persistor

Implement this method to handle Insert/Put callbacks. An insert is expected to overwrite the previously stored value associated with the provided key

Specified by:

onInsert in interface Persistor

Parameters:

persistedValue - The PersistedValue to be stored

onGet

public PersistedValue onGet(String key)

Description copied from interface: Persistor

Retrieve a row from the Database

Specified by:

onGet in interface Persistor

Parameters:

key - The key associated with the row

Returns:

A PersistedValue representing the row

onQuery

public PersistedValue[] onQuery(String query)

Description copied from interface: Persistor

A Query is a prefix match for all keys in the database.

Specified by:

onQuery in interface Persistor

Parameters:

query - an arbitrary String, can be empty too

Returns:

An array PersistedValue representing all rows whose key starts with the query

onDelete

public void onDelete(String key)

Description copied from interface: Persistor

Delete a row with the provided key from the Database

Specified by:

onDelete in interface Persistor

Parameters:

key - the key of the row to be deleted

onShutdown

public void onShutdown()

Description copied from interface: Persistor

When transformer unloads the module, usually a shutdown. This callback is being called, so that open connections can be closed

Specified by:

onShutdown in interface Persistor