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