class RedshiftConnector::QueueryDataSource

Public Class Methods

new(client = nil) click to toggle source
# File lib/redshift_connector/queuery_data_source.rb, line 8
def initialize(client = nil)
  @client = client || QueueryClient::Client.new
end

Public Instance Methods

execute_query(stmt, params = []) click to toggle source
# 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() click to toggle source
# File lib/redshift_connector/queuery_data_source.rb, line 12
def exporter_builder
  ExporterBuilder.new(ds: self, exporter_class: QueueryExporter)
end