почему эта рельсовая ассоциация загружается индивидуально после энергичной нагрузки? - PullRequest
1 голос
/ 21 января 2010

Я пытаюсь избежать проблем с N + 1 запросами при активной загрузке, но это не работает. Связанные модели по-прежнему загружаются по отдельности.

Вот соответствующие ActiveRecords и их отношения:

class Player < ActiveRecord::Base
  has_one :tableau
end

Class Tableau < ActiveRecord::Base
  belongs_to :player
  has_many :tableau_cards
  has_many :deck_cards, :through => :tableau_cards
end

Class TableauCard < ActiveRecord::Base
  belongs_to :tableau
  belongs_to :deck_card, :include => :card
end

class DeckCard < ActiveRecord::Base
  belongs_to :card
  has_many :tableaus, :through => :tableau_cards
end

class Card < ActiveRecord::Base
  has_many :deck_cards
end

class Turn < ActiveRecord::Base
  belongs_to :game
end

и используемый мной запрос находится внутри метода Player:

def tableau_contains(card_id)
  self.tableau.tableau_cards = TableauCard.find :all, :include => [ {:deck_card => (:card)}], :conditions => ['tableau_cards.tableau_id = ?', self.tableau.id]
  contains = false
  for tableau_card in self.tableau.tableau_cards
    # my logic here, looking at attributes of the Card model, with        
    # tableau_card.deck_card.card;
    # individual loads of related Card models related to tableau_card are done here
  end
  return contains
end

Это имеет отношение к сфере? Этот метод tableau_contains завершает несколько вызовов методов в более крупном цикле, где я изначально пытался выполнить энергичную загрузку, потому что есть несколько мест, где эти самые объекты перебираются и проверяются. Затем я в конце концов попробовал код, как указано выше, с загрузкой непосредственно перед циклом, и я все еще вижу отдельные запросы SELECT для Card внутри цикла tableau_cards в журнале. Я также вижу запрос на загрузку с предложением IN непосредственно перед циклом tableau_cards.

РЕДАКТИРОВАТЬ: дополнительная информация ниже с большим внешним контуром

РЕДАКТИРОВАТЬ2: исправленный цикл ниже с советами из ответов

EDIT3: добавлено больше деталей в цикле с целями

Вот большая петля. Он находится внутри наблюдателя на after_save

def after_save(pa)
  turn = Turn.find(pa.turn_id, :include => :player_actions)
  game = Game.find(turn.game_id, :include => :goals)
  game.players.all(:include => [ :player_goals, {:tableau => [:tableau_cards => [:deck_card => [:card]]]} ])
  if turn.phase_complete(pa, players)  # calls player.tableau_contains(card)
    for goal in game.goals
      if goal.checks_on_this_phase(pa)
        if goal.is_available(players, pa, turn)
          for player in game.players
            goal.check_if_player_takes(player, turn, pa)
              ... # loop through player.tableau_cards
            end
          end
        end
      end
    end
  end

Вот соответствующий код в классе хода:

def phase_complete(phase, players)
  all_players_complete = true
  for player in players
    if(!player_completed_phase(player, phase))
      all_players_complete = false
    end
  end
  return all_players_complete
end

for player in game.players выполняет другой запрос для загрузки игроков. Он кэшируется, я имею в виду, что в журнале есть метка CACHE, но я бы подумал, что запросов вообще не будет, потому что game.players уже должны быть загружены в память.

Еще один фрагмент модели Goal:

class Goal < ActiveRecord::Base
  has_many :game_goals
  has_many :games, :through => :game_goals
  has_many :player_goals
  has_many :players, :through => :player_goals

  def check_if_player_takes(player, turn, phase)
    ...
    for tab_card in player.tableau_cards
    ...
  end
end

Ответы [ 3 ]

6 голосов
/ 03 мая 2010

Попробуйте:

class Game
  has_many :players
end

Измените логику tableau_contains следующим образом:

class Player < ActiveRecord::Base
  has_one :tableau
  belongs_to :game

  def tableau_contains(card_id)
    tableau.tableau_cards.any?{|tc| tc.deck_card.card.id == card_id}
  end

end

Измените логику after_save следующим образом:

def after_save(turn)
  game = Game.find(turn.game_id, :include => :goals))
  Rails.logger.info("Begin  eager loading..")                
  players = game.players.all(:include => [:player_goals,
            {:tableau => [:tableau_cards=> [:deck_card => [:card]]]} ])
  Rails.logger.info("End  eager loading..")                
  Rails.logger.info("Begin  tableau_contains check..")                
  if players.any?{|player| player.tableau_contains(turn.card_id)}
    # do something..                
  end
  Rails.logger.info("End  tableau_contains check..")                
end

Вторая строка в методе after_save eager загружает данные, необходимые для проверки tableau_contains.Такие вызовы, как tableau.tableau_cards и tc.deck_card.card не должны / не попадут в БД.

Проблемы в вашем коде:

1) Присвоение массива для has_many ассоциации

@game.players = Player.find :all, :include => ...

Вышеприведенный оператор не является простым оператором присваивания,Изменяет palyers строк таблицы с game_id данной игры.Я предполагаю, что это не то, что вы хотите.Если вы проверите таблицу БД, то заметите, что updated_time строк таблицы игроков изменились после назначения.

Необходимо присвоить значение отдельной переменной, как показано в примере кода в after_savemethod.

2) Связанное вручную кодирование SQL

Во многих местах кода вы вручную кодируете SQL для данных ассоциации.Rails предоставляет ассоциации для этого.

Например:

tcards= TableauCard.find :all, :include => [ {:deck_card => (:card)}], 
         :conditions => ['tableau_cards.tableau_id = ?', self.tableau.id]

Может быть переписан как:

tcards = tableau.tableau_cards.all(:include => [ {:deck_card => (:card)}])

Ассоциация карт tableau_cards на модели Tableau создаеттот же SQL, который вы написали от руки.

Вы можете еще больше улучшить приведенное выше утверждение, добавив has_many :through связь к Player классу.

class Player
  has_one :tableau
  has_many :tableau_cards, :through => :tableau
end

tcards = tableau_cards.all(:include => [ {:deck_card => (:card)}])

Редактировать 1

Iсоздал приложение для проверки этого кода.Работает как положено.Rails запускает несколько SQL для загрузки данных, например:

Begin  eager loading..
SELECT * FROM `players` WHERE (`players`.game_id = 1) 
SELECT `tableau`.* FROM `tableau` WHERE (`tableau`.player_id IN (1,2))
SELECT `tableau_cards`.* FROM `tableau_cards` 
          WHERE (`tableau_cards`.tableau_id IN (1,2))
SELECT * FROM `deck_cards` WHERE (`deck_cards`.`id` IN (6,7,8,1,2,3,4,5))
SELECT * FROM `cards` WHERE (`cards`.`id` IN (6,7,8,1,2,3,4,5))
End  eager loading..
Begin  tableau_contains check..
End  tableau_contains check..

Я не вижу ни одного SQL, выполненного после быстрой загрузки данных.

Изменить 2

Внести следующие изменения в ваш код.

def after_save(pa)
  turn = Turn.find(pa.turn_id, :include => :player_actions)
  game = Game.find(turn.game_id, :include => :goals)
  players = game.players.all(:include => [ :player_goals, {:tableau => [:tableau_cards => [:deck_card => [:card]]]} ])
  if turn.phase_complete(pa, game, players)
    for player in game.players
      if(player.tableau_contains(card))
      ...
      end
    end
  end
end
def phase_complete(phase, game, players)
  all_players_complete = true
  for player in players
    if(!player_completed_phase(player, phase))
      all_players_complete = false
    end
  end
  return all_players_complete
end

Кэширование работает следующим образом:

game.players # cached in the game object
game.players.all # not cached in the game object

players = game.players.all(:include => [:player_goals])
players.first.player_goals # cached

Второй приведенный выше оператор приводит к пользовательскому запросу на сопоставление.Следовательно, AR не кэширует результаты.Где player_goals кэшируются для каждого объекта проигрывателя в 3-м операторе, поскольку они выбираются с использованием стандартной ассоциации SQL.

1 голос
/ 01 мая 2010

Что произойдет, если вы отделите вызов cards = TableauCard.find... от вызова player.tableau.tableau_cards = cards? Возможно, rails сбрасывает кэшированные записи ассоциации в этот момент кода и перезагружает ассоциации после этого.

Это также позволит вам убедиться, что тот же массив передается в tableau_contains, передав переменную явно.

Похоже, что вы пытаетесь сохранить загруженные связи между несколькими вызовами в ассоциацию player.cards.tableau_cards. Я не уверен, возможна ли эта функциональность при работе рельсов. Я полагаю, что он кэширует необработанные данные, возвращаемые из оператора SQL, но не фактический массив, который возвращается. Итак:

  def test_association_identity
   a = player.tableau.tableau_cards.all(
          :include => {:deck_card => :card}) 
          #=> Array with object_id 12345
          # and all the eager loaded deck and card associations set up
   b = player.tableau.tableau_cards 
          #=> Array 320984230 with no eager loaded associations set up. 
          #But no extra sql query since it should be cached.
   assert_equal a.object_id, b.object_id #probably fails 
   a.each{|card| card.deck_card.card}
   puts("shouldn't have fired any sql queries, 
         unless the b call reloaded the association magically.")
   b.each{|card| card.deck_card.card; puts("should fire a query 
                                        for each deck_card and card")}
  end

Единственное, о чем я могу подумать, - это разбросать некоторые выходные данные по всему коду и точно определить, где происходит отложенная загрузка.

Вот что я имею в виду:

# наблюдатель

def after_save(pa)
  @game = Game.find(turn.game_id, :include => :goals)
  @game.players = Player.find( :all, 
                :include => [ {:tableau => (:tableau_cards)},:player_goals ], 
                :conditions => ['players.game_id =?', @game.id]
  for player in @game.players
    cards = TableauCard.find( :all, 
          :include =>{:deck_card => :card}, 
          :conditions => ['tableau_cards.tableau_id = ?', player.tableau.id])
    logger.error("First load")
    player.tableau.tableau_cards =  cards #See above comments as well.
    # Both sides of this ^ line should always be == since: 
    # Given player.tableau => Tableau(n) then Tableau(n).tableau_cards 
    # will all have tableau_id == n. In other words, if there are 
    # `tableau_cards.`tableau_id = n in the db (as in the find call),
    # then they'll already be found in the tableau.tableau_cards call.
    logger.error("Any second loads?")
    if(tableau_contains(cards,card))
       logger.error("There certainly shouldn't be any loads here.") 
       #so that we're not relying on any additional association calls, 
       #this should at least remove one point of confusion.
    ...
    end
  end
end

#Also in the Observer, for just these purposes (it can be moved back out 
#to Player after the subject problem here is understood better)

def tableau_contains(cards,card_id)
  contains = false
          logger.error("Is this for loop loading the cards?")
  for card in cards
           logger.error("Are they being loaded after `card` is set?")
    # my logic here, looking at attributes of the Card model, with        
    # card.deck_card.card;
    logger.error("What about prior to this call?")
  end
  return contains
end
1 голос
/ 29 апреля 2010

Проблема номер один: вы каждый раз сбрасываете карты player.tableau.tableau_cards

player.tableau.tableau_cards = TableauCard.find :all, :include => [ {:deck_card => (:card)}], :conditions => ['tableau_cards.tableau_id = ?', player.tableau.id] 

Если предполагается, что это временный массив, то вы выполняете больше работы, чем необходимо. Следующее было бы лучше:

temp_tableau_cards = TableauCard.find :all, :include => [ {:deck_card => (:card)}], :conditions => ['tableau_cards.tableau_id = ?', player.tableau.id] 

Я бы также разделил эти две операции, если вы на самом деле пытаетесь установить tableau_cards и что-то с ними сделать.

player.tableau.tableau_cards = TableauCard.find :all, :include => [ {:deck_card => (:card)}], :conditions => ['tableau_cards.tableau_id = ?', player.tableau.id] 
card.whatever_logic if player.tableau.tableau_cards.include? card

Опять же, похоже, что вы удваиваете запрос, когда вам это не нужно.

...