Class: ROM::Memory::Dataset

Inherits:
Object
  • Object
show all
Includes:
ArrayDataset
Defined in:
lib/rom/memory/dataset.rb

Overview

In-memory dataset

This class can be used as a base class for other adapters.

Instance Method Summary collapse

Methods included from ArrayDataset

included

Methods included from DataProxy::ClassMethods

#forward, #row_proc

Methods included from EnumerableDataset

included

Instance Method Details

#delete(tuple) ⇒ Dataset

Delete tuples from a dataset

Parameters:

  • tuple (Hash) —

    A new tuple for deletion

Returns:



108
109
110
111
 
# File 'lib/rom/memory/dataset.rb', line 108

def delete(tuple)
  data.delete(tuple)
  self
end

#insert(tuple) ⇒ Dataset Also known as: <<

Insert tuple into a dataset

Parameters:

  • tuple (Hash) —

    A new tuple for insertion

Returns:



95
96
97
98
 
# File 'lib/rom/memory/dataset.rb', line 95

def insert(tuple)
  data << tuple
  self
end

#join(*args) ⇒ Dataset

Join with other datasets

Parameters:

  • args (Array<Dataset>) —

    A list of dataset to join with

Returns:



20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/rom/memory/dataset.rb', line 20

def join(*args)
  left, right = args.size > 1 ? args : [self, args.first]

  join_map = left.each_with_object({}) { |tuple, h|
    others = right.to_a.find_all { |t| (tuple.to_a & t.to_a).any? }
    (h[tuple] ||= []).concat(others)
  }

  tuples = left.flat_map { |tuple|
    join_map[tuple].map { |other| tuple.merge(other) }
  }

  self.class.new(tuples, options)
end

#order(*fields) ⇒ Dataset

Sort a dataset

Parameters:

  • fields (Array<Symbol>) —

    Names of fields to order tuples by

  • [Boolean] (Hash) —

    a customizable set of options

Returns:



78
79
80
81
82
83
84
85
86
 
# File 'lib/rom/memory/dataset.rb', line 78

def order(*fields)
  nils_first = fields.pop[:nils_first] if fields.last.is_a?(Hash)

  sort do |a, b|
    fields # finds the first difference between selected fields of tuples
      .map { |n| __compare__ a[n], b[n], nils_first }
      .detect(-> { 0 }) { |r| r != 0 }
  end
end

#project(*names) ⇒ Dataset

Project a dataset

Parameters:

  • names (Array<Symbol>) —

    A list of attribute names

Returns:



63
64
65
 
# File 'lib/rom/memory/dataset.rb', line 63

def project(*names)
  map { |tuple| tuple.reject { |key| !names.include?(key) } }
end

#restrict(criteria = nil) ⇒ Dataset

Restrict a dataset

Parameters:

  • criteria (Hash) (defaults to: nil) —

    A hash with conditions

Returns:



42
43
44
45
46
47
48
49
50
51
52
53
54
 
# File 'lib/rom/memory/dataset.rb', line 42

def restrict(criteria = nil)
  return find_all { |tuple| yield(tuple) } unless criteria

  find_all do |tuple|
    criteria.all? do |k, v|
      case v
      when Array then v.include?(tuple[k])
      when Regexp then tuple[k].match(v)
      else tuple[k].eql?(v)
      end
    end
  end
end