kaslo/synapse
1
0
Fork 0
Code Wiki Activity

fixup

Browse Source
This commit is contained in:
Erik Johnston
2018-05-31 19:20:50 +01:00
parent c5da3f697e
commit 397e4c1d3d
1 changed files with 22 additions and 21 deletions
Download Patch File Download Diff File Expand all files Collapse all files
synapse/storage/chunk_ordered_table.py
+22 -21
View File
@@ -327,27 +327,14 @@ class ChunkDBOrderedListStore(OrderedListStore):
def _delete_ordering(self, node_id):
"""Implements OrderedListStore"""
sql = """
UPDATE chunk_linearized SET next_chunk_id = (
SELECT next_chunk_id
FROM chunk_linearized
WHERE chunk_id = ?
)
WHERE next_chunk_id = ?
"""
self.txn.execute(sql, (node_id, node_id,))
sql = """
UPDATE chunk_linearized_first SET chunk_id = (
SELECT next_chunk_id
FROM chunk_linearized
WHERE chunk_id = ?
)
WHERE chunk_id = ?
"""
self.txn.execute(sql, (node_id, node_id,))
next_chunk_id = SQLBaseStore._simple_select_one_onecol_txn(
txn,
table="chunk_linearized",
keyvalues={
"chunk_id": node_id,
},
retcol="next_chunk_id",
)
SQLBaseStore._simple_delete_txn(
self.txn,
@@ -355,6 +342,20 @@ class ChunkDBOrderedListStore(OrderedListStore):
keyvalues={"chunk_id": node_id},
)
sql = """
UPDATE chunk_linearized SET next_chunk_id = ?
WHERE next_chunk_id = ?
"""
self.txn.execute(sql, (next_chunk_id, node_id,))
sql = """
UPDATE chunk_linearized_first SET chunk_id = ?
WHERE chunk_id = ?
"""
self.txn.execute(sql, (next_chunk_id, node_id,))
def _add_edge_to_graph(self, source_id, target_id):
"""Implements OrderedListStore"""