Feature prepareupdate

rdflib/plugins/sparql/__init__.py

@@ -35,7 +35,7 @@
 from . import operators
 from . import parserutils
 
-from .processor import prepareQuery, processUpdate
+from .processor import prepareQuery, prepareUpdate, processUpdate
 
 assert parser
 assert operators

rdflib/plugins/sparql/algebra.py

@@ -13,7 +13,7 @@
 
 from rdflib import Literal, Variable, URIRef, BNode
 
-from rdflib.plugins.sparql.sparql import Prologue, Query
+from rdflib.plugins.sparql.sparql import Prologue, Query, Update
 from rdflib.plugins.sparql.parserutils import CompValue, Expr
 from rdflib.plugins.sparql.operators import (
     and_,
@@ -761,7 +761,7 @@ def translateUpdate(q, base=None, initNs=None):
 
         res.append(translateUpdate1(u, prologue))
 
-    return res
+    return Update(prologue, res)
 
 
 def translateQuery(q, base=None, initNs=None):

rdflib/plugins/sparql/processor.py

@@ -26,6 +26,15 @@ def prepareQuery(queryString, initNs={}, base=None) -> Query:
     return ret
 
 
+def prepareUpdate(updateString, initNs={}, base=None):
+    """
+    Parse and translate a SPARQL Update
+    """
+    ret = translateUpdate(parseUpdate(updateString), base, initNs)
+    ret._original_args = (updateString, initNs, base)
+    return ret
+
+
 def processUpdate(graph, updateString, initBindings={}, initNs={}, base=None):
     """
     Process a SPARQL Update Request

rdflib/plugins/sparql/sparql.py

@@ -408,3 +408,13 @@ class Query:
     def __init__(self, prologue, algebra):
         self.prologue = prologue
         self.algebra = algebra
+
+
+class Update:
+    """
+    A parsed and translated update
+    """
+
+    def __init__(self, prologue, algebra):
+        self.prologue = prologue
+        self.algebra = algebra

rdflib/plugins/sparql/update.py

@@ -273,7 +273,7 @@ def evalUpdate(graph, update, initBindings={}):
 
     """
 
-    for u in update:
+    for u in update.algebra:
 
         initBindings = dict((Variable(k), v) for k, v in initBindings.items())
 

test/test_sparql_prepare.py

@@ -0,0 +1,43 @@
+import os
+from rdflib.plugins.sparql import prepareUpdate, prepareQuery
+from rdflib.namespace import FOAF
+from rdflib import (
+    Graph,
+    URIRef,
+)
+
+
+def test_prepare_update():
+
+    q = prepareUpdate(
+        """\
+PREFIX dc: <http://purl.org/dc/elements/1.1/>
+INSERT DATA
+{ <http://example/book3> dc:title "A new book" ;
+                         dc:creator "A.N.Other" .
+ } ;
+""",
+        initNs={},
+    )
+
+    g = Graph()
+    g.update(q, initBindings={})
+    assert len(g) == 2
+
+
+def test_prepare_query():
+
+    q = prepareQuery(
+        "SELECT ?name WHERE { ?person foaf:knows/foaf:name ?name . }",
+        initNs={"foaf": FOAF},
+    )
+
+    g = Graph()
+    g.parse(
+        location=os.path.join(os.path.dirname(__file__), "..", "examples", "foaf.n3"),
+        format="n3",
+    )
+
+    tim = URIRef("http://www.w3.org/People/Berners-Lee/card#i")
+
+    assert len(list(g.query(q, initBindings={"person": tim}))) == 50