class RedshiftConnector::QueueryExporter

Attributes

bundle[R]
bundle_params[R]
logger[R]
query[R]

Public Class Methods

new(ds:, query:, bundle_params: nil, enable_sort: false, logger: RedshiftConnector.logger) click to toggle source
# File lib/redshift_connector/queuery_exporter.rb, line 5
def initialize(ds:, query:, bundle_params: nil, enable_sort: false, logger: RedshiftConnector.logger)
  @ds = ds
  @query = query
  @bundle_params = bundle_params
  @bundle = nil
  @enable_sort = enable_sort
  @logger = logger
end

Public Instance Methods

execute() click to toggle source
# File lib/redshift_connector/queuery_exporter.rb, line 19
def execute
  @logger.info "EXPORT #{@query.description} -> (Queuery S3 tmp)"
  stmt = @query.to_sql
  @logger.info "[SQL/Queuery] #{stmt.strip}"
  # FIXME: support enable_sort
  # FIXME: pass bundle_params?
  @bundle = @ds.execute_query(stmt)
  @bundle
end