Add scripts to delete DC and DCG rows and associated rows in other tables

Author: KarlLevik

schemas/ispyb/scripts/DataCollectionGroup_delete.sql

@@ -0,0 +1,34 @@
+-- This is a script to delete a given DataCollectionGroup (by
+-- dataCollectionGroupId) and all associated rows in other tables except
+-- DataCollection.
+-- To delete DataCollections, run the DataCollection_delete.sql script first
+-- before you run this.
+-- Change the value of @dcgId and @sessionId to the values of
+-- dataCollectionGroupId and sessionId you would like to delete.
+-- Disclaimer:
+-- This script is not extensively tested.
+-- Run this at your own risk and beware of cascading deletes.
+
+SET @dcgId := 1000;
+SET @sessionId = 999;
+
+DELETE XrayCentringResult
+FROM XrayCentringResult
+  JOIN XrayCentring
+WHERE XrayCentring.xrayCentringId = XrayCentringResult.xrayCentringId AND
+  XrayCentring.dataCollectionGroupId = @dcgId;
+
+DELETE
+FROM XrayCentring
+WHERE dataCollectionGroupId = @dcgId;
+
+DELETE
+FROM DataCollectionGroup
+WHERE dataCollectionGroupId = @dcgId;
+
+DELETE RobotAction
+FROM RobotAction
+  JOIN DataCollectionGroup
+WHERE RobotAction.blsessionId = @sessionId AND
+  DataCollectionGroup.blSampleId = RobotAction.blSampleId AND
+  DataCollectionGroup.dataCollectionGroupId = @dcgId;

schemas/ispyb/scripts/DataCollection_delete.sql

@@ -0,0 +1,69 @@
+-- This is a script to delete a given DataCollection (by dataCollectionId) and
+-- all associated rows in other tables.
+-- Change the value of @dcId to the dataCollectionId you would like to delete.
+-- Disclaimer:
+-- This script is not extensively tested. It also currently will leave behind
+-- some orphaned rows.
+-- Run this at your own risk and beware of cascading deletes.
+
+SET @dcId := 1000;
+
+DELETE
+FROM ImageQualityIndicators
+WHERE dataCollectionId = @dcId;
+
+DELETE ProcessingJobParameter
+FROM ProcessingJobParameter
+  JOIN ProcessingJob
+WHERE ProcessingJob.processingJobId = ProcessingJobParameter.processingJobId AND
+  ProcessingJob.dataCollectionId = @dcId;
+
+DELETE ProcessingJobImageSweep
+FROM ProcessingJobImageSweep
+  JOIN ProcessingJob
+WHERE ProcessingJob.processingJobId = ProcessingJobImageSweep.processingJobId AND
+  ProcessingJob.dataCollectionId = @dcId;
+
+DELETE AutoProcProgramMessage
+FROM AutoProcProgramMessage
+  JOIN ProcessingJob
+  JOIN AutoProcProgram
+WHERE ProcessingJob.processingJobId = AutoProcProgram.processingJobId AND
+  AutoProcProgramMessage.autoProcProgramId = AutoProcProgram.autoProcProgramId AND
+  ProcessingJob.dataCollectionId = @dcId;
+
+DELETE AutoProcProgram
+FROM AutoProcProgram
+  JOIN ProcessingJob
+WHERE ProcessingJob.processingJobId = AutoProcProgram.processingJobId AND
+  ProcessingJob.dataCollectionId = @dcId;
+
+DELETE
+FROM ProcessingJob
+WHERE dataCollectionId = @dcId;
+
+DELETE AutoProcProgramMessage
+FROM AutoProcProgramMessage
+  JOIN AutoProcProgram
+  JOIN AutoProcIntegration
+WHERE AutoProcIntegration.autoProcProgramId = AutoProcProgram.autoProcProgramId AND
+  AutoProcProgramMessage.autoProcProgramId = AutoProcProgram.autoProcProgramId AND
+  AutoProcIntegration.dataCollectionId = @dcId;
+
+DELETE AutoProcProgram
+FROM AutoProcProgram
+  JOIN AutoProcIntegration
+WHERE AutoProcIntegration.autoProcProgramId = AutoProcProgram.autoProcProgramId AND
+  AutoProcIntegration.dataCollectionId = @dcId;
+
+DELETE
+FROM AutoProcIntegration
+WHERE dataCollectionId = @dcId;
+
+DELETE
+FROM GridInfo
+WHERE dataCollectionId = @dcId;
+
+DELETE
+FROM DataCollection
+WHERE dataCollectionId = @dcId;