Skip to content

Commit 71b2611

Browse files
committed
Loop over sparql results
1 parent d07b9cd commit 71b2611

File tree

1 file changed

+7
-3
lines changed

1 file changed

+7
-3
lines changed

lib/sparql/sparql.js

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -127,7 +127,11 @@ function query (sparql, graphUri, accept, explorer = false) {
127127
function queryJson (sparql, graphUri, explorer = false) {
128128
// const timer = Timer('sparql query')
129129

130-
return query(sparql, graphUri, 'application/sparql-results+json', explorer).then(parseResult, handleError)
130+
if (sparql.includes('LIMIT')) {
131+
return query(sparql, graphUri, 'application/sparql-results+json', explorer).then(parseResult, handleError)
132+
} else {
133+
return queryJsonStaggered(sparql, graphUri, explorer)
134+
}
131135

132136
function parseResult (res) {
133137
// timer()
@@ -154,7 +158,7 @@ function queryJson (sparql, graphUri, explorer = false) {
154158
}
155159
}
156160

157-
function queryJsonStaggered (sparql, graphUri) {
161+
function queryJsonStaggered (sparql, graphUri, explorer = false) {
158162
var offset = 0
159163
var limit = config.get('staggeredQueryLimit')
160164

@@ -165,7 +169,7 @@ function queryJsonStaggered (sparql, graphUri) {
165169
function performQuery () {
166170
console.log('queryJsonStaggered: offset ' + offset + ', limit ' + limit + ', ' + resultsUnion.length + ' results so far')
167171

168-
return queryJson(sparql + ' OFFSET ' + offset + ' LIMIT ' + limit, graphUri).then((results) => {
172+
return queryJson(sparql + ' OFFSET ' + offset + ' LIMIT ' + limit, graphUri, explorer).then((results) => {
169173
// console.log('qj results')
170174
// console.log(JSON.stringify(results))
171175

0 commit comments

Comments
 (0)