org.openrdf.sail.rdbms.managers.base
Class ValueManagerBase<V extends RdbmsValue>

java.lang.Object
  org.openrdf.sail.rdbms.managers.base.ManagerBase
      org.openrdf.sail.rdbms.managers.base.ValueManagerBase<V>

Direct Known Subclasses:

BNodeManager, LiteralManager, UriManager

public abstract class ValueManagerBase<V extends RdbmsValue>
extends ManagerBase

Field Summary

Fields inherited from class org.openrdf.sail.rdbms.managers.base.ManagerBase

BATCH_SIZE, MAX_QUEUE, MIN_QUEUE, queue

Constructor Summary

ValueManagerBase()

Method Summary

void	cache(V value)
protected abstract boolean	expunge(String condition)
V	findInCache(Object key)
void	flush()
protected abstract int	getBatchSize()
IdSequence	getIdSequence()
int	getIdVersion()
Number	getInternalId(V value)
void	init()
protected abstract void	insert(Number id, V value)
protected abstract Object	key(V value)
protected void	optimize()
void	removedStatements(String condition)
void	setHashManager(HashManager hashes)
void	setIdSequence(IdSequence ids)

Methods inherited from class org.openrdf.sail.rdbms.managers.base.ManagerBase

clear, close, flush, getQueue

Methods inherited from class java.lang.Object

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

Constructor Detail

ValueManagerBase

public ValueManagerBase()

Method Detail

setHashManager

public void setHashManager(HashManager hashes)

getIdSequence

public IdSequence getIdSequence()

setIdSequence

public void setIdSequence(IdSequence ids)

init

public void init()

flush

public void flush()
           throws SQLException,
                  InterruptedException

Overrides:

flush in class ManagerBase

Throws:

SQLException

InterruptedException

findInCache

public V findInCache(Object key)

cache

public void cache(V value)
           throws InterruptedException

Throws:

InterruptedException

getInternalId

public Number getInternalId(V value)
                     throws SQLException,
                            InterruptedException

Throws:

SQLException

InterruptedException

getIdVersion

public int getIdVersion()

removedStatements

public void removedStatements(String condition)
                       throws SQLException

Throws:

SQLException

getBatchSize

protected abstract int getBatchSize()

insert

protected abstract void insert(Number id,
                               V value)
                        throws SQLException,
                               InterruptedException

Throws:

SQLException

InterruptedException

key

protected abstract Object key(V value)

expunge

protected abstract boolean expunge(String condition)
                            throws SQLException

Throws:

SQLException

optimize

protected void optimize()
                 throws SQLException

Overrides:

optimize in class ManagerBase

Throws:

SQLException