Class: ETL::Processor::TruncateProcessor

Inherits:
Processor show all
Defined in:
lib/etl/processor/truncate_processor.rb

Overview

A processor which will truncate a table. Use as a pre-processor for cleaning out a table prior to loading

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(control, configuration) ⇒ TruncateProcessor

Initialize the processor

Options:

  • :target: The target connection

  • :table: The table name

  • :options: Optional truncate options



18
19
20
21
22
23
24
 
# File 'lib/etl/processor/truncate_processor.rb', line 18

def initialize(control, configuration)
  super
  #@file = File.join(File.dirname(control.file), configuration[:file])
  @target = configuration[:target] || {}
  @table = configuration[:table]
  @options = configuration[:options] 
end

Instance Attribute Details

#table ⇒ Object (readonly)

Defines the table to truncate



7
8
9
 
# File 'lib/etl/processor/truncate_processor.rb', line 7

def table
  @table
end

#target ⇒ Object (readonly)

Defines the database connection to use



10
11
12
 
# File 'lib/etl/processor/truncate_processor.rb', line 10

def target
  @target
end

Instance Method Details

#process ⇒ Object 



26
27
28
29
30
31
32
 
# File 'lib/etl/processor/truncate_processor.rb', line 26

def process
  conn = ETL::Engine.connection(target)
  if conn.is_a?(ActiveRecord::ConnectionAdapters::PostgreSQLAdapter)
    @options ||= 'RESTART IDENTITY'
  end
  conn.truncate(table_name, @options)
end