blob: bb32d3f438dcbe281944e612b18a40132cb08c05 [file]
use experiment_catalog;
ALTER TABLE EXPERIMENT_INPUT ADD COLUMN IF NOT EXISTS OVERRIDE_FILENAME VARCHAR(255);
ALTER TABLE PROCESS_INPUT ADD COLUMN IF NOT EXISTS OVERRIDE_FILENAME VARCHAR(255);
CREATE TABLE IF NOT EXISTS GATEWAY_USAGE_REPORTING_COMMAND (
GATEWAY_ID VARCHAR(255) NOT NULL,
COMPUTE_RESOURCE_ID VARCHAR(255) NOT NULL,
COMMAND LONGTEXT NOT NULL,
PRIMARY KEY (GATEWAY_ID, COMPUTE_RESOURCE_ID)
)ENGINE=InnoDB DEFAULT CHARSET=latin1;
-- AIRAVATA-3369: Convert USER_FRIENDLY_DESCRIPTION from VARCHAR to TEXT (CLOB)
alter table EXPERIMENT_INPUT modify column USER_FRIENDLY_DESCRIPTION TEXT;
alter table PROCESS_INPUT modify column USER_FRIENDLY_DESCRIPTION TEXT;
CREATE TABLE IF NOT EXISTS COMPUTE_RESOURCE_SCHEDULING (
EXPERIMENT_ID varchar(255) NOT NULL,
RESOURCE_HOST_ID varchar(255) NOT NULL,
TOTAL_CPU_COUNT INT,
NODE_COUNT INT,
NUMBER_OF_THREADS INT,
QUEUE_NAME varchar(255) NOT NULL,
WALL_TIME_LIMIT INT,
TOTAL_PHYSICAL_MEMORY INT,
STATIC_WORKING_DIR varchar(255),
OVERRIDE_LOGIN_USER_NAME varchar(255),
OVERRIDE_SCRATCH_LOCATION varchar(255),
OVERRIDE_ALLOCATION_PROJECT_NUMBER varchar(255),
PARALLEL_GROUP_COUNT INT,
PRIMARY KEY (EXPERIMENT_ID,RESOURCE_HOST_ID,QUEUE_NAME),
FOREIGN KEY (EXPERIMENT_ID) REFERENCES EXPERIMENT(EXPERIMENT_ID) ON DELETE CASCADE
)ENGINE=InnoDB DEFAULT CHARSET=latin1;
-- Rename storage resource ID to input storage resource ID
ALTER TABLE USER_CONFIGURATION_DATA CHANGE COLUMN STORAGE_RESOURCE_ID INPUT_STORAGE_RESOURCE_ID VARCHAR(255) DEFAULT NULL;
ALTER TABLE PROCESS CHANGE COLUMN STORAGE_RESOURCE_ID INPUT_STORAGE_RESOURCE_ID VARCHAR(255) DEFAULT NULL;
-- Add output storage resource ID columns
ALTER TABLE USER_CONFIGURATION_DATA ADD COLUMN IF NOT EXISTS OUTPUT_STORAGE_RESOURCE_ID VARCHAR(255) DEFAULT NULL;
ALTER TABLE PROCESS ADD COLUMN IF NOT EXISTS OUTPUT_STORAGE_RESOURCE_ID VARCHAR(255) DEFAULT NULL;
-- Update OUTPUT_STORAGE_RESOURCE_ID with INPUT_STORAGE_RESOURCE_ID when missing
UPDATE USER_CONFIGURATION_DATA
SET OUTPUT_STORAGE_RESOURCE_ID = INPUT_STORAGE_RESOURCE_ID
WHERE (OUTPUT_STORAGE_RESOURCE_ID IS NULL OR OUTPUT_STORAGE_RESOURCE_ID = '')
AND INPUT_STORAGE_RESOURCE_ID IS NOT NULL
AND INPUT_STORAGE_RESOURCE_ID != '';
UPDATE PROCESS
SET OUTPUT_STORAGE_RESOURCE_ID = INPUT_STORAGE_RESOURCE_ID
WHERE (OUTPUT_STORAGE_RESOURCE_ID IS NULL OR OUTPUT_STORAGE_RESOURCE_ID = '')
AND INPUT_STORAGE_RESOURCE_ID IS NOT NULL
AND INPUT_STORAGE_RESOURCE_ID != '';