class BeetleETL::Configuration

Attributes

database[W]
database_config[W]
external_source[RW]
logger[RW]
stage_schema[RW]
target_schema[RW]
transformation_file[RW]

Public Class Methods

new() click to toggle source
# File lib/beetle_etl/configuration.rb, line 17
def initialize
  @target_schema = 'public'
  @logger = ::Logger.new(STDOUT)
end

Public Instance Methods

database() click to toggle source
# File lib/beetle_etl/configuration.rb, line 35
def database
  if @adapter.nil?
    msg = "Either Sequel connection database_config, Sequel::Database object or ActiveRecord::Base.connection required!"
    raise InvalidConfigurationError.new(msg)
  end

  @adapter
end
disconnect_database() click to toggle source
# File lib/beetle_etl/configuration.rb, line 44
def disconnect_database
  @adapter.disconnect if @database_config
end

Private Instance Methods

sequel?(database) click to toggle source
# File lib/beetle_etl/configuration.rb, line 50
def sequel?(database)
  defined?(::Sequel::Database) && database.is_a?(::Sequel::Database)
end