org.openrdf.sail.rdbms.managers
Class TransTableManager

java.lang.Object
  org.openrdf.sail.rdbms.managers.TransTableManager

public class TransTableManager
extends Object

Manages and delegates to a collection of TransactionTables.

Author:

James Leigh

Field Summary

static int	BATCH_SIZE
static boolean	TEMPORARY_TABLE_USED

Constructor Summary

TransTableManager()

Method Summary

void	close()
void	committed(boolean locked)
protected RdbmsTable	createTemporaryTable(Connection conn)
protected void	createTemporaryTable(RdbmsTable table)
protected TransactionTable	createTransactionTable()
protected TransactionTable	createTransactionTable(TripleTable predicate)
String	findTableName(Number pred)
int	getBatchSize()
String	getCombinedTableName()
ValueTypes	getObjTypes(Number pred)
Collection<Number>	getPredicateIds()
ValueTypes	getSubjTypes(Number pred)
protected TransactionTable	getTable(Number pred)
String	getTableName(Number pred)
protected String	getZeroBigInt()
void	initialize()
void	insert(Number ctx, Number subj, Number pred, Number obj)
boolean	isEmpty()
boolean	isPredColumnPresent(Number id)
void	removed(Number pred, int count)
void	setBatchQueue(BlockingQueue<Batch> queue)
void	setConnection(Connection conn)
void	setFromDummyTable(String fromDummy)
void	setIdSequence(IdSequence ids)
void	setSailChangedEvent(DefaultSailChangedEvent sailChangedEvent)
void	setStatementsTable(TripleTableManager predicateTableManager)
void	setTemporaryTableFactory(TableFactory factory)

Methods inherited from class java.lang.Object

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

Field Detail

BATCH_SIZE

public static int BATCH_SIZE

TEMPORARY_TABLE_USED

public static final boolean TEMPORARY_TABLE_USED

See Also:

Constant Field Values

Constructor Detail

TransTableManager

public TransTableManager()

Method Detail

setConnection

public void setConnection(Connection conn)

setTemporaryTableFactory

public void setTemporaryTableFactory(TableFactory factory)

setStatementsTable

public void setStatementsTable(TripleTableManager predicateTableManager)

setFromDummyTable

public void setFromDummyTable(String fromDummy)

setBatchQueue

public void setBatchQueue(BlockingQueue<Batch> queue)

setSailChangedEvent

public void setSailChangedEvent(DefaultSailChangedEvent sailChangedEvent)

setIdSequence

public void setIdSequence(IdSequence ids)

getBatchSize

public int getBatchSize()

initialize

public void initialize()
                throws SQLException

Throws:

SQLException

insert

public void insert(Number ctx,
                   Number subj,
                   Number pred,
                   Number obj)
            throws SQLException,
                   InterruptedException

Throws:

SQLException

InterruptedException

close

public void close()
           throws SQLException

Throws:

SQLException

findTableName

public String findTableName(Number pred)
                     throws SQLException

Throws:

SQLException

getCombinedTableName

public String getCombinedTableName()
                            throws SQLException

Throws:

SQLException

getTableName

public String getTableName(Number pred)
                    throws SQLException

Throws:

SQLException

committed

public void committed(boolean locked)
               throws SQLException

Throws:

SQLException

removed

public void removed(Number pred,
                    int count)
             throws SQLException

Throws:

SQLException

getPredicateIds

public Collection<Number> getPredicateIds()

isPredColumnPresent

public boolean isPredColumnPresent(Number id)
                            throws SQLException

Throws:

SQLException

getObjTypes

public ValueTypes getObjTypes(Number pred)

getSubjTypes

public ValueTypes getSubjTypes(Number pred)

isEmpty

public boolean isEmpty()
                throws SQLException

Throws:

SQLException

getZeroBigInt

protected String getZeroBigInt()

getTable

protected TransactionTable getTable(Number pred)
                             throws SQLException

Throws:

SQLException

createTransactionTable

protected TransactionTable createTransactionTable(TripleTable predicate)
                                           throws SQLException

Throws:

SQLException

createTemporaryTable

protected RdbmsTable createTemporaryTable(Connection conn)

createTransactionTable

protected TransactionTable createTransactionTable()

createTemporaryTable

protected void createTemporaryTable(RdbmsTable table)
                             throws SQLException

Throws:

SQLException