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.Exceptionpublic java.util.Map<Ref,DatabasePersistenceManager.RowData> loadSession(java.lang.String session) throws java.lang.Exception
java.lang.Exceptionpublic 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.Exceptionpublic void delete(java.lang.String session,
Ref ref)
throws java.lang.Exception
java.lang.Exceptionpublic 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.Exceptionpublic java.lang.String getId()
getId in interface TransactionListenerpublic boolean rollbackOnFailure()
beforePrepare(com.bea.wli.config.transaction.Transaction) methods cause the transaction to rollback.rollbackOnFailure in interface TransactionListenerTransactionListener.beforePrepare(com.bea.wli.config.transaction.Transaction) method raises exceptions; false otherwisepublic void afterBegin(Transaction tr)
afterBegin in interface TransactionListenerpublic void beforePrepare(Transaction tr) throws java.lang.Exception
beforePrepare in interface TransactionListenerjava.lang.Exceptionpublic void beforeEnd(Transaction tr)
beforeEnd in interface TransactionListenerpublic void afterEnd(Transaction tr)
afterEnd in interface TransactionListener