Uses of Interface
org.cojen.tupl.Transaction

Packages that use Transaction
Package
Description
See Database to get started with Tupl.
Support for database extensions.
  • Uses of Transaction in org.cojen.tupl

    Fields in org.cojen.tupl declared as Transaction
    Modifier and Type
    Field
    Description
    static final Transaction
    Transaction.BOGUS
    Transaction instance which isn't a transaction at all.
    Methods in org.cojen.tupl that return Transaction
    Modifier and Type
    Method
    Description
    Cursor.link()
    Returns the transaction the cursor is currently linked to.
    Cursor.link(Transaction txn)
    Link to a transaction, which can be null for auto-commit mode.
    default Transaction
    Database.newTransaction()
    Returns a new Transaction with the default durability mode.
    Database.newTransaction(DurabilityMode durabilityMode)
    Returns a new Transaction with the given durability mode.
    Table.newTransaction(DurabilityMode durabilityMode)
    Returns a new transaction which is compatible with this table.
    default Transaction
    View.newTransaction(DurabilityMode durabilityMode)
    Returns a new transaction which is compatible with this view.
    Methods in org.cojen.tupl with parameters of type Transaction
    Modifier and Type
    Method
    Description
    default boolean
    Query.anyRows(Transaction txn, Object... args)
    Returns true if this query produces any rows.
    default boolean
    Table.anyRows(Transaction txn)
    Returns true if any rows exist in this table.
    default boolean
    Table.anyRows(Transaction txn, String query, Object... args)
    Returns true if a subset of rows from this table exists, as specified by the query expression.
    default void
    Table.delete(Transaction txn, R row)
    Unconditionally removes an existing row by primary key.
    default boolean
    View.delete(Transaction txn, byte[] key)
    Unconditionally removes the entry associated with the given key.
    default long
    Query.deleteAll(Transaction txn, Object... args)
    Deletes all rows specified by this query.
    long
    Index.evict(Transaction txn, byte[] lowKey, byte[] highKey, Filter evictionFilter, boolean autoload)
    Select a few entries, and delete them from the index.
    default R
    Table.exchange(Transaction txn, R row)
    Unconditionally stores the given row, potentially replacing a corresponding row which already exists.
    default byte[]
    View.exchange(Transaction txn, byte[] key, byte[] value)
    Unconditionally associates a value with the given key, returning the previous value.
    boolean
    Table.exists(Transaction txn, R row)
    Checks if a row exists by searching against the primary key.
    default boolean
    View.exists(Transaction txn, byte[] key)
    Checks if an entry for the given key exists.
    default void
    Table.insert(Transaction txn, R row)
    Stores the given row when a corresponding row doesn't exist.
    default boolean
    View.insert(Transaction txn, byte[] key, byte[] value)
    Associates a value with the given key, unless a corresponding value already exists.
    Cursor.link(Transaction txn)
    Link to a transaction, which can be null for auto-commit mode.
    default void
    Table.load(Transaction txn, R row)
    Fully loads the row by primary key.
    default byte[]
    View.load(Transaction txn, byte[] key)
    Returns a copy of the value for the given key, or null if no matching entry exists.
    default byte[]
    Combiner.loadDifference(Transaction txn, byte[] key, View first, View second)
    If requireValues always returns false, consider overriding this method and implement a more efficient load for two views in a difference.
    default byte[]
    Combiner.loadIntersection(Transaction txn, byte[] key, View first, View second)
    If requireValues always returns false, consider overriding this method and implement a more efficient load for two views in an intersection.
    default byte[]
    Combiner.loadUnion(Transaction txn, byte[] key, View first, View second)
    If requireValues always returns false, consider overriding this method and implement a more efficient load for two views in a union.
    View.lockCheck(Transaction txn, byte[] key)
    Checks the lock ownership for the given key.
    View.lockExclusive(Transaction txn, byte[] key)
    Explicitly acquire an exclusive lock for the given key, denying any additional locks.
    View.lockShared(Transaction txn, byte[] key)
    Explicitly acquire a shared lock for the given key, denying exclusive locks.
    View.lockUpgradable(Transaction txn, byte[] key)
    Explicitly acquire an upgradable lock for the given key, denying exclusive and additional upgradable locks.
    default void
    Table.merge(Transaction txn, R row)
    Updates an existing row with the modified columns of the given row, and then loads the result back into the given row.
    default Cursor
    View.newAccessor(Transaction txn, byte[] key)
    Returns a cursor intended for accessing values in chunks, permitting them to be larger than what can fit in main memory.
    Returns a new cursor over this view.
    default Scanner<R>
    Query.newScanner(Transaction txn, Object... args)
    Returns a new scanner for all the rows of this query.
    default Scanner<R>
    Returns a new scanner for all rows of this table.
    default Scanner<R>
    Table.newScanner(Transaction txn, String query, Object... args)
    Returns a new scanner for a subset of rows from this table, as specified by the query expression.
    default Stream<R>
    Query.newStream(Transaction txn, Object... args)
    Returns a new stream for all the rows of this query.
    default Stream<R>
    Returns a new stream for all rows of this table.
    default Stream<R>
    Table.newStream(Transaction txn, String query, Object... args)
    Returns a new stream for a subset of rows from this table, as specified by the query expression.
    default Updater<R>
    Query.newUpdater(Transaction txn, Object... args)
    Returns a new updater for all the rows of this query.
    default Updater<R>
    Returns a new updater for all rows of this table.
    default Updater<R>
    Table.newUpdater(Transaction txn, String query, Object... args)
    Returns a new updater for a subset of rows from this table, as specified by the query expression.
    default boolean
    View.remove(Transaction txn, byte[] key, byte[] value)
    Removes the entry associated with the given key, but only if the given value matches.
    default void
    Table.replace(Transaction txn, R row)
    Stores the given row when a corresponding row already exists.
    default boolean
    View.replace(Transaction txn, byte[] key, byte[] value)
    Associates a value with the given key, but only if a corresponding value already exists.
    Query.scannerPlan(Transaction txn, Object... args)
    Returns a query plan used by newScanner.
    default void
    Table.store(Transaction txn, R row)
    Unconditionally stores the given row, potentially replacing a corresponding row which already exists.
    default void
    View.store(Transaction txn, byte[] key, byte[] value)
    Unconditionally associates a value with the given key.
    default QueryPlan
    Query.streamPlan(Transaction txn, Object... args)
    Returns a query plan used by newStream.
    default LockResult
    View.touch(Transaction txn, byte[] key)
    Touch the given key as if calling load, but instead only acquiring any necessary locks.
    default boolean
    Table.tryDelete(Transaction txn, R row)
    Unconditionally removes an existing row by primary key.
    default boolean
    Table.tryInsert(Transaction txn, R row)
    Stores the given row when a corresponding row doesn't exist.
    boolean
    Table.tryLoad(Transaction txn, R row)
    Fully loads the row by primary key.
    default LockResult
    View.tryLockExclusive(Transaction txn, byte[] key, long nanosTimeout)
    Explicitly acquire an exclusive lock for the given key, denying any additional locks.
    default LockResult
    View.tryLockShared(Transaction txn, byte[] key, long nanosTimeout)
    Explicitly acquire a shared lock for the given key, denying exclusive locks.
    default LockResult
    View.tryLockUpgradable(Transaction txn, byte[] key, long nanosTimeout)
    Explicitly acquire an upgradable lock for the given key, denying exclusive and additional upgradable locks.
    default boolean
    Table.tryMerge(Transaction txn, R row)
    Updates an existing row with the modified columns of the given row, and then loads the result back into the given row.
    default boolean
    Table.tryReplace(Transaction txn, R row)
    Stores the given row when a corresponding row already exists.
    default boolean
    Table.tryUpdate(Transaction txn, R row)
    Updates an existing row with the modified columns of the given row, but the resulting row isn't loaded back.
    default void
    Table.update(Transaction txn, R row)
    Updates an existing row with the modified columns of the given row, but the resulting row isn't loaded back.
    default boolean
    View.update(Transaction txn, byte[] key, byte[] value)
    Associates a value with the given key, but only if the given value differs from the existing value.
    default boolean
    View.update(Transaction txn, byte[] key, byte[] oldValue, byte[] newValue)
    Associates a value with the given key, but only if the given old value matches the existing value.
    default QueryPlan
    Query.updaterPlan(Transaction txn, Object... args)
    Returns a query plan used by newUpdater.
  • Uses of Transaction in org.cojen.tupl.ext

    Methods in org.cojen.tupl.ext with parameters of type Transaction
    Modifier and Type
    Method
    Description
    void
    PrepareHandler.prepare(Transaction txn, byte[] message)
    Called to prepare a transaction or to recover one.
    void
    PrepareHandler.prepareCommit(Transaction txn, byte[] message)
    A prepare variant intended to be called by a two-phase commit coordinator after all participants have prepared their transactions.
    void
    CustomHandler.redo(Transaction txn, byte[] message)
    Called to write or apply an idempotent redo operation.
    void
    CustomHandler.redo(Transaction txn, byte[] message, long indexId, byte[] key)
    Called to write or apply an idempotent redo operation which locked an index key.
    void
    CustomHandler.undo(Transaction txn, byte[] message)
    Called to write or apply an idempotent undo operation.