added parameters support

redisgraph/graph.py

@@ -103,12 +103,24 @@ def flush(self):
         self.nodes = {}
         self.edges = []
 
-    def query(self, q):
+    def query(self, q, params=None):
         """
         Executes a query against the graph.
         """
+        if params is not None:
+            assert type(params) == dict
+            params_header = "CYPHER "
+            for key, value in params.items():
+                if type(value) == str:
+                    value = quote_string(value)
+                if value is None:
+                    value = "null"
+                params_header += str(key) + "=" + str(value) + " "
+            q = params_header + q
+
         statistics = None
         result_set = None
+
         response = self.redis_con.execute_command("GRAPH.QUERY", self.name, q, "--compact")
         return QueryResult(self, response)
 

test.py

@@ -94,6 +94,19 @@ def test_path(self):
         # All done, remove graph.
         redis_graph.delete()
 
+    def test_param(self):
+        redis_graph = Graph('params', self.r)
+
+        params = [1, 2.3, "str", True, False, None, [0, 1, 2]]
+
+        for param in params:
+            query = "RETURN $param"
+            result = redis_graph.query(query, {'param': param})
+            expected_results = [[param]]
+            self.assertEqual(expected_results, result.result_set)
+
+        # All done, remove graph.
+        redis_graph.delete()
 
 if __name__ == '__main__':
 	unittest.main()