setScience("ETL", subProj="reportsAR", create=TRUE, subl=FALSE)
setGitBranchToSystem();  .g()

options("tbl.dontclean" = TRUE)

wh <- "REPORTSAR_MIGRATION"
dbname <- "prod"
schema.out <- "art_relations"

initial_tables <- c("artist_info", "asset", "publishing_escrow", "publishing_escrow_released", "releases", "track", "track_artist", "vendor") %>% selfname_
files.tsv <-  emptylist(initial_tables)


##################################
CONFIRM
##################################


{
  setDBall("MySQL")
  con <- giveMeACon(refresh=TRUE)
  message(" ------------------- CHECKING THE ROW COUNTS IN reportsAR -------------------")
  DT.counts_ar <- sapply(initial_tables, function(x) {cat("*  ", x, "\n"); qRowCount(x, schema=NULL, verbose=FALSE)})
}

{
  setSnowflake(wh=wh, dbname=dbname)
  con <- giveMeACon(refresh=TRUE)
  message(" ------------------- CHECKING THE ROW COUNTS IN Snowflake -------------------")
  DT.counts_sf <- sapply(initial_tables, function(x) {cat("*  ", x, "\n"); qRowCount(x, schema=schema.out, verbose=FALSE, wh=wh, dbname=dbname, snowflake_inuse=TRUE, msg_sf=FALSE)})
}

stopifnot(names(DT.counts_ar) == names(DT.counts_sf))
DT.compare <- data.table(tbl=names(DT.counts_ar), ar=DT.counts_ar, sf=DT.counts_sf)[, c("OK", "missing_from_sf", "perc_missing") := list(ar == sf, ar - sf, fwp((ar - sf) / ar))]
DT.compare