### snowflake cursor doesn't support string sseparation, thus this var is adjusted

sf_check_2 = """select count(*) "count", 'dest; SF raw' "table" \
from "DELPHI_CHARTMETRIC_RAW"."AMAZON"."AMAZON_PLAYLIST" \
where CREATED_AT < current_date() - 1  \
union \
select count(*), 'src; SF ds' "table" \
from "DS_CHARTMETRIC"."RAW_DATA"."AMAZON_PLAYLIST" \
where created_at < current_date ( )-1"""

sf_check_3 = """select count(*) "count", 'dest; SF raw' "table" \
from "DELPHI_CHARTMETRIC_RAW"."AMAZON"."AMAZON" \
where CREATED_AT < current_date() - 1 \
union \
select count(*) "count", 'src; SF ds' "table" \
from "DS_CHARTMETRIC"."RAW_DATA"."AMAZON" \
where CREATED_AT < current_date() - 1;"""

sf_check_4 = """select count(*) "count", 'dest; SF raw' "table" \
from "DELPHI_CHARTMETRIC_RAW"."AMAZON"."L_CM_AMAZON_PLAYLIST" \
where CREATED_AT < current_date() - 1 \
union \
select count(*) "count", 'src; SF ds' "table" \
from "DS_CHARTMETRIC"."RAW_DATA"."L_CM_AMAZON_PLAYLIST" \
where CREATED_AT < current_date() - 1;"""

sf_check_5 = """select 1 - ( \
  select count(*) \
  from "DELPHI_CHARTMETRIC_RAW"."AMAZON"."L_AMAZON_PLAYLIST" \
  where START_SYS_PERIOD > current_date() - 50 \
) / ( \
  select count(*) \
  from "DS_CHARTMETRIC"."RAW_DATA"."L_AMAZON_PLAYLIST" \
  where START_SYS_PERIOD > current_date() - 50 \
) as "count"  \
;"""

sf_check_6 = """select count(*) "count" \
from ( \
  select max(DATE) \
  from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."PLAYLIST_AMAZON_TRACK_POSITION" \
  minus \
  select current_date);"""

sf_check_7 = """select ( \
  select count(distinct CM_AMAZON_PLAYLIST_ID) \
  from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."PLAYLIST_AMAZON_TRACK_POSITION" \
  where DATE = current_date \
) - ( \
  select count(distinct CM_AMAZON_PLAYLIST_ID) \
  from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."PLAYLIST_AMAZON_TRACK_POSITION" \
  where DATE = current_date - 1 \
) as "count";"""

sf_check_8 = """select count(distinct DATE, CM_AMAZON_PLAYLIST_ID, COUNTRY_CODE, POSITION) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."PLAYLIST_AMAZON_TRACK_POSITION" \
union \
select count(distinct DATE, CM_AMAZON_PLAYLIST_ID, COUNTRY_CODE, POSITION) "count", 'dest; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."AMAZON_PLAYLIST_DAILY_META" \
; """

sf_check_9 = """select count(distinct DATE, CM_AMAZON_PLAYLIST_ID, COUNTRY_CODE, ISRC) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."PLAYLIST_AMAZON_TRACK_POSITION" \
union \
select count(distinct DATE, CM_AMAZON_PLAYLIST_ID, COUNTRY_CODE, ISRC) "count", 'dest; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."AMAZON_PLAYLIST_DAILY_META" \
;"""

sf_check_10 = """select count(distinct CM_AMAZON_PLAYLIST_ID, COUNTRY_CODE, ISRC) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."AMAZON_PLAYLIST_DAILY_META" \
where is_min_isrc \
union \
select count(*) "count", 'dest; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."AMAZON_PLAYLIST_LIFETIME" \
;"""

sf_check_11 = """select count(distinct PLAYLIST_ID, COUNTRY_CODE) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."DIM_AMAZON_PLAYLIST" \
union \
select count(*) "count", 'dest; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."CM_AMAZON_PLAYLIST_ID_MAPPING" \
;"""

sf_check_12 = """select count(*) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."DIM_AMAZON_TRACK" \
union \
select count(*) "count", 'dest; SF main' "table" \
from "DELPHI_CHARTMETRIC_RAW"."AMAZON"."AMAZON" \
;"""

sf_check_13 = """select count(*) "count", 'dest; SF etl' "table" \
from "DELPHI_CHARTMETRIC_ETL"."AMAZON"."AMAZON_PLAYLIST_DAILY_META" \
union \
select count(*) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."AMAZON_PLAYLIST_DAILY_META" \
;"""

sf_check_14 = """select count(*) "count", 'dest; SF etl' "table" \
from "DELPHI_CHARTMETRIC_ETL"."AMAZON"."AMAZON_PLAYLIST_LIFETIME" \
union \
select count(*) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."AMAZON_PLAYLIST_LIFETIME" \
;"""

sf_check_15 = """select count(*) "count", 'dest; SF etl' "table" \
from "DELPHI_CHARTMETRIC_ETL"."AMAZON"."CM_AMAZON_PLAYLIST_ID_MAPPING" \
union \
select count(*) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."CM_AMAZON_PLAYLIST_ID_MAPPING" \
;"""

sf_check_16 = """select count(*) "count", 'dest; SF etl' "table" \
from "DELPHI_CHARTMETRIC_ETL"."AMAZON"."DIM_AMAZON_PLAYLIST" \
union \
select count(*) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."DIM_AMAZON_PLAYLIST" \
;"""

sf_check_17 = """select count(*) "count", 'dest; SF etl' "table" \
from "DELPHI_CHARTMETRIC_ETL"."AMAZON"."DIM_AMAZON_TRACK" \
union \
select count(*) "count", 'src; SF main' "table" \
from "DELPHI_CHARTMETRIC_MAIN"."AMAZON"."DIM_AMAZON_TRACK" \
;"""

pg_check_18 = """SELECT 
  uow_meta.unit_of_work.uow_id,
  uow_meta.unit_of_work.status,
  uow_meta.audit_log.extra_data,
  uow_meta.audit_log.new_status
FROM uow_meta.unit_of_work 
INNER JOIN uow_meta.audit_log 
  ON uow_meta.unit_of_work.uow_id = uow_meta.audit_log.uow_id
WHERE status = 'IMPORT_FAILED'
  AND project = 'cm_amazon_playlists'
  AND new_status = 'IMPORT_FAILED'
  AND uow_meta.audit_log.created_at >= current_date - 2
;"""

sf_check_19 = """select count(*) "count", 'src; SF etl' "table" \
from "DELPHI_CHARTMETRIC_ETL"."AMAZON"."CM_AMAZON_PLAYLIST_ID_MAPPING" \
;"""
pg_check_19 = """select count(*) "count", 'dest; pg ' "table"
from AMAZON.CM_AMAZON_PLAYLIST_ID_MAPPING CAPIM
;"""

sf_check_20 = """SELECT COUNT(*) "count" \
FROM DELPHI_CHARTMETRIC_ETL.AMAZON.DIM_AMAZON_TRACK T \
WHERE AMAZON_TRACK_ID IN (SELECT DISTINCT AMAZON_TRACK_ID \
FROM DELPHI_CHARTMETRIC_ETL.AMAZON.FACT_AMAZON_CHART_LIFETIME \
UNION \
SELECT DISTINCT AMAZON_TRACK_ID \
FROM DELPHI_CHARTMETRIC_ETL.AMAZON.AMAZON_PLAYLIST_DAILY_META);"""
pg_check_20 = """select count(*) "count", 'dest; pg' "table"
from AMAZON.DIM_AMAZON_TRACK DAT
;"""

if __name__ == '__main__':
    pass