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