|
|
|
@ -132,19 +132,19 @@ public class RunSPARQLQueryService {
|
|
|
|
|
} catch (InterruptedException e) {
|
|
|
|
|
e.printStackTrace();
|
|
|
|
|
}
|
|
|
|
|
// log.info("Retrieving "+recordId+" - isCollection:"+isCollection );
|
|
|
|
|
log.debug("Retrieving "+recordId+" - isCollection:"+isCollection );
|
|
|
|
|
String query = selectQueryTemplate.replaceAll("%record", "<"+recordId+">");
|
|
|
|
|
openConnection();
|
|
|
|
|
StringWriter recordWriter = null;
|
|
|
|
|
Model resultsModel = null;
|
|
|
|
|
try {
|
|
|
|
|
// log.debug("Started at: "+Calendar.getInstance().getTime().toString());
|
|
|
|
|
log.debug("Started at: "+Calendar.getInstance().getTime().toString());
|
|
|
|
|
GraphQuery graphQuery = connection.prepareGraphQuery(QueryLanguage.SPARQL, query);
|
|
|
|
|
GraphQueryResult graphQueryResult = graphQuery.evaluate();
|
|
|
|
|
resultsModel = QueryResults.asModel(graphQueryResult);
|
|
|
|
|
graphQueryResult.close();
|
|
|
|
|
// log.debug("Finished at: "+Calendar.getInstance().getTime().toString());
|
|
|
|
|
// log.info("Statements retrieved: " + resultsModel.size());
|
|
|
|
|
log.debug("Finished at: "+Calendar.getInstance().getTime().toString());
|
|
|
|
|
log.debug("Statements retrieved: " + resultsModel.size());
|
|
|
|
|
if (resultsModel.size()==0) {
|
|
|
|
|
return -2;
|
|
|
|
|
}
|
|
|
|
@ -154,7 +154,7 @@ public class RunSPARQLQueryService {
|
|
|
|
|
parser.setCollection(isCollection);
|
|
|
|
|
String bufferedRecord = recordWriter.toString();
|
|
|
|
|
int size = parser.parse(bufferedRecord);
|
|
|
|
|
// log.debug("json elements: "+size);
|
|
|
|
|
log.debug("json elements: "+size);
|
|
|
|
|
if (size==-1) {
|
|
|
|
|
return -4;
|
|
|
|
|
}
|
|
|
|
|