fix: update SQL queries to use QUALIFY instead of LIMIT for row selection

Author: raimannma

glicko-mmr/src/types.rs

@@ -23,8 +23,7 @@ impl Glicko2HistoryEntry {
                 r"
                     SELECT ?fields FROM glicko
                     WHERE match_id < ?
-                    ORDER BY match_id DESC
-                    LIMIT 1 BY account_id
+                    QUALIFY ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY match_id DESC) = 1
                 ",
             )
             .bind(match_id)

mmr-calc/hero_mmr_calc.py

@@ -182,8 +182,7 @@ def get_all_player_mmrs(client, at_match_id: int) -> dict[tuple[int, int], float
     SELECT account_id, hero_id, player_score
     FROM hero_mmr_history FINAL
     WHERE match_id <= {at_match_id}
-    ORDER BY account_id, match_id DESC
-    LIMIT 1 BY account_id;
+    QUALIFY ROW_NUMBER() OVER (PARTITION BY account_id, hero_id ORDER BY match_id DESC) = 1;
     """
     result = client.execute(query)
     return {(row[0], row[1]): row[2] for row in result}

mmr-calc/hero_mmr_calc_optim.py

@@ -182,8 +182,7 @@ def get_all_player_mmrs(client, at_match_id: int) -> dict[tuple[int, int], float
     SELECT account_id, hero_id, player_score
     FROM hero_mmr_history2 FINAL
     WHERE match_id <= {at_match_id}
-    ORDER BY account_id, match_id DESC
-    LIMIT 1 BY account_id;
+    QUALIFY ROW_NUMBER() OVER (PARTITION BY account_id, hero_id ORDER BY match_id DESC) = 1;
     """
     result = client.execute(query)
     return {(row[0], row[1]): row[2] for row in result}

mmr-calc/mmr_calc.py

@@ -182,8 +182,7 @@ def get_all_player_mmrs(client, at_match_id: int) -> dict[int, float]:
     SELECT account_id, player_score
     FROM mmr_history FINAL
     WHERE match_id <= {at_match_id}
-    ORDER BY account_id, match_id DESC
-    LIMIT 1 BY account_id;
+    QUALIFY ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY match_id DESC) = 1;
     """
     result = client.execute(query)
     return {row[0]: row[1] for row in result}

mmr-calc/mmr_calc_optim.py

@@ -182,8 +182,7 @@ def get_all_player_mmrs(client, at_match_id: int) -> dict[int, float]:
     SELECT account_id, player_score
     FROM mmr_history2 FINAL
     WHERE match_id <= {at_match_id}
-    ORDER BY account_id, match_id DESC
-    LIMIT 1 BY account_id;
+    QUALIFY ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY match_id DESC) = 1;
     """
     result = client.execute(query)
     return {row[0]: row[1] for row in result}

rank-fetcher/player_rank_fetcher.py

@@ -38,8 +38,7 @@ def get_accounts(client: Client, empty_cards: set) -> list[int]:
         query = """
         WITH last_cards AS (SELECT *
                             FROM player_card
-                            ORDER BY account_id, created_at DESC
-                            LIMIT 1 BY account_id)
+                            QUALIFY ROW_NUMBER() OVER (PARTITION BY account_id ORDER BY created_at DESC) = 1)
         SELECT account_id
         FROM last_cards
         ORDER BY created_at