Class NotifyingRepositoryConnectionWrapper
java.lang.Object
org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection
org.eclipse.rdf4j.repository.base.RepositoryConnectionWrapper
org.eclipse.rdf4j.repository.event.base.NotifyingRepositoryConnectionWrapper
- All Implemented Interfaces:
AutoCloseable,DelegatingRepositoryConnection,NotifyingRepositoryConnection,RepositoryConnection
public class NotifyingRepositoryConnectionWrapper
extends RepositoryConnectionWrapper
implements NotifyingRepositoryConnection
This broadcaster is used by the RepositoryBroadcaster to wrap the delegate repository connection. Listeners are
notified of changes after they have occurred.
- Author:
- James Leigh, Herko ter Horst
-
Field Summary
Fields inherited from class org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection
logger -
Constructor Summary
ConstructorsConstructorDescriptionNotifyingRepositoryConnectionWrapper(Repository repository, RepositoryConnection connection) NotifyingRepositoryConnectionWrapper(Repository repository, RepositoryConnection connection, boolean reportDeltas) -
Method Summary
Modifier and TypeMethodDescriptionvoidRegisters a RepositoryConnectionListener that will receive notifications of operations that are performed on this connection.voidaddWithoutCommit(Resource subject, IRI predicate, Value object, Resource... contexts) voidbegin()Begins a new transaction, requiringRepositoryConnection.commit()orRepositoryConnection.rollback()to be called to end the transaction.voidRemoves all statements from a specific contexts in the repository.voidRemoves all namespace declarations from the repository.voidclose()Closes the connection, freeing resources.voidcommit()Commits the active transaction.protected booleanIf false then the following add methods will callRepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[]).protected booleanIf false then the following remove methods will callRepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource[]).prepareUpdate(QueryLanguage ql, String update, String baseURI) Prepares an Update operation.voidremoveNamespace(String prefix) Removes a namespace declaration by removing the association between a prefix and a namespace name.voidRemoves a registered RepositoryConnectionListener from this connection.voidremoveWithoutCommit(Resource subj, IRI pred, Value obj, Resource... ctx) booleanvoidrollback()Rolls back all updates in the active transaction.voidsetAutoCommit(boolean autoCommit) Deprecated.voidsetNamespace(String prefix, String name) Sets the prefix for a namespace.voidsetReportDeltas(boolean reportDeltas) Methods inherited from class org.eclipse.rdf4j.repository.base.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, sizeMethods inherited from class org.eclipse.rdf4j.repository.base.AbstractRepositoryConnection
addWithoutCommit, conditionalCommit, conditionalRollback, export, getParserConfig, getRepository, getValueFactory, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareTupleQuery, prepareUpdate, removeWithoutCommit, startLocalTransactionMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.eclipse.rdf4j.repository.RepositoryConnection
add, add, add, add, add, add, add, add, add, add, add, add, add, add, add, add, begin, begin, export, exportStatements, getContextIDs, getIsolationLevel, getNamespace, getNamespaces, getParserConfig, getRepository, getStatements, getStatements, getValueFactory, hasStatement, hasStatement, isActive, isAutoCommit, isEmpty, isOpen, prepare, prepareBooleanQuery, prepareBooleanQuery, prepareBooleanQuery, prepareGraphQuery, prepareGraphQuery, prepareGraphQuery, prepareQuery, prepareQuery, prepareQuery, prepareTupleQuery, prepareTupleQuery, prepareTupleQuery, prepareUpdate, prepareUpdate, remove, remove, remove, remove, remove, remove, setIsolationLevel, setParserConfig, size
-
Constructor Details
-
NotifyingRepositoryConnectionWrapper
-
NotifyingRepositoryConnectionWrapper
public NotifyingRepositoryConnectionWrapper(Repository repository, RepositoryConnection connection, boolean reportDeltas)
-
-
Method Details
-
reportDeltas
public boolean reportDeltas() -
setReportDeltas
public void setReportDeltas(boolean reportDeltas) -
addRepositoryConnectionListener
Registers a RepositoryConnectionListener that will receive notifications of operations that are performed on this connection.- Specified by:
addRepositoryConnectionListenerin interfaceNotifyingRepositoryConnection
-
removeRepositoryConnectionListener
Removes a registered RepositoryConnectionListener from this connection.- Specified by:
removeRepositoryConnectionListenerin interfaceNotifyingRepositoryConnection
-
isDelegatingAdd
protected boolean isDelegatingAdd()Description copied from class:RepositoryConnectionWrapperIf false then the following add methods will callRepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[]).- Overrides:
isDelegatingAddin classRepositoryConnectionWrapper- Returns:
trueto delegate add methods,falseto callRepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[])- See Also:
-
RepositoryConnectionWrapper.add(Iterable, Resource...)RepositoryConnectionWrapper.add(Iteration, 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:RepositoryConnectionWrapperIf false then the following remove methods will callRepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource[]).- Overrides:
isDelegatingRemovein classRepositoryConnectionWrapper- Returns:
trueto delegate remove methods,falseto callRepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource...)- See Also:
-
addWithoutCommit
public void addWithoutCommit(Resource subject, IRI predicate, Value object, Resource... contexts) throws RepositoryException - Overrides:
addWithoutCommitin classRepositoryConnectionWrapper- Throws:
RepositoryException
-
clear
Description copied from interface:RepositoryConnectionRemoves all statements from a specific contexts in the repository.- Specified by:
clearin interfaceRepositoryConnection- Overrides:
clearin classRepositoryConnectionWrapper- 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.
-
close
Description copied from interface:RepositoryConnectionCloses the connection, freeing resources. If atransactionisactiveon the connection, all non-committed operations will be lost by actively callingRepositoryConnection.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:
closein interfaceAutoCloseable- Specified by:
closein interfaceRepositoryConnection- Overrides:
closein classRepositoryConnectionWrapper- Throws:
RepositoryException- If the connection could not be closed.
-
commit
Description copied from interface:RepositoryConnectionCommits the active transaction. This operation ends the active transaction.- Specified by:
commitin interfaceRepositoryConnection- Overrides:
commitin classRepositoryConnectionWrapper- Throws:
UnknownTransactionStateException- if the transaction state can not be determined. This can happen for instance when communication with a repository fails or times out.RepositoryException- If the connection could not be committed, or if the connection does not have an active transaction.- See Also:
-
removeWithoutCommit
public void removeWithoutCommit(Resource subj, IRI pred, Value obj, Resource... ctx) throws RepositoryException - Overrides:
removeWithoutCommitin classRepositoryConnectionWrapper- Throws:
RepositoryException
-
removeNamespace
Description copied from interface:RepositoryConnectionRemoves a namespace declaration by removing the association between a prefix and a namespace name.- Specified by:
removeNamespacein interfaceRepositoryConnection- Overrides:
removeNamespacein classRepositoryConnectionWrapper- 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
Description copied from interface:RepositoryConnectionRemoves all namespace declarations from the repository.- Specified by:
clearNamespacesin interfaceRepositoryConnection- Overrides:
clearNamespacesin classRepositoryConnectionWrapper- Throws:
RepositoryException- If the namespace declarations could not be removed.
-
begin
Description copied from interface:RepositoryConnectionBegins a new transaction, requiringRepositoryConnection.commit()orRepositoryConnection.rollback()to be called to end the transaction. The transaction will use the currently setisolation levelfor this connection.- Specified by:
beginin interfaceRepositoryConnection- Overrides:
beginin classRepositoryConnectionWrapper- Throws:
RepositoryException- If the connection could not start the transaction. One possible reason this may happen is if a transaction is alreadyactiveon the current connection.- See Also:
-
rollback
Description copied from interface:RepositoryConnectionRolls back all updates in the active transaction. This operation ends the active transaction.- Specified by:
rollbackin interfaceRepositoryConnection- Overrides:
rollbackin classRepositoryConnectionWrapper- Throws:
UnknownTransactionStateException- if the transaction state can not be determined. This can happen for instance when communication with a repository fails or times out.RepositoryException- If the transaction could not be rolled back, or if the connection does not have an active transaction.- See Also:
-
setAutoCommit
Deprecated.Description copied from interface:RepositoryConnectionEnables 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 eitherRepositoryConnection.commit()orRepositoryConnection.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:
setAutoCommitin interfaceRepositoryConnection- Overrides:
setAutoCommitin classRepositoryConnectionWrapper- Throws:
RepositoryException- In case the mode switch failed, for example because a currently active transaction failed to commit.- See Also:
-
setNamespace
Description copied from interface:RepositoryConnectionSets the prefix for a namespace.- Specified by:
setNamespacein interfaceRepositoryConnection- Overrides:
setNamespacein classRepositoryConnectionWrapper- 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:RepositoryConnectionPrepares an Update operation.- Specified by:
prepareUpdatein interfaceRepositoryConnection- Overrides:
prepareUpdatein classRepositoryConnectionWrapper- Parameters:
ql- Thequery languagein 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
Updateready to be executed on thisRepositoryConnection. - Throws:
MalformedQueryException- If the supplied update operation string is malformed.RepositoryException
-