setScience("DeNormalizing", subProj="StatementsDB")
setDBall("Statements")

tbl <- "dig_sales_analytics"

DT.dig_sales_analytics <- runQry(sprintf("SELECT * from %s", tbl))

dateCols <- c("date")
timeCols <- c("date_created", "date_updated")

for (col in dateCols) {
  if (!is.Date(DT.dig_sales_analytics[[col]]))
    DT.dig_sales_analytics[, (col) := as.Date(get(col))]
}

for (col in timeCols) {
  if (!is.POSIXct(DT.dig_sales_analytics[[col]]))
    DT.dig_sales_analytics[, (col) := as.POSIXct(get(col))]
}

DT.dig_sales_analytics[, when_copied_from_statements_db := now(tz="UTC")]

wh <- "CRON_JOBS_SMALL"
dbname <- "prod"
schema <- "statements_db"
setSnowflake(wh=wh, dbname=dbname)

ingestIntoSQL(DT.dig_sales_analytics, tbl=paste0(tbl, "_copy"), schema=schema, dbname=dbname, wh=wh, add.ingestDate=FALSE, dont_take_copy_of_DT=TRUE, intColsToCoerce=NULL, datetime_type='TIMESTAMP_NTZ', snowflake_inuse=TRUE, drop=TRUE, truncInsteadOfDrop=TRUE)


if (FALSE) {
  sourceSupportFns(proj="Looker")
  create_lookml_from_tbl(tbl=paste0(tbl, "_copy"), schema=schema, dbname=dbname, wh=wh, snowflake_inuse=TRUE)  
}