diff --git a/mysql/alter_tables_0.13.0.sql b/mysql/alter_tables_0.13.0.sql deleted file mode 100644 index b2046be8..00000000 --- a/mysql/alter_tables_0.13.0.sql +++ /dev/null @@ -1,5 +0,0 @@ -ALTER TABLE mxq_group - ADD COLUMN ( - depends_on_group INT8 UNSIGNED NULL DEFAULT NULL, - dependency_of_group INT8 UNSIGNED NULL DEFAULT NULL - ); diff --git a/mysql/alter_tables_0.15.0.sql b/mysql/alter_tables_0.15.0.sql deleted file mode 100644 index 95faa894..00000000 --- a/mysql/alter_tables_0.15.0.sql +++ /dev/null @@ -1,11 +0,0 @@ -ALTER TABLE mxq_group - ADD COLUMN - job_max_per_node INT2 UNSIGNED NOT NULL DEFAULT 0 - AFTER - job_time; - -ALTER TABLE mxq_job - ADD COLUMN - host_id VARCHAR(1023) NOT NULL DEFAULT "" - AFTER - server_id; diff --git a/mysql/alter_tables_0.17.0.sql b/mysql/alter_tables_0.17.0.sql deleted file mode 100644 index b9daa722..00000000 --- a/mysql/alter_tables_0.17.0.sql +++ /dev/null @@ -1,11 +0,0 @@ -ALTER TABLE mxq_group - ADD COLUMN - stats_max_sumrss INT8 UNSIGNED NOT NULL DEFAULT 0 - AFTER - group_date_end; - -ALTER TABLE mxq_job - ADD COLUMN - stats_max_sumrss INT8 UNSIGNED NOT NULL DEFAULT 0 - AFTER - job_id_first; diff --git a/mysql/alter_tables_0.18.2.sql b/mysql/alter_tables_0.18.2.sql deleted file mode 100644 index 1be5d73d..00000000 --- a/mysql/alter_tables_0.18.2.sql +++ /dev/null @@ -1,5 +0,0 @@ -ALTER TABLE mxq_job - ADD COLUMN - host_cpu_set VARCHAR(4095) NOT NULL DEFAULT "" - AFTER - host_slots; diff --git a/mysql/alter_tables_0.21.3.sql b/mysql/alter_tables_0.21.3.sql deleted file mode 100644 index 19365a67..00000000 --- a/mysql/alter_tables_0.21.3.sql +++ /dev/null @@ -1,46 +0,0 @@ - -ALTER TABLE mxq_group - MODIFY COLUMN - group_name VARCHAR(128) NOT NULL DEFAULT 'default', - MODIFY COLUMN - user_name VARCHAR(256) NOT NULL, - MODIFY COLUMN - user_group VARCHAR(256) NOT NULL, - MODIFY COLUMN - job_command VARCHAR(256) NOT NULL; - -ALTER TABLE mxq_job - MODIFY COLUMN - job_workdir VARCHAR(4096) NOT NULL, - MODIFY COLUMN - job_argc INT4 UNSIGNED NOT NULL, - MODIFY COLUMN - job_argv VARCHAR(32768) NOT NULL, - MODIFY COLUMN - job_stdout VARCHAR(4096) NOT NULL DEFAULT '/dev/null', - MODIFY COLUMN - job_stderr VARCHAR(4096) NOT NULL DEFAULT '/dev/null', - MODIFY COLUMN - server_id VARCHAR(64) NOT NULL DEFAULT "", - MODIFY COLUMN - host_id VARCHAR(128) NOT NULL DEFAULT "", - MODIFY COLUMN - host_cpu_set VARCHAR(4096) NOT NULL DEFAULT "", - DROP INDEX - server_id, - ADD INDEX - server_id (server_id(64)); - -ALTER TABLE mxq_job - ADD INDEX - host_id (host_id(128)); - -DROP TABLE IF EXISTS mxq_server; - -ALTER TABLE mxq_job - ADD COLUMN - daemon_id INT4 UNSIGNED NOT NULL DEFAULT 0 - AFTER - host_id, - ADD INDEX - daemon_id (daemon_id); diff --git a/mysql/alter_tables_0.22.2.sql b/mysql/alter_tables_0.22.2.sql deleted file mode 100644 index 309ed9e7..00000000 --- a/mysql/alter_tables_0.22.2.sql +++ /dev/null @@ -1,5 +0,0 @@ -ALTER TABLE mxq_group - ADD COLUMN - group_sum_starttime INT8 UNSIGNED NOT NULL DEFAULT 0 - AFTER group_slots_running; - diff --git a/mysql/alter_tables_0.24.0-post.sql b/mysql/alter_tables_0.24.0-post.sql deleted file mode 100644 index dadfc7d7..00000000 --- a/mysql/alter_tables_0.24.0-post.sql +++ /dev/null @@ -1,2 +0,0 @@ -ALTER TABLE mxq_daemon - DROP COLUMN daemon_time; diff --git a/mysql/alter_tables_0.24.0-pre.sql b/mysql/alter_tables_0.24.0-pre.sql deleted file mode 100644 index a0adb28c..00000000 --- a/mysql/alter_tables_0.24.0-pre.sql +++ /dev/null @@ -1,4 +0,0 @@ -ALTER TABLE mxq_daemon - ADD COLUMN - daemon_maxtime INT8 UNSIGNED NOT NULL DEFAULT 0 - AFTER daemon_memory; diff --git a/mysql/create_tables.sql b/mysql/create_tables.sql index 6fd0db8d..ce12f9ab 100644 --- a/mysql/create_tables.sql +++ b/mysql/create_tables.sql @@ -6,7 +6,8 @@ CREATE TABLE IF NOT EXISTS mxq_group ( group_priority INT2 UNSIGNED NOT NULL DEFAULT 127, group_blacklist VARCHAR(1000) NOT NULL DEFAULT '', group_whitelist VARCHAR(1000) NOT NULL DEFAULT '', - prerequisites VARCHAR(40) NOT NULL DEFAULT '', + prerequisites VARCHAR(1000) NOT NULL DEFAULT '', + tags VARCHAR(1000) NOT NULL DEFAULT '', user_uid INT4 UNSIGNED NOT NULL, user_name VARCHAR(256) NOT NULL, @@ -167,7 +168,8 @@ CREATE TABLE IF NOT EXISTS mxq_daemon ( daemon_stop TIMESTAMP NOT NULL DEFAULT 0, daemon_flags INT4 NOT NULL DEFAULT 0, - prerequisites VARCHAR(1024) NOT NULL DEFAULT '', + prerequisites VARCHAR(1000) NOT NULL DEFAULT '', + tags VARCHAR(1000) NOT NULL DEFAULT '', INDEX (daemon_name(64)), INDEX (hostname(64)) diff --git a/mysql/drop_tables.sql b/mysql/drop_tables.sql deleted file mode 100644 index b70e280f..00000000 --- a/mysql/drop_tables.sql +++ /dev/null @@ -1,3 +0,0 @@ -DROP TABLE IF EXISTS mxq_group; -DROP TABLE IF EXISTS mxq_job; -DROP TABLE IF EXISTS mxq_daemon; diff --git a/mysql/fix_cancelled_job_dates.sql b/mysql/fix_cancelled_job_dates.sql deleted file mode 100644 index 4a935764..00000000 --- a/mysql/fix_cancelled_job_dates.sql +++ /dev/null @@ -1,8 +0,0 @@ -UPDATE mxq_job - JOIN mxq_group - ON mxq_job.group_id = mxq_group.group_id - SET mxq_job.date_start = mxq_group.group_date_end, - mxq_job.date_end = mxq_group.group_date_end - WHERE job_status = 990 - AND (date_start = 0 OR date_end = 0); - diff --git a/mysql/fix_host_id.sql b/mysql/fix_host_id.sql deleted file mode 100644 index c3c6fa35..00000000 --- a/mysql/fix_host_id.sql +++ /dev/null @@ -1,7 +0,0 @@ -UPDATE mxq_job - SET - host_id = CONCAT(host_hostname, '::', server_id) - WHERE - host_id = "" - AND server_id != "" - AND host_hostname != ""; diff --git a/mysql/fix_stats_runwaitidle_sec.sql b/mysql/fix_stats_runwaitidle_sec.sql deleted file mode 100644 index ea1c7ce7..00000000 --- a/mysql/fix_stats_runwaitidle_sec.sql +++ /dev/null @@ -1,173 +0,0 @@ - --- fix stats_wait_sec, stats_run_sec, stats_idle_sec in mxq_group --- for all finished groups (group_date_end > 0) - --- do not touch active jobs - -DROP TEMPORARY TABLE IF EXISTS - mytemp; - -SET - @sinq=0, - @srun=0, - @gid=0, - @dt=0, - @ot=0, - @gidchange=0, - @last="none" - ; - -CREATE TEMPORARY TABLE IF NOT EXISTS - mytemp -AS -( - SELECT - group_id, - MAX(IF(last = "run", dtime, 0)) AS run, - MAX(IF(last = "wait", dtime, 0)) AS wait, - MAX(IF(last = "idle", dtime, 0)) AS idle, - MAX(date_end) AS date_end - FROM - ( - SELECT - group_id, - last, - SUM(dt) AS dtime, - MAX(date_end) AS date_end - FROM - ( - SELECT - @gidchange := @gid != group_id AS gidchange, - @gid := group_id AS group_id, - time, - sdinq, - sdrun, - @sinq := IF(@gidchange = 1, - sdinq, - @sinq + sdinq - ) AS sinq, - @srun := IF(@gidchange = 1, - sdrun, - @srun + sdrun - ) AS srun, - IF(@gidchange, "new", @last) as last, - @last := IF(@srun > 0, - "run", - IF(@sinq > 0, - "wait", - "idle" - ) - ) AS phase, - @dt := IF(@gidchange, - 0, - time - @ot - ) AS dt, - @ot := time, - date_end - FROM - ( - SELECT - group_id, - time, - SUM(dinq) as sdinq, - SUM(drun) as sdrun, - MAX(date_end) AS date_end - FROM - ( - ( - SELECT - mxq_job.group_id AS group_id, - job_status, - unix_timestamp(date_submit) AS time, - 1 AS event, - 1 AS dinq, - 0 AS drun, - date_end - FROM - mxq_job - ) - UNION ALL - ( - SELECT - mxq_job.group_id AS group_id, - job_status, - unix_timestamp(date_start), - 2, - -1, - 1, - date_end - FROM - mxq_job - WHERE - date_start > 0 - ) - UNION ALL - ( - SELECT - mxq_job.group_id AS group_id, - job_status, - unix_timestamp(date_end), - 3, - 0, - -1, - date_end - FROM - mxq_job - WHERE - date_end > 0 - ) - ORDER BY - group_id, - time, - event - ) AS S1 - GROUP BY - group_id, - time - ORDER BY - group_id, - time - ) AS S2 - ) AS S3 - WHERE - last != "new" - GROUP BY - group_id, - last - ORDER BY - group_id, - last - ) AS S4 - GROUP BY - group_id -) -; - -SET - @sinq=0, - @srun=0, - @gid=0, - @dt=0, - @ot=0, - @gidchange=0, - @last="none" - ; - -UPDATE - mxq_group AS g - LEFT JOIN - mytemp AS t - ON - g.group_id = t.group_id - SET - g.stats_wait_sec = wait, - g.stats_run_sec = run, - g.stats_idle_sec = idle - WHERE - t.group_id - AND - g.group_date_end -; - -DROP TEMPORARY TABLE IF EXISTS - mytemp; diff --git a/mysql/fix_sum_starttime.sql b/mysql/fix_sum_starttime.sql deleted file mode 100644 index 2f49099a..00000000 --- a/mysql/fix_sum_starttime.sql +++ /dev/null @@ -1,41 +0,0 @@ - -LOCK TABLES mxq_group WRITE, mxq_job WRITE; - -UPDATE - mxq_group -SET - group_slots_running = 0, - group_sum_starttime = 0; - -UPDATE - mxq_group -JOIN ( - SELECT - group_id, - SUM(S) AS rs, - SUM(SS) AS ss - FROM ( - SELECT - group_id, - host_slots, - COUNT(job_id) AS N, - SUM(host_slots) AS S, - SUM(UNIX_TIMESTAMP(date_start)) AS SS - FROM - mxq_job - WHERE - job_status IN (150, 200) - GROUP BY - group_id, - host_slots - ) AS ANONYM - GROUP BY - group_id - ) AS J - ON - mxq_group.group_id = J.group_id - SET - group_slots_running = rs, - group_sum_starttime = ss; - -UNLOCK TABLES; diff --git a/mysql/migrate_010_add_mxq_daemon_tags.sql b/mysql/migrate_010_add_mxq_daemon_tags.sql new file mode 100644 index 00000000..0057f9df --- /dev/null +++ b/mysql/migrate_010_add_mxq_daemon_tags.sql @@ -0,0 +1,9 @@ +ALTER TABLE mxq_daemon MODIFY COLUMN prerequisites VARCHAR(1000) NOT NULL DEFAULT ''; + +ALTER TABLE mxq_daemon + ADD COLUMN + tags VARCHAR(1000) NOT NULL DEFAULT '' + AFTER + prerequisites; + +UPDATE mxq_daemon SET tags=prerequisites; diff --git a/mysql/migrate_010_add_mxq_group_tags.sql b/mysql/migrate_010_add_mxq_group_tags.sql new file mode 100644 index 00000000..46141af2 --- /dev/null +++ b/mysql/migrate_010_add_mxq_group_tags.sql @@ -0,0 +1,6 @@ +ALTER TABLE mxq_group MODIFY COLUMN prerequisites VARCHAR(1000) NOT NULL DEFAULT ''; +ALTER TABLE mxq_group + ADD COLUMN + tags VARCHAR(1000) NOT NULL DEFAULT '' + AFTER + prerequisites;