[dolphinscheduler] branch dev updated: add index (#8500)

[caishunfeng]

This is an automated email from the ASF dual-hosted git repository.

caishunfeng pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new 512f8cb  add index (#8500)
512f8cb is described below

commit 512f8cb5dde7fb42398e7caa50c0c6665b6ec45f
Author: xiangzihao <460888...@qq.com>
AuthorDate: Wed Feb 23 16:53:36 2022 +0800

    add index (#8500)
---
 .../src/main/resources/sql/dolphinscheduler_mysql.sql               | 4 +++-
 .../src/main/resources/sql/dolphinscheduler_postgresql.sql          | 2 ++
 .../sql/upgrade/2.1.0_schema/mysql/dolphinscheduler_ddl.sql         | 2 ++
 .../sql/upgrade/2.1.0_schema/postgresql/dolphinscheduler_ddl.sql    | 6 ++++++
 4 files changed, 13 insertions(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql 
b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql
index d70c6b8d..cde9a55 100644
--- a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql
+++ b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_mysql.sql
@@ -539,7 +539,9 @@ CREATE TABLE `t_ds_process_task_relation` (
   `create_time` datetime NOT NULL COMMENT 'create time',
   `update_time` datetime NOT NULL COMMENT 'update time',
   PRIMARY KEY (`id`),
-  KEY `idx_code` (`project_code`,`process_definition_code`)
+  KEY `idx_code` (`project_code`,`process_definition_code`),
+  KEY `idx_pre_task_code_version` (`pre_task_code`,`pre_task_version`),
+  KEY `idx_post_task_code_version` (`post_task_code`,`post_task_version`)
 ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
 
 -- ----------------------------
diff --git 
a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql 
b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
index 225e3c4..a0329b7 100644
--- 
a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
+++ 
b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
@@ -462,6 +462,8 @@ CREATE TABLE t_ds_process_task_relation (
 ) ;
 
 create index process_task_relation_idx_project_code_process_definition_code on 
t_ds_process_task_relation (project_code,process_definition_code);
+create index process_task_relation_idx_pre_task_code_version on 
t_ds_process_task_relation (pre_task_code, pre_task_version);
+create index process_task_relation_idx_post_task_code_version on 
t_ds_process_task_relation (post_task_code, post_task_version);
 
 --
 -- Table structure for table t_ds_process_task_relation_log
diff --git 
a/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/mysql/dolphinscheduler_ddl.sql
 
b/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/mysql/dolphinscheduler_ddl.sql
index 0723715..b33b580 100644
--- 
a/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/mysql/dolphinscheduler_ddl.sql
+++ 
b/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/mysql/dolphinscheduler_ddl.sql
@@ -18,6 +18,8 @@
 ALTER TABLE `t_ds_task_instance` ADD INDEX `idx_code_version` (`task_code`, 
`task_definition_version`) USING BTREE;
 ALTER TABLE `t_ds_task_instance` MODIFY COLUMN `task_params` longtext COMMENT 
'job custom parameters' AFTER `app_link`;
 ALTER TABLE `t_ds_process_task_relation` ADD KEY `idx_code` (`project_code`, 
`process_definition_code`) USING BTREE;
+ALTER TABLE `t_ds_process_task_relation` ADD KEY `idx_pre_task_code_version` 
(`pre_task_code`,`pre_task_version`);
+ALTER TABLE `t_ds_process_task_relation` ADD KEY `idx_post_task_code_version` 
(`post_task_code`,`post_task_version`);
 ALTER TABLE `t_ds_process_task_relation_log` ADD KEY 
`idx_process_code_version` 
(`process_definition_code`,`process_definition_version`) USING BTREE;
 
 ALTER TABLE `t_ds_task_definition_log` ADD INDEX `idx_project_code` 
(`project_code`) USING BTREE;
diff --git 
a/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/postgresql/dolphinscheduler_ddl.sql
 
b/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/postgresql/dolphinscheduler_ddl.sql
index fc30b0f..1943262 100644
--- 
a/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/postgresql/dolphinscheduler_ddl.sql
+++ 
b/dolphinscheduler-dao/src/main/resources/sql/upgrade/2.1.0_schema/postgresql/dolphinscheduler_ddl.sql
@@ -32,6 +32,12 @@ BEGIN
 EXECUTE 'DROP INDEX IF EXISTS 
"process_task_relation_idx_project_code_process_definition_code"';
 EXECUTE 'CREATE INDEX IF NOT EXISTS 
process_task_relation_idx_project_code_process_definition_code ON ' || 
quote_ident(v_schema) ||'.t_ds_process_task_relation USING 
Btree("project_code","process_definition_code")';
 
+EXECUTE 'DROP INDEX IF EXISTS 
"process_task_relation_idx_pre_task_code_version"';
+EXECUTE 'CREATE INDEX IF NOT EXISTS 
process_task_relation_idx_pre_task_code_version ON ' || quote_ident(v_schema) 
||'.t_ds_process_task_relation USING Btree("pre_task_code","pre_task_version")';
+
+EXECUTE 'DROP INDEX IF EXISTS 
"process_task_relation_idx_post_task_code_version"';
+EXECUTE 'CREATE INDEX IF NOT EXISTS 
process_task_relation_idx_post_task_code_version ON ' || quote_ident(v_schema) 
||'.t_ds_process_task_relation USING 
Btree("post_task_code","post_task_version")';
+
 EXECUTE 'DROP INDEX IF EXISTS 
"process_task_relation_log_idx_project_code_process_definition_code"';
 EXECUTE 'CREATE INDEX IF NOT EXISTS 
process_task_relation_log_idx_project_code_process_definition_code ON ' || 
quote_ident(v_schema) ||'.t_ds_process_task_relation_log USING 
Btree("project_code","process_definition_code")';