Package lu.kbra.pclib.db.base

Class Database.TableTransaction

java.lang.Object

lu.kbra.pclib.db.base.Database.TableTransaction

All Implemented Interfaces:

AutoCloseable, DBTransaction

Direct Known Subclasses:

DeferredDatabase.DeferredTableTransaction

Enclosing class:

Database

public class Database.TableTransaction
extends Object
implements DBTransaction

Nested Class Summary

Nested classes/interfaces inherited from interface lu.kbra.pclib.db.base.transaction.DBTransaction

DBTransaction.TransactionCustomizer

Field Summary

Fields

Modifier and Type	Field	Description
protected final Connection	backingConnection
protected boolean	closed
protected boolean	completed
protected final DelegatingConnection	connection
protected final ReentrantLock	lock
protected final Set<TransactionOption>	options
protected final Supplier<AbstractConnection>	useMethod

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TableTransaction(Connection backingConnection, Consumer<DBTransaction.TransactionCustomizer> customizer)

Method Summary

Modifier and Type	Method	Description
void	close()
void	commit()
protected void	ensureOpen()
protected void	executeLocked(Runnable action)
protected <B> B	executeLocked(Supplier<B> action)
AbstractConnection	getConnection()
boolean	isClosed()
void	rollback()
<T extends DatabaseEntry, V extends DatabaseTable<T>> AbstractDBTable<T>	use(V inst)

Methods inherited from class java.lang.Object

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

Field Details

lock

protected final ReentrantLock lock

closed

protected volatile boolean closed

completed

protected volatile boolean completed

backingConnection

protected final Connection backingConnection

connection

protected final DelegatingConnection connection

useMethod

protected final Supplier<AbstractConnection> useMethod

options

protected final Set<TransactionOption> options

Constructor Details

TableTransaction

protected TableTransaction(Connection backingConnection,
 Consumer<DBTransaction.TransactionCustomizer> customizer)

Method Details

close

public void close()
           throws DBException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface DBTransaction

Throws:

DBException

commit

public void commit()
            throws DBException

Specified by:

commit in interface DBTransaction

Throws:

DBException

getConnection

public AbstractConnection getConnection()

Specified by:

getConnection in interface DBTransaction

isClosed

public boolean isClosed()

Specified by:

isClosed in interface DBTransaction

rollback

public void rollback()
              throws DBException

Specified by:

rollback in interface DBTransaction

Throws:

DBException

use

public <T extends DatabaseEntry,
V extends DatabaseTable<T>>
AbstractDBTable<T> use(V inst)

Specified by:

use in interface DBTransaction

ensureOpen

protected void ensureOpen()

executeLocked

protected void executeLocked(Runnable action)
                      throws DBException

Throws:

DBException

executeLocked

protected <B> B executeLocked(Supplier<B> action)
                       throws DBException

Throws:

DBException