Always execute txid_visible_in_snapshot on slave pools

instacart · Nov 2, 2020 · 7961f3b · 7961f3b
1 parent 17b43d0
commit 7961f3b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/active_record/connection_adapters/makara_abstract_adapter.rb b/lib/active_record/connection_adapters/makara_abstract_adapter.rb
@@ -114,7 +114,7 @@ def custom_error_message?(connection, message)
 
 
       SQL_MASTER_MATCHERS           = [/select.+txid_current\(\)\Z/i, /\A\s*select.+for update\Z/i, /select.+lock in share mode\Z/i, /\A\s*select.+(nextval|currval|lastval|get_lock|release_lock|pg_advisory_lock|pg_advisory_unlock)\(/i].map(&:freeze).freeze
-      SQL_SLAVE_MATCHERS            = [/\A\s*(select|with.+\)\s*select)\s/i].map(&:freeze).freeze
+      SQL_SLAVE_MATCHERS            = [/select.+txid_visible_in_snapshot\(/i, /\A\s*(select|with.+\)\s*select)\s/i].map(&:freeze).freeze
       SQL_ALL_MATCHERS              = [/\A\s*set\s/i].map(&:freeze).freeze
       SQL_SKIP_STICKINESS_MATCHERS  = [/select.+txid_current\(\)\Z/i, /select.+txid_visible_in_snapshot\(/i, /\A\s*show\s([\w]+\s)?(field|table|database|schema|view|index)(es|s)?/i, /\A\s*(set|describe|explain|pragma)\s/i].map(&:freeze).freeze