Package org.axonframework.modelling.saga.repository.jdbc

Class Oracle11SagaSqlSchema

java.lang.Object

org.axonframework.modelling.saga.repository.jdbc.GenericSagaSqlSchema

org.axonframework.modelling.saga.repository.jdbc.Oracle11SagaSqlSchema

All Implemented Interfaces:

SagaSqlSchema

public class Oracle11SagaSqlSchema
extends GenericSagaSqlSchema

Oracle 11 does not support AUTO_INCREMENT. A workaround is used in this class in order to create the same behavior. Oracle 11 does not like semicolons at the end of a CREATE TABLE statement. These semicolons are dropped in this class.

Field Summary

Fields inherited from class org.axonframework.modelling.saga.repository.jdbc.GenericSagaSqlSchema

sagaSchema

Constructor Summary

Constructors

Constructor	Description
Oracle11SagaSqlSchema(SagaSchema sagaSchema)	Initialize a Oracle11SagaSqlSchema using the given sagaSchema.

Method Summary

Modifier and Type	Method	Description
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.modelling.saga.repository.jdbc.GenericSagaSqlSchema

readAssociationValues, readSerializedSaga, readToken, sagaSchema, sql_deleteAssociationEntries, sql_deleteSagaEntry, sql_findAssociations, 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 Details

Oracle11SagaSqlSchema

public Oracle11SagaSqlSchema(SagaSchema sagaSchema)

Initialize a Oracle11SagaSqlSchema using the given sagaSchema.

Parameters:

sagaSchema - the saga schema configuration

Method Details

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