public abstract class SparqlQueryBase extends Query
Constructor and Description |
---|
SparqlQueryBase(DataService dataService,
String queryId,
String configId,
String query,
List<QueryParam> queryParams,
Result result,
EventTrigger inputEventTrigger,
EventTrigger outputEventTrigger,
Map<String,String> advancedProperties,
String inputNamespace) |
Modifier and Type | Method and Description |
---|---|
com.hp.hpl.jena.rdf.model.RDFNode |
convertTypeLiteral(com.hp.hpl.jena.rdf.model.Model model,
InternalParam param) |
DataEntry |
getDataEntryFromRS(com.hp.hpl.jena.query.ResultSet rs) |
com.hp.hpl.jena.rdf.model.Model |
getModelForValidation()
Gets the model used to validate input parameters
|
String |
getQuery()
Gets the Query string
|
abstract com.hp.hpl.jena.query.QueryExecution |
getQueryExecution()
Gets a Query Execution for the query
|
abstract void |
processPostQuery(Object result,
XMLStreamWriter xmlWriter,
InternalParamCollection params,
int queryLevel) |
abstract Object |
processPreQuery(InternalParamCollection params,
int queryLevel) |
void |
runPostQuery(Object result,
XMLStreamWriter xmlWriter,
InternalParamCollection params,
int queryLevel)
This method must be implemented by concrete implementations of this class,
to provide the logic to execute the query.
|
Object |
runPreQuery(InternalParamCollection params,
int queryLevel)
This method must be implemented by concrete implementations of this class,
to provide the logic to execute the query.
|
addQueryPreprocessedObject, execute, getAdvancedProperties, getAndRemoveQueryPreprocessObject, getConfigId, getCurrentInternalParams, getDataService, getInputEventTrigger, getInputNamespace, getOutputEventTrigger, getQueryId, getQueryParams, getResult, hasResult, isPreBuildResult, isQueryPreprocessInitial, isQueryPreprocessSecondary, isUsingColumnNumbers, isWriteRow, resetCurrentInternalParams, resetQueryPreprocessing, setCurrentInternalParams, setQueryPreprocessingInitial, setQueryPreprocessingSecondary, writeResultEntry
addAttribute, endElement, getNamespace, setNamespace, startRowElement, startWrapperElement, writeResultElement
public SparqlQueryBase(DataService dataService, String queryId, String configId, String query, List<QueryParam> queryParams, Result result, EventTrigger inputEventTrigger, EventTrigger outputEventTrigger, Map<String,String> advancedProperties, String inputNamespace) throws DataServiceFault
DataServiceFault
public Object runPreQuery(InternalParamCollection params, int queryLevel) throws DataServiceFault
Query
runPreQuery
in class Query
DataServiceFault
public void runPostQuery(Object result, XMLStreamWriter xmlWriter, InternalParamCollection params, int queryLevel) throws DataServiceFault
Query
runPostQuery
in class Query
DataServiceFault
public com.hp.hpl.jena.rdf.model.RDFNode convertTypeLiteral(com.hp.hpl.jena.rdf.model.Model model, InternalParam param) throws DataServiceFault
DataServiceFault
public DataEntry getDataEntryFromRS(com.hp.hpl.jena.query.ResultSet rs)
public abstract Object processPreQuery(InternalParamCollection params, int queryLevel) throws DataServiceFault
DataServiceFault
public abstract void processPostQuery(Object result, XMLStreamWriter xmlWriter, InternalParamCollection params, int queryLevel) throws DataServiceFault
DataServiceFault
public String getQuery()
public abstract com.hp.hpl.jena.query.QueryExecution getQueryExecution() throws IOException, DataServiceFault
DataServiceFault
IOException
public com.hp.hpl.jena.rdf.model.Model getModelForValidation()
Copyright © 2019 WSO2. All rights reserved.