Fixed Issue #552 - Parameterized Query Support in NDB (#553)

Fixed Issue #552 by adding proper passing of the parameters through into
the query call when using Neptune database

Co-authored-by: Dave Bechberger <[email protected]>

Author: bechbd

libs/aws/langchain_aws/graphs/neptune_graph.py

@@ -458,9 +458,14 @@ def __init__(
     def query(self, query: str, params: dict = {}) -> Dict[str, Any]:
         """Query Neptune database."""
         try:
-            return self.client.execute_open_cypher_query(openCypherQuery=query)[
-                "results"
-            ]
+            if params:
+                return self.client.execute_open_cypher_query(openCypherQuery=query, parameters = json.dumps(params))[
+                    "results"
+                ]
+            else:
+                return self.client.execute_open_cypher_query(openCypherQuery=query)[
+                    "results"
+                ]
         except Exception as e:
             raise NeptuneQueryException(
                 {