mirror of
https://code.briarproject.org/briar/briar.git
synced 2026-02-21 23:29:52 +01:00
Add javadocs for database.
This commit is contained in:
@@ -33,11 +33,18 @@ import java.util.List;
|
|||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
import javax.annotation.Nullable;
|
import javax.annotation.Nullable;
|
||||||
|
import javax.annotation.concurrent.ThreadSafe;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Encapsulates the database implementation and exposes high-level operations
|
* Encapsulates the database implementation and exposes high-level operations
|
||||||
* to other components.
|
* to other components.
|
||||||
|
* <p>
|
||||||
|
* With the exception of the {@link #open(SecretKey, MigrationListener)} and
|
||||||
|
* {@link #close()} methods, which must not be called concurrently, the
|
||||||
|
* database can be accessed from any thread. See {@link TransactionManager}
|
||||||
|
* for locking behaviour.
|
||||||
*/
|
*/
|
||||||
|
@ThreadSafe
|
||||||
@NotNullByDefault
|
@NotNullByDefault
|
||||||
public interface DatabaseComponent extends TransactionManager {
|
public interface DatabaseComponent extends TransactionManager {
|
||||||
|
|
||||||
|
|||||||
@@ -18,6 +18,10 @@ import static java.lang.annotation.RetentionPolicy.RUNTIME;
|
|||||||
* submitted, tasks are not run concurrently, and submitting a task will never
|
* submitted, tasks are not run concurrently, and submitting a task will never
|
||||||
* block. Tasks must not run indefinitely. Tasks submitted during shutdown are
|
* block. Tasks must not run indefinitely. Tasks submitted during shutdown are
|
||||||
* discarded.
|
* discarded.
|
||||||
|
* <p>
|
||||||
|
* It is not mandatory to use this executor for database tasks. The database
|
||||||
|
* can be accessed from any thread, but this executor's guarantee that tasks
|
||||||
|
* are run in the order they're submitted may be useful in some cases.
|
||||||
*/
|
*/
|
||||||
@Qualifier
|
@Qualifier
|
||||||
@Target({FIELD, METHOD, PARAMETER})
|
@Target({FIELD, METHOD, PARAMETER})
|
||||||
|
|||||||
@@ -45,6 +45,9 @@ public class Transaction {
|
|||||||
/**
|
/**
|
||||||
* Attaches an event to be broadcast when the transaction has been
|
* Attaches an event to be broadcast when the transaction has been
|
||||||
* committed. The event will be broadcast on the {@link EventExecutor}.
|
* committed. The event will be broadcast on the {@link EventExecutor}.
|
||||||
|
* Events and {@link #attach(Runnable) tasks} are submitted to the
|
||||||
|
* {@link EventExecutor} in the order they were attached to the
|
||||||
|
* transaction.
|
||||||
*/
|
*/
|
||||||
public void attach(Event e) {
|
public void attach(Event e) {
|
||||||
if (actions == null) actions = new ArrayList<>();
|
if (actions == null) actions = new ArrayList<>();
|
||||||
@@ -54,6 +57,9 @@ public class Transaction {
|
|||||||
/**
|
/**
|
||||||
* Attaches a task to be executed when the transaction has been
|
* Attaches a task to be executed when the transaction has been
|
||||||
* committed. The task will be run on the {@link EventExecutor}.
|
* committed. The task will be run on the {@link EventExecutor}.
|
||||||
|
* {@link #attach(Event) Events} and tasks are submitted to the
|
||||||
|
* {@link EventExecutor} in the order they were attached to the
|
||||||
|
* transaction.
|
||||||
*/
|
*/
|
||||||
public void attach(Runnable r) {
|
public void attach(Runnable r) {
|
||||||
if (actions == null) actions = new ArrayList<>();
|
if (actions == null) actions = new ArrayList<>();
|
||||||
|
|||||||
@@ -1,51 +1,95 @@
|
|||||||
package org.briarproject.bramble.api.db;
|
package org.briarproject.bramble.api.db;
|
||||||
|
|
||||||
|
import org.briarproject.bramble.api.event.EventExecutor;
|
||||||
import org.briarproject.bramble.api.nullsafety.NotNullByDefault;
|
import org.briarproject.bramble.api.nullsafety.NotNullByDefault;
|
||||||
|
|
||||||
import javax.annotation.Nullable;
|
import javax.annotation.Nullable;
|
||||||
|
import javax.annotation.concurrent.ThreadSafe;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* An interface for managing database transactions.
|
||||||
|
* <p>
|
||||||
|
* Read-only transactions may access the database concurrently. Read-write
|
||||||
|
* transactions access the database exclusively, so starting a read-only or
|
||||||
|
* read-write transaction will block until there are no read-write
|
||||||
|
* transactions in progress.
|
||||||
|
* <p>
|
||||||
|
* Failing to {@link #endTransaction(Transaction) end} a transaction will
|
||||||
|
* prevent other callers from accessing the database, so it is recommended to
|
||||||
|
* use the {@link #transaction(boolean, DbRunnable)},
|
||||||
|
* {@link #transactionWithResult(boolean, DbCallable)} and
|
||||||
|
* {@link #transactionWithNullableResult(boolean, NullableDbCallable)} methods
|
||||||
|
* where possible, which handle committing or aborting the transaction on the
|
||||||
|
* caller's behalf.
|
||||||
|
* <p>
|
||||||
|
* Transactions are not reentrant, i.e. it is not permitted to start a
|
||||||
|
* transaction on a thread that already has a transaction in progress.
|
||||||
|
*/
|
||||||
|
@ThreadSafe
|
||||||
@NotNullByDefault
|
@NotNullByDefault
|
||||||
public interface TransactionManager {
|
public interface TransactionManager {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Starts a new transaction and returns an object representing it.
|
* Starts a new transaction and returns an object representing it. This
|
||||||
* <p/>
|
* method acquires the database lock, which is held until
|
||||||
* This method acquires locks, so it must not be called while holding a
|
* {@link #endTransaction(Transaction)} is called.
|
||||||
* lock.
|
|
||||||
*
|
*
|
||||||
* @param readOnly true if the transaction will only be used for reading.
|
* @param readOnly True if the transaction will only be used for reading,
|
||||||
|
* in which case the database lock can be shared with other read-only
|
||||||
|
* transactions.
|
||||||
*/
|
*/
|
||||||
Transaction startTransaction(boolean readOnly) throws DbException;
|
Transaction startTransaction(boolean readOnly) throws DbException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Commits a transaction to the database.
|
* Commits a transaction to the database.
|
||||||
|
* {@link #endTransaction(Transaction)} must be called to release the
|
||||||
|
* database lock.
|
||||||
*/
|
*/
|
||||||
void commitTransaction(Transaction txn) throws DbException;
|
void commitTransaction(Transaction txn) throws DbException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Ends a transaction. If the transaction has not been committed,
|
* Ends a transaction. If the transaction has not been committed by
|
||||||
* it will be aborted. If the transaction has been committed,
|
* calling {@link #commitTransaction(Transaction)}, it is aborted and the
|
||||||
* any events attached to the transaction are broadcast.
|
* database lock is released.
|
||||||
* The database lock will be released in either case.
|
* <p>
|
||||||
|
* If the transaction has been committed, any
|
||||||
|
* {@link Transaction#attach events} attached to the transaction are
|
||||||
|
* broadcast and any {@link Transaction#attach(Runnable) tasks} attached
|
||||||
|
* to the transaction are submitted to the {@link EventExecutor}. The
|
||||||
|
* database lock is then released.
|
||||||
*/
|
*/
|
||||||
void endTransaction(Transaction txn);
|
void endTransaction(Transaction txn);
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Runs the given task within a transaction.
|
* Runs the given task within a transaction. The database lock is held
|
||||||
|
* while running the task.
|
||||||
|
*
|
||||||
|
* @param readOnly True if the transaction will only be used for reading,
|
||||||
|
* in which case the database lock can be shared with other read-only
|
||||||
|
* transactions.
|
||||||
*/
|
*/
|
||||||
<E extends Exception> void transaction(boolean readOnly,
|
<E extends Exception> void transaction(boolean readOnly,
|
||||||
DbRunnable<E> task) throws DbException, E;
|
DbRunnable<E> task) throws DbException, E;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Runs the given task within a transaction and returns the result of the
|
* Runs the given task within a transaction and returns the result of the
|
||||||
* task.
|
* task. The database lock is held while running the task.
|
||||||
|
*
|
||||||
|
* @param readOnly True if the transaction will only be used for reading,
|
||||||
|
* in which case the database lock can be shared with other read-only
|
||||||
|
* transactions.
|
||||||
*/
|
*/
|
||||||
<R, E extends Exception> R transactionWithResult(boolean readOnly,
|
<R, E extends Exception> R transactionWithResult(boolean readOnly,
|
||||||
DbCallable<R, E> task) throws DbException, E;
|
DbCallable<R, E> task) throws DbException, E;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Runs the given task within a transaction and returns the result of the
|
* Runs the given task within a transaction and returns the result of the
|
||||||
* task, which may be null.
|
* task, which may be null. The database lock is held while running the
|
||||||
|
* task.
|
||||||
|
*
|
||||||
|
* @param readOnly True if the transaction will only be used for reading,
|
||||||
|
* in which case the database lock can be shared with other read-only
|
||||||
|
* transactions.
|
||||||
*/
|
*/
|
||||||
@Nullable
|
@Nullable
|
||||||
<R, E extends Exception> R transactionWithNullableResult(boolean readOnly,
|
<R, E extends Exception> R transactionWithNullableResult(boolean readOnly,
|
||||||
|
|||||||
Reference in New Issue
Block a user