ActiveRecord интересный кейс?

Question

[Андрій Степанюк]

class A < ActiveRecord::Base
  has_many :ab_relationships
  has_many :bs, through: :ab_relationships, source: :b
end

class B < ActiveRecord::Base
  has_many :ab_relationships
  has_many :as, through: :ab_relationships, source: :a
end

class AbRelationship < ActiveRecord::Base
  belongs_to :a
  belongs_to :b

  validate :ololo_validator

private
  def ololo_validator
    if AbRelationship.where(a: self.a).first.present?
      errors.add(:ab_relationships, "error")
    end
  end
end

Теперь если сделать
a = A.create(b_ids: [ 12 ]) # реальные ids

то a.valid? будет true
но a.presisted? будет false

2.2.2 :005 > B.create
   (0.1ms)  begin transaction
  SQL (0.3ms)  INSERT INTO "bs" ("created_at", "updated_at") VALUES (?, ?)  [["created_at", "2015-10-10 08:46:40.136477"], ["updated_at", "2015-10-10 08:46:40.136477"]]
   (1.7ms)  commit transaction
 => #<B id: 2, created_at: "2015-10-10 08:46:40", updated_at: "2015-10-10 08:46:40"> 
2.2.2 :006 > a = A.create(b_ids: [B.first.id])
  B Load (0.2ms)  SELECT  "bs".* FROM "bs"  ORDER BY "bs"."id" ASC LIMIT 1
  B Load (0.1ms)  SELECT  "bs".* FROM "bs" WHERE "bs"."id" = ? LIMIT 1  [["id", 1]]
   (0.1ms)  begin transaction
  AbRelationship Load (0.1ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" IS NULL  ORDER BY "ab_relationships"."id" ASC LIMIT 1
  SQL (0.3ms)  INSERT INTO "as" ("created_at", "updated_at") VALUES (?, ?)  [["created_at", "2015-10-10 08:46:58.276925"], ["updated_at", "2015-10-10 08:46:58.276925"]]
  AbRelationship Load (0.1ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" = 1  ORDER BY "ab_relationships"."id" ASC LIMIT 1
  SQL (0.1ms)  INSERT INTO "ab_relationships" ("b_id", "a_id", "created_at", "updated_at") VALUES (?, ?, ?, ?)  [["b_id", 1], ["a_id", 1], ["created_at", "2015-10-10 08:46:58.279207"], ["updated_at", "2015-10-10 08:46:58.279207"]]
  AbRelationship Load (0.1ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" = 1  ORDER BY "ab_relationships"."id" ASC LIMIT 1
   (0.8ms)  rollback transaction
 => #<A id: nil, created_at: "2015-10-10 08:46:58", updated_at: "2015-10-10 08:46:58"> 
2.2.2 :007 > a.valid?
  AbRelationship Load (0.2ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" IS NULL  ORDER BY "ab_relationships"."id" ASC LIMIT 1
 => true 
2.2.2 :008 > a.persisted?
 => false 
2.2.2 :009 >

я понимаю, что эту задачу можно по другому решить и все будет работать, но почему происходит то что происходит?
Основной вопрос в том почему ololo_validator вызывается 2 раза, в результате все ломается.

Answer 1

[Кирилл Пензин]

Всё логично же. Сначала создаётся первая связующая модель(id 12), потом при попытке создать вторую видим, что уже с данной записью a существует связь у другой модели из b. Так что, да, оно должно ломаться. Фактически, ваш валидатор проверяет, чтобы у вас была связь one-to-one-through(правда, непонятно зачем такое).

UPD: не объявлены полностью связи в моделях, должно быть так:

class A < ActiveRecord::Base
has_many :ab_relationships,  class_name: ABRelationship
has_many :bs, through: :ab_relationships, source: :b
end

class B < ActiveRecord::Base
has_many :ab_relationships,  class_name: ABRelationship
has_many :as, through: :ab_relationships, source: :a
end

UPD2: Причины пока неизвестны, но выглядит очень необычно

a = A.create!(b_ids: [1])
  B Load (0.2ms)  SELECT  `bs`.* FROM `bs` WHERE `bs`.`id` = 1 LIMIT 1
   (0.1ms)  BEGIN
  ABRelationship Load (0.4ms)  SELECT  `ab_relationships`.* FROM `ab_relationships` WHERE `ab_relationships`.`a_id` IS NULL  ORDER BY `ab_relationships`.`id` ASC LIMIT 1
  SQL (21.7ms)  INSERT INTO `as` (`created_at`, `updated_at`) VALUES ('2015-10-10 08:43:24', '2015-10-10 08:43:24')
  ABRelationship Load (0.6ms)  SELECT  `ab_relationships`.* FROM `ab_relationships` WHERE `ab_relationships`.`a_id` = 4  ORDER BY `ab_relationships`.`id` ASC LIMIT 1
  SQL (0.5ms)  INSERT INTO `ab_relationships` (`b_id`, `a_id`, `created_at`, `updated_at`) VALUES (1, 4, '2015-10-10 08:43:24', '2015-10-10 08:43:24')
  ABRelationship Load (0.6ms)  SELECT  `ab_relationships`.* FROM `ab_relationships` WHERE `ab_relationships`.`a_id` = 4  ORDER BY `ab_relationships`.`id` ASC LIMIT 1
   (85.8ms)  ROLLBACK
ActiveRecord::RecordInvalid: Validation failed: Ab relationships error

UPD3: В итоге, логика Rails сводится здесь к следующему. Создадим запись в связывающей таблице, а потом перед сохранением основной записи запустим все валидации, в том числе и у связанных записей.

Comments

[Андрій Степанюк]

Да вы правы не совсем корректный вопрос, я должен был написать так:
a = A.create(b_ids: [ 12])
Потому что в этом случае он тоже ломается.

[Андрій Степанюк]

Исправил вопрос.

[Андрій Степанюк]

И да вы правы, one-to-one-through тогда я мог бы написать has_one и никакой валидатор писать бы не понадобилось.

Но дело в том что это не весь код и A содержит дополнительное поле и в некотором случае должно быть ha_one во всех остальных has_many

т.е.

def ololo_validator
if !self.a.property_w? && ABRelationship.where(a: self.a).first.present?
errors.add(:ab_relationships, "error")
end
end

[Кирилл Пензин]

tid0wlas: Так у вас просто нет такого поля, как b_ids. Вы его указали, как bs. Или это тоже ваша опечатка?

[Андрій Степанюк]

Нет это не опечатка, rails понимает такую запись. Так же я мог бы написать bs: [ B.first ], например.

[Андрій Степанюк]

У меня был scaffold контроллер который принимал из params массив b_ids. в таком виде он передался в A.create(params). И не ждал что это будет работать, но он мне все успешно записал в базу (Изначально я планировал в цикле пробежаться по b_ids и насдавать связей, все это конечно в одной транзакции, а потом обнаружил что заработало и так. Тогда я стал дописывать валидаторы в модели и тут возникла эта проблема).

[Кирилл Пензин]

Ошибка примерно такая: irb(main):012:0> A.create!(b_ids:[1])
ActiveRecord::HasManyThroughAssociationNotFoundError: Could not find the association :ab_relationships in model A

И, да, я проглядел вашу ошибку. Рекоменду внимательно перечитать доку по реализации has-many-through. Вам надо было в каждой модели(A, B) дополнительно указать has_many: :ab_relationships.

[Кирилл Пензин]

Отработало крайне необычно. В выводе консоли видно, что он создаёт в БД запись, а затем проверяет наличие уже существующих. В результате он видит, что такая уже есть(та самая запись, которую только что создали) и удаляет её.

[Андрій Степанюк]

вы правы, накосячил когда переносил вопрос из другого проекта, вот весь код с поведением про которое я спрашиваю:

class A < ActiveRecord::Base
  has_many :ab_relationships
  has_many :bs, through: :ab_relationships, source: :b
end

class B < ActiveRecord::Base
  has_many :ab_relationships
  has_many :as, through: :ab_relationships, source: :a
end

class AbRelationship < ActiveRecord::Base
  belongs_to :a
  belongs_to :b

  validate :ololo_validator

private
  def ololo_validator
    if AbRelationship.where(a: self.a).first.present?
      errors.add(:ab_relationships, "error")
    end
  end
end

2.2.2 :005 > B.create
   (0.1ms)  begin transaction
  SQL (0.3ms)  INSERT INTO "bs" ("created_at", "updated_at") VALUES (?, ?)  [["created_at", "2015-10-10 08:46:40.136477"], ["updated_at", "2015-10-10 08:46:40.136477"]]
   (1.7ms)  commit transaction
 => #<B id: 2, created_at: "2015-10-10 08:46:40", updated_at: "2015-10-10 08:46:40"> 
2.2.2 :006 > a = A.create(b_ids: [B.first.id])
  B Load (0.2ms)  SELECT  "bs".* FROM "bs"  ORDER BY "bs"."id" ASC LIMIT 1
  B Load (0.1ms)  SELECT  "bs".* FROM "bs" WHERE "bs"."id" = ? LIMIT 1  [["id", 1]]
   (0.1ms)  begin transaction
  AbRelationship Load (0.1ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" IS NULL  ORDER BY "ab_relationships"."id" ASC LIMIT 1
  SQL (0.3ms)  INSERT INTO "as" ("created_at", "updated_at") VALUES (?, ?)  [["created_at", "2015-10-10 08:46:58.276925"], ["updated_at", "2015-10-10 08:46:58.276925"]]
  AbRelationship Load (0.1ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" = 1  ORDER BY "ab_relationships"."id" ASC LIMIT 1
  SQL (0.1ms)  INSERT INTO "ab_relationships" ("b_id", "a_id", "created_at", "updated_at") VALUES (?, ?, ?, ?)  [["b_id", 1], ["a_id", 1], ["created_at", "2015-10-10 08:46:58.279207"], ["updated_at", "2015-10-10 08:46:58.279207"]]
  AbRelationship Load (0.1ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" = 1  ORDER BY "ab_relationships"."id" ASC LIMIT 1
   (0.8ms)  rollback transaction
 => #<A id: nil, created_at: "2015-10-10 08:46:58", updated_at: "2015-10-10 08:46:58"> 
2.2.2 :007 > a.valid?
  AbRelationship Load (0.2ms)  SELECT  "ab_relationships".* FROM "ab_relationships" WHERE "ab_relationships"."a_id" IS NULL  ORDER BY "ab_relationships"."id" ASC LIMIT 1
 => true 
2.2.2 :008 > a.persisted?
 => false 
2.2.2 :009 >

[Андрій Степанюк]

Исправлю в вопросе тоже

[Андрій Степанюк]

Кирилл Пензин: крайне необычно, в этом и суть вопроса. Извините за множественные косяки я просто переносил вопрос из проекта где было много лишнего, а новый чистый проект специально под этот вопрос не создал.

[Кирилл Пензин]

tid0wlas: Persisted false и должен отдавать. Т.к. такую запись уже пытались создать и она была удалена. В данном случае Rails ведёт себя немного нелогично. Она вначале создаёт запись в связующей таблице, а потом уже запускает все валидации.

[Кирилл Пензин]

tid0wlas: Но если попробовать создать всё последовательно, то проблем нет. Видимо, тут логика следующая: в начале создаются промежуточные записи, а потом, при сохранении основной, уже начинают проходить все валидации, что и порождает данную ошибку.

[Андрій Степанюк]

Кирилл Пензин: да, было интересно поднять этот вопрос. и узнать некоторые нюансы AR.
Спасибо!

[Андрій Степанюк]

В итоге создание записи можно написать как то так:

class A < ActiveRecord::Base
  has_many :ab_relationships
  has_many :bs, through: :ab_relationships, source: :b

  def self.create_with_ids b_ids
    a = nil
    A.transaction do
      a = A.create
      b_ids.each do |id|
        b = B.find(id)
        r = AbRelationship.create(a: a, b: b)
      end
    end
    a.persisted? ? a : nil
  end
end

[Кирилл Пензин]

tid0wlas: можно сделать гораздо проще)

def ololo_validator
    if ABRelationship.where(a: self.a).where.not(id:self.id).first.present?
      errors.add(:ab_relationships, "error")
    end
  end

[Андрій Степанюк]

спасибо еще раз

[Кирилл Пензин]

tid0wlas: Всегда пожалуйста