mirror of
https://github.com/discourse/discourse.git
synced 2024-11-30 20:34:32 +08:00
5f64fd0a21
Introduce new patterns for direct sql that are safe and fast. MiniSql is not prone to memory bloat that can happen with direct PG usage. It also has an extremely fast materializer and very a convenient API - DB.exec(sql, *params) => runs sql returns row count - DB.query(sql, *params) => runs sql returns usable objects (not a hash) - DB.query_hash(sql, *params) => runs sql returns an array of hashes - DB.query_single(sql, *params) => runs sql and returns a flat one dimensional array - DB.build(sql) => returns a sql builder See more at: https://github.com/discourse/mini_sql
22 lines
533 B
Ruby
22 lines
533 B
Ruby
module Jobs
|
|
class FixPostsRead < Jobs::Onceoff
|
|
def execute_onceoff(args)
|
|
# Skipping to the last post in a topic used to count all posts in the topic
|
|
# as read in user stats. Cap the posts read count to 50 * topics_entered.
|
|
|
|
sql = <<~SQL
|
|
UPDATE user_stats
|
|
SET posts_read_count = topics_entered * 50
|
|
WHERE user_id IN (
|
|
SELECT us2.user_id
|
|
FROM user_stats us2
|
|
WHERE us2.topics_entered > 0
|
|
AND us2.posts_read_count / us2.topics_entered > 50
|
|
)
|
|
SQL
|
|
|
|
DB.exec(sql)
|
|
end
|
|
end
|
|
end
|