public class TransactionalDb extends BasicDb
Modifier and Type | Class and Description |
---|---|
static interface |
TransactionalDb.TransactionCallback
Transaction callback interface
|
BasicDb.DbProperties
Constructor and Description |
---|
TransactionalDb(BasicDb.DbProperties dbProperties) |
Modifier and Type | Method and Description |
---|---|
java.sql.Connection |
beginTransaction() |
java.sql.Connection |
beginTransaction(java.lang.String schema) |
static <V> V |
callInDbTransaction(java.util.concurrent.Callable<V> callable) |
void |
clearCache() |
void |
commitTransaction() |
void |
endTransaction() |
java.sql.Connection |
getConnection(java.lang.String schema) |
boolean |
isInTransaction() |
void |
registerCallback(TransactionalDb.TransactionCallback callback) |
void |
rollbackTransaction() |
static void |
runInDbTransaction(java.lang.Runnable runnable) |
analyzeTables, getPooledConnection, getUrl, init, shutdown
public TransactionalDb(BasicDb.DbProperties dbProperties)
public static <V> V callInDbTransaction(java.util.concurrent.Callable<V> callable)
public static void runInDbTransaction(java.lang.Runnable runnable)
public java.sql.Connection getConnection(java.lang.String schema) throws java.sql.SQLException
getConnection
in class BasicDb
java.sql.SQLException
public boolean isInTransaction()
public java.sql.Connection beginTransaction()
public java.sql.Connection beginTransaction(java.lang.String schema)
public void commitTransaction()
public void rollbackTransaction()
public void endTransaction()
public void registerCallback(TransactionalDb.TransactionCallback callback)
public void clearCache()