class RedshiftConnector::Importer::Upsert

Public Class Methods

new(dao:, columns:, upsert_columns:, logger: RedshiftConnector.logger) click to toggle source
# File lib/redshift_connector/importer/upsert.rb, line 6
def initialize(dao:, columns:, upsert_columns:, logger: RedshiftConnector.logger)
  @dao = dao
  @columns = columns
  @upsert_columns = upsert_columns
  @logger = logger
end

Public Instance Methods

execute(bundle) click to toggle source
# File lib/redshift_connector/importer/upsert.rb, line 13
def execute(bundle)
  import(bundle)
end
import(bundle) click to toggle source
# File lib/redshift_connector/importer/upsert.rb, line 17
def import(bundle)
  @logger.info "IMPORT #{bundle.url}* -> #{@dao.table_name} (#{@columns.join(', ')}) upsert (#{@upsert_columns.join(', ')})"
  bundle.each_batch do |rows|
    @dao.import(@columns, rows, on_duplicate_key_update: @upsert_columns)
  end
end