Update subqueries building import query based on neo4j version

CHANGELOG.md

@@ -2,6 +2,9 @@
 
 ## Next
 
+### Updated
+- Fixed bugs in the Neo4jVector and GraphCypherQAChain classes preventing these classes from working with versions < 5.23 of Neo4j
+
 ## 0.1.0
 
 ### Added

libs/neo4j/langchain_neo4j/vectorstores/neo4j_vector.py

@@ -594,17 +594,29 @@ def __init__(
         if pre_delete_collection:
             from neo4j.exceptions import DatabaseError
 
-            self.query(
-                f"MATCH (n:`{self.node_label}`) "
-                "CALL (n) { DETACH DELETE n } "
-                "IN TRANSACTIONS OF 10000 ROWS;"
-            )
+            delete_query = self._build_delete_query()
+            self.query(delete_query)
             # Delete index
             try:
                 self.query(f"DROP INDEX {self.index_name}")
             except DatabaseError:  # Index didn't exist yet
                 pass
 
+    def _build_delete_query(self) -> str:
+        if self.neo4j_version_is_5_23_or_above:
+            query = (
+                f"MATCH (n:`{self.node_label}`) "
+                "CALL (n) { DETACH DELETE n } "
+                "IN TRANSACTIONS OF 10000 ROWS;"
+            )
+        else:
+            query = (
+                f"MATCH (n:`{self.node_label}`) "
+                "CALL { WITH n DETACH DELETE n } "
+                "IN TRANSACTIONS OF 10000 ROWS;"
+            )
+        return query
+
     def query(
         self,
         query: str,
@@ -903,17 +915,7 @@ def add_embeddings(
         if not metadatas:
             metadatas = [{} for _ in texts]
 
-        import_query = (
-            "UNWIND $data AS row "
-            "CALL (row) { WITH row "
-            f"MERGE (c:`{self.node_label}` {{id: row.id}}) "
-            "WITH c, row "
-            f"CALL db.create.setNodeVectorProperty(c, "
-            f"'{self.embedding_node_property}', row.embedding) "
-            f"SET c.`{self.text_node_property}` = row.text "
-            "SET c += row.metadata "
-            "} IN TRANSACTIONS OF 1000 ROWS "
-        )
+        import_query = self._build_import_query()
 
         parameters = {
             "data": [
@@ -928,6 +930,32 @@ def add_embeddings(
 
         return ids
 
+    def _build_import_query(self) -> str:
+        """
+        Build the Cypher import query string based on the Neo4j version.
+
+        Returns:
+            str: The constructed Cypher query string.
+        """
+        if self.neo4j_version_is_5_23_or_above:
+            call_prefix = "CALL (row) { "
+        else:
+            call_prefix = "CALL { WITH row "
+
+        import_query = (
+            "UNWIND $data AS row "
+            f"{call_prefix}"
+            f"MERGE (c:`{self.node_label}` {{id: row.id}}) "
+            "WITH c, row "
+            f"CALL db.create.setNodeVectorProperty(c, "
+            f"'{self.embedding_node_property}', row.embedding) "
+            f"SET c.`{self.text_node_property}` = row.text "
+            "SET c += row.metadata "
+            "} IN TRANSACTIONS OF 1000 ROWS "
+        )
+
+        return import_query
+
     def add_texts(
         self,
         texts: Iterable[str],