Uses of Interface
org.cojen.tupl.Transaction
Packages that use Transaction
-
Uses of Transaction in org.cojen.tupl
Fields in org.cojen.tupl declared as TransactionModifier and TypeFieldDescriptionstatic final Transaction
Transaction.BOGUS
Transaction instance which isn't a transaction at all.Methods in org.cojen.tupl that return TransactionModifier and TypeMethodDescriptionCursor.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 TransactionModifier and TypeMethodDescriptiondefault boolean
Query.anyRows
(Transaction txn, Object... args) Returns true if this query produces any rows.default boolean
Query.anyRows
(R row, 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 boolean
Table.anyRows
(R row, 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) IfrequireValues
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) IfrequireValues
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) IfrequireValues
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.View.newCursor
(Transaction txn) Returns a new cursor over this view.Query.newScanner
(Transaction txn, Object... args) Returns a new scanner for all the rows of this query.Query.newScanner
(R row, Transaction txn, Object... args) Returns a new scanner for all the rows of this query.Table.newScanner
(Transaction txn) Returns a new scanner for all rows of this table.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.Table.newScanner
(R row, Transaction txn) Returns a new scanner for all rows of this table.Table.newScanner
(R row, Transaction txn, String query, Object... args) Returns a new scanner for a subset of rows from this table, as specified by the query expression.Query.newStream
(Transaction txn, Object... args) Returns a new stream for all the rows of this query.Table.newStream
(Transaction txn) Returns a new stream for all rows of this table.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.Query.newUpdater
(Transaction txn, Object... args) Returns a new updater for all the rows of this query.Query.newUpdater
(R row, Transaction txn, Object... args) Returns a new updater for all the rows of this query.Table.newUpdater
(Transaction txn) Returns a new updater for all rows of this table.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.Table.newUpdater
(R row, Transaction txn) Returns a new updater for all rows of this table.Table.newUpdater
(R row, 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 bynewScanner
.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 bynewStream
.default LockResult
View.touch
(Transaction txn, byte[] key) Touch the given key as if callingload
, 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 bynewUpdater
. -
Uses of Transaction in org.cojen.tupl.ext
Methods in org.cojen.tupl.ext with parameters of type TransactionModifier and TypeMethodDescriptionvoid
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.