public class LuceneSailConnection extends NotifyingSailConnectionWrapper
Modifier and Type | Field and Description |
---|---|
protected SailConnectionListener |
connectionListener
The listener that listens to the underlying connection.
|
Constructor and Description |
---|
LuceneSailConnection(NotifyingSailConnection wrappedConnection,
SearchIndex luceneIndex,
LuceneSail sail) |
Modifier and Type | Method and Description |
---|---|
void |
addStatement(Resource arg0,
URI arg1,
Value arg2,
Resource... arg3)
Adds a statement to the store.
|
void |
begin()
Begins a transaction requiring
SailConnection.commit() or SailConnection.rollback() to
be called to close the transaction. |
void |
clear(Resource... arg0)
Removes all statements from the specified/all contexts.
|
void |
close()
Closes the connection.
|
void |
commit()
Commits any updates that have been performed since the last time
SailConnection.commit() or SailConnection.rollback() was called. |
CloseableIteration<? extends BindingSet,QueryEvaluationException> |
evaluate(TupleExpr tupleExpr,
Dataset dataset,
BindingSet bindings,
boolean includeInferred)
Evaluates the supplied TupleExpr on the data contained in this Sail
object, using the (optional) dataset and supplied bindings as input
parameters.
|
void |
removeStatements(Resource arg0,
URI arg1,
Value arg2,
Resource... arg3)
Removes all statements matching the specified subject, predicate and
object from the repository.
|
void |
rollback()
Rolls back the transaction, discarding any uncommitted changes that have
been made in this SailConnection.
|
addConnectionListener, getWrappedConnection, removeConnectionListener
addStatement, begin, clearNamespaces, endUpdate, flush, getContextIDs, getNamespace, getNamespaces, getStatements, isActive, isOpen, prepare, removeNamespace, removeStatement, setFederatedServiceResolver, setNamespace, size, size, startUpdate
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addStatement, begin, clearNamespaces, endUpdate, flush, getContextIDs, getNamespace, getNamespaces, getStatements, isActive, isOpen, prepare, removeNamespace, removeStatement, setNamespace, size, startUpdate
protected final SailConnectionListener connectionListener
public LuceneSailConnection(NotifyingSailConnection wrappedConnection, SearchIndex luceneIndex, LuceneSail sail)
public void addStatement(Resource arg0, URI arg1, Value arg2, Resource... arg3) throws SailException
SailConnection
addStatement
in interface SailConnection
addStatement
in class SailConnectionWrapper
arg0
- The subject of the statement to add.arg1
- The predicate of the statement to add.arg2
- The object of the statement to add.arg3
- The context(s) to add the statement to. Note that this parameter is
a vararg and as such is optional. If no contexts are specified, a
context-less statement will be added.SailException
- If the statement could not be added, for example because no
transaction is active.public void close() throws SailException
SailConnection
close
in interface SailConnection
close
in class SailConnectionWrapper
SailException
public void clear(Resource... arg0) throws SailException
SailConnection
clear
in interface SailConnection
clear
in class SailConnectionWrapper
arg0
- 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
specified the method operates on the entire repository. A
null value can be used to match context-less statements.SailException
- If the statements could not be removed.public void begin() throws SailException
SailConnection
SailConnection.commit()
or SailConnection.rollback()
to
be called to close the transaction. The transaction will use the default
IsolationLevel
level for the SAIL, as returned by
Sail.getDefaultIsolationLevel()
.begin
in interface SailConnection
begin
in class SailConnectionWrapper
SailException
- If the connection could not start a transaction or if a
transaction is already active on this connection.public void commit() throws SailException
SailConnection
SailConnection.commit()
or SailConnection.rollback()
was called.commit
in interface SailConnection
commit
in class SailConnectionWrapper
UnknownSailTransactionStateException
- If the transaction state can not be determined (this can happen
for instance when communication between client and server fails or
times-out). It does not indicate a problem with the integrity of
the store.SailException
- If the SailConnection could not be committed.public CloseableIteration<? extends BindingSet,QueryEvaluationException> evaluate(TupleExpr tupleExpr, Dataset dataset, BindingSet bindings, boolean includeInferred) throws SailException
SailConnection
evaluate
in interface SailConnection
evaluate
in class SailConnectionWrapper
tupleExpr
- The tuple expression to evaluate.dataset
- The dataset to use for evaluating the query, null to use
the Sail's default dataset.bindings
- A set of input parameters for the query evaluation. The keys
reference variable names that should be bound to the value they map
to.includeInferred
- Indicates whether inferred triples are to be considered in the
query result. If false, no inferred statements are returned; if
true, inferred statements are returned if availableSailException
- If the Sail object encountered an error or unexpected situation
internally.public void removeStatements(Resource arg0, URI arg1, Value arg2, Resource... arg3) throws SailException
SailConnection
removeStatements
in interface SailConnection
removeStatements
in class SailConnectionWrapper
arg0
- The subject of the statement that should be removed, or
null to indicate a wildcard.arg1
- The predicate of the statement that should be removed, or
null to indicate a wildcard.arg2
- The object of the statement that should be removed , or
null to indicate a wildcard. *arg3
- The context(s) from which to remove the statement. Note that this
parameter is a vararg and as such is optional. If no contexts are
specified the method operates on the entire repository. A
null value can be used to match context-less statements.SailException
- If the statement could not be removed, for example because no
transaction is active.public void rollback() throws SailException
SailConnection
rollback
in interface SailConnection
rollback
in class SailConnectionWrapper
UnknownSailTransactionStateException
- If the transaction state can not be determined (this can happen
for instance when communication between client and server fails or
times-out). It does not indicate a problem with the integrity of
the store.SailException
- If the SailConnection could not be rolled back.Copyright © 2001–2016 Aduna. All rights reserved.