cleandb.sql

DELETE FROM failure_event;
DELETE FROM runtime_attributes;
DELETE FROM execution_info;
DELETE FROM symbol;
DELETE FROM workflow_execution_aux;
DELETE FROM execution_event;
DELETE FROM execution;
DELETE FROM workflow_execution;

ALTER TABLE failure_event AUTO_INCREMENT = 1;
ALTER TABLE runtime_attributes AUTO_INCREMENT = 1;
ALTER TABLE execution_info AUTO_INCREMENT = 1;
ALTER TABLE symbol AUTO_INCREMENT = 1;
ALTER TABLE workflow_execution_aux AUTO_INCREMENT = 1;
ALTER TABLE execution_event AUTO_INCREMENT = 1;
ALTER TABLE execution AUTO_INCREMENT = 1;
ALTER TABLE workflow_execution AUTO_INCREMENT = 1;

queries_ordered.sql

=========================
= Session 1
=========================

SET autocommit=0;
insert into `WORKFLOW_EXECUTION` (`WORKFLOW_EXECUTION_UUID`,`WORKFLOW_NAME`,`STATUS`,`START_DT`,`END_DT`)  values ('3db8b664-177d-40e7-9176-0f1e0e05be7a','w','Submitted','2016-04-01 09:09:25.322',null);
insert into `WORKFLOW_EXECUTION_AUX` (`WORKFLOW_EXECUTION_ID`,`WDL_SOURCE`,`JSON_INPUTS`,`WORKFLOW_OPTIONS`)  values (1,'task a {command{}}\nworkflow w {\n  call a\n  call a as b\n  call a as c\n}\n          ','{}','{}');
insert into `EXECUTION` (`WORKFLOW_EXECUTION_ID`,`CALL_FQN`,`IDX`,`STATUS`,`RC`,`START_DT`,`END_DT`,`BACKEND_TYPE`,`ALLOWS_RESULT_REUSE`,`DOCKER_IMAGE_HASH`,`RESULTS_CLONED_FROM`,`EXECUTION_HASH`,`ATTEMPT`)  values (1,'w.a',-1,'NotStarted',null,null,null,'Local',1,null,null,null,1);
insert into `EXECUTION_INFO` (`EXECUTION_ID`,`INFO_KEY`,`INFO_VALUE`)  values (1,'PID',null);
insert into `EXECUTION` (`WORKFLOW_EXECUTION_ID`,`CALL_FQN`,`IDX`,`STATUS`,`RC`,`START_DT`,`END_DT`,`BACKEND_TYPE`,`ALLOWS_RESULT_REUSE`,`DOCKER_IMAGE_HASH`,`RESULTS_CLONED_FROM`,`EXECUTION_HASH`,`ATTEMPT`)  values (1,'w.b',-1,'NotStarted',null,null,null,'Local',1,null,null,null,1);
insert into `EXECUTION_INFO` (`EXECUTION_ID`,`INFO_KEY`,`INFO_VALUE`)  values (2,'PID',null);
insert into `EXECUTION` (`WORKFLOW_EXECUTION_ID`,`CALL_FQN`,`IDX`,`STATUS`,`RC`,`START_DT`,`END_DT`,`BACKEND_TYPE`,`ALLOWS_RESULT_REUSE`,`DOCKER_IMAGE_HASH`,`RESULTS_CLONED_FROM`,`EXECUTION_HASH`,`ATTEMPT`)  values (1,'w.c',-1,'NotStarted',null,null,null,'Local',1,null,null,null,1);
insert into `EXECUTION_INFO` (`EXECUTION_ID`,`INFO_KEY`,`INFO_VALUE`)  values (3,'PID',null);
SET autocommit=0;

=========================
= Session 2
=========================

SET autocommit=0

=========================
= Session 3
=========================

SET autocommit=0;
select s58.`WORKFLOW_EXECUTION_ID`, s58.`CALL_FQN`, s58.`IDX`, s58.`STATUS`, s58.`RC`, s58.`START_DT`, s58.`END_DT`, s58.`BACKEND_TYPE`, s58.`ALLOWS_RESULT_REUSE`, s58.`DOCKER_IMAGE_HASH`, s58.`RESULTS_CLONED_FROM`, s58.`EXECUTION_HASH`, s58.`ATTEMPT`, s58.`EXECUTION_ID` from `EXECUTION` s58, `WORKFLOW_EXECUTION` s59 where (((s58.`CALL_FQN` = 'w.b') and (s58.`IDX` = -1)) and (s58.`ATTEMPT` = 1)) and ((s59.`WORKFLOW_EXECUTION_ID` = s58.`WORKFLOW_EXECUTION_ID`) and (s59.`WORKFLOW_EXECUTION_UUID` = '3db8b664-177d-40e7-9176-0f1e0e05be7a'));

=========================
= Session 2
=========================

select s58.`WORKFLOW_EXECUTION_ID`, s58.`CALL_FQN`, s58.`IDX`, s58.`STATUS`, s58.`RC`, s58.`START_DT`, s58.`END_DT`, s58.`BACKEND_TYPE`, s58.`ALLOWS_RESULT_REUSE`, s58.`DOCKER_IMAGE_HASH`, s58.`RESULTS_CLONED_FROM`, s58.`EXECUTION_HASH`, s58.`ATTEMPT`, s58.`EXECUTION_ID` from `EXECUTION` s58, `WORKFLOW_EXECUTION` s59 where (((s58.`CALL_FQN` = 'w.a') and (s58.`IDX` = -1)) and (s58.`ATTEMPT` = 1)) and ((s59.`WORKFLOW_EXECUTION_ID` = s58.`WORKFLOW_EXECUTION_ID`) and (s59.`WORKFLOW_EXECUTION_UUID` = '3db8b664-177d-40e7-9176-0f1e0e05be7a'));

=========================
= Session 1
=========================

commit;
select s49.`WORKFLOW_EXECUTION_ID`, s49.`CALL_FQN`, s49.`IDX`, s49.`STATUS`, s49.`RC`, s49.`START_DT`, s49.`END_DT`, s49.`BACKEND_TYPE`, s49.`ALLOWS_RESULT_REUSE`, s49.`DOCKER_IMAGE_HASH`, s49.`RESULTS_CLONED_FROM`, s49.`EXECUTION_HASH`, s49.`ATTEMPT`, s49.`EXECUTION_ID` from `EXECUTION` s49, `WORKFLOW_EXECUTION` s50 where (s50.`WORKFLOW_EXECUTION_ID` = s49.`WORKFLOW_EXECUTION_ID`) and (s50.`WORKFLOW_EXECUTION_UUID` = '3db8b664-177d-40e7-9176-0f1e0e05be7a');
commit;

=========================
= Session 2
=========================

insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (1,'e','1',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);

=========================
= Session 3
=========================

insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (2,'e','1',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);

# !!!!!! The query above is where MySQL will hang !!!!!!

=========================
= Session 2
=========================

insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (1,'f','2.2',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);
insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (1,'a','foo',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);

=========================
= Session 3
=========================

rollback;

=========================
= Session 2
=========================

insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (1,'b','1',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);
insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (1,'c','2.2',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);
insert into `RUNTIME_ATTRIBUTES` (`EXECUTION_ID`,`ATTRIBUTE_NAME`,`ATTRIBUTE_VALUE`,`RUNTIME_ATTRIBUTE_ID`)  values (1,'d','foo',null) on duplicate key update `EXECUTION_ID`=VALUES(`EXECUTION_ID`), `ATTRIBUTE_NAME`=VALUES(`ATTRIBUTE_NAME`), `ATTRIBUTE_VALUE`=VALUES(`ATTRIBUTE_VALUE`);
commit;