Class: Datafusion::DbExecutor

Inherits:
Object
  • Object
show all
Defined in:
lib/datafusion/db_executor.rb

Constant Summary collapse

TAG = 
"DBEXECUTOR"

Instance Method Summary collapse

Constructor Details

#initialize(conn) ⇒ DbExecutor

Returns a new instance of DbExecutor.



7
8
9
 
# File 'lib/datafusion/db_executor.rb', line 7

def initialize(conn)
  @db = Sequel.connect(conn)
end

Instance Method Details

#execute(sql, label = '') ⇒ Object 



11
12
13
14
15
16
17
18
19
 
# File 'lib/datafusion/db_executor.rb', line 11

def execute(sql, label='')
  run = rand(36**5).to_s(36)

  Datafusion.log.info("#{TAG}: starting run id:#{run} for: '#{label}'")
  @db[sql].each do |r|
    Datafusion.log.info("#{TAG}: out: #{r}")
  end
  Datafusion.log.info("#{TAG}: finished run id:#{run}")
end