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