(self)
| 76 | |
| 77 | # asserts that master and replica have the same view over the graph |
| 78 | def assert_graph_eq(self): |
| 79 | #validate schema: |
| 80 | # labels |
| 81 | q = "CALL db.labels()" |
| 82 | master_labels = self.master_graph.query(q).result_set |
| 83 | replica_labels = self.replica_graph.query(q, read_only=True).result_set |
| 84 | self.env.assertEquals(master_labels, replica_labels) |
| 85 | |
| 86 | # relationship-types |
| 87 | q = "CALL db.relationshiptypes()" |
| 88 | master_relations = self.master_graph.query(q).result_set |
| 89 | replica_relations = self.replica_graph.query(q, read_only=True).result_set |
| 90 | self.env.assertEquals(master_relations, replica_relations) |
| 91 | |
| 92 | # properties |
| 93 | q = "CALL db.propertyKeys()" |
| 94 | master_props = self.master_graph.query(q).result_set |
| 95 | replica_props = self.replica_graph.query(q, read_only=True).result_set |
| 96 | self.env.assertEquals(master_props, replica_props) |
| 97 | |
| 98 | # validate nodes |
| 99 | q = "MATCH (n) RETURN n ORDER BY(n)" |
| 100 | master_resultset = self.master_graph.query(q).result_set |
| 101 | replica_resultset = self.replica_graph.query(q, read_only=True).result_set |
| 102 | self.env.assertEquals(master_resultset, replica_resultset) |
| 103 | |
| 104 | # validate relationships |
| 105 | q = "MATCH ()-[e]->() RETURN e ORDER BY(e)" |
| 106 | master_resultset = self.master_graph.query(q).result_set |
| 107 | replica_resultset = self.replica_graph.query(q, read_only=True).result_set |
| 108 | self.env.assertEquals(master_resultset, replica_resultset) |
| 109 | |
| 110 | def __init__(self): |
| 111 | self.env = Env(decodeResponses=True, env='oss', useSlaves=True) |
no test coverage detected