Class: Kiba::Extend::Transforms::Count::MatchingRowsInLookup

Inherits:

Object

• Object
• Kiba::Extend::Transforms::Count::MatchingRowsInLookup

Defined in:

lib/kiba/extend/transforms/count/matching_rows_in_lookup.rb

Overview

Merges count of lookup rows to be merged into specified field. By default it retuns the count as a string, since many of the other transforms assume string values

Since:

• 2.6.0

Instance Method Summary

• #initialize(lookup:, keycolumn:, targetfield:, conditions: {}, result_type: :str) ⇒ MatchingRowsInLookup constructor

  A new instance of MatchingRowsInLookup.

• #process(row) ⇒ Object

Constructor Details

#initialize(lookup:, keycolumn:, targetfield:, conditions: {}, result_type: :str) ⇒ MatchingRowsInLookup

Returns a new instance of MatchingRowsInLookup.

Parameters:

• lookup (Hash) —

  created with csv_to_multihash

• keycolumn (Symbol) —

  field in the source containing value to match on

• targetfield (Symbol) —

  field to put the result value in

• conditions (Hash) (defaults to: {}) —

  See https://github.com/lyrasis/kiba-extend/blob/e5a77d4622334cd4f021ba3c4d7bf59f010472b2/spec/kiba/extend/utils/lookup_spec.rb#L477 for examples on how to use

• result_type (Symbol<:str, :int>) (defaults to: :str) —

  form in which to return the resulting values

Since:

• 2.6.0

# File 'lib/kiba/extend/transforms/count/matching_rows_in_lookup.rb', line 19

def initialize(lookup:, keycolumn:, targetfield:, conditions: {},
  result_type: :str)
  @lookup = lookup
  @keycolumn = keycolumn
  @target = targetfield
  @conditions = conditions
  @result_type = result_type
  @selector = Lookup::RowSelector.call(
    conditions: conditions
  )
end

Instance Method Details

#process(row) ⇒ Object

Parameters:

• row (Hash{ Symbol => String, nil })

Since:

• 2.6.0

# File 'lib/kiba/extend/transforms/count/matching_rows_in_lookup.rb', line 32

def process(row)
  id = row.fetch(keycolumn)
  matches = lookup.fetch(id, [])
  if matches.size.zero?
    row[target] = finalize(0)
  else
    merge_rows = selector.call(
      origrow: row,
      mergerows: matches
    )
    row[target] = finalize(merge_rows.size)
  end
  row
end