Class: Oxidized::SQL
Instance Method Summary
collapse
Methods inherited from Source
#map_model, #node_var_interpolate
Instance Method Details
#load ⇒ Object
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
# File 'lib/oxidized/source/sql.rb', line 21
def load
nodes = []
db = connect
query = db[@cfg.table.to_sym]
query = query.with_sql(@cfg.query) if @cfg.query?
query.each do |node|
keys = {}
@cfg.map.each { |key, sql_column| keys[key.to_sym] = node_var_interpolate node[sql_column.to_sym] }
keys[:model] = map_model keys[:model] if keys.key? :model
vars = {}
@cfg.vars_map.each do |key, sql_column|
vars[key.to_sym] = node_var_interpolate node[sql_column.to_sym]
end
keys[:vars] = vars unless vars.empty?
nodes << keys
end
db.disconnect
nodes
end
|