Module: Rake::DSL

Defined in:
lib/rake/table_import.rb,
lib/rake/logger.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#logger ⇒ Object 



4
5
6
 
# File 'lib/rake/logger.rb', line 4

def logger
  @logger ||= Logger.new STDOUT
end

Instance Method Details

#table_import(args, &block) ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/rake/table_import.rb', line 5

def table_import args, &block
  table_name = args.keys[0]
  task args.extract!(table_name) do |t|
    source = DataSource.new table_name, t.prerequisites[0], args[:csv], &block
    unless source.table_exists?
      begin
        logger.info { "Importing #{source.table_name} from #{source.input_path}" }
        source.import
      rescue
        if source.table_exists?
          logger.warn { "dropping #{table_name} due to errors during import" }
          source.drop_table
        end
        raise
      end
    end
  end
end