Modifier and Type | Class and Description |
---|---|
static class |
EndpointBase.ManagedRepositoryConnection
A wrapper for managed
RepositoryConnection s which makes sure that EndpointBase.ManagedRepositoryConnection.close() is a no-op, i.e. |
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
EndpointBase.getConnection() |
RepositoryConnection |
Endpoint.getConnection()
Return a
RepositoryConnection for the Repository represented by this endpoint. |
protected RepositoryConnection |
EndpointBase.getFreshConnection() |
Constructor and Description |
---|
ManagedRepositoryConnection(Repository repository,
RepositoryConnection delegate) |
Modifier and Type | Method and Description |
---|---|
void |
TripleSourceBase.ConnectionOperation.perform(RepositoryConnection conn,
TripleSourceBase.ResultHolder<T> resultHolder) |
Modifier and Type | Field and Description |
---|---|
protected RepositoryConnection |
CloseDependentConnectionIteration.dependentConn |
Constructor and Description |
---|
CloseDependentConnectionIteration(CloseableIteration<T,QueryEvaluationException> inner,
RepositoryConnection dependentConn) |
Modifier and Type | Class and Description |
---|---|
class |
FedXRepositoryConnection
A special
SailRepositoryConnection which adds the original query string as binding to the returned query. |
Modifier and Type | Method and Description |
---|---|
void |
RemoveStatementsOperation.execute(RepositoryConnection con) |
void |
ClearNamespacesOperation.execute(RepositoryConnection con) |
void |
SPARQLUpdateOperation.execute(RepositoryConnection con) |
void |
RemoveNamespaceOperation.execute(RepositoryConnection con) |
void |
AddStatementOperation.execute(RepositoryConnection con) |
void |
SetNamespaceOperation.execute(RepositoryConnection con) |
void |
ClearOperation.execute(RepositoryConnection con) |
void |
TransactionOperation.execute(RepositoryConnection con)
Executes this operation on the supplied connection.
|
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
RepositoryConfigRepository.getConnection() |
static RepositoryConnection |
RepositoryInterceptor.getRepositoryConnection(javax.servlet.http.HttpServletRequest request)
Obtain a new
RepositoryConnection with suitable parser/writer configuration for handling the incoming
HTTP request. |
Modifier and Type | Field and Description |
---|---|
protected RepositoryConnection |
SPARQLUpdateTest.con |
protected RepositoryConnection |
ComplexSPARQLQueryTest.conn |
Modifier and Type | Method and Description |
---|---|
protected static String |
SPARQLQueryTest.getManifestName(Repository manifestRep,
RepositoryConnection con,
String manifestFileURL) |
protected static String |
SPARQLUpdateConformanceTest.getManifestName(Repository manifestRep,
RepositoryConnection con,
String manifestFileURL) |
Modifier and Type | Interface and Description |
---|---|
interface |
DelegatingRepositoryConnection |
Modifier and Type | Field and Description |
---|---|
protected RepositoryConnection |
RepositoryConnectionTest.testCon |
protected RepositoryConnection |
RepositoryConnectionTest.testCon2 |
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
Repository.getConnection()
Opens a connection to this repository that can be used for querying and updating the contents of the repository.
|
RepositoryConnection |
DelegatingRepositoryConnection.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
DelegatingRepositoryConnection.setDelegate(RepositoryConnection delegate) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractRepositoryConnection
Abstract class implementing most 'convenience' methods in the
RepositoryConnection interface by transforming
parameters and mapping the methods to the basic (abstractly declared) methods. |
class |
RepositoryConnectionBase
Deprecated.
since 2.0. Use
AbstractRepositoryConnection instead. |
class |
RepositoryConnectionWrapper
Delegates all calls to the delegate RepositoryConnection.
|
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
RepositoryWrapper.getConnection() |
RepositoryConnection |
RepositoryConnectionWrapper.getDelegate() |
Modifier and Type | Method and Description |
---|---|
void |
RepositoryConnectionWrapper.setDelegate(RepositoryConnection delegate) |
Constructor and Description |
---|
RepositoryConnectionWrapper(Repository repository,
RepositoryConnection delegate) |
Modifier and Type | Method and Description |
---|---|
static Resource |
RepositoryConfigUtil.getContext(RepositoryConnection con,
String repositoryID)
Deprecated.
|
static void |
RepositoryConfigUtil.updateRepositoryConfigs(RepositoryConnection con,
RepositoryConfig... configs)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ContextAwareConnection
Allows contexts to be specified at the connection level or the method level.
|
Constructor and Description |
---|
ContextAwareConnection(RepositoryConnection connection) |
ContextAwareConnection(Repository repository,
RepositoryConnection connection) |
Modifier and Type | Class and Description |
---|---|
class |
DatasetRepositoryConnection |
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
DatasetRepository.getConnection() |
Constructor and Description |
---|
RepositoryTripleSource(RepositoryConnection repo) |
RepositoryTripleSource(RepositoryConnection repo,
boolean includeInferred) |
Modifier and Type | Interface and Description |
---|---|
interface |
InterceptingRepositoryConnection |
interface |
NotifyingRepositoryConnection |
Modifier and Type | Method and Description |
---|---|
boolean |
RepositoryConnectionInterceptor.add(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
void |
RepositoryConnectionListener.add(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
boolean |
RepositoryConnectionInterceptor.begin(RepositoryConnection conn) |
void |
RepositoryConnectionListener.begin(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptor.clear(RepositoryConnection conn,
Resource... contexts) |
void |
RepositoryConnectionListener.clear(RepositoryConnection conn,
Resource... contexts) |
boolean |
RepositoryConnectionInterceptor.clearNamespaces(RepositoryConnection conn) |
void |
RepositoryConnectionListener.clearNamespaces(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptor.close(RepositoryConnection conn) |
void |
RepositoryConnectionListener.close(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptor.commit(RepositoryConnection conn) |
void |
RepositoryConnectionListener.commit(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptor.execute(RepositoryConnection conn,
QueryLanguage ql,
String update,
String baseURI,
Update operation) |
void |
RepositoryConnectionListener.execute(RepositoryConnection conn,
QueryLanguage ql,
String update,
String baseURI,
Update operation) |
boolean |
RepositoryInterceptor.getConnection(Repository repo,
RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptor.remove(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
void |
RepositoryConnectionListener.remove(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
boolean |
RepositoryConnectionInterceptor.removeNamespace(RepositoryConnection conn,
String prefix) |
void |
RepositoryConnectionListener.removeNamespace(RepositoryConnection conn,
String prefix) |
boolean |
RepositoryConnectionInterceptor.rollback(RepositoryConnection conn) |
void |
RepositoryConnectionListener.rollback(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptor.setAutoCommit(RepositoryConnection conn,
boolean autoCommit)
Deprecated.
since 2.0. Use
RepositoryConnectionInterceptor.begin(RepositoryConnection) instead. |
void |
RepositoryConnectionListener.setAutoCommit(RepositoryConnection conn,
boolean autoCommit)
Deprecated.
since 2.0. Use
RepositoryConnectionListener.begin(RepositoryConnection) instead. |
boolean |
RepositoryConnectionInterceptor.setNamespace(RepositoryConnection conn,
String prefix,
String name) |
void |
RepositoryConnectionListener.setNamespace(RepositoryConnection conn,
String prefix,
String name) |
Modifier and Type | Class and Description |
---|---|
class |
InterceptingRepositoryConnectionWrapper
Wrapper that notifies interceptors of events on RepositoryConnections before they happen.
|
class |
NotifyingRepositoryConnectionWrapper
This broadcaster is used by the RepositoryBroadcaster to wrap the delegate repository connection.
|
Modifier and Type | Method and Description |
---|---|
boolean |
RepositoryConnectionInterceptorAdapter.add(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
void |
RepositoryConnectionListenerAdapter.add(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
boolean |
RepositoryConnectionInterceptorAdapter.begin(RepositoryConnection conn) |
void |
RepositoryConnectionListenerAdapter.begin(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptorAdapter.clear(RepositoryConnection conn,
Resource... contexts) |
void |
RepositoryConnectionListenerAdapter.clear(RepositoryConnection conn,
Resource... contexts) |
boolean |
RepositoryConnectionInterceptorAdapter.clearNamespaces(RepositoryConnection conn) |
void |
RepositoryConnectionListenerAdapter.clearNamespaces(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptorAdapter.close(RepositoryConnection conn) |
void |
RepositoryConnectionListenerAdapter.close(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptorAdapter.commit(RepositoryConnection conn) |
void |
RepositoryConnectionListenerAdapter.commit(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptorAdapter.execute(RepositoryConnection conn,
QueryLanguage ql,
String update,
String baseURI,
Update operation) |
void |
RepositoryConnectionListenerAdapter.execute(RepositoryConnection conn,
QueryLanguage ql,
String update,
String baseURI,
Update operation) |
boolean |
RepositoryConnectionInterceptorAdapter.remove(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
void |
RepositoryConnectionListenerAdapter.remove(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
boolean |
RepositoryConnectionInterceptorAdapter.removeNamespace(RepositoryConnection conn,
String prefix) |
void |
RepositoryConnectionListenerAdapter.removeNamespace(RepositoryConnection conn,
String prefix) |
boolean |
RepositoryConnectionInterceptorAdapter.rollback(RepositoryConnection conn) |
void |
RepositoryConnectionListenerAdapter.rollback(RepositoryConnection conn) |
boolean |
RepositoryConnectionInterceptorAdapter.setAutoCommit(RepositoryConnection conn,
boolean autoCommit)
Deprecated.
|
void |
RepositoryConnectionListenerAdapter.setAutoCommit(RepositoryConnection conn,
boolean autoCommit)
Deprecated.
|
boolean |
RepositoryConnectionInterceptorAdapter.setNamespace(RepositoryConnection conn,
String prefix,
String name) |
void |
RepositoryConnectionListenerAdapter.setNamespace(RepositoryConnection conn,
String prefix,
String name) |
Constructor and Description |
---|
InterceptingRepositoryConnectionWrapper(Repository repository,
RepositoryConnection connection) |
NotifyingRepositoryConnectionWrapper(Repository repository,
RepositoryConnection connection) |
NotifyingRepositoryConnectionWrapper(Repository repository,
RepositoryConnection connection,
boolean reportDeltas) |
Modifier and Type | Method and Description |
---|---|
void |
DebugRepositoryConnectionListener.add(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
void |
DebugRepositoryConnectionListener.begin(RepositoryConnection conn) |
void |
DebugRepositoryConnectionListener.clear(RepositoryConnection conn,
Resource... contexts) |
void |
DebugRepositoryConnectionListener.clearNamespaces(RepositoryConnection conn) |
void |
DebugRepositoryConnectionListener.close(RepositoryConnection conn) |
void |
DebugRepositoryConnectionListener.commit(RepositoryConnection conn) |
void |
DebugRepositoryConnectionListener.execute(RepositoryConnection conn,
QueryLanguage ql,
String update,
String baseURI,
Update operation) |
protected String |
DebugRepositoryConnectionListener.getConnectionID(RepositoryConnection conn) |
void |
DebugRepositoryConnectionListener.remove(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts) |
void |
DebugRepositoryConnectionListener.removeNamespace(RepositoryConnection conn,
String prefix) |
void |
DebugRepositoryConnectionListener.rollback(RepositoryConnection conn) |
void |
DebugRepositoryConnectionListener.setAutoCommit(RepositoryConnection conn,
boolean autoCommit)
Deprecated.
|
void |
DebugRepositoryConnectionListener.setNamespace(RepositoryConnection conn,
String prefix,
String name) |
Modifier and Type | Method and Description |
---|---|
boolean |
AccurateRepositoryBloomFilter.mayHaveStatement(RepositoryConnection conn,
Resource subj,
IRI pred,
Value obj,
Resource... contexts) |
boolean |
RepositoryBloomFilter.mayHaveStatement(RepositoryConnection conn,
Resource subj,
IRI pred,
Value obj,
Resource... ctxs)
Returns true if the repository may have such a statement or false if it definitely does not.
|
boolean |
InaccurateRepositoryBloomFilter.mayHaveStatement(RepositoryConnection conn,
Resource subj,
IRI pred,
Value obj,
Resource... contexts) |
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
HTTPRepository.getConnection() |
Modifier and Type | Method and Description |
---|---|
protected long |
IsolationLevelTest.count(RepositoryConnection con,
Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
Resource... contexts) |
protected void |
IsolationLevelTest.insertTestStatement(RepositoryConnection connection,
int i) |
protected Literal |
IsolationLevelTest.readLiteral(RepositoryConnection con,
IRI subj,
IRI pred) |
Modifier and Type | Class and Description |
---|---|
class |
SailRepositoryConnection
An implementation of the
RepositoryConnection interface that wraps a SailConnection . |
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
ProxyRepository.getConnection() |
Modifier and Type | Class and Description |
---|---|
class |
SPARQLConnection
Provides a
RepositoryConnection interface to any SPARQL endpoint. |
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
SPARQLRepository.getConnection() |
Modifier and Type | Method and Description |
---|---|
protected RepositoryConnection |
RepositoryFederatedService.getConnection()
Retrieve a (re-usable) connection.
|
Modifier and Type | Field and Description |
---|---|
protected RepositoryConnection |
RDFInserter.con
The connection to use for the add operations.
|
Modifier and Type | Method and Description |
---|---|
static void |
Connections.consumeRDFCollection(RepositoryConnection conn,
Resource head,
java.util.function.Consumer<Statement> collectionConsumer,
Resource... contexts)
|
static <C extends Collection<Statement>> |
Connections.getRDFCollection(RepositoryConnection conn,
Resource head,
C statementCollection,
Resource... contexts)
Retrieve all
Statement s that together form the RDF Collection starting with the supplied starting
resource. |
static Optional<Statement> |
Connections.getStatement(RepositoryConnection conn,
Resource subject,
IRI predicate,
Value object,
Resource... contexts)
Retrieve a single
Statement matching with the supplied subject, predicate, object and context(s) from the
given RepositoryConnection . |
Modifier and Type | Method and Description |
---|---|
static void |
Repositories.consume(Repository repository,
java.util.function.Consumer<RepositoryConnection> processFunction)
Opens a
RepositoryConnection to the given Repository within a transaction, sends the connection to the
given Consumer , before either rolling back the transaction if it failed, or committing the transaction if
it was successful. |
static void |
Repositories.consume(Repository repository,
java.util.function.Consumer<RepositoryConnection> processFunction,
java.util.function.Consumer<RepositoryException> exceptionHandler)
Opens a
RepositoryConnection to the given Repository within a transaction, sends the connection to the
given Consumer , before either rolling back the transaction if it failed, or committing the transaction if
it was successful. |
static void |
Repositories.consumeNoTransaction(Repository repository,
java.util.function.Consumer<RepositoryConnection> processFunction)
Opens a
RepositoryConnection to the given Repository without opening a transaction, sends the connection
to the given Consumer . |
static void |
Repositories.consumeNoTransaction(Repository repository,
java.util.function.Consumer<RepositoryConnection> processFunction,
java.util.function.Consumer<RepositoryException> exceptionHandler)
Opens a
RepositoryConnection to the given Repository without opening a transaction, sends the connection
to the given Consumer . |
static void |
Repositories.consumeSilent(Repository repository,
java.util.function.Consumer<RepositoryConnection> processFunction)
Opens a
RepositoryConnection to the given Repository within a transaction, sends the connection to the
given Consumer , before either rolling back the transaction if it failed, or committing the transaction if
it was successful. |
static void |
Repositories.consumeSilentNoTransaction(Repository repository,
java.util.function.Consumer<RepositoryConnection> processFunction)
Opens a
RepositoryConnection to the given Repository without opening a transaction, sends the connection
to the given Consumer . |
static <T> T |
Repositories.get(Repository repository,
java.util.function.Function<RepositoryConnection,T> processFunction)
Opens a
RepositoryConnection to the given Repository within a transaction, sends the connection to the
given Function , before either rolling back the transaction if it failed, or committing the transaction if
it was successful. |
static <T> T |
Repositories.get(Repository repository,
java.util.function.Function<RepositoryConnection,T> processFunction,
java.util.function.Consumer<RepositoryException> exceptionHandler)
Opens a
RepositoryConnection to the given Repository within a transaction, sends the connection to the
given Function , before either rolling back the transaction if it failed, or committing the transaction if
it was successful. |
static <T> T |
Repositories.getNoTransaction(Repository repository,
java.util.function.Function<RepositoryConnection,T> processFunction)
Opens a
RepositoryConnection to the given Repository without opening a transaction, sends the connection
to the given Function . |
static <T> T |
Repositories.getNoTransaction(Repository repository,
java.util.function.Function<RepositoryConnection,T> processFunction,
java.util.function.Consumer<RepositoryException> exceptionHandler)
Opens a
RepositoryConnection to the given Repository without opening a transaction, sends the connection
to the given Function . |
static <T> T |
Repositories.getSilent(Repository repository,
java.util.function.Function<RepositoryConnection,T> processFunction)
Opens a
RepositoryConnection to the given Repository within a transaction, sends the connection to the
given Function , before either rolling back the transaction if it failed, or committing the transaction if
it was successful. |
static <T> T |
Repositories.getSilentNoTransaction(Repository repository,
java.util.function.Function<RepositoryConnection,T> processFunction)
Opens a
RepositoryConnection to the given Repository without opening a transaction, sends the connection
to the given Function . |
Constructor and Description |
---|
RDFInserter(RepositoryConnection con)
Creates a new RDFInserter object that preserves bnode IDs and that does not enforce any context upon statements
that are reported to it.
|
RDFRemover(RepositoryConnection con)
Creates a new RDFRemover object that removes the data from the default context.
|
Modifier and Type | Method and Description |
---|---|
RepositoryConnection |
OwnedTupleExpr.getOwner() |
Constructor and Description |
---|
OwnedTupleExpr(RepositoryConnection owner,
TupleExpr arg) |
Constructor and Description |
---|
RepositoryTripleSource(RepositoryConnection repo)
Deprecated.
|
Constructor and Description |
---|
EmptyPatternOptimizer(Collection<? extends RepositoryConnection> members) |
EmptyPatternOptimizer(Collection<? extends RepositoryConnection> members,
java.util.function.Function<? super Repository,? extends RepositoryBloomFilter> bloomFilters) |
FederationJoinOptimizer(Collection<? extends RepositoryConnection> members,
boolean distinct,
PrefixHashSet localSpace)
Deprecated.
|
FederationJoinOptimizer(Collection<? extends RepositoryConnection> members,
boolean distinct,
PrefixHashSet localSpace,
java.util.function.Function<? super Repository,? extends RepositoryBloomFilter> bloomFilters)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
protected void |
TupleServlet.service(TupleResultBuilder builder,
RepositoryConnection con) |
protected void |
TupleServlet.service(WorkbenchRequest req,
javax.servlet.http.HttpServletResponse resp,
TupleResultBuilder builder,
RepositoryConnection con) |
Modifier and Type | Method and Description |
---|---|
protected ExploreServlet.ResultCursor |
ExploreServlet.processResource(RepositoryConnection con,
TupleResultBuilder builder,
Value value,
int offset,
int limit,
boolean render)
Query the repository for all instances of the given value, optionally writing the results into the HTTP response.
|
protected void |
TypesServlet.service(TupleResultBuilder builder,
RepositoryConnection con) |
protected void |
ContextsServlet.service(TupleResultBuilder builder,
RepositoryConnection con) |
protected void |
ExploreServlet.service(WorkbenchRequest req,
javax.servlet.http.HttpServletResponse resp,
TupleResultBuilder builder,
RepositoryConnection con) |
protected void |
ExportServlet.service(WorkbenchRequest req,
javax.servlet.http.HttpServletResponse resp,
TupleResultBuilder builder,
RepositoryConnection con) |
Modifier and Type | Method and Description |
---|---|
void |
QueryEvaluator.extractQueryAndEvaluate(TupleResultBuilder builder,
javax.servlet.http.HttpServletResponse resp,
OutputStream out,
String xslPath,
RepositoryConnection con,
String queryText,
WorkbenchRequest req,
CookieHandler cookies)
Evaluates the query submitted with the given request.
|
static Query |
QueryFactory.prepareQuery(RepositoryConnection con,
QueryLanguage queryLn,
String query) |
Copyright © 2015-2020 Eclipse Foundation. All Rights Reserved.