public class InterceptingRepositoryConnectionWrapper extends RepositoryConnectionWrapper implements InterceptingRepositoryConnection
InterceptingRepositoryWrapperlogger| Constructor and Description |
|---|
InterceptingRepositoryConnectionWrapper(Repository repository,
RepositoryConnection connection) |
| Modifier and Type | Method and 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.
|
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, sizeaddWithoutCommit, conditionalCommit, conditionalRollback, export, getParserConfig, getRepository, getValueFactory, prepareBooleanQuery, prepareGraphQuery, prepareQuery, prepareTupleQuery, prepareUpdate, removeWithoutCommit, startLocalTransactionclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitadd, 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, getStatements, getValueFactory, hasStatement, 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, sizepublic InterceptingRepositoryConnectionWrapper(Repository repository, RepositoryConnection connection)
public void addRepositoryConnectionInterceptor(RepositoryConnectionInterceptor interceptor)
addRepositoryConnectionInterceptor in interface InterceptingRepositoryConnectionpublic void removeRepositoryConnectionInterceptor(RepositoryConnectionInterceptor interceptor)
removeRepositoryConnectionInterceptor in interface InterceptingRepositoryConnectionprotected boolean isDelegatingAdd()
RepositoryConnectionWrapperRepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[]).isDelegatingAdd in class RepositoryConnectionWrappertrue to delegate add methods, false to call
RepositoryConnectionWrapper.addWithoutCommit(Resource, IRI, Value, Resource[])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...)protected boolean isDelegatingRemove()
RepositoryConnectionWrapperRepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource[]).isDelegatingRemove in class RepositoryConnectionWrappertrue to delegate remove methods, false to call
RepositoryConnectionWrapper.removeWithoutCommit(Resource, IRI, Value, Resource...)RepositoryConnectionWrapper.clear(Resource...),
RepositoryConnectionWrapper.remove(Iterable, Resource...),
RepositoryConnectionWrapper.remove(Iteration, Resource...),
RepositoryConnectionWrapper.remove(Statement, Resource...),
RepositoryConnectionWrapper.remove(Resource, IRI, Value, Resource...)public void addWithoutCommit(Resource subject, IRI predicate, Value object, Resource... contexts) throws RepositoryException
addWithoutCommit in class RepositoryConnectionWrapperRepositoryExceptionpublic void clear(Resource... contexts) throws RepositoryException
RepositoryConnectionclear in interface RepositoryConnectionclear in class RepositoryConnectionWrappercontexts - 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.RepositoryException - If the statements could not be removed from the repository, for example because the
repository is not writable.public void begin()
throws RepositoryException
RepositoryConnectionRepositoryConnection.commit() or RepositoryConnection.rollback() to be called to end the transaction.
The transaction will use the currently set isolation level for this connection.begin in interface RepositoryConnectionbegin in class RepositoryConnectionWrapperRepositoryException - 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.RepositoryConnection.begin(IsolationLevel),
RepositoryConnection.isActive(),
RepositoryConnection.commit(),
RepositoryConnection.rollback(),
RepositoryConnection.setIsolationLevel(IsolationLevel)public void close()
throws RepositoryException
RepositoryConnectiontransaction 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.
close in interface AutoCloseableclose in interface RepositoryConnectionclose in class RepositoryConnectionWrapperRepositoryException - If the connection could not be closed.public void commit()
throws RepositoryException
RepositoryConnectioncommit in interface RepositoryConnectioncommit in class RepositoryConnectionWrapperUnknownTransactionStateException - 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.RepositoryConnection.isActive(),
RepositoryConnection.begin(),
RepositoryConnection.rollback(),
RepositoryConnection.prepare()public void removeWithoutCommit(Resource subject, IRI predicate, Value object, Resource... contexts) throws RepositoryException
removeWithoutCommit in class RepositoryConnectionWrapperRepositoryExceptionpublic void removeNamespace(String prefix) throws RepositoryException
RepositoryConnectionremoveNamespace in interface RepositoryConnectionremoveNamespace in class RepositoryConnectionWrapperprefix - The namespace prefix, or an empty string in case of the default namespace.RepositoryException - If the namespace prefix could not be removed.public void clearNamespaces()
throws RepositoryException
RepositoryConnectionclearNamespaces in interface RepositoryConnectionclearNamespaces in class RepositoryConnectionWrapperRepositoryException - If the namespace declarations could not be removed.public void rollback()
throws RepositoryException
RepositoryConnectionrollback in interface RepositoryConnectionrollback in class RepositoryConnectionWrapperUnknownTransactionStateException - 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.RepositoryConnection.isActive(),
RepositoryConnection.begin(),
RepositoryConnection.commit()@Deprecated public void setAutoCommit(boolean autoCommit) throws RepositoryException
RepositoryConnectionRepositoryConnection.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.
setAutoCommit in interface RepositoryConnectionsetAutoCommit in class RepositoryConnectionWrapperRepositoryException - In case the mode switch failed, for example because a currently active transaction
failed to commit.RepositoryConnection.commit()public void setNamespace(String prefix, String name) throws RepositoryException
RepositoryConnectionsetNamespace in interface RepositoryConnectionsetNamespace in class RepositoryConnectionWrapperprefix - The new prefix, or an empty string in case of the default namespace.name - The namespace name that the prefix maps to.RepositoryException - If the namespace could not be set in the repository, for example because the
repository is not writable.public Update prepareUpdate(QueryLanguage ql, String update, String baseURI) throws MalformedQueryException, RepositoryException
RepositoryConnectionprepareUpdate in interface RepositoryConnectionprepareUpdate in class RepositoryConnectionWrapperql - 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.Update ready to be executed on this RepositoryConnection.MalformedQueryException - If the supplied update operation string is malformed.RepositoryExceptionCopyright © 2015-2020 Eclipse Foundation. All Rights Reserved.