Contents

class RecordLoader < GraphQL::Batch::Loader
  def initialize(model, column: model.primary_key, where: nil)
    @model = model
    @column = column.to_s
    @column_type = model.type_for_attribute(@column)
    @where = where
  end

  def load(key)
    super(@column_type.cast(key))
  end

  def perform(keys)
    query(keys).each do |record|
      value = @column_type.cast(record.public_send(@column))
      fulfill(value, record)
    end
    keys.each { |key| fulfill(key, nil) unless fulfilled?(key) }
  end

  private

  def query(keys)
    scope = @model
    scope = scope.where(@where) if @where
    scope.where(@column => keys)
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
graphql-batch-0.3.5	examples/record_loader.rb