module RedshiftExtractor; class Copy

  attr_reader :aws_access_key_id, :aws_secret_access_key, :data_source, :destination_schema, :destination_table

  def initialize(args)
    @aws_access_key_id = args.fetch(:aws_access_key_id)
    @aws_secret_access_key = args.fetch(:aws_secret_access_key)
    @data_source = args.fetch(:data_source)
    @destination_schema = args.fetch(:destination_schema)
    @destination_table = args.fetch(:destination_table)
  end

  def copy_sql
    "copy #{destination_schema}.#{destination_table} from '#{data_source}'"\
    " credentials '#{credentials}'"\
    " manifest dateformat 'auto' timeformat 'auto' blanksasnull emptyasnull escape gzip removequotes delimiter '|';"
  end

  def credentials
    "aws_access_key_id=#{aws_access_key_id};aws_secret_access_key=#{aws_secret_access_key}"
  end

end; end