一意のIDのないデータベースのActiveRecord

コードをデプロイした直後に、電話が鳴り始めました。顧客は、合計されなかった数を見ていました。彼らは自分の記録を更新することができませんでした。あらゆる種類の機能が壊れていました。

私たちは何をすべきか？コードをデプロイするだけではありません。また、あるデータベースから別のデータベースにデータを移動しました（また、デプロイ後に新しいデータが作成/更新されました）。それは単純なロールバック状況ではありませんでした。物事を迅速に修正する必要がありました。

Railsは何をしていますか？

デバッグの最初のステップは、現在の動作とエラーの再現方法を確認することでした。本番データのクローンを取り、Railsコンソールを起動しました。設定によっては、ActiveRecordクエリを実行したときにRailsが実行するSQLクエリが自動的に表示されない場合があります。 SQLステートメントがコンソールに表示されるようにする方法は次のとおりです。

ActiveRecord::Base.logger = Logger.new(STDOUT)

その後、いくつかの一般的なRailsクエリを試しました：

$ FavoriteFruit.find_by(id: 123, user_id: 456)

FavoriteFruit Load (0.6ms)
SELECT  "favorite_fruits".*
FROM "favorite_fruits"
WHERE "favorite_fruits"."id" = $1
AND "favorite_fruits"."user_id" = $2
[["id", "123"], ["user_id", "456"]]

find_by 正常に動作しているように見えましたが、次のようなコードが表示されました：

fruit = FavoriteFruit.find_by(id: 123, user_id: 456)
...
...
fruit.reload

そのreload 興味をそそられたので、それもテストしました：

$ fruit.reload

FavoriteFruit Load (0.3ms)
SELECT  "favorite_fruits".*
FROM "favorite_fruits"
WHERE "favorite_fruits"."id" = $1
LIMIT $2
[["id", 123], ["LIMIT", 1]]

ええとああ。したがって、最初はfind_byを使用して正しいレコードをフェッチしましたが 、reloadを呼び出すたびに 、レコードのIDを取得し、単純なIDによる検索クエリを実行します。もちろん、IDが重複しているため、誤ったデータが返されることがよくあります。

なぜそれをしたのですか？手がかりがないかRailsのソースコードを調べました。これはRubyonRailsを使用したコーディングの優れた側面であり、ソースコードはプレーンなRubyであり、自由にアクセスできます。 「ActiveRecordreload」をグーグルで検索したところ、すぐに見つかりました：

# File activerecord/lib/active_record/persistence.rb, line 602
def reload(options = nil)
  self.class.connection.clear_query_cache

  fresh_object =
    if options && options[:lock]
      self.class.unscoped { self.class.lock(options[:lock]).find(id) }
    else
      self.class.unscoped { self.class.find(id) }
    end

  @attributes = fresh_object.instance_variable_get("@attributes")
  @new_record = false
  self
end

これは、reloadであることを示しています は、多かれ少なかれ、self.class.find(id)のラッパーです。 。 IDのみによるクエリは、このメソッドに組み込まれていました。重複するIDを処理するには、コアRailsメソッドをオーバーライドするか（推奨されません）、reloadの使用を停止する必要があります。 完全に。

$ fruit = FavoriteFruit.find_by(id: 123, user_id: 456)
$ fruit.update(last_eaten: Time.now)

FavoriteFruit Update (43.3ms)
UPDATE "favorite_fruits"
SET "last_eaten" = $1
WHERE "favorite_fruits"."id" = $2
[["updated_at", "2020-04-16 06:24:57.989195"], ["id", 123]]

class FavoriteFruit
  def update_unique(attributes)
    run_callbacks :save do
      self.class
        .where(id: id, user_id: user_id)
        .update_all(attributes)
    end
    self.class.find_by(id: id, user_id: user_id)
  end
end

$ fruit.update_unique(last_eaten: Time.now)

FavoriteFruit Update All (3.2ms)
UPDATE "favorite_fruits"
SET "last_eaten" = '2020-04-16 06:24:57.989195'
WHERE "favorite_fruits"."id" = $1
AND "favorite_fruits"."user_id" = $2
[["id", "123"], ["user_id", "456"]]