Class: AnyQuery::Adapters::Sql Private

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

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.

Defined Under Namespace

Classes: Config

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from Base

#fallback_where, #group_join_data, #instantiate_model, #load_single, #map_multi_threaded, #parse_field_type, #parse_field_type_boolean, #parse_field_type_date, #parse_field_type_datetime, #parse_field_type_decimal, #parse_field_type_float, #parse_field_type_integer, #parse_field_type_string, #resolve_join, #resolve_path, #resolve_select, #run_external_join

Constructor Details

#initialize(config) ⇒ Sql

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 Sql.



20
21
22
23
24
25
26
27
28
29
 
# File 'lib/any_query/adapters/sql.rb', line 20

def initialize(config)
  super(config)
  ActiveRecord::Base.establish_connection(@config[:url])
  table_name = @config[:table]

  @rails_model = declare_model!
  @rails_model.table_name = table_name
  @rails_model.inheritance_column = :_sti_disabled
  Object.const_set("AnyQuery#{table_name.classify}", @rails_model)
end

Instance Attribute Details

#rails_model ⇒ Object (readonly)

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. 



44
45
46
 
# File 'lib/any_query/adapters/sql.rb', line 44

def rails_model
  @rails_model
end

Instance Method Details

#declare_model! ⇒ 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. 



31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/any_query/adapters/sql.rb', line 31

def declare_model!
  Class.new(ActiveRecord::Base) do
    def dig(key, *other)
      data = public_send(key)
      return data if other.empty?

      return unless data.respond_to?(:dig)

      data.dig(*other)
    end
  end
end

#declare_required_associations!(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. 



62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
 
# File 'lib/any_query/adapters/sql.rb', line 62

def declare_required_associations!(joins)
  joins&.each do |join|
    next if join[:model]._adapter.url != @config[:url]

    relation = join_relation_name(join)

    if join[:as] == :list
      @rails_model.has_many(relation, class_name: join[:model]._adapter.rails_model.to_s,
                                      foreign_key: join[:foreign_key], primary_key: join[:primary_key])
    else
      @rails_model.belongs_to(relation, class_name: join[:model]._adapter.rails_model.to_s,
                                        foreign_key: join[:foreign_key], primary_key: join[:primary_key])
    end
  end
end

#join_relation_name(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. 



91
92
93
94
95
96
97
 
# File 'lib/any_query/adapters/sql.rb', line 91

def join_relation_name(join)
  if join[:as] == :list
    join[:model].table_name.pluralize.to_sym
  else
    join[:model].table_name.singularize.to_sym
  end
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. 



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

def load(_model, select:, joins:, where:, limit:)
  declare_required_associations!(joins)
  chain = @rails_model.all
  chain = chain.where(*where) if where.present?
  chain = chain.limit(limit) if limit.present?
  chain = resolve_joins(chain, joins) if joins.present?

  chain = resolve_select(chain, select) if select.present?

  chain
end

#resolve_joins(data, 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. 



78
79
80
81
82
83
84
85
86
87
88
89
 
# File 'lib/any_query/adapters/sql.rb', line 78

def resolve_joins(data, joins)
  joins.map do |join|
    if join[:model]._adapter.url == @config[:url]
      relation = join_relation_name(join)

      data = data.eager_load(relation)
    else
      resolve_join(data, join)
    end
  end
  data
end

#url ⇒ 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. 



46
47
48
 
# File 'lib/any_query/adapters/sql.rb', line 46

def url
  @config[:url]
end