org.apache.directory.server.core.partition.impl.btree.mavibot

Class MavibotTable<K,V>

java.lang.Object

org.apache.directory.server.xdbm.AbstractTable<K,V>

org.apache.directory.server.core.partition.impl.btree.mavibot.MavibotTable<K,V>

All Implemented Interfaces:

org.apache.directory.server.xdbm.Table<K,V>

Direct Known Subclasses:

MavibotMasterTable

public class MavibotTable<K,V>
extends org.apache.directory.server.xdbm.AbstractTable<K,V>

A Mavibot Table. It extends the default Apache DS Table, when Mavibot is the underlying database.

Author:

Apache Directory Project

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.directory.mavibot.btree.RecordManager	recordMan The used recordManager

Fields inherited from class org.apache.directory.server.xdbm.AbstractTable

allowsDuplicates, commitNumber, count, keyComparator, name, schemaManager, valueComparator

Constructor Summary

Constructors

Constructor and Description
MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan, org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager, String name, org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer, org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer, boolean allowDuplicates) Creates a new instance of MavibotTable.
MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan, org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager, String name, org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer, org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer, boolean allowDuplicates, int cacheSize) Creates a new instance of MavibotTable.

Method Summary

Modifier and Type	Method and Description
void	close()
long	count(K key)
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>>	cursor()
org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>>	cursor(K key)
V	get(K key)
protected org.apache.directory.mavibot.btree.BTree<K,V>	getBTree()
org.apache.directory.server.core.avltree.ArrayTree<V>	getDupsContainer(byte[] serialized)
long	greaterThanCount(K key)
boolean	has(K key)
boolean	has(K key, V value)
boolean	hasGreaterOrEqual(K key)
boolean	hasGreaterOrEqual(K key, V val)
boolean	hasLessOrEqual(K key)
boolean	hasLessOrEqual(K key, V val)
boolean	isDupsEnabled()
long	lessThanCount(K key)
void	put(K key, V value)
void	remove(K key)
void	remove(K key, V value)
void	sync() Synchronizes the buffers with disk.
String	toString()
org.apache.directory.api.ldap.model.cursor.Cursor<V>	valueCursor(K key)

Methods inherited from class org.apache.directory.server.xdbm.AbstractTable

count, getKeyComparator, getName, getValueComparator

Methods inherited from class java.lang.Object

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

Field Detail

recordMan

protected org.apache.directory.mavibot.btree.RecordManager recordMan

The used recordManager

Constructor Detail

MavibotTable

public MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan,
                    org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager,
                    String name,
                    org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer,
                    org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer,
                    boolean allowDuplicates)
             throws IOException

Creates a new instance of MavibotTable.

Parameters:

recordMan - The associated RecordManager

schemaManager - The SchemaManager

name - The Table name

keySerializer - The Key serializer

valueSerializer - The Value serializer

allowDuplicates - If the table allows duplicate values

Throws:

IOException - If the instance creation failed

MavibotTable

public MavibotTable(org.apache.directory.mavibot.btree.RecordManager recordMan,
                    org.apache.directory.api.ldap.model.schema.SchemaManager schemaManager,
                    String name,
                    org.apache.directory.mavibot.btree.serializer.ElementSerializer<K> keySerializer,
                    org.apache.directory.mavibot.btree.serializer.ElementSerializer<V> valueSerializer,
                    boolean allowDuplicates,
                    int cacheSize)
             throws IOException

Creates a new instance of MavibotTable.

Parameters:

recordMan - The associated RecordManager

schemaManager - The SchemaManager

name - The Table name

keySerializer - The Key serializer

valueSerializer - The Value serializer

allowDuplicates - If the table allows duplicate values

cacheSize - The cache size to use

Throws:

IOException - If the instance creation failed

Method Detail

isDupsEnabled

public boolean isDupsEnabled()

has

public boolean has(K key)
            throws org.apache.directory.api.ldap.model.exception.LdapException

Throws:

org.apache.directory.api.ldap.model.exception.LdapException

has

public boolean has(K key,
                   V value)
            throws org.apache.directory.api.ldap.model.exception.LdapException

Throws:

org.apache.directory.api.ldap.model.exception.LdapException

hasGreaterOrEqual

public boolean hasGreaterOrEqual(K key)
                          throws Exception

Throws:

Exception

hasLessOrEqual

public boolean hasLessOrEqual(K key)
                       throws Exception

Throws:

Exception

hasGreaterOrEqual

public boolean hasGreaterOrEqual(K key,
                                 V val)
                          throws org.apache.directory.api.ldap.model.exception.LdapException

Throws:

org.apache.directory.api.ldap.model.exception.LdapException

hasLessOrEqual

public boolean hasLessOrEqual(K key,
                              V val)
                       throws Exception

Throws:

Exception

get

public V get(K key)
      throws org.apache.directory.api.ldap.model.exception.LdapException

Throws:

org.apache.directory.api.ldap.model.exception.LdapException

put

public void put(K key,
                V value)
         throws Exception

Throws:

Exception

remove

public void remove(K key)
            throws Exception

Throws:

Exception

remove

public void remove(K key,
                   V value)
            throws Exception

Throws:

Exception

cursor

public org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>> cursor()
                                                                                                                throws org.apache.directory.api.ldap.model.exception.LdapException

Throws:

org.apache.directory.api.ldap.model.exception.LdapException

cursor

public org.apache.directory.api.ldap.model.cursor.Cursor<org.apache.directory.api.ldap.model.cursor.Tuple<K,V>> cursor(K key)
                                                                                                                throws org.apache.directory.api.ldap.model.exception.LdapException

Throws:

org.apache.directory.api.ldap.model.exception.LdapException

valueCursor

public org.apache.directory.api.ldap.model.cursor.Cursor<V> valueCursor(K key)
                                                                 throws Exception

Throws:

Exception

count

public long count(K key)
           throws Exception

Throws:

Exception

greaterThanCount

public long greaterThanCount(K key)
                      throws Exception

Throws:

Exception

lessThanCount

public long lessThanCount(K key)
                   throws Exception

Throws:

Exception

close

public void close()
           throws Exception

Throws:

Exception

getDupsContainer

public org.apache.directory.server.core.avltree.ArrayTree<V> getDupsContainer(byte[] serialized)
                                                                       throws IOException

Throws:

IOException

getBTree

protected org.apache.directory.mavibot.btree.BTree<K,V> getBTree()

Returns:

the underlying B-tree

sync

public void sync()
          throws IOException

Synchronizes the buffers with disk.

Throws:

IOException - if errors are encountered on the flush

toString

public String toString()

Overrides:

toString in class org.apache.directory.server.xdbm.AbstractTable<K,V>

See Also:

Object.toString()