io.permazen.kv.leveldb

Class LevelDBKVDatabase

java.lang.Object

io.permazen.kv.mvcc.SnapshotKVDatabase

io.permazen.kv.leveldb.LevelDBKVDatabase

All Implemented Interfaces:

KVDatabase

public class LevelDBKVDatabase
extends SnapshotKVDatabase

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

Key watches are supported.

Field Summary

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

log

Constructor Summary

Constructors

Constructor and Description
LevelDBKVDatabase()

Method Summary

Modifier and Type	Method and Description
protected LevelDBKVTransaction	createSnapshotKVTransaction(MutableView view, long baseVersion) Instantiate a new SnapshotKVTransaction instance.
LevelDBKVTransaction	createTransaction() Create a new transaction.
LevelDBAtomicKVStore	getKVStore() Get the underlying LevelDBAtomicKVStore used by this instance.
void	setKVStore(LevelDBAtomicKVStore kvstore) Configure the underlying LevelDBAtomicKVStore 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 Detail

LevelDBKVDatabase

public LevelDBKVDatabase()

Method Detail

getKVStore

public LevelDBAtomicKVStore getKVStore()

Get the underlying LevelDBAtomicKVStore used by this instance.

Overrides:

getKVStore in class SnapshotKVDatabase

Returns:

underlying key/value store

setKVStore

public void setKVStore(LevelDBAtomicKVStore kvstore)

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

Parameters:

kvstore - underlying key/value store

Throws:

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

createTransaction

public LevelDBKVTransaction 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 LevelDBKVTransaction 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