public class RDF4JProtocolSession extends SPARQLProtocolSession
SPARQLProtocolSession
subclass which extends the standard SPARQL 1.1 Protocol with additional
functionality, as documented in the RDF4J REST API.DEFAULT_MAXIMUM_URL_LENGTH, MAXIMUM_URL_LENGTH, MAXIMUM_URL_LENGTH_PARAM, UTF8
Constructor and Description |
---|
RDF4JProtocolSession(org.apache.http.client.HttpClient client,
ScheduledExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
void |
addData(InputStream contents,
String baseURI,
RDFFormat dataFormat,
Resource... contexts) |
void |
beginTransaction(IsolationLevel isolationLevel) |
void |
beginTransaction(TransactionSetting... transactionSettings) |
protected void |
checkRepositoryURL() |
protected void |
checkServerURL() |
void |
clearNamespaces() |
void |
close() |
void |
commitTransaction() |
void |
createRepository(RepositoryConfig config)
Create a new repository.
|
void |
deleteRepository(String repositoryID) |
TupleQueryResult |
getContextIDs() |
void |
getContextIDs(TupleQueryResultHandler handler) |
String |
getNamespace(String prefix) |
TupleQueryResult |
getNamespaces() |
void |
getNamespaces(TupleQueryResultHandler handler) |
protected org.apache.http.client.methods.HttpUriRequest |
getQueryMethod(QueryLanguage ql,
String query,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxQueryTime,
Binding... bindings) |
protected List<org.apache.http.NameValuePair> |
getQueryMethodParameters(QueryLanguage ql,
String query,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxQueryTime,
Binding... bindings) |
void |
getRepositoryConfig(StatementCollector statementCollector)
Retrieve configuration of the current repository and send it to the supplied
StatementCollector |
TupleQueryResult |
getRepositoryList() |
void |
getRepositoryList(TupleQueryResultHandler handler) |
String |
getRepositoryURL() |
String |
getServerProtocol() |
String |
getServerURL() |
void |
getStatements(Resource subj,
IRI pred,
Value obj,
boolean includeInferred,
RDFHandler handler,
Resource... contexts) |
protected org.apache.http.client.methods.HttpUriRequest |
getUpdateMethod(QueryLanguage ql,
String update,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxExecutionTime,
Binding... bindings) |
protected List<org.apache.http.NameValuePair> |
getUpdateMethodParameters(QueryLanguage ql,
String update,
String baseURI,
Dataset dataset,
boolean includeInferred,
int maxQueryTime,
Binding... bindings) |
String |
getUpdateURL() |
void |
prepareTransaction() |
void |
removeData(InputStream contents,
String baseURI,
RDFFormat dataFormat,
Resource... contexts) |
void |
removeNamespacePrefix(String prefix) |
void |
rollbackTransaction() |
void |
sendTransaction(Iterable<? extends TransactionOperation> txn)
Deprecated.
since 2.8.0
|
void |
setNamespacePrefix(String prefix,
String name) |
void |
setRepository(String repositoryURL) |
void |
setServerURL(String serverURL) |
void |
setUsernameAndPassword(String username,
String password)
Set the username and password for authentication with the remote server.
|
long |
size(Resource... contexts) |
void |
updateRepository(RepositoryConfig config)
Update the config of an existing repository.
|
protected void |
upload(org.apache.http.HttpEntity reqEntity,
String baseURI,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts) |
protected void |
upload(InputStream contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts) |
void |
upload(InputStream contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Resource... contexts) |
protected void |
upload(Reader contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Protocol.Action action,
Resource... contexts) |
void |
upload(Reader contents,
String baseURI,
RDFFormat dataFormat,
boolean overwrite,
boolean preserveNodeIds,
Resource... contexts) |
execute, executeNoContent, executeOK, getAdditionalHttpHeaders, getBackgroundTupleQueryResult, getBoolean, getConnectionTimeout, getErrorInfo, getHttpClient, getHttpContext, getParserConfig, getPreferredBooleanQueryResultFormat, getPreferredRDFFormat, getPreferredTupleQueryResultFormat, getQueryURL, getRDF, getRDFBackground, getResponseMIMEType, getTupleQueryResult, getUpdateMethod, getUpdateMethodParameters, getValueFactory, sendBooleanQuery, sendBooleanQuery, sendGraphQuery, sendGraphQuery, sendGraphQuery, sendGraphQuery, sendTupleQuery, sendTupleQuery, sendTupleQuery, sendUpdate, sendUpdate, setAdditionalHttpHeaders, setConnectionTimeout, setHttpClient, setParserConfig, setPreferredBooleanQueryResultFormat, setPreferredRDFFormat, setPreferredTupleQueryResultFormat, setQueryURL, setUpdateURL, setUsernameAndPasswordForUrl, setValueFactory, shouldUsePost
public RDF4JProtocolSession(org.apache.http.client.HttpClient client, ScheduledExecutorService executor)
public void setServerURL(String serverURL)
public String getServerURL()
public String getRepositoryURL()
public void setRepository(String repositoryURL)
protected void checkRepositoryURL()
protected void checkServerURL()
public String getUpdateURL()
getUpdateURL
in class SPARQLProtocolSession
public void close()
close
in interface AutoCloseable
close
in class SPARQLProtocolSession
public TupleQueryResult getRepositoryList() throws IOException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getRepositoryList(TupleQueryResultHandler handler) throws IOException, TupleQueryResultHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public String getServerProtocol() throws IOException, RepositoryException, UnauthorizedException
public long size(Resource... contexts) throws IOException, RepositoryException, UnauthorizedException
public void createRepository(RepositoryConfig config) throws IOException, RepositoryException
config
- the repository configurationIOException
RepositoryException
public void updateRepository(RepositoryConfig config) throws IOException, RepositoryException
config
- the repository configurationIOException
RepositoryException
public void deleteRepository(String repositoryID) throws IOException, RepositoryException
IOException
RepositoryException
public void getRepositoryConfig(StatementCollector statementCollector) throws UnauthorizedException, QueryInterruptedException, RDFHandlerException, RepositoryException, IOException
StatementCollector
statementCollector
- receiver of the repository config informationIOException
RepositoryException
RDFHandlerException
QueryInterruptedException
UnauthorizedException
public TupleQueryResult getNamespaces() throws IOException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getNamespaces(TupleQueryResultHandler handler) throws IOException, TupleQueryResultHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public String getNamespace(String prefix) throws IOException, RepositoryException, UnauthorizedException
public void setNamespacePrefix(String prefix, String name) throws IOException, RepositoryException, UnauthorizedException
public void removeNamespacePrefix(String prefix) throws IOException, RepositoryException, UnauthorizedException
public void clearNamespaces() throws IOException, RepositoryException, UnauthorizedException
public TupleQueryResult getContextIDs() throws IOException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getContextIDs(TupleQueryResultHandler handler) throws IOException, TupleQueryResultHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void getStatements(Resource subj, IRI pred, Value obj, boolean includeInferred, RDFHandler handler, Resource... contexts) throws IOException, RDFHandlerException, RepositoryException, UnauthorizedException, QueryInterruptedException
public void beginTransaction(IsolationLevel isolationLevel) throws RDF4JException, IOException, UnauthorizedException
public void beginTransaction(TransactionSetting... transactionSettings) throws RDF4JException, IOException, UnauthorizedException
public void prepareTransaction() throws RDF4JException, IOException, UnauthorizedException
public void commitTransaction() throws RDF4JException, IOException, UnauthorizedException
public void rollbackTransaction() throws RDF4JException, IOException, UnauthorizedException
@Deprecated public void sendTransaction(Iterable<? extends TransactionOperation> txn) throws IOException, RepositoryException, UnauthorizedException
txn
- IOException
RepositoryException
UnauthorizedException
public void addData(InputStream contents, String baseURI, RDFFormat dataFormat, Resource... contexts) throws UnauthorizedException, RDFParseException, RepositoryException, IOException
public void removeData(InputStream contents, String baseURI, RDFFormat dataFormat, Resource... contexts) throws UnauthorizedException, RDFParseException, RepositoryException, IOException
public void upload(InputStream contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
protected void upload(InputStream contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Protocol.Action action, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
public void upload(Reader contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Resource... contexts) throws UnauthorizedException, RDFParseException, RepositoryException, IOException
protected org.apache.http.client.methods.HttpUriRequest getQueryMethod(QueryLanguage ql, String query, String baseURI, Dataset dataset, boolean includeInferred, int maxQueryTime, Binding... bindings)
getQueryMethod
in class SPARQLProtocolSession
protected org.apache.http.client.methods.HttpUriRequest getUpdateMethod(QueryLanguage ql, String update, String baseURI, Dataset dataset, boolean includeInferred, int maxExecutionTime, Binding... bindings)
getUpdateMethod
in class SPARQLProtocolSession
protected void upload(Reader contents, String baseURI, RDFFormat dataFormat, boolean overwrite, boolean preserveNodeIds, Protocol.Action action, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
protected void upload(org.apache.http.HttpEntity reqEntity, String baseURI, boolean overwrite, boolean preserveNodeIds, Protocol.Action action, Resource... contexts) throws IOException, RDFParseException, RepositoryException, UnauthorizedException
public void setUsernameAndPassword(String username, String password)
SPARQLProtocolSession
setUsernameAndPassword
in class SPARQLProtocolSession
username
- the usernamepassword
- the passwordprotected List<org.apache.http.NameValuePair> getQueryMethodParameters(QueryLanguage ql, String query, String baseURI, Dataset dataset, boolean includeInferred, int maxQueryTime, Binding... bindings)
getQueryMethodParameters
in class SPARQLProtocolSession
protected List<org.apache.http.NameValuePair> getUpdateMethodParameters(QueryLanguage ql, String update, String baseURI, Dataset dataset, boolean includeInferred, int maxQueryTime, Binding... bindings)
getUpdateMethodParameters
in class SPARQLProtocolSession
Copyright © 2015-2020 Eclipse Foundation. All Rights Reserved.