org.aksw.facete2.web.api

Class ServletExportSparql

java.lang.Object

org.aksw.facete2.web.api.ServletExportSparql

@Service
@Path(value="/export/")
public class ServletExportSparql
extends Object

Constructor Summary

Constructors

Constructor and Description
ServletExportSparql()

Method Summary

Methods

Modifier and Type	Method and Description
String	cancelExport(String id) Aborts an export
static long	countQuery(com.hp.hpl.jena.query.Query query, org.aksw.jena_sparql_api.core.QueryExecutionFactory qef)
Long	getExportJobExecutionId(String id)
static Map<String,Object>	makeSimple(Map<org.aksw.sparqlify.algebra.sql.exprs2.S_ColumnRef,org.aksw.sparqlify.core.cast.SqlValue> map)
static void	resultSetToCsv(com.google.common.base.Supplier<InputStream> xmlSparqlResultSetStreamSupplier, Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap, OutputStream out)
javax.ws.rs.core.Response	retrieveExport(String id, String format, String varMapStr)
javax.ws.rs.core.Response	retrieveExportCore(String id, String format, Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap)
javax.ws.rs.core.Response	retrieveExportCsv(String id, Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap)
javax.ws.rs.core.Response	retrieveExportXml(String id, Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap) Return a data stream if the resource exist.
String	startExportCore(String serviceUri, List<String> defaultGraphUris, String queryString, String id)
String	startExportGet(String serviceUri, List<String> defaultGraphUris, String queryString, String id) Starts an export of the given query
String	startExportPost(String serviceUri, List<String> defaultGraphUris, String queryString, String id)
static String	toCsvString(com.hp.hpl.jena.graph.Node node)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServletExportSparql

public ServletExportSparql()

Method Detail

countQuery

public static long countQuery(com.hp.hpl.jena.query.Query query,
              org.aksw.jena_sparql_api.core.QueryExecutionFactory qef)

startExportGet

@GET
@Produces(value="application/json")
@Path(value="start")
public String startExportGet(@QueryParam(value="service-uri")
                                      String serviceUri,
                                      @QueryParam(value="default-graph-uri")
                                      List<String> defaultGraphUris,
                                      @QueryParam(value="query")
                                      String queryString,
                                      @QueryParam(value="id")
                                      String id)
                      throws Exception

Starts an export of the given query

Parameters:

queryString -

id -

varMapStr - A json object that maps variable names to alternative strings, such as for use in headings

Throws:

Exception

startExportPost

@POST
@Produces(value="application/json")
@Path(value="start")
public String startExportPost(@FormParam(value="service-uri")
                                        String serviceUri,
                                        @FormParam(value="default-graph-uri")
                                        List<String> defaultGraphUris,
                                        @FormParam(value="query")
                                        String queryString,
                                        @FormParam(value="id")
                                        String id)
                       throws Exception

Throws:

Exception

startExportCore

public String startExportCore(@NotNull
                     String serviceUri,
                     List<String> defaultGraphUris,
                     String queryString,
                     String id)
                       throws Exception

Throws:

Exception

cancelExport

@Path(value="/cancel")
@GET
public String cancelExport(@QueryParam(value="id")
                           String id)

Aborts an export

Parameters:

id -

getExportJobExecutionId

public Long getExportJobExecutionId(String id)

retrieveExportCsv

public javax.ws.rs.core.Response retrieveExportCsv(String id,
                                          Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap)

retrieveExport

@Path(value="/retrieve")
@GET
@Produces(value="application/octet-stream")
public javax.ws.rs.core.Response retrieveExport(@QueryParam(value="id")
                                                         String id,
                                                         @QueryParam(value="format")
                                                         String format,
                                                         @QueryParam(value="rename")
                                                         String varMapStr)
                                         throws FileNotFoundException

Throws:

FileNotFoundException

retrieveExportCore

public javax.ws.rs.core.Response retrieveExportCore(String id,
                                           String format,
                                           Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap)
                                             throws FileNotFoundException

Throws:

FileNotFoundException

retrieveExportXml

public javax.ws.rs.core.Response retrieveExportXml(String id,
                                          Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap)
                                            throws FileNotFoundException

Return a data stream if the resource exist. Otherwise, returns the following errors - 'resource is being created' if the export is still in progress - 'resource does not exists' regardless of the reason. Use status to request resource state.

Parameters:

id -

Throws:

FileNotFoundException

resultSetToCsv

public static void resultSetToCsv(com.google.common.base.Supplier<InputStream> xmlSparqlResultSetStreamSupplier,
                  Map<com.hp.hpl.jena.sparql.core.Var,com.hp.hpl.jena.sparql.core.Var> varMap,
                  OutputStream out)

toCsvString

public static String toCsvString(com.hp.hpl.jena.graph.Node node)

makeSimple

public static Map<String,Object> makeSimple(Map<org.aksw.sparqlify.algebra.sql.exprs2.S_ColumnRef,org.aksw.sparqlify.core.cast.SqlValue> map)