CREATE_TABLE = """ CREATE TABLE `{new_table}` ({id_column} PRIMARY KEY) DEFAULT CHARSET=utf8 SELECT * FROM `{old_table}` LIMIT 0; """ RENAME_TABLE = "RENAME TABLE {old_name} TO {new_name};" DROP_TABLE = "DROP TABLE {table};" DOWNLOAD_FROM_S3 = """ LOAD DATA FROM S3 PREFIX '{s3_path}' IGNORE INTO TABLE {table} FIELDS TERMINATED BY ',' ENCLOSED BY '"' LINES TERMINATED BY '\n' IGNORE 1 LINES ({columns}); """ SHOW_CREATE_TABLE = "SHOW CREATE TABLE {table};" SHOW_INDEXES = "SHOW INDEXES FROM {table};" CREATE_INDEX = "ALTER TABLE {table} ADD {index};" GET_VALUE = "SELECT `Value` FROM `tblApolloKeyValueStorage` WHERE `Key` = '{key}';" SET_VALUE = "UPDATE `tblApolloKeyValueStorage` SET `Value` = '{value}' WHERE `Key` = '{key}';" DELETE_DATE_RANGE = "DELETE FROM {table} WHERE `Date` BETWEEN '{start_date}' AND '{end_date}';"