Package io.permazen.kv.array

Class ArrayKVDatabase

java.lang.Object

io.permazen.kv.mvcc.SnapshotKVDatabase

io.permazen.kv.array.ArrayKVDatabase

All Implemented Interfaces:

KVDatabase

public class ArrayKVDatabase
extends SnapshotKVDatabase

KVDatabase implementation based on a AtomicArrayKVStore, providing concurrent transactions and linearizable ACID semantics.

Key watches, snapshots, and hot backups are supported.

See Also:

• AtomicArrayKVStore

Field Summary

Fields inherited from class io.permazen.kv.mvcc.SnapshotKVDatabase

log

Constructor Summary

Constructors

Constructor	Description
ArrayKVDatabase()

Method Summary

Modifier and Type	Method	Description
protected ArrayKVTransaction	createSnapshotKVTransaction(MutableView view, long baseVersion)	Instantiate a new SnapshotKVTransaction instance.
ArrayKVTransaction	createTransaction()	Create a new transaction.
AtomicArrayKVStore	getKVStore()	Get the underlying AtomicArrayKVStore used by this instance.
void	setKVStore(AtomicArrayKVStore kvstore)	Configure the underlying AtomicArrayKVStore used by this instance.
protected RuntimeException	wrapException(SnapshotKVTransaction tx, RuntimeException e)	Wrap a RuntimeException as needed.

Methods inherited from class io.permazen.kv.mvcc.SnapshotKVDatabase

closeTransactions, createTransaction, getCurrentVersion, logException, setKVStore, start, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Details

ArrayKVDatabase

public ArrayKVDatabase()

Method Details

getKVStore

public AtomicArrayKVStore getKVStore()

Get the underlying AtomicArrayKVStore used by this instance.

Overrides:

getKVStore in class SnapshotKVDatabase

Returns:

underlying key/value store

setKVStore

public void setKVStore(AtomicArrayKVStore kvstore)

Configure the underlying AtomicArrayKVStore used by this instance. Required property.

Parameters:

kvstore - underlying key/value store

Throws:

IllegalStateException - if this instance is already SnapshotKVDatabase.start()ed

createTransaction

public ArrayKVTransaction createTransaction()

Description copied from class: SnapshotKVDatabase

Create a new transaction.

Specified by:

createTransaction in interface KVDatabase

Overrides:

createTransaction in class SnapshotKVDatabase

Returns:

newly created transaction

createSnapshotKVTransaction

protected ArrayKVTransaction createSnapshotKVTransaction(MutableView view,
 long baseVersion)

Description copied from class: SnapshotKVDatabase

Instantiate a new SnapshotKVTransaction instance.

The implementation in SnapshotKVDatabase just invokes the SnapshotKVTransaction constructor using this. Subclasses may want to override this method to create a more specific subclass.

Overrides:

createSnapshotKVTransaction in class SnapshotKVDatabase

Parameters:

view - mutable view to be used for this transaction

baseVersion - the database version associated with base

Returns:

new transaction instance

wrapException

protected RuntimeException wrapException(SnapshotKVTransaction tx,
 RuntimeException e)

Description copied from class: SnapshotKVDatabase

Wrap a RuntimeException as needed.

The implementation in SnapshotKVDatabase just returns e.

Overrides:

wrapException in class SnapshotKVDatabase

Parameters:

tx - transaction in which the exception occurred

e - original exception

Returns:

wrapped exception, or just e