# PostgreSQL Queries get_yt_asset_report_query = """SELECT * FROM {} LIMIT 1;""" # MySQL Queries check_table_query = """SHOW TABLES LIKE %s;""" create_table_query = """CREATE TABLE `{}` ( `id` BIGINT(20) NOT NULL AUTO_INCREMENT, `filename` VARCHAR(255) DEFAULT NULL, `asset_id` VARCHAR(255) DEFAULT NULL, `custom_id` VARCHAR(1000) DEFAULT NULL, `upc` VARCHAR(255) DEFAULT NULL, `isrc` VARCHAR(255) DEFAULT NULL, `derived_tuid` VARCHAR(50) DEFAULT NULL, `reason` VARCHAR(255) DEFAULT NULL, `derived_ownership` VARCHAR(1000) DEFAULT NULL, -- `derived_conflicts` VARCHAR(1000) DEFAULT NULL, `last_delivery_date` varchar(25) DEFAULT NULL, PRIMARY KEY (`id`) ) DEFAULT CHARSET=utf8mb4;""" source_assets_query = """SELECT * FROM `{}` LIMIT %s OFFSET %s""" get_track_by_upc_and_isrc_query = """SELECT * FROM track WHERE upc = %s AND isrc = %s""" update_tuid_query = """UPDATE `{}` SET derived_tuid = %s, reason = %s, derived_ownership = %s, derived_conflicts = %s WHERE id = %s""" insert_tuid_query = """INSERT INTO `{}` (`custom_id`, `filename`, `asset_id`, `upc`, `isrc`, `derived_tuid`, `reason`, `derived_ownership`, `last_delivery_date`) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s); """ update_isrc_and_upc_query = """UPDATE `{}` SET isrc = %s, upc = %s WHERE id = %s""" get_track_by_itm_query = """SELECT itm.`ioda_track_id`, t.id, t.upc, t.isrc FROM ioda_track_mapping itm LEFT JOIN track t ON itm.`orchard_track_id` = t.`id` WHERE ioda_track_id = %s """ get_track_by_isrc_query = """SELECT id AS tuid, upc FROM track WHERE isrc = %s """ truncate_target_table = """TRUNCATE TABLE `{}`""" get_delivery_history = """SELECT date_delivered FROM delivery_history dh WHERE dh.`customer_master_master_id` = 453 AND upc = %s ORDER BY dh.date_delivered DESC LIMIT 1"""