added hook for stores to provide their own query processor. A bit hackish, but does not break anything. (Fixes issue 121)3.1.0

1 files changed, 10 insertions, 3 deletions

diff --git a/rdflib/graph.py b/rdflib/graph.py
index d4399d44..d90f4de9 100644
--- a/rdflib/graph.py
+++ b/rdflib/graph.py
@@ -783,13 +783,20 @@ class Graph(Node):
     def load(self, source, publicID=None, format="xml"):
         self.parse(source, publicID, format)
 
-    def query(self, query_object, processor='sparql', result='sparql', initNs={}, initBindings={}, **kwargs):
+    def query(self, query_object, processor='sparql', result='sparql', initNs={}, initBindings={}, use_store_provided=True, **kwargs):
         """
         """
-        if not isinstance(processor, query.Processor):
-            processor = plugin.get(processor, query.Processor)(self)
+
+        
+
+        if hasattr(self.store, "query") and use_store_provided:
+            return self.store.query(self,query_object, initNs, initBindings, **kwargs)
+
         if not isinstance(result, query.Result):
             result = plugin.get(result, query.Result)
+        if not isinstance(processor, query.Processor):
+            processor = plugin.get(processor, query.Processor)(self)
+
         return result(processor.query(query_object, initBindings, initNs, **kwargs))