public class TransactionContext extends Object
Constructor and Description |
---|
TransactionContext(JDBCPersistenceAdapter persistenceAdapter) |
Modifier and Type | Method and Description |
---|---|
void |
begin() |
void |
close() |
void |
commit() |
void |
executeBatch() |
PreparedStatement |
getAddMessageStatement() |
Connection |
getConnection() |
PreparedStatement |
getRemovedMessageStatement() |
PreparedStatement |
getUpdateLastAckStatement() |
void |
rollback() |
void |
setAddMessageStatement(PreparedStatement addMessageStatement) |
void |
setRemovedMessageStatement(PreparedStatement removedMessageStatement) |
void |
setTransactionIsolation(int transactionIsolation) |
void |
setUpdateLastAckStatement(PreparedStatement ackMessageStatement) |
public TransactionContext(JDBCPersistenceAdapter persistenceAdapter) throws IOException
IOException
public Connection getConnection() throws IOException
IOException
public void executeBatch() throws SQLException
SQLException
public void close() throws IOException
IOException
public void begin() throws IOException
IOException
public void commit() throws IOException
IOException
public void rollback() throws IOException
IOException
public PreparedStatement getAddMessageStatement()
public void setAddMessageStatement(PreparedStatement addMessageStatement)
public PreparedStatement getUpdateLastAckStatement()
public void setUpdateLastAckStatement(PreparedStatement ackMessageStatement)
public PreparedStatement getRemovedMessageStatement()
public void setRemovedMessageStatement(PreparedStatement removedMessageStatement)
public void setTransactionIsolation(int transactionIsolation)
Copyright © 2005–2015 The Apache Software Foundation. All rights reserved.