"""RDS queries.""" # The query needs as many "%s" (placeholder value) as there are columns # The columns use the order of declaration in the class, not the "column_order" # The "ingest_format" class field is called "format" in the DB INSERT_INTO_CATALOG_INGESTION = """ INSERT INTO catalog_ingestion ( state_machine_name, state_machine_execution_name, s3_bucket_name, s3_key_name, format, timestamp, catalog_ingestion_source_id, vendor_id, subaccount_id, status, error_message ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s); """ INSERT_INTO_CATALOG_INGESTION_ACTION = """ INSERT INTO catalog_ingestion_action ( state_machine_name, state_machine_execution_name, action, entity_type, result, time_created, project_code, project_id, project_name, upc, release_id, release_name, vendor_catalog_number, isrc, tuid, track_sequence_number, track_volume_number, track_name, message ) VALUES ( %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s); """ INSERT_INTO_CATALOG_INGESTION_VALIDATION_RESULT = """ INSERT INTO catalog_ingestion_validation_result ( state_machine_name, state_machine_execution_name, validation_rule_id, response, message, isrc, category ) VALUES (%s, %s, %s, %s, %s, %s, %s); """