You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@dolphinscheduler.apache.org by GitBox <gi...@apache.org> on 2021/05/12 10:32:36 UTC
[GitHub] [dolphinscheduler] lenboo commented on a change in pull request #5390: [Feature-4417] Process definition json split
lenboo commented on a change in pull request #5390:
URL: https://github.com/apache/dolphinscheduler/pull/5390#discussion_r630921994
##########
File path: sql/dolphinscheduler_postgre.sql
##########
@@ -287,52 +287,146 @@ CREATE TABLE t_ds_error_command (
DROP TABLE IF EXISTS t_ds_process_definition;
CREATE TABLE t_ds_process_definition (
id int NOT NULL ,
+ code bigint NOT NULL,
name varchar(255) DEFAULT NULL ,
version int DEFAULT NULL ,
+ description text ,
+ project_code bigint DEFAULT NULL ,
release_state int DEFAULT NULL ,
- project_id int DEFAULT NULL ,
user_id int DEFAULT NULL ,
- process_definition_json text ,
- description text ,
global_params text ,
- flag int DEFAULT NULL ,
locations text ,
connects text ,
- warning_group_id int4 DEFAULT NULL ,
- create_time timestamp DEFAULT NULL ,
+ warning_group_id int DEFAULT NULL ,
+ flag int DEFAULT NULL ,
timeout int DEFAULT '0' ,
- tenant_id int NOT NULL DEFAULT '-1' ,
+ tenant_id int DEFAULT '-1' ,
+ create_time timestamp DEFAULT NULL ,
update_time timestamp DEFAULT NULL ,
- modify_by varchar(36) DEFAULT '' ,
- resource_ids varchar(64),
- PRIMARY KEY (id),
- CONSTRAINT process_definition_unique UNIQUE (name, project_id)
+ PRIMARY KEY (id) ,
+ CONSTRAINT process_definition_unique UNIQUE (name, project_code)
) ;
-create index process_definition_index on t_ds_process_definition (project_id,id);
-
---
--- Table structure for table t_ds_process_definition_version
---
+create index process_definition_index on t_ds_process_definition (code,id);
-DROP TABLE IF EXISTS t_ds_process_definition_version;
-CREATE TABLE t_ds_process_definition_version (
+DROP TABLE IF EXISTS t_ds_process_definition_log;
+CREATE TABLE t_ds_process_definition_log (
id int NOT NULL ,
- process_definition_id int NOT NULL ,
+ code bigint NOT NULL,
+ name varchar(255) DEFAULT NULL ,
version int DEFAULT NULL ,
- process_definition_json text ,
description text ,
+ project_code bigint DEFAULT NULL ,
+ release_state int DEFAULT NULL ,
+ user_id int DEFAULT NULL ,
global_params text ,
locations text ,
connects text ,
- warning_group_id int4 DEFAULT NULL,
+ warning_group_id int DEFAULT NULL ,
+ flag int DEFAULT NULL ,
+ timeout int DEFAULT '0' ,
+ tenant_id int DEFAULT '-1' ,
+ operator int DEFAULT NULL ,
+ operate_time timestamp DEFAULT NULL ,
create_time timestamp DEFAULT NULL ,
+ update_time timestamp DEFAULT NULL ,
+ PRIMARY KEY (id)
+) ;
+
+DROP TABLE IF EXISTS t_ds_task_definition;
+CREATE TABLE t_ds_task_definition (
+ id int NOT NULL ,
+ code bigint NOT NULL,
+ name varchar(255) DEFAULT NULL ,
+ version int DEFAULT NULL ,
+ description text ,
+ project_code bigint DEFAULT NULL ,
+ user_id int DEFAULT NULL ,
+ task_type varchar(50) DEFAULT NULL ,
+ task_params text ,
+ flag int DEFAULT NULL ,
+ task_priority int DEFAULT NULL ,
+ worker_group varchar(255) DEFAULT NULL ,
+ fail_retry_times int DEFAULT NULL ,
+ fail_retry_interval int DEFAULT NULL ,
+ timeout_flag int DEFAULT NULL ,
+ timeout_notify_strategy int DEFAULT NULL ,
timeout int DEFAULT '0' ,
- resource_ids varchar(64),
+ delay_time int DEFAULT '0' ,
+ resource_ids varchar(255) DEFAULT NULL ,
+ create_time timestamp DEFAULT NULL ,
+ update_time timestamp DEFAULT NULL ,
+ PRIMARY KEY (id) ,
+ CONSTRAINT task_definition_unique UNIQUE (name, project_code)
+) ;
+
+create index task_definition_index on t_ds_task_definition (project_code,id);
+
+DROP TABLE IF EXISTS t_ds_task_definition_log;
+CREATE TABLE t_ds_task_definition_log (
+ id int NOT NULL ,
+ code bigint NOT NULL,
+ name varchar(255) DEFAULT NULL ,
+ version int DEFAULT NULL ,
+ description text ,
+ project_code bigint DEFAULT NULL ,
+ user_id int DEFAULT NULL ,
+ task_type varchar(50) DEFAULT NULL ,
+ task_params text ,
+ flag int DEFAULT NULL ,
+ task_priority int DEFAULT NULL ,
+ worker_group varchar(255) DEFAULT NULL ,
+ fail_retry_times int DEFAULT NULL ,
+ fail_retry_interval int DEFAULT NULL ,
+ timeout_flag int DEFAULT NULL ,
+ timeout_notify_strategy int DEFAULT NULL ,
+ timeout int DEFAULT '0' ,
+ delay_time int DEFAULT '0' ,
+ resource_ids varchar(255) DEFAULT NULL ,
+ operator int DEFAULT NULL ,
+ operate_time timestamp DEFAULT NULL ,
+ create_time timestamp DEFAULT NULL ,
+ update_time timestamp DEFAULT NULL ,
+ PRIMARY KEY (id)
+) ;
+
+DROP TABLE IF EXISTS t_ds_process_task_relation;
+CREATE TABLE t_ds_process_task_relation (
+ id int NOT NULL ,
+ name varchar(255) DEFAULT NULL ,
+ process_definition_version int DEFAULT NULL ,
+ project_code bigint DEFAULT NULL ,
+ process_definition_code bigint DEFAULT NULL ,
+ pre_task_code bigint DEFAULT NULL ,
+ pre_task_version int DEFAULT '0' ,
+ post_task_code bigint DEFAULT NULL ,
+ post_task_version int DEFAULT '0' ,
+ condition_type int DEFAULT NULL ,
+ condition_params text ,
+ create_time timestamp DEFAULT NULL ,
+ update_time timestamp DEFAULT NULL ,
PRIMARY KEY (id)
) ;
-create index process_definition_id_and_version on t_ds_process_definition_version (process_definition_id,version);
+DROP TABLE IF EXISTS t_ds_process_task_relation_log;
+CREATE TABLE t_ds_process_task_relation_log (
+ id int NOT NULL ,
+ name varchar(255) DEFAULT NULL ,
+ process_definition_version int DEFAULT NULL ,
+ project_code bigint DEFAULT NULL ,
+ process_definition_code bigint DEFAULT NULL ,
+ pre_task_code bigint DEFAULT NULL ,
+ pre_task_version int DEFAULT '0' ,
+ post_task_code bigint DEFAULT NULL ,
+ post_task_version int DEFAULT '0' ,
+ condition_type int DEFAULT NULL ,
+ condition_params text ,
+ operator int DEFAULT NULL ,
+ operate_time timestamp DEFAULT NULL ,
+ create_time timestamp DEFAULT NULL ,
+ update_time timestamp DEFAULT NULL ,
Review comment:
not all database can manage the time, and we will support other databases in the future.
so we can manage it ourself.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
users@infra.apache.org