fix: solve setlocal mismatch and upsert

SET LOCAL só vale dentro de uma transação explícita, fora dela o Postgres ignora silenciosamente, SET sem LOCAL altera o timeout para toda a conexão (que volta ao pool depois do job, mas connections do Sidekiq são dedicadas, então o efeito é o esperado)

Author: Bulletdev

app/modules/ai_intelligence/jobs/rebuild_champion_matrix_job.rb

@@ -19,7 +19,7 @@ def perform(scope: :all, league: nil)
       # 31k+ records with per-row upserts exceed the default 10s statement_timeout.
       # Scope this to the current session only — the connection returns to the pool
       # with its normal timeout restored after the job finishes.
-      ActiveRecord::Base.connection.execute('SET LOCAL statement_timeout = 0')
+      ActiveRecord::Base.connection.execute('SET statement_timeout = 0')
       rebuild_matrices(scope:, league:)
     ensure
       Sidekiq.redis { |r| r.call('DEL', lock_key) } if acquired

app/modules/ai_intelligence/models/ai_champion_matrix.rb

@@ -8,25 +8,18 @@ class AiChampionMatrix < ApplicationRecord
 
   scope :with_sufficient_sample, -> { where('total_games >= ?', 10) }
 
+  UPSERT_WIN_SQL = <<~SQL.squish.freeze
+    INSERT INTO ai_champion_matrices
+      (champion_a, champion_b, patch, league, wins_a, total_games, updated_at, created_at)
+    VALUES (?, ?, ?, ?, 1, 1, NOW(), NOW())
+    ON CONFLICT (champion_a, champion_b) WHERE patch IS NULL AND league IS NULL
+    DO UPDATE SET wins_a      = ai_champion_matrices.wins_a + 1,
+                  total_games = ai_champion_matrices.total_games + 1,
+                  updated_at  = NOW()
+  SQL
+
   def self.upsert_win(winner, loser, patch: nil, league: nil)
-    # Two separate partial indexes cover the two cases:
-    # - both null  → index_ai_champion_matrices_null_pair
-    # - both present → index_ai_champion_matrices_unique
-    index = if patch.nil? && league.nil?
-              :index_ai_champion_matrices_null_pair
-            else
-              :index_ai_champion_matrices_unique
-            end
-    upsert(
-      { champion_a: winner, champion_b: loser, patch: patch, league: league,
-        wins_a: 1, total_games: 1, updated_at: Time.current },
-      unique_by: index,
-      on_duplicate: Arel.sql(
-        'wins_a = ai_champion_matrices.wins_a + 1, ' \
-        'total_games = ai_champion_matrices.total_games + 1, ' \
-        'updated_at = excluded.updated_at'
-      )
-    )
+    connection.execute(sanitize_sql_array([UPSERT_WIN_SQL, winner, loser, patch, league]))
   end
 
   def win_rate

app/modules/ai_intelligence/services/champion_matrix_builder.rb

@@ -28,6 +28,15 @@ def build
     end
   end
 
+  RECORD_APPEARANCE_SQL = <<~SQL.squish.freeze
+    INSERT INTO ai_champion_matrices
+      (champion_a, champion_b, patch, league, wins_a, total_games, updated_at, created_at)
+    VALUES (?, ?, NULL, NULL, 0, 1, NOW(), NOW())
+    ON CONFLICT (champion_a, champion_b) WHERE patch IS NULL AND league IS NULL
+    DO UPDATE SET total_games = ai_champion_matrices.total_games + 1,
+                  updated_at  = NOW()
+  SQL
+
   private
 
   def register_matchups(winner_picks, loser_picks)
@@ -43,14 +52,7 @@ def register_matchups(winner_picks, loser_picks)
   end
 
   def record_appearance(champion_a, champion_b)
-    AiChampionMatrix.upsert(
-      { champion_a: champion_a, champion_b: champion_b, patch: nil, league: nil,
-        wins_a: 0, total_games: 1, updated_at: Time.current },
-      unique_by: :index_ai_champion_matrices_null_pair,
-      on_duplicate: Arel.sql(
-        'total_games = ai_champion_matrices.total_games + 1, ' \
-        'updated_at = excluded.updated_at'
-      )
-    )
+    sql = AiChampionMatrix.sanitize_sql_array([RECORD_APPEARANCE_SQL, champion_a, champion_b])
+    AiChampionMatrix.connection.execute(sql)
   end
 end