Class: RedshiftConnector::QueueryDataSource

Inherits:
Object
  • Object
show all
Defined in:
lib/redshift_connector/queuery_data_source.rb

Direct Known Subclasses

QueueryDirectDataSource

Instance Method Summary collapse

Constructor Details

#initialize(client = nil) ⇒ QueueryDataSource

Returns a new instance of QueueryDataSource.



8
9
10
 
# File 'lib/redshift_connector/queuery_data_source.rb', line 8

def initialize(client = nil)
  @client = client || QueueryClient::Client.new
end

Instance Method Details

#execute_query(stmt, params = []) ⇒ Object 



16
17
18
19
20
 
# File 'lib/redshift_connector/queuery_data_source.rb', line 16

def execute_query(stmt, params = [])
  @client.query(stmt, params)
rescue QueueryClient::QueryError => ex
  raise ExportError, ex.message
end

#exporter_builder ⇒ Object 



12
13
14
 
# File 'lib/redshift_connector/queuery_data_source.rb', line 12

def exporter_builder
  ExporterBuilder.new(ds: self, exporter_class: QueueryExporter)
end