summaryrefslogtreecommitdiff
path: root/src/server/neo4j_util.py
diff options
context:
space:
mode:
authorLV-426 <lv-426@taproot.org.il>2015-01-05 18:40:48 +0200
committerLV-426 <lv-426@taproot.org.il>2015-01-05 18:40:48 +0200
commit870282c1df3bcf0ead8a0f6048aabd941220b30d (patch)
tree9008fe665871628e7060fd1dec2709c717f3811c /src/server/neo4j_util.py
parent89319e8eb9237c6db1840d724c17c8cab76fcd93 (diff)
DB_op#add_statement(): support query addition via query array
Diffstat (limited to 'src/server/neo4j_util.py')
-rw-r--r--src/server/neo4j_util.py6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/server/neo4j_util.py b/src/server/neo4j_util.py
index 5cd920a1..2fb44889 100644
--- a/src/server/neo4j_util.py
+++ b/src/server/neo4j_util.py
@@ -115,6 +115,7 @@ def statement_to_REST_form(query, parameters={}):
turn cypher query to neo4j json API format
"""
assert isinstance(query, six.string_types)
+
if isinstance(parameters, list):
for v in parameters:
assert isinstance(v, dict)
@@ -188,7 +189,6 @@ def gen_query_create_from_node_map(node_map, input_to_DB_property_map=lambda _:
'return n, labels(n)'
]
- q = ' '.join(q_arr)
q_params_set = []
for n_prop_set in n_set:
@@ -196,7 +196,9 @@ def gen_query_create_from_node_map(node_map, input_to_DB_property_map=lambda _:
q_params = input_to_DB_property_map(n_prop_set)
q_params_set.append(q_params)
- ret.append((q, {'node_attr': q_params_set}))
+
+ ret.append((q_arr, {'node_attr': q_params_set}))
+
return ret
def gen_query_create_from_link_map(link_map, input_to_DB_property_map=lambda _: _):