#!/usr/bin/env embulk exec
require 'embulk'
require 'date'

today = Date.today
yesterday = today -1

from = yesterday.strftime("%Y-%m-%d")
to = today.strftime("%Y-%m-%d")

select_query = <<EOS
select
  col1 as c1
, col2 as c2
, col3 as c3
from table1 t1
where
  create_at between #{from} and #{to}
EOS

embulk = Embulk.new
embulk
  .input("jdbc")
    .driver_path("/opt/oracle/ojdbc6.jar")
    .driver_class("oracle.jdbc.driver.OracleDriver")
    .url("jdbc:oracle:thin:@127.0.0.1:1521:mydb")
    .user("myuser")
    .password("mypassword")
    .query(select_query)
  .filters([type: "speedometer"])
  .output("stdout")
  .start(ARGV)  # run or preview
  .on_complete(lambda {|config_diff|
    puts "diff: #{config_diff}"
  })
  .join