diff options
| author | LV-426 <lv-426@taproot.org.il> | 2015-01-18 22:20:46 +0200 |
|---|---|---|
| committer | LV-426 <lv-426@taproot.org.il> | 2015-01-18 22:20:46 +0200 |
| commit | 3482a90a7b8f0443711991fb5aa866085f586678 (patch) | |
| tree | 8f2403212b1ba390057bd85cb14217acf5066cd9 /src/server-tests/neo4j_test_util.py | |
| parent | 989e09da7abd703a9209da130a92b6fbbb6e381e (diff) | |
flush_db: dedicated DBO class, cleanup
Diffstat (limited to 'src/server-tests/neo4j_test_util.py')
| -rw-r--r-- | src/server-tests/neo4j_test_util.py | 27 |
1 files changed, 11 insertions, 16 deletions
diff --git a/src/server-tests/neo4j_test_util.py b/src/server-tests/neo4j_test_util.py index 8f63a1a5..7755032d 100644 --- a/src/server-tests/neo4j_test_util.py +++ b/src/server-tests/neo4j_test_util.py @@ -3,8 +3,18 @@ import random import string import uuid -from db_op import DB_op +from db_op import DB_op, DBO_cypher_query +class DBO_flush_db(DBO_cypher_query): + """ + complete DB flush: remove all nodes & links + """ + def __init__(self): + q_arr = ['match (n)', + 'optional match (n)-[r]-()', + 'delete n,r' + ] + super(DBO_flush_db, self).__init__(q_arr) class DBO_random_data_generation(DB_op): @@ -56,18 +66,3 @@ def rand_label(prefix='T_', length=8): ret = ''.join([choice(string.ascii_lowercase)] + [choice(char_set) for _ in range(length - 1)]) ret = prefix + ret return ret - -def flush_db(db_ctl): - """ - complete DB flush: remove all nodes & links - """ - db_ctl.exec_cypher_query('match (n) optional match (n)-[r]-() delete n,r') - - - - q = ' '.join(q_arr) - op = DBO_cypher_query(q) - db_ctl.exec_op(op) - - return (n_label, r_label) - |
