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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
<?php
namespace SMW\SPARQLStore\RepositoryConnectors;
use SMW\SPARQLStore\Exception\BadHttpEndpointResponseException;
/**
* Virtuoso specific adjustments for GenericRepositoryConnector
*
* Specific modifications of the SPARQL database implementation for Virtuoso.
* In particular, Virtuoso does not support SPARQL Update but only the non-standard
* SPARUL protocol that requires different syntax for update queries.
* If future versions of Virtuoso support SPARQL Update, the standard SPARQL
* database connector should work properly.
*
* Virtuoso uses the SPARQL query endpoint for updates as well. So both
* - $smwgSparqlEndpoint['update'] and
* - $smwgSparqlEndpoint['query'] should be something like 'http://localhost:8890/sparql/'.
* - $smwgSparqlEndpoint['data'] should be left empty.
*
* A graph is always needed, i.e., $smwgSparqlDefaultGraph must be set to some
* graph name (URI).
*
* Known limitations:
* (might be fixed in recent Virtuoso versions, please let us know)
*
* - Data endpoint not tested: $smwgSparqlEndpoint['data'] should be left empty
* - Numerical datatypes are not supported properly, and Virtuoso
* will miss query results when query conditions require number values.
* This also affects Type:Date properties since the use numerical values for
* querying.
* - Some edit (insert) queries fail for unknown reasons, probably related to
* unusual/complex input data (e.g., using special characters in strings);
* errors will occur when trying to store such values on a page.
* - Virtuoso stumbles over XSD dates with negative years, even if they have
* only four digits as per ISO. Trying to store such data will cause errors.
*
* @ingroup Sparql
*
* @license GNU GPL v2+
* @since 1.7.1
*
* @author Markus Krötzsch
*/
class VirtuosoRepositoryConnector extends GenericRepositoryConnector {
/**
* DELETE wrapper.
* The function declares the standard namespaces wiki, swivt, rdf, owl,
* rdfs, property, xsd, so these do not have to be included in
* $extraNamespaces.
*
* @param $deletePattern string CONSTRUCT pattern of tripples to delete
* @param $where string condition for data to delete
* @param $extraNamespaces array (associative) of namespaceId => namespaceUri
* @return boolean stating whether the operations succeeded
*/
public function delete( $deletePattern, $where, $extraNamespaces = [] ) {
$defaultGraph = $this->repositoryClient->getDefaultGraph();
$sparql = self::getPrefixString( $extraNamespaces ) . "DELETE" .
( ( $defaultGraph !== '' )? " FROM <{$defaultGraph}> " : '' ) .
"{ $deletePattern } WHERE { $where }";
return $this->doUpdate( $sparql );
}
/**
* INSERT DELETE wrapper.
* The function declares the standard namespaces wiki, swivt, rdf, owl,
* rdfs, property, xsd, so these do not have to be included in
* $extraNamespaces.
*
* @param $insertPattern string CONSTRUCT pattern of tripples to insert
* @param $deletePattern string CONSTRUCT pattern of tripples to delete
* @param $where string condition for data to delete
* @param $extraNamespaces array (associative) of namespaceId => namespaceUri
* @return boolean stating whether the operations succeeded
*/
public function insertDelete( $insertPattern, $deletePattern, $where, $extraNamespaces = [] ) {
$defaultGraph = $this->repositoryClient->getDefaultGraph();
$sparql = self::getPrefixString( $extraNamespaces ) . "MODIFY" .
( ( $defaultGraph !== '' )? " GRAPH <{$defaultGraph}> " : '' ) .
"DELETE { $deletePattern } INSERT { $insertPattern } WHERE { $where }";
return $this->doUpdate( $sparql );
}
/**
* INSERT DATA wrapper.
* The function declares the standard namespaces wiki, swivt, rdf, owl,
* rdfs, property, xsd, so these do not have to be included in
* $extraNamespaces.
*
* @param $triples string of triples to insert
* @param $extraNamespaces array (associative) of namespaceId => namespaceUri
* @return boolean stating whether the operations succeeded
*/
public function insertData( $triples, $extraNamespaces = [] ) {
if ( $this->repositoryClient->getDataEndpoint() !== '' ) {
$turtle = self::getPrefixString( $extraNamespaces, false ) . $triples;
return $this->doHttpPost( $turtle );
}
$defaultGraph = $this->repositoryClient->getDefaultGraph();
$sparql = self::getPrefixString( $extraNamespaces, true ) .
"INSERT DATA " .
( ( $defaultGraph !== '' )? "INTO GRAPH <{$defaultGraph}> " : '' ) .
"{ $triples }";
return $this->doUpdate( $sparql );
}
/**
* DELETE DATA wrapper.
* The function declares the standard namespaces wiki, swivt, rdf, owl,
* rdfs, property, xsd, so these do not have to be included in
* $extraNamespaces.
*
* @param $triples string of triples to delete
* @param $extraNamespaces array (associative) of namespaceId => namespaceUri
* @return boolean stating whether the operations succeeded
*/
public function deleteData( $triples, $extraNamespaces = [] ) {
$defaultGraph = $this->repositoryClient->getDefaultGraph();
$sparql = self::getPrefixString( $extraNamespaces ) .
"DELETE DATA " .
( ( $defaultGraph !== '' )? "FROM GRAPH <{$defaultGraph}> " : '' ) .
"{ $triples }";
return $this->doUpdate( $sparql );
}
/**
* Execute a SPARQL update and return a boolean to indicate if the
* operations was successful.
*
* Virtuoso expects SPARQL updates to be posted using the "query"
* parameter (rather than "update").
*
* @param $sparql string with the complete SPARQL update query (INSERT or DELETE)
* @return boolean
*/
public function doUpdate( $sparql ) {
if ( $this->repositoryClient->getUpdateEndpoint() === '' ) {
throw new BadHttpEndpointResponseException( BadHttpEndpointResponseException::ERROR_NOSERVICE, $sparql, 'not specified' );
}
$this->httpRequest->setOption( CURLOPT_URL, $this->repositoryClient->getUpdateEndpoint() );
$this->httpRequest->setOption( CURLOPT_POST, true );
$parameterString = "query=" . urlencode( $sparql );
$this->httpRequest->setOption( CURLOPT_POSTFIELDS, $parameterString );
$this->httpRequest->execute();
if ( $this->httpRequest->getLastErrorCode() == 0 ) {
return true;
}
$this->mapHttpRequestError( $this->repositoryClient->getUpdateEndpoint(), $sparql );
return false;
}
}
|
