nxt.db

Class TransactionalDb

java.lang.Object

nxt.db.BasicDb

nxt.db.TransactionalDb

public class TransactionalDb
extends BasicDb

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	TransactionalDb.TransactionCallback Transaction callback interface

Nested classes/interfaces inherited from class nxt.db.BasicDb

BasicDb.DbProperties

Constructor Summary

Constructors

Constructor and Description
TransactionalDb(BasicDb.DbProperties dbProperties)

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	beginTransaction()
java.sql.Connection	beginTransaction(java.lang.String schema)
<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()
void	runInDbTransaction(java.lang.Runnable runnable)
void	setThreadQueryTimeout(int seconds) Sets the timeout which will be used in Statement.executeQuery(String) and Statement.executeQuery(String) calls, done by this thread (for the current database).

Methods inherited from class nxt.db.BasicDb

analyzeTables, getPooledConnection, getUrl, init, shutdown

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TransactionalDb

public TransactionalDb(BasicDb.DbProperties dbProperties)

Method Detail

callInDbTransaction

public <V> V callInDbTransaction(java.util.concurrent.Callable<V> callable)

runInDbTransaction

public void runInDbTransaction(java.lang.Runnable runnable)

getConnection

public java.sql.Connection getConnection(java.lang.String schema)
                                  throws java.sql.SQLException

Overrides:

getConnection in class BasicDb

Throws:

java.sql.SQLException

isInTransaction

public boolean isInTransaction()

beginTransaction

public java.sql.Connection beginTransaction()

beginTransaction

public java.sql.Connection beginTransaction(java.lang.String schema)

commitTransaction

public void commitTransaction()

rollbackTransaction

public void rollbackTransaction()

endTransaction

public void endTransaction()

registerCallback

public void registerCallback(TransactionalDb.TransactionCallback callback)

setThreadQueryTimeout

public void setThreadQueryTimeout(int seconds)

Sets the timeout which will be used in Statement.executeQuery(String) and Statement.executeQuery(String) calls, done by this thread (for the current database).

Due to an issue in H2 implementation, Statement.setQueryTimeout(int) affects all statements in the connection - see https://github.com/h2database/h2database/issues/243. So always reset to 0 after executing the queries that must be limited

Parameters:

seconds - the new query timeout limit in seconds for the current thread; zero means there is no limit

clearCache

public void clearCache()