Module: RunQueryProcesses

Defined in:
lib/utils/run_query_processes.rb

Class Method Summary collapse

Class Method Details

.map_queries(queries, target_connection) ⇒ Object 



22
23
24
25
26
27
 
# File 'lib/utils/run_query_processes.rb', line 22

def self.map_queries(queries, target_connection)
  queries.map do |query|
    result = target_connection.query(query)
    result[:rows]
  end
end

.remove_fields(query_results, fields_to_remove) ⇒ Object 



13
14
15
16
17
18
19
20
 
# File 'lib/utils/run_query_processes.rb', line 13

def self.remove_fields(query_results, fields_to_remove)
  fields = query_results[:fields].reject { |field| fields_to_remove.include?(field[:name]) }
  rows = query_results[:rows].map do |row|
    fields_to_remove.each { |field| row.delete(field) }
    row
  end
  { fields: fields, rows: rows }
end