org.apache.marmotta.kiwi.sail

Class KiWiSailConnection

java.lang.Object

org.openrdf.sail.helpers.SailConnectionBase

org.openrdf.sail.helpers.NotifyingSailConnectionBase

org.apache.marmotta.kiwi.sail.KiWiSailConnection

All Implemented Interfaces:

org.apache.marmotta.commons.sesame.repository.ResourceConnection, org.openrdf.sail.inferencer.InferencerConnection, org.openrdf.sail.NotifyingSailConnection, org.openrdf.sail.SailConnection

public class KiWiSailConnection
extends org.openrdf.sail.helpers.NotifyingSailConnectionBase
implements org.openrdf.sail.inferencer.InferencerConnection, org.apache.marmotta.commons.sesame.repository.ResourceConnection

A sail connection wrapping a KiWi database connection. Mostly delegates method calls to the underlying connection.

Author: Sebastian Schaffert

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	KiWiSailConnection.KiWiEvaluationStatistics

Field Summary

Fields

Modifier and Type	Field and Description
protected KiWiConnection	databaseConnection Internal JDBC connection to the database.

Fields inherited from class org.openrdf.sail.helpers.SailConnectionBase

connectionLock, logger, updateLock

Constructor Summary

Constructors

Constructor and Description
KiWiSailConnection(KiWiStore sailBase)

Method Summary

Methods

Modifier and Type	Method and Description
KiWiTriple	addInferredStatement(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj) Used by the KiWi reasoner, returns the created inferred statement directly.
boolean	addInferredStatement(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj, org.openrdf.model.Resource... contexts) Adds an inferred statement to a specific context.
Set<KiWiTriple>	addStatementInternal(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj, boolean inferred, org.openrdf.model.Resource... contexts)
protected void	addStatementInternal(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj, org.openrdf.model.Resource... contexts)
void	clearInferred(org.openrdf.model.Resource... contexts) Removes all inferred statements from the specified/all contexts.
protected void	clearInternal(org.openrdf.model.Resource... contexts)
protected void	clearNamespacesInternal()
protected void	closeInternal()
protected void	commitInternal()
protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.query.BindingSet,org.openrdf.query.QueryEvaluationException>	evaluateInternal(org.openrdf.query.algebra.TupleExpr tupleExpr, org.openrdf.query.Dataset dataset, org.openrdf.query.BindingSet bindings, boolean includeInferred) Implementation of SPARQL/SeRQL querying using an abstract query expression.
void	flushUpdates()
org.openrdf.model.BNode	getBNode(String id) Return the Sesame BNode with the given anonymous ID if it exists, or null if it does not exist.
protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.model.Resource,org.openrdf.sail.SailException>	getContextIDsInternal()
KiWiConnection	getDatabaseConnection()
protected String	getNamespaceInternal(String prefix)
protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.model.Namespace,org.openrdf.sail.SailException>	getNamespacesInternal()
org.openrdf.repository.RepositoryResult<org.openrdf.model.Resource>	getResources() Return an iterator over the resources contained in this repository.
org.openrdf.repository.RepositoryResult<org.openrdf.model.URI>	getResources(String prefix) Return an iterator over the resources contained in this repository matching the given prefix.
protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.model.Statement,org.openrdf.sail.SailException>	getStatementsInternal(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj, boolean includeInferred, org.openrdf.model.Resource... contexts)
org.openrdf.model.URI	getURI(String uri) Return the Sesame URI with the given uri identifier if it exists, or null if it does not exist.
KiWiValueFactory	getValueFactory()
boolean	removeInferredStatement(KiWiTriple triple) Removes an inferred statement from a specific context.
boolean	removeInferredStatement(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj, org.openrdf.model.Resource... contexts) Removes an inferred statement from a specific context.
protected void	removeNamespaceInternal(String prefix)
void	removeResource(org.openrdf.model.Resource resource) Remove the resource given as argument from the triple store and the resource repository.
protected void	removeStatementsInternal(org.openrdf.model.Resource subj, org.openrdf.model.URI pred, org.openrdf.model.Value obj, org.openrdf.model.Resource... contexts)
protected KiWiResource	resolveContextInternal(org.openrdf.model.Resource input)
protected void	rollbackInternal()
protected void	setNamespaceInternal(String prefix, String name)
protected long	sizeInternal(org.openrdf.model.Resource... contexts)
protected void	startTransactionInternal()

Methods inherited from class org.openrdf.sail.helpers.NotifyingSailConnectionBase

addConnectionListener, hasConnectionListeners, notifyStatementAdded, notifyStatementRemoved, removeConnectionListener

Methods inherited from class org.openrdf.sail.helpers.SailConnectionBase

addStatement, addStatement, autoStartTransaction, begin, clear, clearNamespaces, close, commit, endUpdate, evaluate, finalize, getContextIDs, getExclusiveConnectionLock, getNamespace, getNamespaces, getSharedConnectionLock, getStatements, getTransactionLock, isActive, isOpen, iterationClosed, prepare, registerIteration, removeNamespace, removeStatement, removeStatements, rollback, setNamespace, size, startUpdate, transactionActive, verifyIsActive, verifyIsOpen

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.openrdf.sail.NotifyingSailConnection

addConnectionListener, removeConnectionListener

Methods inherited from interface org.openrdf.sail.SailConnection

addStatement, addStatement, begin, clear, clearNamespaces, close, commit, endUpdate, evaluate, getContextIDs, getNamespace, getNamespaces, getStatements, isActive, isOpen, prepare, removeNamespace, removeStatement, removeStatements, rollback, setNamespace, size, startUpdate

Field Detail

databaseConnection

protected KiWiConnection databaseConnection

Internal JDBC connection to the database. Will be committed when the SailConnection commits.

Constructor Detail

KiWiSailConnection

public KiWiSailConnection(KiWiStore sailBase)
                   throws org.openrdf.sail.SailException

Throws:

org.openrdf.sail.SailException

Method Detail

getDatabaseConnection

public KiWiConnection getDatabaseConnection()

addStatementInternal

protected void addStatementInternal(org.openrdf.model.Resource subj,
                        org.openrdf.model.URI pred,
                        org.openrdf.model.Value obj,
                        org.openrdf.model.Resource... contexts)
                             throws org.openrdf.sail.SailException

Specified by:

addStatementInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

addInferredStatement

public boolean addInferredStatement(org.openrdf.model.Resource subj,
                           org.openrdf.model.URI pred,
                           org.openrdf.model.Value obj,
                           org.openrdf.model.Resource... contexts)
                             throws org.openrdf.sail.SailException

Adds an inferred statement to a specific context.

Specified by:

addInferredStatement in interface org.openrdf.sail.inferencer.InferencerConnection

Parameters:

subj - The subject of the statement to add.

pred - The predicate of the statement to add.

obj - The object of the statement to add.

contexts - The context(s) to add the statement to. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on the entire repository.

Throws:

org.openrdf.sail.SailException - If the statement could not be added.

IllegalStateException - If the connection has been closed.

addInferredStatement

public KiWiTriple addInferredStatement(org.openrdf.model.Resource subj,
                              org.openrdf.model.URI pred,
                              org.openrdf.model.Value obj)
                                throws org.openrdf.sail.SailException

Used by the KiWi reasoner, returns the created inferred statement directly.

Throws:

org.openrdf.sail.SailException

addStatementInternal

public Set<KiWiTriple> addStatementInternal(org.openrdf.model.Resource subj,
                                   org.openrdf.model.URI pred,
                                   org.openrdf.model.Value obj,
                                   boolean inferred,
                                   org.openrdf.model.Resource... contexts)
                                     throws org.openrdf.sail.SailException

Throws:

org.openrdf.sail.SailException

closeInternal

protected void closeInternal()
                      throws org.openrdf.sail.SailException

Specified by:

closeInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

evaluateInternal

protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.query.BindingSet,org.openrdf.query.QueryEvaluationException> evaluateInternal(org.openrdf.query.algebra.TupleExpr tupleExpr,
                                                                                                                                          org.openrdf.query.Dataset dataset,
                                                                                                                                          org.openrdf.query.BindingSet bindings,
                                                                                                                                          boolean includeInferred)
                                                                                                                                               throws org.openrdf.sail.SailException

Implementation of SPARQL/SeRQL querying using an abstract query expression. This very basic implementation relies on the getStatements method to list triples and is not very efficient for complex queries. You might want to use the kiwi-sparql module to improve the query performance.

Specified by:

evaluateInternal in class org.openrdf.sail.helpers.SailConnectionBase

Parameters:

tupleExpr -

dataset -

bindings -

includeInferred -

Returns:

Throws:

org.openrdf.sail.SailException

getContextIDsInternal

protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.model.Resource,org.openrdf.sail.SailException> getContextIDsInternal()
                                                                                                                                      throws org.openrdf.sail.SailException

Specified by:

getContextIDsInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

getStatementsInternal

protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.model.Statement,org.openrdf.sail.SailException> getStatementsInternal(org.openrdf.model.Resource subj,
                                                                                                                                  org.openrdf.model.URI pred,
                                                                                                                                  org.openrdf.model.Value obj,
                                                                                                                                  boolean includeInferred,
                                                                                                                                  org.openrdf.model.Resource... contexts)
                                                                                                                                       throws org.openrdf.sail.SailException

Specified by:

getStatementsInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

sizeInternal

protected long sizeInternal(org.openrdf.model.Resource... contexts)
                     throws org.openrdf.sail.SailException

Specified by:

sizeInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

startTransactionInternal

protected void startTransactionInternal()
                                 throws org.openrdf.sail.SailException

Specified by:

startTransactionInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

commitInternal

protected void commitInternal()
                       throws org.openrdf.sail.SailException

Specified by:

commitInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

rollbackInternal

protected void rollbackInternal()
                         throws org.openrdf.sail.SailException

Specified by:

rollbackInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

removeStatementsInternal

protected void removeStatementsInternal(org.openrdf.model.Resource subj,
                            org.openrdf.model.URI pred,
                            org.openrdf.model.Value obj,
                            org.openrdf.model.Resource... contexts)
                                 throws org.openrdf.sail.SailException

Specified by:

removeStatementsInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

removeInferredStatement

public boolean removeInferredStatement(org.openrdf.model.Resource subj,
                              org.openrdf.model.URI pred,
                              org.openrdf.model.Value obj,
                              org.openrdf.model.Resource... contexts)
                                throws org.openrdf.sail.SailException

Removes an inferred statement from a specific context.

Specified by:

removeInferredStatement in interface org.openrdf.sail.inferencer.InferencerConnection

Parameters:

subj - The subject of the statement that should be removed.

pred - The predicate of the statement that should be removed.

obj - The object of the statement that should be removed.

contexts - The context(s) from which to remove the statements. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on the entire repository.

Throws:

org.openrdf.sail.SailException - If the statement could not be removed.

IllegalStateException - If the connection has been closed.

removeInferredStatement

public boolean removeInferredStatement(KiWiTriple triple)
                                throws org.openrdf.sail.SailException

Removes an inferred statement from a specific context.

Throws:

org.openrdf.sail.SailException - If the statement could not be removed.

IllegalStateException - If the connection has been closed.

clearInternal

protected void clearInternal(org.openrdf.model.Resource... contexts)
                      throws org.openrdf.sail.SailException

Specified by:

clearInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

clearInferred

public void clearInferred(org.openrdf.model.Resource... contexts)
                   throws org.openrdf.sail.SailException

Removes all inferred statements from the specified/all contexts. If no contexts are specified the method operates on the entire repository.

Specified by:

clearInferred in interface org.openrdf.sail.inferencer.InferencerConnection

Parameters:

contexts - The context(s) from which to remove the statements. Note that this parameter is a vararg and as such is optional. If no contexts are supplied the method operates on the entire repository.

Throws:

org.openrdf.sail.SailException - If the statements could not be removed.

IllegalStateException - If the connection has been closed.

flushUpdates

public void flushUpdates()

Specified by:

flushUpdates in interface org.openrdf.sail.inferencer.InferencerConnection

getNamespacesInternal

protected info.aduna.iteration.CloseableIteration<? extends org.openrdf.model.Namespace,org.openrdf.sail.SailException> getNamespacesInternal()
                                                                                                                                       throws org.openrdf.sail.SailException

Specified by:

getNamespacesInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

getNamespaceInternal

protected String getNamespaceInternal(String prefix)
                               throws org.openrdf.sail.SailException

Specified by:

getNamespaceInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

setNamespaceInternal

protected void setNamespaceInternal(String prefix,
                        String name)
                             throws org.openrdf.sail.SailException

Specified by:

setNamespaceInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

removeNamespaceInternal

protected void removeNamespaceInternal(String prefix)
                                throws org.openrdf.sail.SailException

Specified by:

removeNamespaceInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

clearNamespacesInternal

protected void clearNamespacesInternal()
                                throws org.openrdf.sail.SailException

Specified by:

clearNamespacesInternal in class org.openrdf.sail.helpers.SailConnectionBase

Throws:

org.openrdf.sail.SailException

resolveContextInternal

protected KiWiResource resolveContextInternal(org.openrdf.model.Resource input)

getValueFactory

public KiWiValueFactory getValueFactory()

getResources

public org.openrdf.repository.RepositoryResult<org.openrdf.model.Resource> getResources()
                                                                                 throws org.openrdf.repository.RepositoryException

Return an iterator over the resources contained in this repository.

Specified by:

getResources in interface org.apache.marmotta.commons.sesame.repository.ResourceConnection

Returns:

Throws:

org.openrdf.repository.RepositoryException

getResources

public org.openrdf.repository.RepositoryResult<org.openrdf.model.URI> getResources(String prefix)
                                                                            throws org.openrdf.repository.RepositoryException

Return an iterator over the resources contained in this repository matching the given prefix.

Specified by:

getResources in interface org.apache.marmotta.commons.sesame.repository.ResourceConnection

Returns:

Throws:

org.openrdf.repository.RepositoryException

getURI

public org.openrdf.model.URI getURI(String uri)

Return the Sesame URI with the given uri identifier if it exists, or null if it does not exist.

Specified by:

getURI in interface org.apache.marmotta.commons.sesame.repository.ResourceConnection

Parameters:

uri -

Returns:

getBNode

public org.openrdf.model.BNode getBNode(String id)

Return the Sesame BNode with the given anonymous ID if it exists, or null if it does not exist.

Specified by:

getBNode in interface org.apache.marmotta.commons.sesame.repository.ResourceConnection

Parameters:

id -

Returns:

removeResource

public void removeResource(org.openrdf.model.Resource resource)

Remove the resource given as argument from the triple store and the resource repository.

Specified by:

removeResource in interface org.apache.marmotta.commons.sesame.repository.ResourceConnection

Parameters:

resource -