creds <- read_credentials('../cred/bi.3bpo.com')
db_bi <- src_mysql(  host = 'bi.3bpo.com', dbname = 'bu_adv_sem'
                     , user = creds$user
                     , password = creds$password)

tbl_cpl_max <- tbl(src = db_bi, 'cpl_max_archive')

tbl_cpl_max <- filter(tbl_cpl_max, channel == 'SEM' & Day >= '2016-01-01')

tbl_cpl_max <- select(  tbl_cpl_max
                      , channel
                      , cplmax = cpl_max
                      , product_group_name = product_group
                      , country_iso2 = country
                      , aid
                      , cplmax_date = Day)

DT_cpl_max <- as.data.table(collect(tbl_cpl_max))

DT_cpl_max[, `:=`(channel = NULL, aid = NULL)]


db_zolv <- open_channel(host_name, credentials_path, db_name = 'semai')
dbWriteTable(  db_zolv, name = 'exchange_cplmax', value = DT_cpl_max
             , append = TRUE
             , row.names = FALSE)

disconnect_all_MySQL()