Active Record并发创建时读取查询结果异常问题及解决咨询

你遇到的是典型的并发读-写不一致问题：两个请求同时读取历史数据，第一个请求创建的新记录还没被第二个请求的读操作感知到，导致逻辑判断错误。以下是几种可行的解决方式：

1. 事务+隔离级别控制 #

将查询历史记录与创建新事件的逻辑包裹在同一个事务中，并使用更高的事务隔离级别，确保事务内的读操作能看到所有已提交的最新数据，或者强制事务串行执行。

Ruby（ActiveRecord）示例：

def create(event)
  Event.transaction(isolation: :repeatable_read) do
    events = fetch_last_n_events_of_rating_x
    event.rating = 'Y' if events.present?
    event.save!
  end
end

• 不同数据库的隔离级别支持有差异：MySQL默认的REPEATABLE READ就能保证事务内读一致性；PostgreSQL的REPEATABLE READ同样适用，若要彻底避免并发冲突，可改用SERIALIZABLE级别，但会牺牲部分并发性能，根据业务场景权衡。

2. 把判断逻辑嵌入SQL，实现原子化操作 #

将“查询历史记录+设置rating+插入新记录”合并为一个数据库层面的原子操作，彻底避免应用层拆分逻辑带来的并发问题。

示例1：用ActiveRecord的exists?实时判断

def create(event_params)
  has_recent_x_rating = Event.where(rating: 'X').limit(N).exists?
  Event.create!(
    rating: has_recent_x_rating ? 'Y' : event_params[:rating],
    # 填充其他字段
    title: event_params[:title],
    content: event_params[:content]
  )
end

示例2：直接用原生SQL完成插入（更严谨，避免中间状态）

def create(event_params)
  Event.connection.execute(<<~SQL)
    INSERT INTO events (rating, title, content, created_at, updated_at)
    SELECT 
      CASE WHEN EXISTS (SELECT 1 FROM events WHERE rating = 'X' LIMIT #{N}) 
           THEN 'Y' 
           ELSE '#{event_params[:rating]}' 
      END,
      '#{event_params[:title]}',
      '#{event_params[:content]}',
      NOW(),
      NOW()
  SQL
end

• 注意：原生SQL要做好参数转义，避免SQL注入，或者用ActiveRecord的参数绑定方式。

3. 数据库锁机制（慎用，影响并发） #

如果业务对性能要求不高，可以在查询历史记录时加排他锁，阻止其他并发请求同时执行相同的查询和插入操作。

示例：

def create(event)
  Event.transaction do
    # 查询时加锁，确保其他事务无法插入/修改符合条件的记录
    events = Event.where(rating: 'X').limit(N).lock(true)
    event.rating = 'Y' if events.present?
    event.save!
  end
end

• 这种方式会降低系统并发能力，仅适合低并发场景。

方案选型建议 #

• 低并发场景：优先用事务+隔离级别，实现简单，侵入性小。
• 高并发场景：推荐SQL原子化操作，性能最优，原子性最强。
• 尽量避免使用数据库锁，除非业务逻辑必须。

内容的提问来源于stack exchange，提问作者Yesha