org.axonframework.saga.repository.jdbc
Class PostgresSagaSqlSchema

java.lang.Object
  extended by org.axonframework.saga.repository.jdbc.GenericSagaSqlSchema
      extended by org.axonframework.saga.repository.jdbc.PostgresSagaSqlSchema
All Implemented Interfaces:
SagaSqlSchema

public class PostgresSagaSqlSchema
extends GenericSagaSqlSchema

SQL schema supporting postgres databases.

This implementation uses the appropriate postgres data types (serial, bytea).

Since:
2.4
Author:
Jochen Munz

Field Summary
 
Fields inherited from class org.axonframework.saga.repository.jdbc.GenericSagaSqlSchema
schemaConfiguration
 
Constructor Summary
PostgresSagaSqlSchema()
           
PostgresSagaSqlSchema(SchemaConfiguration schemaConfiguration)
           
 
Method Summary
 PreparedStatement sql_createTableAssocValueEntry(Connection conn)
          Creates a PreparedStatement that creates the table for storing Association Values for Sagas.
 PreparedStatement sql_createTableSagaEntry(Connection conn)
          Creates a PreparedStatement that creates the table for storing Sagas.
 
Methods inherited from class org.axonframework.saga.repository.jdbc.GenericSagaSqlSchema
readSerializedSaga, sql_deleteAssociationEntries, sql_deleteSagaEntry, sql_findAssocSagaIdentifiers, sql_loadSaga, sql_removeAssocValue, sql_storeAssocValue, sql_storeSaga, sql_updateSaga
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PostgresSagaSqlSchema

public PostgresSagaSqlSchema()

PostgresSagaSqlSchema

public PostgresSagaSqlSchema(SchemaConfiguration schemaConfiguration)
Method Detail

sql_createTableAssocValueEntry

public PreparedStatement sql_createTableAssocValueEntry(Connection conn)
                                                 throws SQLException
Description copied from interface: SagaSqlSchema
Creates a PreparedStatement that creates the table for storing Association Values for Sagas.

Specified by:
sql_createTableAssocValueEntry in interface SagaSqlSchema
Overrides:
sql_createTableAssocValueEntry in class GenericSagaSqlSchema
Parameters:
conn - The connection to create the PreparedStatement for
Returns:
a Prepared statement that created the Association Value table, when executed
Throws:
SQLException - when an error occurs creating the PreparedStatement

sql_createTableSagaEntry

public PreparedStatement sql_createTableSagaEntry(Connection conn)
                                           throws SQLException
Description copied from interface: SagaSqlSchema
Creates a PreparedStatement that creates the table for storing Sagas.

Specified by:
sql_createTableSagaEntry in interface SagaSqlSchema
Overrides:
sql_createTableSagaEntry in class GenericSagaSqlSchema
Parameters:
conn - The connection to create the PreparedStatement for
Returns:
a Prepared statement that created the Saga table, when executed
Throws:
SQLException - when an error occurs creating the PreparedStatement


Copyright © 2010-2016. All Rights Reserved.