diff options
author | Jim McCusker <jmccusker@5amsolutions.com> | 2015-05-26 19:34:31 -0400 |
---|---|---|
committer | Jim McCusker <jmccusker@5amsolutions.com> | 2015-05-26 19:34:31 -0400 |
commit | d217c3c8f4ae02a212230937f0835083f187afa0 (patch) | |
tree | b4cdab14a83d509e1ffea59608971dbda21cd574 /rdflib/plugins/stores/sparqlstore.py | |
parent | 509d85170c9d5b27e8edecb9636f48b784642ab7 (diff) | |
download | rdflib-d217c3c8f4ae02a212230937f0835083f187afa0.tar.gz |
Now properly autocommitting. Trying this on the road from a tethered iPad didn't work out. :-)
Diffstat (limited to 'rdflib/plugins/stores/sparqlstore.py')
-rw-r--r-- | rdflib/plugins/stores/sparqlstore.py | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/rdflib/plugins/stores/sparqlstore.py b/rdflib/plugins/stores/sparqlstore.py index 2618cfe9..0bea8af5 100644 --- a/rdflib/plugins/stores/sparqlstore.py +++ b/rdflib/plugins/stores/sparqlstore.py @@ -627,6 +627,8 @@ class SPARQLUpdateStore(SPARQLStore): else: q = "INSERT DATA { %s }" % triple self._transaction().append(q) + if self.autocommit: + self.commit() def addN(self, quads): """ Add a list of quads to the store. """ @@ -641,6 +643,8 @@ class SPARQLUpdateStore(SPARQLStore): triples = ["%s %s %s ." % (x[0].n3(), x[1].n3(), x[2].n3()) for x in contexts[context]] data.append("INSERT DATA { GRAPH <%s> { %s } }\n" % (context.identifier, '\n'.join(triples))) self._transaction().extend(data) + if self.autocommit: + self.commit() def remove(self, spo, context): """ Remove a triple from the store """ @@ -663,6 +667,8 @@ class SPARQLUpdateStore(SPARQLStore): else: q = "DELETE { %s } WHERE { %s } " % (triple, triple) self._transaction().append(q) + if self.autocommit: + self.commit() def _do_update(self, update): print update @@ -672,8 +678,6 @@ class SPARQLUpdateStore(SPARQLStore): self.setRequestMethod(URLENCODED if self.postAsEncoded else POSTDIRECTLY) result = SPARQLWrapper.query(self) - if self.autocommit: - self.commit() return result def update(self, query, @@ -738,6 +742,8 @@ class SPARQLUpdateStore(SPARQLStore): query = self.where_pattern.sub("WHERE { " + values, query) self._transaction().append(query) + if self.autocommit: + self.commit() def _insert_named_graph(self, query, query_graph): """ |