blob: 1ffdc94b93c86ce35a43e98150b028a87dd8a7b5 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
<?php
namespace SMW\SPARQLStore\RepositoryConnectors;
use SMW\SPARQLStore\Exception\BadHttpEndpointResponseException;
use SMW\SPARQLStore\QueryEngine\RepositoryResult;
use SMW\SPARQLStore\QueryEngine\XmlResponseParser;
/**
* @see https://jena.apache.org/documentation/serving_data/index.html
*
* @license GNU GPL v2+
* @since 2.0
*
* @author mwjames
*/
class FusekiRepositoryConnector extends GenericRepositoryConnector {
/**
* @see GenericRepositoryConnector::doQuery
*/
public function doQuery( $sparql ) {
if ( $this->repositoryClient->getQueryEndpoint() === '' ) {
throw new BadHttpEndpointResponseException( BadHttpEndpointResponseException::ERROR_NOSERVICE, $sparql, 'not specified' );
}
$this->httpRequest->setOption( CURLOPT_URL, $this->repositoryClient->getQueryEndpoint() );
$this->httpRequest->setOption( CURLOPT_HTTPHEADER, [
'Accept: application/sparql-results+xml,application/xml;q=0.8',
'Content-Type: application/x-www-form-urlencoded;charset=UTF-8'
] );
$this->httpRequest->setOption( CURLOPT_POST, true );
$defaultGraph = $this->repositoryClient->getDefaultGraph();
$parameterString = "query=" . urlencode( $sparql ) .
( ( $defaultGraph !== '' )? '&default-graph-uri=' . urlencode( $defaultGraph ) : '' ) . '&output=xml';
$this->httpRequest->setOption( CURLOPT_POSTFIELDS, $parameterString );
$httpResponse = $this->httpRequest->execute();
if ( $this->httpRequest->getLastErrorCode() == 0 ) {
$xmlResponseParser = new XmlResponseParser();
return $xmlResponseParser->parse( $httpResponse );
}
$this->mapHttpRequestError( $this->repositoryClient->getQueryEndpoint(), $sparql );
$repositoryResult = new RepositoryResult();
$repositoryResult->setErrorCode( RepositoryResult::ERROR_UNREACHABLE );
return $repositoryResult;
}
}
|
