"""Constants for queries.""" # setup queries # setup encoding queue entries INSERT_ENCODING_QUEUE = """ INSERT INTO encoding_queue ( encoding_queue_id, encoding_order_id, priority, encoder_id, encoding_order_type) VALUES (100, 1000, 1, 18, 'release') """ # setup encoding queue detail entries INSERT_ENCODING_QUEUE_DETAILS = """ INSERT INTO encoding_queue_detail ( encoding_queue_detail_id, encoding_queue_id, upc, dms_master_master_id) VALUES (1011, 100, 12345678901, 12), (1012, 100, 12345678902, 12), (1013, 100, 12345678903, 12), (1014, 100, 12345678904, 12), (1015, 100, 12345678905, 12) """ # cleanup queries # remove job_priority entries REMOVE_JOB_PRIORITY = """ DELETE jp.* FROM job_priority jp INNER JOIN encoding_queue_detail eqd ON eqd.encoding_queue_detail_id = jp.encoding_queue_detail_id WHERE eqd.encoding_queue_id = 100; """ # remove encoding queue detail entries REMOVE_ENCODING_QUEUE_DETAILS = """ DELETE FROM encoding_queue_detail WHERE encoding_queue_id = 100; """ # remove encoding_queue entry REMOVE_ENCODING_QUEUE_ENTRY = """ DELETE FROM encoding_queue WHERE encoding_queue_id = 100; """ # assert queries # assert job entries ASSERT_JOB_INSERT = """ SELECT eq.priority as order_priority, eqd.upc, GROUP_CONCAT(eqd.encoding_queue_detail_id) AS encoding_queue_detail_id FROM encoding_queue eq INNER JOIN encoding_queue_detail eqd ON eq.encoding_queue_id = eqd.encoding_queue_id INNER JOIN dms_delivery_spec dds ON dds.dms_master_master_id = eqd.dms_master_master_id AND eq.encoding_order_type = dds.order_type AND dds.encoding = 'y' LEFT JOIN job_priority jp ON eqd.encoding_queue_detail_id = jp.encoding_queue_detail_id WHERE eq.encoding_queue_id = 100 GROUP BY eqd.upc; """