diff --git a/redisgraph/graph.py b/redisgraph/graph.py index 1ab6d37..1b521b2 100644 --- a/redisgraph/graph.py +++ b/redisgraph/graph.py @@ -179,7 +179,7 @@ def query(self, q, params=None, timeout=None, read_only=False): self.version = e.version self._refresh_schema() # re-issue query - return self.query(q, params, timeout) + return self.query(q, params, timeout, read_only) def _execution_plan_to_string(self, plan): return "\n".join(plan) @@ -214,7 +214,7 @@ def merge(self, pattern): return self.query(query) # Procedures. - def call_procedure(self, procedure, *args, **kwagrs): + def call_procedure(self, procedure, read_only=False, *args, **kwagrs): args = [quote_string(arg) for arg in args] q = 'CALL %s(%s)' % (procedure, ','.join(args)) @@ -222,13 +222,13 @@ def call_procedure(self, procedure, *args, **kwagrs): if y: q += ' YIELD %s' % ','.join(y) - return self.query(q) + return self.query(q, read_only=read_only) def labels(self): - return self.call_procedure("db.labels").result_set + return self.call_procedure("db.labels", read_only=True).result_set def relationshipTypes(self): - return self.call_procedure("db.relationshipTypes").result_set + return self.call_procedure("db.relationshipTypes", read_only=True).result_set def propertyKeys(self): - return self.call_procedure("db.propertyKeys").result_set + return self.call_procedure("db.propertyKeys", read_only=True).result_set