public class DatabasePersistenceManager extends java.lang.Object implements TransactionListener
Modifier and Type | Class and Description |
---|---|
static class |
DatabasePersistenceManager.RowData
data for a given row
|
Constructor and Description |
---|
DatabasePersistenceManager(javax.sql.DataSource datasource, java.lang.String prefix, ConfigService configservice)
constructor
|
Modifier and Type | Method and Description |
---|---|
void |
afterBegin(Transaction tr)
Invoked right after the transaction begins.
|
void |
afterEnd(Transaction tr)
Invoked after the transaction ends, namely, after the transaction fully commits or fully rolled back.
|
void |
beforeEnd(Transaction tr)
Invoked right before the transaction commits or rollsback.
|
void |
beforePrepare(Transaction tr)
Invoked right before the prepare phase starts.
|
static void |
createTable(javax.sql.DataSource datasource, java.lang.String prefix)
helper method to create the table
|
void |
delete(java.lang.String session, Ref ref)
deletes the given resource
|
void |
disposeSession(java.lang.String session)
disposes of a given session
|
java.lang.String |
getId()
Unique name for this transactional listener
|
java.util.Set<java.lang.String> |
getSessions()
returns the sessions
|
java.util.Map<Ref,DatabasePersistenceManager.RowData> |
loadSession(java.lang.String session)
load a given session
|
void |
persist(java.lang.String session, Ref ref, byte[] metadata, byte[] data, boolean create)
persists the given resource
|
void |
persist(java.lang.String session, java.util.Set<Ref> deletes, java.util.Map<Ref,DatabasePersistenceManager.RowData> creates, java.util.Map<Ref,DatabasePersistenceManager.RowData> updates)
persists changs in bulk
|
boolean |
rollbackOnFailure()
Indicates whether exceptions from
beforePrepare(com.bea.wli.config.transaction.Transaction) methods cause the transaction to rollback. |
public DatabasePersistenceManager(javax.sql.DataSource datasource, java.lang.String prefix, ConfigService configservice)
public static void createTable(javax.sql.DataSource datasource, java.lang.String prefix)
public java.util.Set<java.lang.String> getSessions() throws java.lang.Exception
java.lang.Exception
public java.util.Map<Ref,DatabasePersistenceManager.RowData> loadSession(java.lang.String session) throws java.lang.Exception
java.lang.Exception
public void disposeSession(java.lang.String session)
public void persist(java.lang.String session, Ref ref, byte[] metadata, byte[] data, boolean create) throws java.lang.Exception
java.lang.Exception
public void delete(java.lang.String session, Ref ref) throws java.lang.Exception
java.lang.Exception
public void persist(java.lang.String session, java.util.Set<Ref> deletes, java.util.Map<Ref,DatabasePersistenceManager.RowData> creates, java.util.Map<Ref,DatabasePersistenceManager.RowData> updates) throws java.lang.Exception
java.lang.Exception
public java.lang.String getId()
getId
in interface TransactionListener
public boolean rollbackOnFailure()
beforePrepare(com.bea.wli.config.transaction.Transaction)
methods cause the transaction to rollback.rollbackOnFailure
in interface TransactionListener
TransactionListener.beforePrepare(com.bea.wli.config.transaction.Transaction)
method raises exceptions; false otherwisepublic void afterBegin(Transaction tr)
afterBegin
in interface TransactionListener
public void beforePrepare(Transaction tr) throws java.lang.Exception
beforePrepare
in interface TransactionListener
java.lang.Exception
public void beforeEnd(Transaction tr)
beforeEnd
in interface TransactionListener
public void afterEnd(Transaction tr)
afterEnd
in interface TransactionListener