module RedshiftConnector::Importer

Public Class Methods

for_delta_upsert(table:, columns:, delete_cond: nil, upsert_columns: nil, logger: RedshiftConnector.logger) click to toggle source
# File lib/redshift_connector/importer.rb, line 15
def Importer.for_delta_upsert(table:, columns:, delete_cond: nil, upsert_columns: nil, logger: RedshiftConnector.logger)
  if delete_cond and upsert_columns
    raise ArgumentError, "delete_cond and upsert_columns are exclusive"
  end
  importer =
    if delete_cond
      Importer::InsertDelta.new(
        dao: table.classify.constantize,
        columns: columns,
        delete_cond: delete_cond,
        logger: logger
      )
    elsif upsert_columns
      Importer::Upsert.new(
        dao: table.classify.constantize,
        columns: columns,
        upsert_columns: upsert_columns,
        logger: logger
      )
    else
      raise ArgumentError, "either of delete_cond or upsert_columns is required for delta import"
    end
  importer
end
for_rebuild(strategy: 'rename', table:, columns:, logger: RedshiftConnector.logger) click to toggle source
# File lib/redshift_connector/importer.rb, line 40
def Importer.for_rebuild(strategy: 'rename', table:, columns:, logger: RedshiftConnector.logger)
  c = get_rebuild_class(strategy)
  c.new(
    dao: table.classify.constantize,
    columns: columns,
    logger: logger
  )
end
get_rebuild_class(strategy) click to toggle source
# File lib/redshift_connector/importer.rb, line 49
def Importer.get_rebuild_class(strategy)
  case strategy.to_s
  when 'rename' then RebuildRename
  when 'truncate' then RebuildTruncate
  else
    raise ArgumentError, "unsupported rebuild strategy: #{strategy.inspect}"
  end
end