Class InterceptingRepositoryConnectionWrapper

java.lang.Object

org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection

org.eclipse.rdf4j.repository.base.RepositoryConnectionWrapper

org.eclipse.rdf4j.repository.event.base.InterceptingRepositoryConnectionWrapper

All Implemented Interfaces:

AutoCloseable, DelegatingRepositoryConnection, InterceptingRepositoryConnection, RepositoryConnection

public class InterceptingRepositoryConnectionWrapper
extends RepositoryConnectionWrapper
implements InterceptingRepositoryConnection

Wrapper that notifies interceptors of events on RepositoryConnections before they happen. Any interceptor can block the operation by returning true from the relevant notification method. To do so will also cause the notification process to stop, i.e. no other interceptors will be notified. The order in which interceptors are notified is unspecified.

Author:

Herko ter Horst

See Also:

• InterceptingRepositoryWrapper

Field Summary

Fields inherited from class AbstractRepositoryConnection

logger

Modifier and Type	Field	Description
protected final org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor	Description
InterceptingRepositoryConnectionWrapper(Repository repository, RepositoryConnection connection)

Method Summary

Modifier and Type	Method	Description
void	addRepositoryConnectionInterceptor(RepositoryConnectionInterceptor interceptor)	Registers a RepositoryConnectionInterceptor that will receive notifications of operations that are performed on this connection.
void	addWithoutCommit(Resource subject, IRI predicate, Value object, Resource... contexts)
void	begin()	Begins a new transaction, requiring RepositoryConnection.commit() or RepositoryConnection.rollback() to be called to end the transaction.
void	clear(Resource... contexts)	Removes all statements from a specific contexts in the repository.
void	clearNamespaces()	Removes all namespace declarations from the repository.
void	close()	Closes the connection, freeing resources.
void	commit()	Commits the active transaction.
protected boolean	isDelegatingAdd()	If false then the following add methods will call RepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[]).
protected boolean	isDelegatingRemove()	If false then the following remove methods will call RepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource[]).
Update	prepareUpdate(QueryLanguage ql, String update, String baseURI)	Prepares an Update operation.
void	removeNamespace(String prefix)	Removes a namespace declaration by removing the association between a prefix and a namespace name.
void	removeRepositoryConnectionInterceptor(RepositoryConnectionInterceptor interceptor)	Removes a registered RepositoryConnectionInterceptor from this connection.
void	removeWithoutCommit(Resource subject, IRI predicate, Value object, Resource... contexts)
void	rollback()	Rolls back all updates in the active transaction.
void	setAutoCommit(boolean autoCommit)	Deprecated.
void	setNamespace(String prefix, String name)	Sets the prefix for a namespace.

Methods inherited from class RepositoryConnectionWrapper

add, add, add, add, add, add, add, add, begin, begin, exportStatements, exportStatements, getContextIDs, getDelegate, getIsolationLevel, getNamespace, getNamespaces, getStatements, hasStatement, hasStatement, isActive, isAutoCommit, isDelegatingRead, isEmpty, isOpen, prepare, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareTupleQuery, remove, remove, remove, remove, setDelegate, setIsolationLevel, setParserConfig, size

Modifier and Type	Method	Description
void	add(File file, String baseURI, RDFFormat dataFormat, Resource... contexts)	Adds RDF data from the specified file to a specific contexts in the repository.
void	add(InputStream in, String baseURI, RDFFormat dataFormat, Resource... contexts)	Adds RDF data from an InputStream to the repository, optionally to one or more named contexts.
void	add(Reader reader, String baseURI, RDFFormat dataFormat, Resource... contexts)	Adds RDF data from a Reader to the repository, optionally to one or more named contexts.
void	add(Iterable<? extends Statement> statements, Resource... contexts)	Adds the supplied statements to this repository, optionally to one or more named contexts.
void	add(URL url, String baseURI, RDFFormat dataFormat, Resource... contexts)	Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
void	add(CloseableIteration<? extends Statement> statementIter, Resource... contexts)	Adds the supplied statements to this repository, optionally to one or more named contexts.
void	add(Resource subject, IRI predicate, Value object, Resource... contexts)	Adds a statement with the specified subject, predicate and object to this repository, optionally to one or more named contexts.
void	add(Statement st, Resource... contexts)	Adds the supplied statement to this repository, optionally to one or more named contexts.
void	begin(IsolationLevel level)	Begins a new transaction with the supplied IsolationLevel, requiring RepositoryConnection.commit() or RepositoryConnection.rollback() to be called to end the transaction.
void	begin(TransactionSetting... settings)	Begins a new transaction with the supplied TransactionSetting, requiring RepositoryConnection.commit() or RepositoryConnection.rollback() to be called to end the transaction.
void	exportStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, RDFHandler handler, Resource... contexts)	Exports all statements with a specific subject, predicate and/or object from the repository, optionally from the specified contexts.
protected void	exportStatements(RepositoryResult<Statement> stIter, RDFHandler handler)	Exports all statements contained in the supplied statement iterator and all relevant namespace information to the supplied RDFHandler.
RepositoryResult<Resource>	getContextIDs()	Gets all resources that are used as context identifiers.
RepositoryConnection	getDelegate()
IsolationLevel	getIsolationLevel()	Retrieves the current transaction isolation level of the connection.
String	getNamespace(String prefix)	Gets the namespace that is associated with the specified prefix, if any.
RepositoryResult<Namespace>	getNamespaces()	Gets all declared namespaces as a RepositoryResult of Namespace objects.
RepositoryResult<Statement>	getStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)	Gets all statements with a specific subject, predicate and/or object from the repository.
boolean	hasStatement(Resource subj, IRI pred, Value obj, boolean includeInferred, Resource... contexts)	Checks whether the repository contains statements with a specific subject, predicate and/or object, optionally in the specified contexts.
boolean	hasStatement(Statement st, boolean includeInferred, Resource... contexts)	Checks whether the repository contains the specified statement, optionally in the specified contexts.
boolean	isActive()	Indicates if a transaction is currently active on the connection.
boolean	isAutoCommit()	Deprecated. Use RepositoryConnectionWrapper.isActive() instead.
protected boolean	isDelegatingRead()	If false then the following has/export/isEmpty methods will call RepositoryConnectionWrapper.getStatements(Resource, IRI, Value, boolean, Resource[]).
boolean	isEmpty()	Returns true if this repository does not contain any (explicit) statements.
boolean	isOpen()	Checks whether this connection is open.
void	prepare()	Checks for an error state in the active transaction that would force the transaction to be rolled back.
BooleanQuery	prepareBooleanQuery(QueryLanguage ql, String query, String baseURI)	Prepares queries that return true or false.
GraphQuery	prepareGraphQuery(QueryLanguage ql, String query, String baseURI)	Prepares queries that produce RDF graphs.
Query	prepareQuery(QueryLanguage ql, String query, String baseURI)	Prepares a query for evaluation on this repository (optional operation).
TupleQuery	prepareTupleQuery(QueryLanguage ql, String query, String baseURI)	Prepares a query that produces sets of value tuples.
void	remove(Iterable<? extends Statement> statements, Resource... contexts)	Removes the supplied statements from the specified contexts in this repository.
void	remove(CloseableIteration<? extends Statement> statementIter, Resource... contexts)	Removes the supplied statements from a specific context in this repository, ignoring any context information carried by the statements themselves.
void	remove(Resource subject, IRI predicate, Value object, Resource... contexts)	Removes the statement(s) with the specified subject, predicate and object from the repository, optionally restricted to the specified contexts.
void	remove(Statement st, Resource... contexts)	Removes the supplied statement from the specified contexts in the repository.
void	setDelegate(RepositoryConnection delegate)
void	setIsolationLevel(IsolationLevel level)	Sets the transaction isolation level for the next transaction(s) on this connection.
void	setParserConfig(ParserConfig parserConfig)	Set the parser configuration this connection should use for RDFParser-based operations.
long	size(Resource... contexts)	Returns the number of (explicit) statements that are in the specified contexts in this repository.

Methods inherited from class AbstractRepositoryConnection

addWithoutCommit, conditionalCommit, conditionalRollback, export, getParserConfig, getRepository, getValueFactory, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareTupleQuery, prepareUpdate, removeWithoutCommit, startLocalTransaction

Modifier and Type	Method	Description
protected void	addWithoutCommit(Statement st, Resource... contexts)
protected final void	conditionalCommit(boolean condition)	Invokes RepositoryConnection.commit() if supplied boolean condition is true.
protected final void	conditionalRollback(boolean condition)	Invokes RepositoryConnection.rollback() if supplied boolean condition is true.
void	export(RDFHandler handler, Resource... contexts)	Exports all explicit statements in the specified contexts to the supplied RDFHandler.
ParserConfig	getParserConfig()	Returns the parser configuration this connection uses for Rio-based operations.
Repository	getRepository()	Returns the Repository object to which this connection belongs.
ValueFactory	getValueFactory()	Gets a ValueFactory for this RepositoryConnection.
BooleanQuery	prepareBooleanQuery(QueryLanguage ql, String query)	Prepares queries that return true or false.
GraphQuery	prepareGraphQuery(QueryLanguage ql, String query)	Prepares queries that produce RDF graphs.
Query	prepareQuery(QueryLanguage ql, String query)	Prepares a query for evaluation on this repository (optional operation).
TupleQuery	prepareTupleQuery(QueryLanguage ql, String query)	Prepares a query that produces sets of value tuples.
Update	prepareUpdate(QueryLanguage ql, String update)	Prepares an Update operation.
protected void	removeWithoutCommit(Statement st, Resource... contexts)
protected final boolean	startLocalTransaction()	Starts a new transaction if one is not already active.

Methods inherited from class Object

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

Methods inherited from interface RepositoryConnection

add, add, add, add, add, add, add, getStatements, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareTupleQuery, prepareUpdate, remove

Modifier and Type	Method	Description
default void	add(File file, Resource... contexts)	Adds RDF data from the specified file to a specific contexts in the repository.
default void	add(File file, RDFFormat dataFormat, Resource... contexts)	Adds RDF data from the specified file to a specific contexts in the repository.
default void	add(InputStream in, RDFFormat dataFormat, Resource... contexts)	Adds RDF data from an InputStream to the repository, optionally to one or more named contexts.
default void	add(Reader reader, RDFFormat dataFormat, Resource... contexts)	Adds RDF data from a Reader to the repository, optionally to one or more named contexts.
default void	add(URL url, Resource... contexts)	Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
default void	add(URL url, RDFFormat dataFormat, Resource... contexts)	Adds the RDF data that can be found at the specified URL to the repository, optionally to one or more named contexts.
default void	add(RepositoryResult<Statement> statements, Resource... contexts)	Adds the supplied statements to this repository, optionally to one or more named contexts.
default RepositoryResult<Statement>	getStatements(Resource subj, IRI pred, Value obj, Resource... contexts)	Gets all statements with a specific subject, predicate and/or object from the repository.
default BooleanQuery	prepareBooleanQuery(String query)	Prepares SPARQL queries that return true or false, that is, SPARQL ASK queries.
default GraphQuery	prepareGraphQuery(String query)	Prepares SPARQL queries that produce RDF graphs, that is, SPARQL CONSTRUCT or DESCRIBE queries.
default Query	prepareQuery(String query)	Prepares a SPARQL query for evaluation on this repository (optional operation).
default TupleQuery	prepareTupleQuery(String query)	Prepares a SPARQL query that produces sets of value tuples, that is a SPARQL SELECT query.
default Update	prepareUpdate(String update)	Prepares a SPARQL Update operation.
default void	remove(RepositoryResult<Statement> statements, Resource... contexts)	Removes the supplied statements from a specific context in this repository, ignoring any context information carried by the statements themselves.

Constructor Details

InterceptingRepositoryConnectionWrapper

public InterceptingRepositoryConnectionWrapper(Repository repository,
 RepositoryConnection connection)

Method Details

addRepositoryConnectionInterceptor

public void addRepositoryConnectionInterceptor(RepositoryConnectionInterceptor interceptor)

Registers a RepositoryConnectionInterceptor that will receive notifications of operations that are performed on this connection.

Specified by:

addRepositoryConnectionInterceptor in interface InterceptingRepositoryConnection

removeRepositoryConnectionInterceptor

public void removeRepositoryConnectionInterceptor(RepositoryConnectionInterceptor interceptor)

Removes a registered RepositoryConnectionInterceptor from this connection.

Specified by:

removeRepositoryConnectionInterceptor in interface InterceptingRepositoryConnection

isDelegatingAdd

protected boolean isDelegatingAdd()

Description copied from class: RepositoryConnectionWrapper

If false then the following add methods will call RepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[]).

Overrides:

isDelegatingAdd in class RepositoryConnectionWrapper

Returns:

true to delegate add methods, false to call RepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[])

See Also:

• RepositoryConnectionWrapper.add(Iterable, Resource...)
• RepositoryConnectionWrapper.add(CloseableIteration, Resource...)
• RepositoryConnectionWrapper.add(Statement, Resource...)
• RepositoryConnectionWrapper.add(File, String, RDFFormat, Resource...)
• RepositoryConnectionWrapper.add(InputStream, String, RDFFormat, Resource...)
• RepositoryConnectionWrapper.add(Reader, String, RDFFormat, Resource...)
• RepositoryConnectionWrapper.add(Resource, IRI, Value, Resource...)
• RepositoryConnectionWrapper.add(URL, String, RDFFormat, Resource...)

isDelegatingRemove

protected boolean isDelegatingRemove()

Description copied from class: RepositoryConnectionWrapper

If false then the following remove methods will call RepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource[]).

Overrides:

isDelegatingRemove in class RepositoryConnectionWrapper

Returns:

true to delegate remove methods, false to call RepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource...)

See Also:

• RepositoryConnectionWrapper.clear(Resource...)
• RepositoryConnectionWrapper.remove(Iterable, Resource...)
• RepositoryConnectionWrapper.remove(CloseableIteration, Resource...)
• RepositoryConnectionWrapper.remove(Statement, Resource...)
• RepositoryConnectionWrapper.remove(Resource, IRI, Value, Resource...)

addWithoutCommit

public void addWithoutCommit(Resource subject,
 IRI predicate,
 Value object,
 Resource... contexts)
                      throws RepositoryException

Overrides:

addWithoutCommit in class RepositoryConnectionWrapper

Throws:

RepositoryException

clear

public void clear(Resource... contexts)
           throws RepositoryException

Description copied from interface: RepositoryConnection

Removes all statements from a specific contexts in the repository.

Specified by:

clear in interface RepositoryConnection

Overrides:

clear in class RepositoryConnectionWrapper

Parameters:

contexts - The context(s) to remove the data from. 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:

RepositoryException - If the statements could not be removed from the repository, for example because the repository is not writable.

begin

public void begin()
           throws RepositoryException

Description copied from interface: RepositoryConnection

Begins a new transaction, requiring RepositoryConnection.commit() or RepositoryConnection.rollback() to be called to end the transaction. The transaction will use the currently set isolation level for this connection.

Specified by:

begin in interface RepositoryConnection

Overrides:

begin in class RepositoryConnectionWrapper

Throws:

RepositoryException - If the connection could not start the transaction. One possible reason this may happen is if a transaction is already active on the current connection.

See Also:

• RepositoryConnection.begin(IsolationLevel)
• RepositoryConnection.isActive()
• RepositoryConnection.commit()
• RepositoryConnection.rollback()
• RepositoryConnection.setIsolationLevel(IsolationLevel)

close

public void close()
           throws RepositoryException

Description copied from interface: RepositoryConnection

Closes the connection, freeing resources. If a transaction is active on the connection, all non-committed operations will be lost by actively calling RepositoryConnection.rollback() on any active transactions.

Implementation note: All implementations must override this method if they have any resources that they need to free.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface RepositoryConnection

Overrides:

close in class RepositoryConnectionWrapper

Throws:

RepositoryException - If the connection could not be closed.

commit

public void commit()
            throws RepositoryException

Description copied from interface: RepositoryConnection

Commits the active transaction. This operation ends the active transaction.

Specified by:

commit in interface RepositoryConnection

Overrides:

commit in class RepositoryConnectionWrapper

Throws:

RepositoryException - If the connection could not be committed, or if the connection does not have an active transaction.

See Also:

• RepositoryConnection.isActive()
• RepositoryConnection.begin()
• RepositoryConnection.rollback()
• RepositoryConnection.prepare()

removeWithoutCommit

public void removeWithoutCommit(Resource subject,
 IRI predicate,
 Value object,
 Resource... contexts)
                         throws RepositoryException

Overrides:

removeWithoutCommit in class RepositoryConnectionWrapper

Throws:

RepositoryException

removeNamespace

public void removeNamespace(String prefix)
                     throws RepositoryException

Description copied from interface: RepositoryConnection

Removes a namespace declaration by removing the association between a prefix and a namespace name.

Specified by:

removeNamespace in interface RepositoryConnection

Overrides:

removeNamespace in class RepositoryConnectionWrapper

Parameters:

prefix - The namespace prefix, or an empty string in case of the default namespace.

Throws:

RepositoryException - If the namespace prefix could not be removed.

clearNamespaces

public void clearNamespaces()
                     throws RepositoryException

Description copied from interface: RepositoryConnection

Removes all namespace declarations from the repository.

Specified by:

clearNamespaces in interface RepositoryConnection

Overrides:

clearNamespaces in class RepositoryConnectionWrapper

Throws:

RepositoryException - If the namespace declarations could not be removed.

rollback

public void rollback()
              throws RepositoryException

Description copied from interface: RepositoryConnection

Rolls back all updates in the active transaction. This operation ends the active transaction.

Specified by:

rollback in interface RepositoryConnection

Overrides:

rollback in class RepositoryConnectionWrapper

Throws:

RepositoryException - If the transaction could not be rolled back, or if the connection does not have an active transaction.

See Also:

• RepositoryConnection.isActive()
• RepositoryConnection.begin()
• RepositoryConnection.commit()

setAutoCommit

@Deprecated
public void setAutoCommit(boolean autoCommit)
                   throws RepositoryException

Deprecated.

Description copied from interface: RepositoryConnection

Enables or disables auto-commit mode for the connection. If a connection is in auto-commit mode, then all updates will be executed and committed as individual transactions. Otherwise, the updates are grouped into transactions that are terminated by a call to either RepositoryConnection.commit() or RepositoryConnection.rollback(). By default, new connections are in auto-commit mode.

NOTE: If this connection is switched to auto-commit mode during a transaction, the transaction is committed.

Specified by:

setAutoCommit in interface RepositoryConnection

Overrides:

setAutoCommit in class RepositoryConnectionWrapper

Throws:

RepositoryException - In case the mode switch failed, for example because a currently active transaction failed to commit.

See Also:

• RepositoryConnection.commit()

setNamespace

public void setNamespace(String prefix,
 String name)
                  throws RepositoryException

Description copied from interface: RepositoryConnection

Sets the prefix for a namespace.

Specified by:

setNamespace in interface RepositoryConnection

Overrides:

setNamespace in class RepositoryConnectionWrapper

Parameters:

prefix - The new prefix, or an empty string in case of the default namespace.

name - The namespace name that the prefix maps to.

Throws:

RepositoryException - If the namespace could not be set in the repository, for example because the repository is not writable.

prepareUpdate

public Update prepareUpdate(QueryLanguage ql,
 String update,
 String baseURI)
                     throws MalformedQueryException,
RepositoryException

Description copied from interface: RepositoryConnection

Prepares an Update operation.

Specified by:

prepareUpdate in interface RepositoryConnection

Overrides:

prepareUpdate in class RepositoryConnectionWrapper

Parameters:

ql - The query language in which the update operation is formulated.

update - The update operation string.

baseURI - The base URI to resolve any relative URIs that are in the update against, can be null if the update does not contain any relative URIs.

Returns:

a Update ready to be executed on this RepositoryConnection.

Throws:

MalformedQueryException - If the supplied update operation string is malformed.

RepositoryException