stage4: AGE graph — DETACH DELETE для идемпотентного sync
This commit is contained in:
1 parent
214c313d53
commit
4a8f06d4ae
1 file changed
+3
-2
@@ -121,11 +121,12 @@ def sync_relations() -> None:
|
|||||||
relations = get_relations()
|
relations = get_relations()
|
||||||
print(f" graph_outbox: {len(relations)} связей → AGE")
|
print(f" graph_outbox: {len(relations)} связей → AGE")
|
||||||
|
|
||||||
# Удалить старые вершины/ёбра для идемпотентности
|
# Удалить старые вершины/рёбра для идемпотентности
|
||||||
|
# AGE: рёбра нужно удалить до вершин → DETACH DELETE
|
||||||
_cypher(
|
_cypher(
|
||||||
"SET search_path TO ag_catalog;"
|
"SET search_path TO ag_catalog;"
|
||||||
f"SELECT * FROM cypher('{GRAPH_NAME}', $$ "
|
f"SELECT * FROM cypher('{GRAPH_NAME}', $$ "
|
||||||
f"MATCH (v) DELETE v $$) AS (v agtype);"
|
f"MATCH (v) DETACH DELETE v $$) AS (v agtype);"
|
||||||
)
|
)
|
||||||
|
|
||||||
# Вершины: уникальный set atom_id (создаём напрямую)
|
# Вершины: уникальный set atom_id (создаём напрямую)
|
||||||
|
|||||||
Reference in new issue
Block a user