Skip to content
Snippets Groups Projects
Commit 682daaae authored by Patrick Godwin's avatar Patrick Godwin
Browse files

(inj_)snr_simplify_and_cluster.sql: change temp table name to avoid name clash

parent 1d488bd5
No related branches found
No related tags found
No related merge requests found
...@@ -22,7 +22,7 @@ DROP table if EXISTS sim_inspiral; ...@@ -22,7 +22,7 @@ DROP table if EXISTS sim_inspiral;
-- --
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
...@@ -36,28 +36,28 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -36,28 +36,28 @@ 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);
CREATE INDEX tmpindex2 ON _idmap_ (new, old); CREATE INDEX tmpindex2 ON __idmap__ (new, 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 INDEX tmpindex2; DROP INDEX tmpindex2;
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
...@@ -69,15 +69,15 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -69,15 +69,15 @@ 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);
CREATE INDEX tmpindex2 ON _idmap_ (new, old); CREATE INDEX tmpindex2 ON __idmap__ (new, 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 INDEX tmpindex2; DROP INDEX tmpindex2;
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
...@@ -87,7 +87,7 @@ DROP TABLE _idmap_; ...@@ -87,7 +87,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
...@@ -99,14 +99,14 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -99,14 +99,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
...@@ -138,7 +138,7 @@ DROP INDEX tmpindex; ...@@ -138,7 +138,7 @@ DROP INDEX tmpindex;
-- 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,
...@@ -147,17 +147,17 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -147,17 +147,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__;
-- --
......
...@@ -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,28 +34,28 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -34,28 +34,28 @@ 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);
CREATE INDEX tmpindex2 ON _idmap_ (new, old); CREATE INDEX tmpindex2 ON ___idmap___ (new, 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 INDEX tmpindex2; DROP INDEX tmpindex2;
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
...@@ -67,15 +67,15 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -67,15 +67,15 @@ 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);
CREATE INDEX tmpindex2 ON _idmap_ (new, old); CREATE INDEX tmpindex2 ON ___idmap___ (new, 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 INDEX tmpindex2; DROP INDEX tmpindex2;
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
...@@ -85,7 +85,7 @@ DROP TABLE _idmap_; ...@@ -85,7 +85,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
...@@ -97,14 +97,14 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -97,14 +97,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
...@@ -136,7 +136,7 @@ DROP INDEX tmpindex; ...@@ -136,7 +136,7 @@ DROP INDEX tmpindex;
-- 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,
...@@ -145,17 +145,17 @@ CREATE TEMPORARY TABLE _idmap_ AS ...@@ -145,17 +145,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