Class: AnyQuery::Adapters::Base Private

Inherits:
Object
  • Object
show all
Defined in:
lib/any_query/adapters/base.rb

Overview

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

API:

  • private

Direct Known Subclasses

Csv, FixedLength, Http, Sql

Defined Under Namespace

Classes: Config

Instance Method Summary collapse

Constructor Details

#initialize(config) ⇒ Base

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of Base.

API:

  • private



7
8
9
 
# File 'lib/any_query/adapters/base.rb', line 7

def initialize(config)
  @config = config.to_h
end

Instance Method Details

#fallback_where(data, wheres) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



41
42
43
44
45
46
47
48
49
 
# File 'lib/any_query/adapters/base.rb', line 41

def fallback_where(data, wheres)
  data.filter do |row|
    wheres.all? do |where|
      where.all? do |key, value|
        resolve_path(row, key) == value
      end
    end
  end
end

#group_join_data(data, join) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



63
64
65
66
67
68
69
 
# File 'lib/any_query/adapters/base.rb', line 63

def group_join_data(data, join)
  if join[:as] == :list
    data.group_by { |e| resolve_path(e, join[:primary_key]) }
  else
    data.index_by { |e| resolve_path(e, join[:primary_key]) }
  end
end

#instantiate_model(model, record) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



19
20
21
22
23
24
25
26
 
# File 'lib/any_query/adapters/base.rb', line 19

def instantiate_model(model, record)
  instance = model.new
  attrs = instance.instance_variable_get(:@attributes)
  record.each do |key, value|
    attrs.send("#{key}=", value)
  end
  instance
end

#load(model, select:, joins:, where:, limit:) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Raises:

API:

  • private



11
12
13
 
# File 'lib/any_query/adapters/base.rb', line 11

def load(model, select:, joins:, where:, limit:)
  raise NotImplementedError
end

#load_single(model, id, joins) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



15
16
17
 
# File 'lib/any_query/adapters/base.rb', line 15

def load_single(model, id, joins)
  load(model, select: [], joins:, where: [{ id: }], limit: 1).first
end

#map_multi_threaded(list, concurrency = 50) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



92
93
94
95
96
97
98
99
 
# File 'lib/any_query/adapters/base.rb', line 92

def map_multi_threaded(list, concurrency = 50)
  list.each_slice(concurrency).flat_map do |slice|
    slice
      .map { |data| Thread.new { yield(data) } }
      .each(&:join)
      .map(&:value)
  end
end

#parse_field_type(field, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



101
102
103
104
105
106
107
108
109
110
111
112
 
# File 'lib/any_query/adapters/base.rb', line 101

def parse_field_type(field, line)
  method_name = "parse_field_type_#{field[:type]}"

  if respond_to?(method_name)
    send(method_name, field, line)
  else
    line.strip
  end
rescue StandardError => e
  AnyQuery::Config.logger.error "Failed to parse field \"#{line}\" with type #{field.inspect}: #{e.message}"
  nil
end

#parse_field_type_boolean(_, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



146
147
148
 
# File 'lib/any_query/adapters/base.rb', line 146

def parse_field_type_boolean(_, line)
  line.strip == 'true'
end

#parse_field_type_date(field, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



118
119
120
121
122
123
124
 
# File 'lib/any_query/adapters/base.rb', line 118

def parse_field_type_date(field, line)
  if field[:format]
    Date.strptime(line.strip, field[:format])
  else
    Date.parse(line)
  end
end

#parse_field_type_datetime(field, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



126
127
128
129
130
131
132
 
# File 'lib/any_query/adapters/base.rb', line 126

def parse_field_type_datetime(field, line)
  if field[:format]
    DateTime.strptime(line.strip, field[:format])
  else
    DateTime.parse(line)
  end
end

#parse_field_type_decimal(_, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



138
139
140
 
# File 'lib/any_query/adapters/base.rb', line 138

def parse_field_type_decimal(_, line)
  BigDecimal(line)
end

#parse_field_type_float(_, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



134
135
136
 
# File 'lib/any_query/adapters/base.rb', line 134

def parse_field_type_float(_, line)
  line.to_f
end

#parse_field_type_integer(_, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



114
115
116
 
# File 'lib/any_query/adapters/base.rb', line 114

def parse_field_type_integer(_, line)
  line.to_i
end

#parse_field_type_string(_, line) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



142
143
144
 
# File 'lib/any_query/adapters/base.rb', line 142

def parse_field_type_string(_, line)
  line.strip
end

#resolve_join(data, join) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/any_query/adapters/base.rb', line 51

def resolve_join(data, join)
  AnyQuery::Config.logger.debug "Joining #{join[:model]} on #{join[:primary_key]} = #{join[:foreign_key]}"
  foreign_keys = data.map { |row| resolve_path(row, join[:foreign_key]) }.compact.uniq
  result = run_external_join(join, foreign_keys)

  result = group_join_data(result, join)

  data.each do |row|
    row[join[:into]] = result[resolve_path(row, join[:foreign_key])] || (join[:as] == :list ? [] : nil)
  end
end

#resolve_path(data, path) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/any_query/adapters/base.rb', line 28

def resolve_path(data, path)
  if path.is_a?(Proc)
    path.call(data)
  elsif path.is_a?(Array)
    data.dig(*path)
  else
    data[path]
  end
rescue StandardError => e
  AnyQuery::Config.logger.error "Failed to resolve path #{path} on #{data.inspect}"
  raise e
end

#resolve_select(chain, select) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



84
85
86
87
88
89
90
 
# File 'lib/any_query/adapters/base.rb', line 84

def resolve_select(chain, select)
  chain.map do |record|
    select.map do |field|
      resolve_path(record, field)
    end
  end
end

#run_external_join(join, foreign_keys) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

API:

  • private



71
72
73
74
75
76
77
78
79
80
81
82
 
# File 'lib/any_query/adapters/base.rb', line 71

def run_external_join(join, foreign_keys)
  case join[:strategy]
  when Proc
    join[:strategy].call(foreign_keys)
  when :single
    map_multi_threaded(foreign_keys.uniq) { |key| join[:model].find(key) }
  when :full_scan
    join[:model].to_a
  else
    join[:model].where(id: foreign_keys).to_a
  end
end