10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
# File 'app/controllers/vertica_history/vertica_history_controller.rb', line 10
def view_history
fetch_columns
connection_configurations = {
host: Rails.configuration.vertica_host,
user: Rails.configuration.vertica_user,
password: Rails.configuration.vertica_password,
ssl: Rails.configuration.vertica_ssl || true,
port: Rails.configuration.vertica_port || 5433,
database: Rails.configuration.vertica_database,
role: Rails.configuration.vertica_role,
search_path: Rails.configuration.vertica_search_path || nil,
row_style: Rails.configuration.vertica_row_style || :hash
}
schema = Rails.configuration.vertica_schema
id = params['id']
history = []
if (@column_filter.nil? && @value_filter.nil?)
@value_filter = [params['filter_column']]
@column_filter = [params['filter_field']]
else
@column_filter += [params['filter_field']]
@value_filter += [params['filter_column']]
end
order_by = params['order_by'] || 'vertica_updated_at'
@columns = params['columns'] || params['attribute-keys'] || @all_columns
table_name = params['class_name']
connection = Vertica.connect(connection_configurations)
@columns = @columns + ['vertica_updated_at'] unless @columns.include?('vertica_updated_at')
if @columns == ["*", "vertica_updated_at"]
unless (@column_filter.compact.empty? && @value_filter.compact.empty?)
sub_query = ""
@query_hash = Hash[@column_filter.zip(@value_filter)]
@query_hash.delete_if { |key, value| value.to_s.strip == '' }
@query_hash.each do |col, val|
next if col.nil? || val.nil?
sub_query = sub_query + "AND #{col}='#{val}' "
end
result = connection.query("SELECT * from #{schema}.#{table_name.pluralize} where id=#{id} #{sub_query} order by #{order_by};")
else
result = connection.query("SELECT * from #{schema}.#{table_name.pluralize} where id=#{id} order by #{order_by};")
end
@columns = ['vertica_updated_at'] + @model.columns.map { |c| c.name }
elsif @columns.include?("*")
unless (@column_filter.compact.empty? && @value_filter.compact.empty?)
sub_query = ""
@query_hash = Hash[@column_filter.zip(@value_filter)]
@query_hash.delete_if { |key, value| value.to_s.strip == '' }
@query_hash.each do |col, val|
next if col.nil? || val.nil?
sub_query = sub_query + "AND #{col}='#{val}' "
end
result = connection.query("SELECT * from #{schema}.#{table_name.pluralize} where id=#{id} #{sub_query} order by #{order_by};")
else
result = connection.query("SELECT * from #{schema}.#{table_name.pluralize} where id=#{id} order by #{order_by};")
end
@columns = ['vertica_updated_at'] + @model.columns.map { |c| c.name }
else
query_columns = ""
@columns.each { |c| query_columns = query_columns + c + "," }
query_columns = query_columns[0..-2]
unless (@column_filter.compact.empty? && @value_filter.compact.empty?)
sub_query = ""
@query_hash = Hash[@column_filter.zip(@value_filter)]
@query_hash.delete_if { |key, value| value.to_s.strip == '' }
@query_hash.each do |col, val|
next if col.nil? || val.nil?
sub_query = sub_query + "AND #{col}='#{val}' "
end
result = connection.query("SELECT #{query_columns} from #{schema}.#{table_name.pluralize} where id=#{id} #{sub_query} order by #{order_by};")
else
result = connection.query("SELECT #{query_columns} from #{schema}.#{table_name.pluralize} where id=#{id} order by #{order_by};")
end
end
@total_records = result.count
result.each do |row|
history << row
end
@history = Kaminari.paginate_array(history, total_count: history.count).page(params[:page]).per(20)
connection.close
rescue => e
Rails.logger.info("Unable to submit query to Vertica: #{e}")
flash[:error] = "Unable to submit query to Vertica: #{e.message}"
redirect_to "/rails_admin/#{@model}/#{id}"
end
|