Fix old-data deletion query

2021-11-01 16:35:19 +01:00 · 2021-11-01 16:35:19 +01:00 · 9fd1f4d25d
parent cf1de61d4c
commit 9fd1f4d25d
1 changed files with 3 additions and 1 deletions
--- a/connector-lib/src/main.rs
+++ b/connector-lib/src/main.rs
@ -511,7 +511,9 @@ fn init_postgres(
                    let query = query!(" \
                        DELETE FROM account_write \
                        USING ( \
-                            SELECT DISTINCT ON(pubkey) pubkey, slot, write_version FROM account_write \
+                            SELECT DISTINCT ON(pubkey) pubkey, slot, write_version \
+                            FROM account_write \
+                            INNER JOIN slot USING(slot) \
                            WHERE slot <= $newest_final_slot AND status = 'rooted' \
                            ORDER BY pubkey, slot DESC, write_version DESC \
                            ) latest_write \