class RedshiftConnector::ActiveRecordDataSource

Public Class Methods

for_dao(dao) click to toggle source
# File lib/redshift_connector/active_record_data_source.rb, line 5
def ActiveRecordDataSource.for_dao(dao)
  new(dao)
end
new(dao) click to toggle source
# File lib/redshift_connector/active_record_data_source.rb, line 9
def initialize(dao)
  @dao = dao
end

Public Instance Methods

execute_query(query_str) click to toggle source
# File lib/redshift_connector/active_record_data_source.rb, line 17
def execute_query(query_str)
  @dao.connection_pool.with_connection {|conn|
    conn.execute(query_str)
  }
end
exporter_builder() click to toggle source
# File lib/redshift_connector/active_record_data_source.rb, line 13
def exporter_builder
  ExporterBuilder.new(ds: self, exporter_class: ActiveRecordExporter)
end