Skip to content
Snippets Groups Projects
Commit 8fd560e5 authored by chad.hanna's avatar chad.hanna
Browse files

share/ll_simplify_and_cluster.sql: rename tmp table to avoid collision

parent a0c6344e
No related branches found
No related tags found
No related merge requests found
...@@ -20,7 +20,7 @@ ...@@ -20,7 +20,7 @@
-- --
CREATE INDEX tmpindex ON process (node, unix_procid, start_time); CREATE INDEX tmpindex ON process (node, unix_procid, start_time);
CREATE TEMPORARY TABLE _idmap_ AS CREATE TEMPORARY TABLE __idmap__ AS
SELECT SELECT
old.process_id AS old, old.process_id AS old,
MIN(new.process_id) AS new MIN(new.process_id) AS new
...@@ -34,26 +34,26 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -34,26 +34,26 @@ CREATE TEMPORARY TABLE _idmap_ AS
GROUP BY GROUP BY
old.process_id; old.process_id;
DROP INDEX tmpindex; DROP INDEX tmpindex;
CREATE INDEX tmpindex ON _idmap_ (old); CREATE INDEX tmpindex ON __idmap__ (old);
UPDATE coinc_event SET process_id = (SELECT new FROM _idmap_ WHERE old == process_id); UPDATE coinc_event SET process_id = (SELECT new FROM __idmap__ WHERE old == process_id);
UPDATE segment SET process_id = (SELECT new FROM _idmap_ WHERE old == process_id); UPDATE segment SET process_id = (SELECT new FROM __idmap__ WHERE old == process_id);
UPDATE segment_definer SET process_id = (SELECT new FROM _idmap_ WHERE old == process_id); UPDATE segment_definer SET process_id = (SELECT new FROM __idmap__ WHERE old == process_id);
UPDATE segment_summary SET process_id = (SELECT new FROM _idmap_ WHERE old == process_id); UPDATE segment_summary SET process_id = (SELECT new FROM __idmap__ WHERE old == process_id);
UPDATE sngl_inspiral SET process_id = (SELECT new FROM _idmap_ WHERE old == process_id); UPDATE sngl_inspiral SET process_id = (SELECT new FROM __idmap__ WHERE old == process_id);
UPDATE time_slide SET process_id = (SELECT new FROM _idmap_ WHERE old == process_id); UPDATE time_slide SET process_id = (SELECT new FROM __idmap__ WHERE old == process_id);
DELETE FROM process WHERE process_id IN (SELECT old FROM _idmap_ WHERE old != new); DELETE FROM process WHERE process_id IN (SELECT old FROM __idmap__ WHERE old != new);
DELETE FROM process_params WHERE process_id NOT IN (SELECT process_id FROM process); DELETE FROM process_params WHERE process_id NOT IN (SELECT process_id FROM process);
DROP INDEX tmpindex; DROP INDEX tmpindex;
DROP TABLE _idmap_; DROP TABLE __idmap__;
-- --
-- coinc_definer clean up -- coinc_definer clean up
-- --
CREATE TEMPORARY TABLE _idmap_ AS CREATE TEMPORARY TABLE __idmap__ AS
SELECT SELECT
old.coinc_def_id AS old, old.coinc_def_id AS old,
MIN(new.coinc_def_id) AS new MIN(new.coinc_def_id) AS new
...@@ -65,13 +65,13 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -65,13 +65,13 @@ CREATE TEMPORARY TABLE _idmap_ AS
) )
GROUP BY GROUP BY
old.coinc_def_id; old.coinc_def_id;
CREATE INDEX tmpindex ON _idmap_ (old); CREATE INDEX tmpindex ON __idmap__ (old);
UPDATE coinc_event SET coinc_def_id = (SELECT new FROM _idmap_ WHERE old == coinc_def_id); UPDATE coinc_event SET coinc_def_id = (SELECT new FROM __idmap__ WHERE old == coinc_def_id);
DELETE FROM coinc_definer WHERE coinc_def_id IN (SELECT old FROM _idmap_ WHERE old != new); DELETE FROM coinc_definer WHERE coinc_def_id IN (SELECT old FROM __idmap__ WHERE old != new);
DROP INDEX tmpindex; DROP INDEX tmpindex;
DROP TABLE _idmap_; DROP TABLE __idmap__;
-- --
-- segment_definer clean up. NOTE: this assumes no meaningful information -- segment_definer clean up. NOTE: this assumes no meaningful information
...@@ -81,7 +81,7 @@ DROP TABLE _idmap_; ...@@ -81,7 +81,7 @@ DROP TABLE _idmap_;
-- with the higher ID will be discarded. -- with the higher ID will be discarded.
-- --
CREATE TEMPORARY TABLE _idmap_ AS CREATE TEMPORARY TABLE __idmap__ AS
SELECT SELECT
old.segment_def_id AS old, old.segment_def_id AS old,
MIN(new.segment_def_id) AS new MIN(new.segment_def_id) AS new
...@@ -93,14 +93,14 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -93,14 +93,14 @@ CREATE TEMPORARY TABLE _idmap_ AS
) )
GROUP BY GROUP BY
old.segment_def_id; old.segment_def_id;
CREATE INDEX tmpindex ON _idmap_ (old); CREATE INDEX tmpindex ON __idmap__ (old);
UPDATE segment_summary SET segment_def_id = (SELECT new FROM _idmap_ WHERE old == segment_def_id); UPDATE segment_summary SET segment_def_id = (SELECT new FROM __idmap__ WHERE old == segment_def_id);
UPDATE segment SET segment_def_id = (SELECT new FROM _idmap_ WHERE old == segment_def_id); UPDATE segment SET segment_def_id = (SELECT new FROM __idmap__ WHERE old == segment_def_id);
DELETE FROM segment_definer WHERE segment_def_id IN (SELECT old FROM _idmap_ WHERE old != new); DELETE FROM segment_definer WHERE segment_def_id IN (SELECT old FROM __idmap__ WHERE old != new);
DROP INDEX tmpindex; DROP INDEX tmpindex;
DROP TABLE _idmap_; DROP TABLE __idmap__;
-- --
-- segment clean up. NOTE: this assumes that nothing references segment -- segment clean up. NOTE: this assumes that nothing references segment
...@@ -129,7 +129,7 @@ WHERE ...@@ -129,7 +129,7 @@ WHERE
-- time_slide clean up -- time_slide clean up
-- --
CREATE TEMPORARY TABLE _idmap_ AS CREATE TEMPORARY TABLE __idmap__ AS
SELECT SELECT
time_slide_id AS old, time_slide_id AS old,
(SELECT group_concat(instrument || "=" || offset) FROM time_slide AS time_slide_a WHERE time_slide_a.time_slide_id == time_slide.time_slide_id ORDER BY instrument) AS repr, (SELECT group_concat(instrument || "=" || offset) FROM time_slide AS time_slide_a WHERE time_slide_a.time_slide_id == time_slide.time_slide_id ORDER BY instrument) AS repr,
...@@ -138,17 +138,17 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -138,17 +138,17 @@ CREATE TEMPORARY TABLE _idmap_ AS
time_slide time_slide
GROUP BY GROUP BY
time_slide_id; time_slide_id;
CREATE INDEX tmpindex ON _idmap_ (repr, old); CREATE INDEX tmpindex ON __idmap__ (repr, old);
UPDATE _idmap_ SET new = (SELECT MIN(old) FROM _idmap_ AS a WHERE a.repr == _idmap_.repr); UPDATE __idmap__ SET new = (SELECT MIN(old) FROM __idmap__ AS a WHERE a.repr == __idmap__.repr);
DROP INDEX tmpindex; DROP INDEX tmpindex;
CREATE INDEX tmpindex ON _idmap_ (old); CREATE INDEX tmpindex ON __idmap__ (old);
UPDATE coinc_event SET time_slide_id = (SELECT _idmap_.new FROM _idmap_ WHERE _idmap_.old == time_slide_id); UPDATE coinc_event SET time_slide_id = (SELECT __idmap__.new FROM __idmap__ WHERE __idmap__.old == time_slide_id);
DELETE FROM time_slide WHERE time_slide_id IN (SELECT old FROM _idmap_ WHERE old != new); DELETE FROM time_slide WHERE time_slide_id IN (SELECT old FROM __idmap__ WHERE old != new);
DROP INDEX tmpindex; DROP INDEX tmpindex;
DROP TABLE _idmap_; DROP TABLE __idmap__;
-- --
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment