gracefully handle bad connection errors to replica db ref #3212
This commit is contained in:
@@ -1226,6 +1226,8 @@ class Post < ApplicationRecord
|
|||||||
end
|
end
|
||||||
|
|
||||||
count ? count.to_i : nil
|
count ? count.to_i : nil
|
||||||
|
rescue PG::ConnectionBad
|
||||||
|
return nil
|
||||||
end
|
end
|
||||||
|
|
||||||
def fast_count_search_batched(tags, options)
|
def fast_count_search_batched(tags, options)
|
||||||
@@ -1243,6 +1245,9 @@ class Post < ApplicationRecord
|
|||||||
end
|
end
|
||||||
end
|
end
|
||||||
sum
|
sum
|
||||||
|
|
||||||
|
rescue PG::ConnectionBad
|
||||||
|
return nil
|
||||||
end
|
end
|
||||||
|
|
||||||
def fix_post_counts(post)
|
def fix_post_counts(post)
|
||||||
@@ -1673,7 +1678,11 @@ class Post < ApplicationRecord
|
|||||||
end
|
end
|
||||||
|
|
||||||
if read_only
|
if read_only
|
||||||
PostQueryBuilder.new(query).build(PostReadOnly.where("true"))
|
begin
|
||||||
|
PostQueryBuilder.new(query).build(PostReadOnly.where("true"))
|
||||||
|
rescue PG::ConnectionBad
|
||||||
|
PostQueryBuilder.new(query).build
|
||||||
|
end
|
||||||
else
|
else
|
||||||
PostQueryBuilder.new(query).build
|
PostQueryBuilder.new(query).build
|
||||||
end
|
end
|
||||||
|
|||||||
Reference in New Issue
Block a user