wip

Author: aucampia

rdflib/plugins/sparql/processor.py

@@ -55,9 +55,9 @@ class SPARQLUpdateProcessor(UpdateProcessor):
     def __init__(self, graph):
         self.graph = graph
 
-    def update(self, strOrQuery, initBindings={}, initNs={}):
+    def update(self, strOrQuery, initBindings={}, initNs={}, base=None):
         if isinstance(strOrQuery, str):
-            strOrQuery = translateUpdate(parseUpdate(strOrQuery), initNs=initNs)
+            strOrQuery = translateUpdate(parseUpdate(strOrQuery), base, initNs=initNs)
 
         return evalUpdate(self.graph, strOrQuery, initBindings)
 

rdflib/term.py

@@ -597,12 +597,6 @@ def __new__(
         datatype: Optional[str] = None,
         normalize: Optional[bool] = None,
     ) -> "Literal":
-        # logging.debug(
-        #     "lexical_or_value = %r, datatype = %s, lang = %s",
-        #     lexical_or_value,
-        #     datatype,
-        #     lang,
-        # )
 
         if lang == "":
             lang = None  # no empty lang-tags in RDF
@@ -680,13 +674,6 @@ def __new__(
         inst._value = value
         inst._ill_formed = ill_formed
 
-        # logging.debug(
-        #     "inst = %s, value = %s, ill_formed = %s",
-        #     inst,
-        #     value,
-        #     ill_formed,
-        # )
-
         return inst
 
     def normalize(self) -> "Literal":

test/test_w3c_spec/test_nquads_w3c_new.py

@@ -50,6 +50,9 @@ def check_entry(entry: ManifestEntry) -> None:
         graph_data = dataset.serialize(format="nquads")
         result_dataset = Dataset()
         result_dataset.parse(data=graph_data, publicID=entry.action, format="nquads")
+        GraphHelper.assert_datasets_isomorphic(
+            dataset, result_dataset, exclude_bnodes=True
+        )
         GraphHelper.assert_sets_equals(
             dataset, result_dataset, bnode_handling=BNodeHandling.COLLAPSE
         )

test/test_w3c_spec/test_sparql_w3c.py

@@ -35,6 +35,8 @@
 from rdflib.query import Result
 from rdflib.term import Identifier, Node
 
+logger = logging.getLogger(__name__)
+
 
 def eq(a, b, msg):
     # return eq_(a, b, msg + ": (%r!=%r)" % (a, b))
@@ -228,10 +230,22 @@ def update_test(t: RDFTest):
             for x, l in graphdata:
                 g.parse(x, publicID=URIRef(l), format=_fmt(x))
 
+        if logger.isEnabledFor(logging.DEBUG):
+            logging.debug(
+                "dataset before = \n%s",
+                g.serialize(format="trig"),
+            )
+
         with bopen(query_path) as f:
             req = translateUpdate(parseUpdate(f))
         evalUpdate(g, req)
 
+        if logger.isEnabledFor(logging.DEBUG):
+            logging.debug(
+                "dataset after = \n%s",
+                g.serialize(format="trig"),
+            )
+
         # read expected results
         resg = Dataset()
         if resdata:
@@ -241,6 +255,12 @@ def update_test(t: RDFTest):
             for x, l in resgraphdata:
                 resg.parse(x, publicID=URIRef(l), format=_fmt(x))
 
+        if logger.isEnabledFor(logging.DEBUG):
+            logging.debug(
+                "expected dataset = \n%s",
+                resg.serialize(format="trig"),
+            )
+
         eq(
             set(ctx.identifier for ctx in g.contexts() if ctx != g.default_context),
             set(