public class BigdataSailRemoteRepositoryConnection extends Object implements org.openrdf.repository.RepositoryConnection
RemoteRepository
. This provides SAIL API based client access
to a bigdata remote NanoSparqlServer.
Repository
or
RepositoryConnection
. Therefore a namespace DOES NOT need to be
configured for isolatable indices in order to create and manipulate
transactions, but it DOES need to be configured with isolatable indices in
order for you to WRITE on the namespace using a transaction.RemoteTransactionManager
,
BigdataSail.Options.ISOLATABLE_INDICES
,
Support read/write
transactions in the REST API,
BigdataSailRemoteRepositoryConnection should implement interface methods
FIXME (***) #698 Fix all the Query objects (TupleQuery, GraphQuery,
BooleanQuery) to support the various possible operations on them, such
as setting a binding.Constructor and Description |
---|
BigdataSailRemoteRepositoryConnection(BigdataSailRemoteRepository repo) |
Modifier and Type | Method and Description |
---|---|
void |
add(File input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
add(InputStream input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
add(Iterable<? extends org.openrdf.model.Statement> stmts,
org.openrdf.model.Resource... c) |
<E extends Exception> |
add(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts,
org.openrdf.model.Resource... c) |
void |
add(Reader input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
add(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c) |
void |
add(org.openrdf.model.Statement stmt,
org.openrdf.model.Resource... c)
single statement updates not recommended for performance
reasons.
|
void |
add(URL input,
String baseURI,
org.openrdf.rio.RDFFormat format,
org.openrdf.model.Resource... c)
TODO support baseURI
|
void |
begin() |
void |
beginReadOnly()
Begin a read-only transaction.
|
void |
beginReadOnly(long timestamp)
Begin a read-only transaction that reads against the most recent committed
state whose commit timestamp is less than or equal to timestamp.
|
void |
clear(org.openrdf.model.Resource... c) |
void |
clearNamespaces() |
void |
close() |
void |
commit() |
long |
count(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c)
Report the fast range count (aka ESTCARD) associated with the specified
access path.
|
void |
export(org.openrdf.rio.RDFHandler handler,
org.openrdf.model.Resource... c) |
void |
exportStatements(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.rio.RDFHandler handler,
org.openrdf.model.Resource... c) |
org.openrdf.repository.RepositoryResult<org.openrdf.model.Resource> |
getContextIDs() |
String |
getNamespace(String arg0) |
org.openrdf.repository.RepositoryResult<org.openrdf.model.Namespace> |
getNamespaces() |
org.openrdf.rio.ParserConfig |
getParserConfig() |
org.openrdf.repository.Repository |
getRepository() |
protected RemoteRepository |
getRepositoryForConnection()
Return a
RemoteRepository for this connection. |
org.openrdf.repository.RepositoryResult<org.openrdf.model.Statement> |
getStatements(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.model.Resource... c) |
org.openrdf.model.ValueFactory |
getValueFactory() |
boolean |
hasStatement(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
boolean includeInferred,
org.openrdf.model.Resource... c) |
boolean |
hasStatement(org.openrdf.model.Statement s,
boolean includeInferred,
org.openrdf.model.Resource... c) |
boolean |
isActive() |
boolean |
isAutoCommit()
Deprecated.
|
boolean |
isEmpty() |
boolean |
isOpen() |
org.openrdf.query.BooleanQuery |
prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.BooleanQuery |
prepareBooleanQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.GraphQuery |
prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.GraphQuery |
prepareGraphQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.Query |
prepareQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.Query |
prepareQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.TupleQuery |
prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.TupleQuery |
prepareTupleQuery(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
org.openrdf.query.Update |
prepareUpdate(org.openrdf.query.QueryLanguage ql,
String query) |
org.openrdf.query.Update |
prepareUpdate(org.openrdf.query.QueryLanguage ql,
String query,
String baseURI) |
void |
remove(Iterable<? extends org.openrdf.model.Statement> stmts,
org.openrdf.model.Resource... c) |
<E extends Exception> |
remove(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts,
org.openrdf.model.Resource... c) |
void |
remove(org.openrdf.model.Resource s,
org.openrdf.model.URI p,
org.openrdf.model.Value o,
org.openrdf.model.Resource... c) |
void |
remove(org.openrdf.model.Statement stmt,
org.openrdf.model.Resource... c)
single statement updates not recommended for performance
reasons.
|
void |
removeNamespace(String arg0) |
void |
rollback() |
void |
setAutoCommit(boolean autoCommit)
Deprecated.
|
void |
setNamespace(String arg0,
String arg1) |
void |
setParserConfig(org.openrdf.rio.ParserConfig arg0) |
long |
size(org.openrdf.model.Resource... c) |
public BigdataSailRemoteRepositoryConnection(BigdataSailRemoteRepository repo)
protected RemoteRepository getRepositoryForConnection()
RemoteRepository
for this connection.RemoteRepositoryManager#new
public long count(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException
public org.openrdf.repository.RepositoryResult<org.openrdf.model.Statement> getStatements(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, boolean includeInferred, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
getStatements
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public boolean hasStatement(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, boolean includeInferred, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
hasStatement
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public org.openrdf.query.BooleanQuery prepareBooleanQuery(org.openrdf.query.QueryLanguage ql, String query, String baseURI) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareBooleanQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.BooleanQuery prepareBooleanQuery(org.openrdf.query.QueryLanguage ql, String query) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareBooleanQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.GraphQuery prepareGraphQuery(org.openrdf.query.QueryLanguage ql, String query, String baseURI) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareGraphQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.GraphQuery prepareGraphQuery(org.openrdf.query.QueryLanguage ql, String query) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareGraphQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.Query prepareQuery(org.openrdf.query.QueryLanguage ql, String query) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.Query prepareQuery(org.openrdf.query.QueryLanguage ql, String query, String baseURI) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.TupleQuery prepareTupleQuery(org.openrdf.query.QueryLanguage ql, String query, String baseURI) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareTupleQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.TupleQuery prepareTupleQuery(org.openrdf.query.QueryLanguage ql, String query) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareTupleQuery
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public boolean hasStatement(org.openrdf.model.Statement s, boolean includeInferred, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
hasStatement
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public <E extends Exception> void add(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException, E extends Exception
add
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
E extends Exception
public void add(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void add(org.openrdf.model.Statement stmt, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void add(Iterable<? extends org.openrdf.model.Statement> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void add(Reader input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
IOException
org.openrdf.rio.RDFParseException
org.openrdf.repository.RepositoryException
public void add(URL input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
IOException
org.openrdf.rio.RDFParseException
org.openrdf.repository.RepositoryException
public void add(File input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
IOException
org.openrdf.rio.RDFParseException
org.openrdf.repository.RepositoryException
public void add(InputStream input, String baseURI, org.openrdf.rio.RDFFormat format, org.openrdf.model.Resource... c) throws IOException, org.openrdf.rio.RDFParseException, org.openrdf.repository.RepositoryException
add
in interface org.openrdf.repository.RepositoryConnection
IOException
org.openrdf.rio.RDFParseException
org.openrdf.repository.RepositoryException
public <E extends Exception> void remove(info.aduna.iteration.Iteration<? extends org.openrdf.model.Statement,E> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException, E extends Exception
remove
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
E extends Exception
public void remove(org.openrdf.model.Statement stmt, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
remove
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void remove(Iterable<? extends org.openrdf.model.Statement> stmts, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
remove
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void remove(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
remove
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public org.openrdf.repository.Repository getRepository()
getRepository
in interface org.openrdf.repository.RepositoryConnection
public org.openrdf.repository.RepositoryResult<org.openrdf.model.Resource> getContextIDs() throws org.openrdf.repository.RepositoryException
getContextIDs
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public boolean isEmpty() throws org.openrdf.repository.RepositoryException
This uses the HASSTMT REST API method to do the minimum amount of work on the server.
isEmpty
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public long size(org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
size
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void clear(org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException
clear
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void export(org.openrdf.rio.RDFHandler handler, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException, org.openrdf.rio.RDFHandlerException
export
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.rio.RDFHandlerException
public void exportStatements(org.openrdf.model.Resource s, org.openrdf.model.URI p, org.openrdf.model.Value o, boolean includeInferred, org.openrdf.rio.RDFHandler handler, org.openrdf.model.Resource... c) throws org.openrdf.repository.RepositoryException, org.openrdf.rio.RDFHandlerException
exportStatements
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.rio.RDFHandlerException
public org.openrdf.query.Update prepareUpdate(org.openrdf.query.QueryLanguage ql, String query) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareUpdate
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public org.openrdf.query.Update prepareUpdate(org.openrdf.query.QueryLanguage ql, String query, String baseURI) throws org.openrdf.repository.RepositoryException, org.openrdf.query.MalformedQueryException
prepareUpdate
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
org.openrdf.query.MalformedQueryException
public void setNamespace(String arg0, String arg1) throws org.openrdf.repository.RepositoryException
setNamespace
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public String getNamespace(String arg0) throws org.openrdf.repository.RepositoryException
getNamespace
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public org.openrdf.repository.RepositoryResult<org.openrdf.model.Namespace> getNamespaces() throws org.openrdf.repository.RepositoryException
getNamespaces
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void removeNamespace(String arg0) throws org.openrdf.repository.RepositoryException
removeNamespace
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void clearNamespaces() throws org.openrdf.repository.RepositoryException
clearNamespaces
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void setParserConfig(org.openrdf.rio.ParserConfig arg0)
setParserConfig
in interface org.openrdf.repository.RepositoryConnection
public org.openrdf.rio.ParserConfig getParserConfig()
getParserConfig
in interface org.openrdf.repository.RepositoryConnection
public org.openrdf.model.ValueFactory getValueFactory()
getValueFactory
in interface org.openrdf.repository.RepositoryConnection
public boolean isOpen() throws org.openrdf.repository.RepositoryException
isOpen
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
@Deprecated public boolean isAutoCommit() throws org.openrdf.repository.RepositoryException
Note: This is deprecated in openrdf since 2.7.x. The semantics are that a connection without an active transaction is in "auto-commit" mode.
isAutoCommit
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
@Deprecated public void setAutoCommit(boolean autoCommit) throws org.openrdf.repository.RepositoryException
Note: This is deprecated in openrdf since 2.7.x. The semantics are that a connection without an active transaction is in "auto-commit" mode. If there is an open transaction and auto-commit is disabled, the open transaction is committed. This is per the openrdf API.
setAutoCommit
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void close() throws org.openrdf.repository.RepositoryException
close
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public boolean isActive() throws org.openrdf.repository.UnknownTransactionStateException, org.openrdf.repository.RepositoryException
isActive
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.UnknownTransactionStateException
org.openrdf.repository.RepositoryException
public void begin() throws org.openrdf.repository.RepositoryException
begin
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void beginReadOnly() throws org.openrdf.repository.RepositoryException
org.openrdf.repository.RepositoryException
public void beginReadOnly(long timestamp) throws org.openrdf.repository.RepositoryException
Note: Since all read operations have snapshot isolation, this is only
necessary when multiple read operations need to read on the same commit
point.
TODO While the ability to do read-only operations against a specified
timestamp without a transaction exists, it is not exposed by this
interface nor can be accomplished using RemoteRepository
since
that interface also lacks mechanisms (e.g.,
prepareTupleQuery(String:query,long:commitTime)) to express this request.
org.openrdf.repository.RepositoryException
public void commit() throws org.openrdf.repository.RepositoryException
commit
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
public void rollback() throws org.openrdf.repository.RepositoryException
rollback
in interface org.openrdf.repository.RepositoryConnection
org.openrdf.repository.RepositoryException
Copyright © 2006–2019 SYSTAP, LLC DBA Blazegraph. All rights reserved.