org.fusesource.leveldbjni.internal

Class JniDB

java.lang.Object

org.fusesource.leveldbjni.internal.JniDB

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.lang.Iterable<java.util.Map.Entry<byte[],byte[]>>, org.iq80.leveldb.DB

public class JniDB
extends java.lang.Object
implements org.iq80.leveldb.DB

Field Summary

Fields

Modifier and Type	Field and Description
private NativeCache	cache
private NativeComparator	comparator
private NativeDB	db
private NativeLogger	logger

Constructor Summary

Constructors

Constructor and Description
JniDB(NativeDB db, NativeCache cache, NativeComparator comparator, NativeLogger logger)

Method Summary

Modifier and Type	Method and Description
void	close()
void	compactRange(byte[] begin, byte[] end)
private NativeReadOptions	convert(org.iq80.leveldb.ReadOptions options)
private NativeWriteOptions	convert(org.iq80.leveldb.WriteOptions options)
org.iq80.leveldb.WriteBatch	createWriteBatch()
void	delete(byte[] key)
org.iq80.leveldb.Snapshot	delete(byte[] key, org.iq80.leveldb.WriteOptions options)
byte[]	get(byte[] key)
byte[]	get(byte[] key, org.iq80.leveldb.ReadOptions options)
long[]	getApproximateSizes(org.iq80.leveldb.Range... ranges)
java.lang.String	getProperty(java.lang.String name)
org.iq80.leveldb.Snapshot	getSnapshot()
org.iq80.leveldb.DBIterator	iterator()
org.iq80.leveldb.DBIterator	iterator(org.iq80.leveldb.ReadOptions options)
void	put(byte[] key, byte[] value)
org.iq80.leveldb.Snapshot	put(byte[] key, byte[] value, org.iq80.leveldb.WriteOptions options)
void	resumeCompactions()
void	suspendCompactions()
void	write(org.iq80.leveldb.WriteBatch updates)
org.iq80.leveldb.Snapshot	write(org.iq80.leveldb.WriteBatch updates, org.iq80.leveldb.WriteOptions options)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

db

private NativeDB db

cache

private NativeCache cache

comparator

private NativeComparator comparator

logger

private NativeLogger logger

Constructor Detail

JniDB

public JniDB(NativeDB db,
             NativeCache cache,
             NativeComparator comparator,
             NativeLogger logger)

Method Detail

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

get

public byte[] get(byte[] key)
           throws org.iq80.leveldb.DBException

Specified by:

get in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

get

public byte[] get(byte[] key,
                  org.iq80.leveldb.ReadOptions options)
           throws org.iq80.leveldb.DBException

Specified by:

get in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

iterator

public org.iq80.leveldb.DBIterator iterator()

Specified by:

iterator in interface java.lang.Iterable<java.util.Map.Entry<byte[],byte[]>>

Specified by:

iterator in interface org.iq80.leveldb.DB

iterator

public org.iq80.leveldb.DBIterator iterator(org.iq80.leveldb.ReadOptions options)

Specified by:

iterator in interface org.iq80.leveldb.DB

put

public void put(byte[] key,
                byte[] value)
         throws org.iq80.leveldb.DBException

Specified by:

put in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

delete

public void delete(byte[] key)
            throws org.iq80.leveldb.DBException

Specified by:

delete in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

write

public void write(org.iq80.leveldb.WriteBatch updates)
           throws org.iq80.leveldb.DBException

Specified by:

write in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

createWriteBatch

public org.iq80.leveldb.WriteBatch createWriteBatch()

Specified by:

createWriteBatch in interface org.iq80.leveldb.DB

put

public org.iq80.leveldb.Snapshot put(byte[] key,
                                     byte[] value,
                                     org.iq80.leveldb.WriteOptions options)
                              throws org.iq80.leveldb.DBException

Specified by:

put in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

delete

public org.iq80.leveldb.Snapshot delete(byte[] key,
                                        org.iq80.leveldb.WriteOptions options)
                                 throws org.iq80.leveldb.DBException

Specified by:

delete in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

write

public org.iq80.leveldb.Snapshot write(org.iq80.leveldb.WriteBatch updates,
                                       org.iq80.leveldb.WriteOptions options)
                                throws org.iq80.leveldb.DBException

Specified by:

write in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

getSnapshot

public org.iq80.leveldb.Snapshot getSnapshot()

Specified by:

getSnapshot in interface org.iq80.leveldb.DB

getApproximateSizes

public long[] getApproximateSizes(org.iq80.leveldb.Range... ranges)

Specified by:

getApproximateSizes in interface org.iq80.leveldb.DB

getProperty

public java.lang.String getProperty(java.lang.String name)

Specified by:

getProperty in interface org.iq80.leveldb.DB

convert

private NativeReadOptions convert(org.iq80.leveldb.ReadOptions options)

convert

private NativeWriteOptions convert(org.iq80.leveldb.WriteOptions options)

compactRange

public void compactRange(byte[] begin,
                         byte[] end)
                  throws org.iq80.leveldb.DBException

Specified by:

compactRange in interface org.iq80.leveldb.DB

Throws:

org.iq80.leveldb.DBException

suspendCompactions

public void suspendCompactions()
                        throws java.lang.InterruptedException

Specified by:

suspendCompactions in interface org.iq80.leveldb.DB

Throws:

java.lang.InterruptedException

resumeCompactions

public void resumeCompactions()

Specified by:

resumeCompactions in interface org.iq80.leveldb.DB