Module: MonsterQueries::ActiveRecord

Extended by:
ActiveSupport::Concern
Defined in:
lib/monster_queries/active_record.rb

Defined Under Namespace

Modules: ClassMethods

Instance Method Summary collapse

Instance Method Details

#execute(query) ⇒ Object 



5
6
7
8
9
10
11
12
13
 
# File 'lib/monster_queries/active_record.rb', line 5

def execute query
  begin
    self.class.connection.execute query
  rescue
    File.open(Rails.root.join('tmp','failed.sql'), 'w') { |file| file.write(query) }
    Rails.root.join
    raise
  end
end

#select_all(query) ⇒ Object 



58
59
60
 
# File 'lib/monster_queries/active_record.rb', line 58

def select_all query
  self.class.connection.select_all query
end

#select_array(query) ⇒ Object 



41
42
43
44
45
46
47
 
# File 'lib/monster_queries/active_record.rb', line 41

def select_array query
  sql = "    SELECT COALESCE(array_to_json(array_agg(row_to_json(query_row))), '[]'::json)\n    FROM (\#{query}) query_row\n  SQL\n  select_value sql\nend\n"

#select_json(query, count) ⇒ Object 



33
34
35
36
37
38
39
 
# File 'lib/monster_queries/active_record.rb', line 33

def select_json query, count
  if count
    select_object query
  else
    select_array query
  end
end

#select_object(query) ⇒ Object 



49
50
51
52
53
54
55
 
# File 'lib/monster_queries/active_record.rb', line 49

def select_object query
  sql = "    SELECT COALESCE(row_to_json(query_row),'{}'::json)\n    FROM (\#{query}) query_row\n  SQL\n  select_value sql\nend\n"

#select_value(query) ⇒ Object 



15
16
17
18
19
20
21
22
 
# File 'lib/monster_queries/active_record.rb', line 15

def select_value query
  begin
    self.class.connection.select_value query
  rescue
    File.open(Rails.root.join('tmp','failed.sql'), 'w') { |file| file.write(query) }
    raise
  end
end

#select_values(query) ⇒ Object 



24
25
26
27
28
29
30
31
 
# File 'lib/monster_queries/active_record.rb', line 24

def select_values query
  begin
    self.class.connection.select_values query
  rescue
    File.open(Rails.root.join('tmp','failed.sql'), 'w') { |file| file.write(query) }
    raise
  end
end