Sha256: b4f56c5edb2e08e7da5aae9d15559634701e47854b04b70a24700b653de8d3e5
Contents?: true
Size: 1003 Bytes
Versions: 19
Compression:
Stored size: 1003 Bytes
Contents
module ETL #:nodoc:
module Processor #:nodoc:
# A processor which will truncate a table. Use as a pre-processor for cleaning out a table
# prior to loading
class TruncateProcessor < ETL::Processor::Processor
# Defines the table to truncate
attr_reader :table
# Defines the database connection to use
attr_reader :target
# Initialize the processor
#
# Options:
# * <tt>:target</tt>: The target connection
# * <tt>:table</tt>: The table name
def initialize(control, configuration)
super
#@file = File.join(File.dirname(control.file), configuration[:file])
@target = configuration[:target] || {}
@table = configuration[:table]
end
def process
conn = ETL::Engine.connection(target)
conn.truncate(table_name)
end
private
def table_name
ETL::Engine.table(table, ETL::Engine.connection(target))
end
end
end
end
Version data entries
19 entries across 19 versions & 7 rubygems