class SqlPartitioner::ARAdapter
Adapter wrapping an Active Record Connection
Public Class Methods
new(connection)
click to toggle source
# File lib/sql_partitioner/adapters/ar_adapter.rb, line 8 def initialize(connection) @connection = connection end
Public Instance Methods
execute(*args)
click to toggle source
# File lib/sql_partitioner/adapters/ar_adapter.rb, line 29 def execute(*args) sanitized_sql = ActiveRecord::Base.send(:sanitize_sql_array, args) @connection.execute(sanitized_sql) end
schema_name()
click to toggle source
# File lib/sql_partitioner/adapters/ar_adapter.rb, line 34 def schema_name @connection.current_database end
select(*args)
click to toggle source
# File lib/sql_partitioner/adapters/ar_adapter.rb, line 12 def select(*args) result = [] strukt = nil sanitized_sql = ActiveRecord::Base.send(:sanitize_sql_array, args) conn_result = @connection.send(:select, sanitized_sql) conn_result.each do |h| if h.keys.size == 1 result << h.values.first else strukt ||= Struct.new(*h.keys.map{ |k| k.downcase.to_sym}) result << strukt.new(*h.values) end end result end