From ef57259386e58c3c12e44760e8e41aade68d219e Mon Sep 17 00:00:00 2001 From: dhb52 <dhb52@126.com> Date: 星期五, 17 五月 2024 09:54:18 +0800 Subject: [PATCH] !535 feat: EasyRetry-v3.2.0 => SnailJob-v1.0.0beta1 * feat: EasyRetry-v3.2.0 => SnailJob-v1.0.0beta1 --- script/sql/sqlserver/snail_job_sqlserver.sql | 3466 +++++++++++++++++++++++++++++------------------------------ 1 files changed, 1,706 insertions(+), 1,760 deletions(-) diff --git a/script/sql/sqlserver/easy_retry_sqlserver.sql b/script/sql/sqlserver/snail_job_sqlserver.sql similarity index 60% rename from script/sql/sqlserver/easy_retry_sqlserver.sql rename to script/sql/sqlserver/snail_job_sqlserver.sql index db6ad4f..d6fa1ae 100644 --- a/script/sql/sqlserver/easy_retry_sqlserver.sql +++ b/script/sql/sqlserver/snail_job_sqlserver.sql @@ -1,1296 +1,419 @@ --- er_distributed_lock -CREATE TABLE er_distributed_lock +/* + SnailJob Database Transfer Tool + Source Server Type : MySQL + Target Server Type : Microsoft SQL Server + Date: 2024-05-13 23:03:34 +*/ + + +-- sj_namespace +CREATE TABLE sj_namespace ( - id bigint PRIMARY KEY IDENTITY, - name nvarchar(64) NOT NULL, - lock_until datetime2 NOT NULL DEFAULT GETDATE(), - locked_at datetime2 NOT NULL DEFAULT GETDATE(), - locked_by nvarchar(255) NOT NULL, - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE UNIQUE NONCLUSTERED INDEX uk_name ON er_distributed_lock (name ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閿佸悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閿佸畾鏃堕暱', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'lock_until' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閿佸畾鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'locked_at' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閿佸畾鑰�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'locked_by' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閿佸畾琛�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_distributed_lock' -GO - --- er_group_config -CREATE TABLE er_group_config -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL DEFAULT '', - description nvarchar(256) NOT NULL DEFAULT '', - token nvarchar(64) NOT NULL DEFAULT 'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', - group_status tinyint NOT NULL DEFAULT '0', - version int NOT NULL, - group_partition int NOT NULL, - id_generator_mode tinyint NOT NULL DEFAULT '1', - init_scene tinyint NOT NULL DEFAULT '0', - bucket_index int NOT NULL DEFAULT '0', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name ON er_group_config (namespace_id ASC, group_name ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勬弿杩�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'description' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'token', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'token' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勭姸鎬� 0銆佹湭鍚敤 1銆佸惎鐢�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'group_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鐗堟湰鍙�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'version' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒嗗尯', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'group_partition' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍞竴id鐢熸垚妯″紡 榛樿鍙锋妯″紡', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'id_generator_mode' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏄惁鍒濆鍖栧満鏅� 0:鍚� 1:鏄�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'init_scene' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'bucket', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'bucket_index' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勯厤缃�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_group_config' -GO - -INSERT INTO er_group_config(namespace_id, group_name, description, token, group_status, version, group_partition, id_generator_mode, init_scene, bucket_index, create_dt, update_dt) VALUES (N'dev', N'ruoyi_group', N'', N'ER_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', N'1', N'1', N'0', N'1', N'1', N'4', getdate(), getdate()); -GO - --- er_job -CREATE TABLE er_job -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - job_name nvarchar(64) NOT NULL, - args_str nvarchar(max) NULL, - args_type tinyint NOT NULL DEFAULT '1', - next_trigger_at bigint NOT NULL, - job_status tinyint NOT NULL DEFAULT '1', - task_type tinyint NOT NULL DEFAULT '1', - route_key tinyint NOT NULL DEFAULT '4', - executor_type tinyint NOT NULL DEFAULT '1', - executor_info nvarchar(255) NULL DEFAULT '', - trigger_type tinyint NOT NULL, - trigger_interval nvarchar(255) NOT NULL, - block_strategy tinyint NOT NULL DEFAULT '1', - executor_timeout int NOT NULL DEFAULT '0', - max_retry_times int NOT NULL DEFAULT '0', - parallel_num int NOT NULL DEFAULT '1', - retry_interval int NOT NULL DEFAULT '0', - bucket_index int NOT NULL DEFAULT '0', - resident tinyint NOT NULL DEFAULT '0', - description nvarchar(256) NOT NULL DEFAULT '', - ext_attrs nvarchar(256) NULL DEFAULT '', - create_dt datetime2 DEFAULT GETDATE(), - update_dt datetime2 DEFAULT GETDATE(), - deleted BIT NOT NULL DEFAULT 0 -) -GO - -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job (namespace_id ASC, group_name ASC) -GO -CREATE NONCLUSTERED INDEX idx_job_status_bucket_index ON er_job (job_status ASC, bucket_index ASC) -GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_job (create_dt ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍚嶇О', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'job_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц鏂规硶鍙傛暟', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'args_str' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍙傛暟绫诲瀷 ', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'args_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓嬫瑙﹀彂鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'next_trigger_at' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鐘舵�� 0銆佸叧闂��1銆佸紑鍚�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'job_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟绫诲瀷 1銆侀泦缇� 2銆佸箍鎾� 3銆佸垏鐗�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'task_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'璺敱绛栫暐', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'route_key' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц鍣ㄧ被鍨�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'executor_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц鍣ㄥ悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'executor_info' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'瑙﹀彂绫诲瀷 1.CRON 琛ㄨ揪寮� 2. 鍥哄畾鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'trigger_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'闂撮殧鏃堕暱', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'trigger_interval' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'闃诲绛栫暐 1銆佷涪寮� 2銆佽鐩� 3銆佸苟琛�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'block_strategy' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵ц瓒呮椂鏃堕棿锛屽崟浣嶇', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'executor_timeout' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏈�澶ч噸璇曟鏁�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'max_retry_times' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'骞惰鏁�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'parallel_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閲嶈瘯闂撮殧(s)', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'retry_interval' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'bucket', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'bucket_index' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏄惁鏄父椹讳换鍔�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'resident' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎻忚堪', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'description' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵╁睍瀛楁', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'ext_attrs' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job', - 'COLUMN', N'deleted' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟淇℃伅', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job' -GO - -INSERT INTO `er_job` VALUES (1, N'dev', N'ruoyi_group', N'demo-job', null, 1, 1710344035622, 1, 1, 4, 1, N'testJobExecutor', 2, N'60', 1, 60, 3, 1, 1, 116, 0, N'', N'', getdate(), getdate(), 0); -GO - --- er_job_log_message -CREATE TABLE er_job_log_message -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - job_id bigint NOT NULL, - task_batch_id bigint NOT NULL, - task_id bigint NOT NULL, - message nvarchar(max) NOT NULL, - log_num int NOT NULL DEFAULT '1', - real_time bigint NOT NULL DEFAULT '0', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - ext_attrs nvarchar(256) NULL DEFAULT '' -) -GO - -CREATE NONCLUSTERED INDEX idx_task_batch_id_task_id ON er_job_log_message (task_batch_id ASC, task_id ASC) -GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_job_log_message (create_dt ASC) -GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job_log_message (namespace_id ASC, group_name ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟淇℃伅id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'job_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵规id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'task_batch_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'璋冨害浠诲姟id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'task_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'璋冨害淇℃伅', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'message' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'log_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婃姤鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'real_time' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵╁睍瀛楁', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message', - 'COLUMN', N'ext_attrs' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'璋冨害鏃ュ織', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_log_message' -GO - - --- er_job_notify_config -CREATE TABLE er_job_notify_config -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - job_id bigint NOT NULL, - notify_status tinyint NOT NULL DEFAULT '0', - notify_type tinyint NOT NULL DEFAULT '0', - notify_attribute nvarchar(512) NOT NULL, - notify_threshold int NOT NULL DEFAULT '0', - notify_scene tinyint NOT NULL DEFAULT '0', - rate_limiter_status tinyint NOT NULL DEFAULT '0', - rate_limiter_threshold int NOT NULL DEFAULT '0', - description nvarchar(256) NOT NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_job_id ON er_job_notify_config (namespace_id ASC, group_name ASC, job_id ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'job_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡鐘舵�� 0銆佹湭鍚敤 1銆佸惎鐢�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'notify_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡绫诲瀷 1銆侀拤閽� 2銆侀偖浠� 3銆佷紒涓氬井淇�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'notify_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閰嶇疆灞炴��', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'notify_attribute' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡闃堝��', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'notify_threshold' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡鍦烘櫙', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'notify_scene' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'闄愭祦鐘舵�� 0銆佹湭鍚敤 1銆佸惎鐢�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'rate_limiter_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'姣忕闄愭祦闃堝��', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'rate_limiter_threshold' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎻忚堪', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'description' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'job閫氱煡閰嶇疆', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_notify_config' -GO - - --- er_job_summary -CREATE TABLE er_job_summary -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - business_id bigint NOT NULL, - system_task_type tinyint NOT NULL DEFAULT '3', - trigger_at datetime2 NOT NULL, - success_num int NOT NULL DEFAULT '0', - fail_num int NOT NULL DEFAULT '0', - fail_reason nvarchar(512) NOT NULL DEFAULT '', - stop_num int NOT NULL DEFAULT '0', - stop_reason nvarchar(512) NOT NULL DEFAULT '', - cancel_num int NOT NULL DEFAULT '0', - cancel_reason nvarchar(512) NOT NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE UNIQUE NONCLUSTERED INDEX uk_trigger_at_system_task_type_business_id ON er_job_summary (trigger_at ASC, system_task_type ASC, business_id ASC) -GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_business_id ON er_job_summary (namespace_id ASC, group_name ASC, business_id ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓氬姟id (job_id鎴杦orkflow_id)', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'business_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟绫诲瀷 3銆丣OB浠诲姟 4銆乄ORKFLOW浠诲姟', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'system_task_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁熻鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'trigger_at' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц鎴愬姛-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'success_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц澶辫触-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'fail_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'澶辫触鍘熷洜', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'fail_reason' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц澶辫触-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'stop_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'澶辫触鍘熷洜', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'stop_reason' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц澶辫触-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'cancel_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'澶辫触鍘熷洜', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'cancel_reason' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'DashBoard_Job', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_summary' -GO - - --- er_job_task -CREATE TABLE er_job_task -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - job_id bigint NOT NULL, - task_batch_id bigint NOT NULL, - parent_id bigint NOT NULL DEFAULT '0', - task_status tinyint NOT NULL DEFAULT '0', - retry_count int NOT NULL DEFAULT '0', - client_info nvarchar(128) NULL, - result_message nvarchar(max) NOT NULL, - args_str nvarchar(max) NULL, - args_type tinyint NOT NULL DEFAULT '1', - ext_attrs nvarchar(256) NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE NONCLUSTERED INDEX idx_task_batch_id_task_status ON er_job_task (task_batch_id ASC, task_status ASC) -GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_job_task (create_dt ASC) -GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job_task (namespace_id ASC, group_name ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟淇℃伅id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'job_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'璋冨害浠诲姟id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'task_batch_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鐖舵墽琛屽櫒id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'parent_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц鐨勭姸鎬� 0銆佸け璐� 1銆佹垚鍔�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'task_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閲嶈瘯娆℃暟', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'retry_count' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'瀹㈡埛绔湴鍧� clientId#ip:port', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'client_info' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц缁撴灉', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'result_message' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵ц鏂规硶鍙傛暟', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'args_str' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍙傛暟绫诲瀷 ', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'args_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵╁睍瀛楁', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'ext_attrs' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟瀹炰緥', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task' -GO - --- er_job_task_batch -CREATE TABLE er_job_task_batch -( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - job_id bigint NOT NULL, - workflow_node_id bigint NOT NULL DEFAULT '0', - parent_workflow_node_id bigint NOT NULL DEFAULT '0', - workflow_task_batch_id bigint NOT NULL DEFAULT '0', - task_batch_status tinyint NOT NULL DEFAULT '0', - operation_reason tinyint NOT NULL DEFAULT '0', - execution_at bigint NOT NULL DEFAULT '0', - system_task_type tinyint NOT NULL DEFAULT '3', - parent_id nvarchar(64) NOT NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE(), - deleted BIT DEFAULT 0, - ext_attrs nvarchar(256) NULL DEFAULT '' -) -GO - -CREATE NONCLUSTERED INDEX idx_job_id_task_batch_status ON er_job_task_batch (job_id ASC, task_batch_status ASC) -GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_job_task_batch (create_dt ASC) -GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_job_task_batch (namespace_id ASC, group_name ASC) -GO -CREATE NONCLUSTERED INDEX idx_workflow_task_batch_id_workflow_node_id ON er_job_task_batch (workflow_task_batch_id ASC, workflow_node_id ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'job_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佽妭鐐筰d', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'workflow_node_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佷换鍔$埗鎵规id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'parent_workflow_node_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佷换鍔℃壒娆d', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'workflow_task_batch_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵规鐘舵�� 0銆佸け璐� 1銆佹垚鍔�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'task_batch_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎿嶄綔鍘熷洜', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'operation_reason' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵ц鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'execution_at' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟绫诲瀷 3銆丣OB浠诲姟 4銆乄ORKFLOW浠诲姟', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'system_task_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鐖惰妭鐐�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'parent_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'deleted' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎵╁睍瀛楁', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch', - 'COLUMN', N'ext_attrs' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵规', - 'SCHEMA', N'dbo', - 'TABLE', N'er_job_task_batch' -GO - --- er_namespace -CREATE TABLE er_namespace -( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, name nvarchar(64) NOT NULL, unique_id nvarchar(64) NOT NULL, description nvarchar(256) NOT NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE(), - deleted BIT NOT NULL DEFAULT 0 + deleted tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE UNIQUE NONCLUSTERED INDEX uk_unique_id ON er_namespace (unique_id ASC) -GO -CREATE NONCLUSTERED INDEX idx_name ON er_namespace (name ASC) +CREATE INDEX idx_sj_namespace_01 ON sj_namespace (name) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', + 'TABLE', N'sj_namespace', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍚嶇О', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', + 'TABLE', N'sj_namespace', 'COLUMN', N'name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍞竴id', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', + 'TABLE', N'sj_namespace', 'COLUMN', N'unique_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鎻忚堪', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', + 'TABLE', N'sj_namespace', 'COLUMN', N'description' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_namespace', + 'COLUMN', N'deleted' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', + 'TABLE', N'sj_namespace', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', + 'TABLE', N'sj_namespace', 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace', - 'COLUMN', N'deleted' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_namespace' + 'TABLE', N'sj_namespace' GO -INSERT INTO er_namespace(name, unique_id, description, create_dt, update_dt, deleted) VALUES (N'Development', N'dev', N'', getdate(), getdate(), N'0'); -INSERT INTO er_namespace(name, unique_id, description, create_dt, update_dt, deleted) VALUES (N'Production', N'prod', N'', getdate(), getdate(), N'0'); +INSERT INTO sj_namespace(name, unique_id, description, deleted, create_dt, update_dt) VALUES (N'Development', N'dev', N'', 0, getdate(), getdate()) +GO +INSERT INTO sj_namespace(name, unique_id, description, deleted, create_dt, update_dt) VALUES (N'Production', N'prod', N'', 0, getdate(), getdate()) GO --- er_notify_config -CREATE TABLE er_notify_config +-- sj_group_config +CREATE TABLE sj_group_config ( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - scene_name nvarchar(64) NOT NULL, - notify_status tinyint NOT NULL DEFAULT '0', - notify_type tinyint NOT NULL DEFAULT '0', - notify_attribute nvarchar(512) NOT NULL, - notify_threshold int NOT NULL DEFAULT '0', - notify_scene tinyint NOT NULL DEFAULT '0', - rate_limiter_status tinyint NOT NULL DEFAULT '0', - rate_limiter_threshold int NOT NULL DEFAULT '0', - description nvarchar(256) NOT NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL DEFAULT '', + description nvarchar(256) NOT NULL DEFAULT '', + token nvarchar(64) NOT NULL DEFAULT 'SJ_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', + group_status tinyint NOT NULL DEFAULT 0, + version int NOT NULL, + group_partition int NOT NULL, + id_generator_mode tinyint NOT NULL DEFAULT 1, + init_scene tinyint NOT NULL DEFAULT 0, + bucket_index int NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_notify_config (namespace_id ASC, group_name ASC, scene_name ASC) +CREATE UNIQUE INDEX uk_sj_group_config_01 ON sj_group_config (namespace_id, group_name) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', + 'TABLE', N'sj_group_config', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', + 'TABLE', N'sj_group_config', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', + 'TABLE', N'sj_group_config', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty - 'MS_Description', N'鍦烘櫙鍚嶇О', + 'MS_Description', N'缁勬弿杩�', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'scene_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡鐘舵�� 0銆佹湭鍚敤 1銆佸惎鐢�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'notify_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡绫诲瀷 1銆侀拤閽� 2銆侀偖浠� 3銆佷紒涓氬井淇�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'notify_type' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閰嶇疆灞炴��', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'notify_attribute' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡闃堝��', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'notify_threshold' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫氱煡鍦烘櫙', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'notify_scene' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'闄愭祦鐘舵�� 0銆佹湭鍚敤 1銆佸惎鐢�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'rate_limiter_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'姣忕闄愭祦闃堝��', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', - 'COLUMN', N'rate_limiter_threshold' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鎻忚堪', - 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', + 'TABLE', N'sj_group_config', 'COLUMN', N'description' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'token', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'token' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勭姸鎬� 0銆佹湭鍚敤 1銆佸惎鐢�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'group_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鐗堟湰鍙�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'version' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒嗗尯', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'group_partition' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍞竴id鐢熸垚妯″紡 榛樿鍙锋妯″紡', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'id_generator_mode' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鏄惁鍒濆鍖栧満鏅� 0:鍚� 1:鏄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'init_scene' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'bucket', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config', + 'COLUMN', N'bucket_index' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', + 'TABLE', N'sj_group_config', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config', + 'TABLE', N'sj_group_config', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勯厤缃�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_group_config' +GO + +INSERT INTO sj_group_config(namespace_id, group_name, description, token, group_status, version, group_partition, id_generator_mode, init_scene, bucket_index, create_dt, update_dt) VALUES (N'dev', N'ruoyi_group', N'', N'SJ_cKqBTPzCsWA3VyuCfFoccmuIEGXjr5KT', N'1', N'1', N'0', N'1', N'1', N'4', getdate(), getdate()) +GO + +-- sj_notify_config +CREATE TABLE sj_notify_config +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + business_id nvarchar(64) NOT NULL, + system_task_type tinyint NOT NULL DEFAULT 3, + notify_status tinyint NOT NULL DEFAULT 0, + recipient_ids nvarchar(128) NOT NULL, + notify_threshold int NOT NULL DEFAULT 0, + notify_scene tinyint NOT NULL DEFAULT 0, + rate_limiter_status tinyint NOT NULL DEFAULT 0, + rate_limiter_threshold int NOT NULL DEFAULT 0, + description nvarchar(256) NOT NULL DEFAULT '', + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_notify_config_01 ON sj_notify_config (namespace_id, group_name, business_id) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓氬姟id ( job_id鎴杦orkflow_id鎴杝cene_name ) ', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'business_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟绫诲瀷 1. 閲嶈瘯浠诲姟 2. 閲嶈瘯鍥炶皟 3銆丣OB浠诲姟 4銆乄ORKFLOW浠诲姟', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'system_task_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫氱煡鐘舵�� 0銆佹湭鍚敤 1銆佸惎鐢�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'notify_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎺ユ敹浜篿d鍒楄〃', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'recipient_ids' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫氱煡闃堝��', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'notify_threshold' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫氱煡鍦烘櫙', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'notify_scene' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'闄愭祦鐘舵�� 0銆佹湭鍚敤 1銆佸惎鐢�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'rate_limiter_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'姣忕闄愭祦闃堝��', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'rate_limiter_threshold' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎻忚堪', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'description' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_config', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'閫氱煡閰嶇疆', 'SCHEMA', N'dbo', - 'TABLE', N'er_notify_config' + 'TABLE', N'sj_notify_config' GO --- er_retry_dead_letter_0 -CREATE TABLE er_retry_dead_letter_0 +-- sj_notify_recipient +CREATE TABLE sj_notify_recipient ( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + recipient_name nvarchar(64) NOT NULL, + notify_type tinyint NOT NULL DEFAULT 0, + notify_attribute nvarchar(512) NOT NULL, + description nvarchar(256) NOT NULL DEFAULT '', + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_notify_recipient_01 ON sj_notify_recipient (namespace_id) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎺ユ敹浜哄悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'recipient_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫氱煡绫诲瀷 1銆侀拤閽� 2銆侀偖浠� 3銆佷紒涓氬井淇� 4 椋炰功', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'notify_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閰嶇疆灞炴��', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'notify_attribute' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎻忚堪', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'description' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛婅閫氱煡鎺ユ敹浜�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_notify_recipient' +GO + +-- sj_retry_dead_letter_0 +CREATE TABLE sj_retry_dead_letter_0 +( + id bigint NOT NULL PRIMARY KEY IDENTITY, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', unique_id nvarchar(64) NOT NULL, group_name nvarchar(64) NOT NULL, @@ -1300,221 +423,117 @@ executor_name nvarchar(512) NOT NULL DEFAULT '', args_str nvarchar(max) NOT NULL, ext_attrs nvarchar(max) NOT NULL, - task_type tinyint NOT NULL DEFAULT '1', - create_dt datetime2 NOT NULL DEFAULT GETDATE() + task_type tinyint NOT NULL DEFAULT 1, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name_unique_id ON er_retry_dead_letter_0 (namespace_id ASC, group_name ASC, unique_id ASC) +CREATE UNIQUE INDEX uk_sj_retry_dead_letter_0_01 ON sj_retry_dead_letter_0 (namespace_id, group_name, unique_id) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_retry_dead_letter_0 (namespace_id ASC, group_name ASC, scene_name ASC) + +CREATE INDEX idx_sj_retry_dead_letter_0_01 ON sj_retry_dead_letter_0 (namespace_id, group_name, scene_name) GO -CREATE NONCLUSTERED INDEX idx_idempotent_id ON er_retry_dead_letter_0 (idempotent_id ASC) +CREATE INDEX idx_sj_retry_dead_letter_0_02 ON sj_retry_dead_letter_0 (idempotent_id) GO -CREATE NONCLUSTERED INDEX idx_biz_no ON er_retry_dead_letter_0 (biz_no ASC) +CREATE INDEX idx_sj_retry_dead_letter_0_03 ON sj_retry_dead_letter_0 (biz_no) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_dead_letter_0 (create_dt ASC) +CREATE INDEX idx_sj_retry_dead_letter_0_04 ON sj_retry_dead_letter_0 (create_dt) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍚岀粍涓媔d鍞竴', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'unique_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍦烘櫙鍚嶇О', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'scene_name' GO EXEC sp_addextendedproperty 'MS_Description', N'骞傜瓑id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'idempotent_id' GO EXEC sp_addextendedproperty 'MS_Description', N'涓氬姟缂栧彿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'biz_no' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵ц鍣ㄥ悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'executor_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵ц鏂规硶鍙傛暟', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'args_str' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵╁睍瀛楁', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'ext_attrs' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟绫诲瀷 1銆侀噸璇曟暟鎹� 2銆佸洖璋冩暟鎹�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'task_type' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0', + 'TABLE', N'sj_retry_dead_letter_0', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'姝讳俊闃熷垪琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_dead_letter_0' + 'TABLE', N'sj_retry_dead_letter_0' GO - --- er_retry_summary -CREATE TABLE er_retry_summary +-- sj_retry_task_0 +CREATE TABLE sj_retry_task_0 ( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL DEFAULT '', - scene_name nvarchar(50) NOT NULL DEFAULT '', - trigger_at datetime2 NOT NULL DEFAULT GETDATE(), - running_num int NOT NULL DEFAULT '0', - finish_num int NOT NULL DEFAULT '0', - max_count_num int NOT NULL DEFAULT '0', - suspend_num int NOT NULL DEFAULT '0', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE UNIQUE NONCLUSTERED INDEX uk_scene_name_trigger_at ON er_retry_summary (namespace_id ASC, group_name ASC, - scene_name ASC, trigger_at ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍦烘櫙鍚嶇О', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'scene_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁熻鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'trigger_at' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閲嶈瘯涓�-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'running_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閲嶈瘯瀹屾垚-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'finish_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閲嶈瘯鍒拌揪鏈�澶ф鏁�-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'max_count_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏆傚仠閲嶈瘯-鏃ュ織鏁伴噺', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'suspend_num' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'DashBoard_Retry', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_summary' -GO - --- er_retry_task_0 -CREATE TABLE er_retry_task_0 -( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', unique_id nvarchar(64) NOT NULL, group_name nvarchar(64) NOT NULL, @@ -1525,151 +544,152 @@ args_str nvarchar(max) NOT NULL, ext_attrs nvarchar(max) NOT NULL, next_trigger_at datetime2 NOT NULL, - retry_count int NOT NULL DEFAULT '0', - retry_status tinyint NOT NULL DEFAULT '0', - task_type tinyint NOT NULL DEFAULT '1', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + retry_count int NOT NULL DEFAULT 0, + retry_status tinyint NOT NULL DEFAULT 0, + task_type tinyint NOT NULL DEFAULT 1, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE UNIQUE NONCLUSTERED INDEX uk_name_unique_id ON er_retry_task_0 (namespace_id ASC, group_name ASC, unique_id ASC) +CREATE UNIQUE INDEX uk_sj_retry_task_0_01 ON sj_retry_task_0 (namespace_id, group_name, unique_id) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_retry_task_0 (namespace_id ASC, group_name ASC, scene_name ASC) + +CREATE INDEX idx_sj_retry_task_0_01 ON sj_retry_task_0 (namespace_id, group_name, scene_name) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_task_type ON er_retry_task_0 (namespace_id ASC, group_name ASC, task_type ASC) +CREATE INDEX idx_sj_retry_task_0_02 ON sj_retry_task_0 (namespace_id, group_name, task_type) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_retry_status ON er_retry_task_0 (namespace_id ASC, group_name ASC, retry_status ASC) +CREATE INDEX idx_sj_retry_task_0_03 ON sj_retry_task_0 (namespace_id, group_name, retry_status) GO -CREATE NONCLUSTERED INDEX idx_idempotent_id ON er_retry_task_0 (idempotent_id ASC) +CREATE INDEX idx_sj_retry_task_0_04 ON sj_retry_task_0 (idempotent_id) GO -CREATE NONCLUSTERED INDEX idx_biz_no ON er_retry_task_0 (biz_no ASC) +CREATE INDEX idx_sj_retry_task_0_05 ON sj_retry_task_0 (biz_no) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_task_0 (create_dt ASC) +CREATE INDEX idx_sj_retry_task_0_06 ON sj_retry_task_0 (create_dt) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍚岀粍涓媔d鍞竴', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'unique_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍦烘櫙鍚嶇О', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'scene_name' GO EXEC sp_addextendedproperty 'MS_Description', N'骞傜瓑id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'idempotent_id' GO EXEC sp_addextendedproperty 'MS_Description', N'涓氬姟缂栧彿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'biz_no' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵ц鍣ㄥ悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'executor_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵ц鏂规硶鍙傛暟', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'args_str' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵╁睍瀛楁', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'ext_attrs' GO EXEC sp_addextendedproperty 'MS_Description', N'涓嬫瑙﹀彂鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'next_trigger_at' GO EXEC sp_addextendedproperty 'MS_Description', N'閲嶈瘯娆℃暟', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'retry_count' GO EXEC sp_addextendedproperty 'MS_Description', N'閲嶈瘯鐘舵�� 0銆侀噸璇曚腑 1銆佹垚鍔� 2銆佹渶澶ч噸璇曟鏁�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'retry_status' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟绫诲瀷 1銆侀噸璇曟暟鎹� 2銆佸洖璋冩暟鎹�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'task_type' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0', + 'TABLE', N'sj_retry_task_0', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_0' + 'TABLE', N'sj_retry_task_0' GO --- er_retry_task_log -CREATE TABLE er_retry_task_log +-- sj_retry_task_log +CREATE TABLE sj_retry_task_log ( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', unique_id nvarchar(64) NOT NULL, group_name nvarchar(64) NOT NULL, @@ -1679,1073 +699,1999 @@ executor_name nvarchar(512) NOT NULL DEFAULT '', args_str nvarchar(max) NOT NULL, ext_attrs nvarchar(max) NOT NULL, - retry_status tinyint NOT NULL DEFAULT '0', - task_type tinyint NOT NULL DEFAULT '1', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + retry_status tinyint NOT NULL DEFAULT 0, + task_type tinyint NOT NULL DEFAULT 1, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE NONCLUSTERED INDEX idx_group_name_scene_name ON er_retry_task_log (namespace_id ASC, group_name ASC, scene_name ASC) +CREATE INDEX idx_sj_retry_task_log_01 ON sj_retry_task_log (namespace_id, group_name, scene_name) GO -CREATE NONCLUSTERED INDEX idx_retry_status ON er_retry_task_log (retry_status ASC) +CREATE INDEX idx_sj_retry_task_log_02 ON sj_retry_task_log (retry_status) GO -CREATE NONCLUSTERED INDEX idx_idempotent_id ON er_retry_task_log (idempotent_id ASC) +CREATE INDEX idx_sj_retry_task_log_03 ON sj_retry_task_log (idempotent_id) GO -CREATE NONCLUSTERED INDEX idx_unique_id ON er_retry_task_log (unique_id ASC) +CREATE INDEX idx_sj_retry_task_log_04 ON sj_retry_task_log (unique_id) GO -CREATE NONCLUSTERED INDEX idx_biz_no ON er_retry_task_log (biz_no ASC) +CREATE INDEX idx_sj_retry_task_log_05 ON sj_retry_task_log (biz_no) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_task_log (create_dt ASC) +CREATE INDEX idx_sj_retry_task_log_06 ON sj_retry_task_log (create_dt) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍚岀粍涓媔d鍞竴', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'unique_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍦烘櫙鍚嶇О', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'scene_name' GO EXEC sp_addextendedproperty 'MS_Description', N'骞傜瓑id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'idempotent_id' GO EXEC sp_addextendedproperty 'MS_Description', N'涓氬姟缂栧彿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'biz_no' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵ц鍣ㄥ悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'executor_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵ц鏂规硶鍙傛暟', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'args_str' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵╁睍瀛楁', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'ext_attrs' GO EXEC sp_addextendedproperty 'MS_Description', N'閲嶈瘯鐘舵�� 0銆侀噸璇曚腑 1銆佹垚鍔� 2銆佹渶澶ф鏁�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'retry_status' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟绫诲瀷 1銆侀噸璇曟暟鎹� 2銆佸洖璋冩暟鎹�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'task_type' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log', + 'TABLE', N'sj_retry_task_log', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟鏃ュ織鍩虹淇℃伅琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log' + 'TABLE', N'sj_retry_task_log' GO --- er_retry_task_log_message -CREATE TABLE er_retry_task_log_message +-- sj_retry_task_log_message +CREATE TABLE sj_retry_task_log_message ( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', group_name nvarchar(64) NOT NULL, unique_id nvarchar(64) NOT NULL, - create_dt datetime2 NOT NULL DEFAULT GETDATE(), message nvarchar(max) NOT NULL, log_num int NOT NULL DEFAULT 1, - real_time bigint NOT NULL DEFAULT 0 + real_time bigint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name_scene_name ON er_retry_task_log_message (namespace_id ASC, group_name ASC, unique_id ASC) +CREATE INDEX idx_sj_retry_task_log_message_01 ON sj_retry_task_log_message (namespace_id, group_name, unique_id) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_retry_task_log_message (create_dt ASC) +CREATE INDEX idx_sj_retry_task_log_message_02 ON sj_retry_task_log_message (create_dt) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍚岀粍涓媔d鍞竴', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'unique_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', - 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'寮傚父淇℃伅', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'message' GO EXEC sp_addextendedproperty 'MS_Description', N'鏃ュ織鏁伴噺', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'log_num' GO EXEC sp_addextendedproperty 'MS_Description', N'涓婃姤鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message', + 'TABLE', N'sj_retry_task_log_message', 'COLUMN', N'real_time' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_task_log_message', + 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟璋冨害鏃ュ織淇℃伅璁板綍琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_retry_task_log_message' + 'TABLE', N'sj_retry_task_log_message' GO --- er_scene_config -CREATE TABLE er_scene_config +-- sj_retry_scene_config +CREATE TABLE sj_retry_scene_config ( - id bigint IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', scene_name nvarchar(64) NOT NULL, group_name nvarchar(64) NOT NULL, - scene_status tinyint NOT NULL DEFAULT '0', - max_retry_count int NOT NULL DEFAULT '5', - back_off tinyint NOT NULL DEFAULT '1', + scene_status tinyint NOT NULL DEFAULT 0, + max_retry_count int NOT NULL DEFAULT 5, + back_off tinyint NOT NULL DEFAULT 1, trigger_interval nvarchar(16) NOT NULL DEFAULT '', - deadline_request bigint NOT NULL DEFAULT '60000', - executor_timeout int NOT NULL DEFAULT '5', - route_key tinyint NOT NULL DEFAULT '4', + deadline_request bigint NOT NULL DEFAULT 60000, + executor_timeout int NOT NULL DEFAULT 5, + route_key tinyint NOT NULL DEFAULT 4, description nvarchar(256) NOT NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name_scene_name ON er_scene_config (namespace_id ASC, group_name ASC, scene_name ASC) +CREATE UNIQUE INDEX uk_sj_retry_scene_config_01 ON sj_retry_scene_config (namespace_id, group_name, scene_name) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍦烘櫙鍚嶇О', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'scene_name' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勭姸鎬� 0銆佹湭鍚敤 1銆佸惎鐢�', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'scene_status' GO EXEC sp_addextendedproperty 'MS_Description', N'鏈�澶ч噸璇曟鏁�', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'max_retry_count' GO EXEC sp_addextendedproperty 'MS_Description', N'1銆侀粯璁ょ瓑绾� 2銆佸浐瀹氶棿闅旀椂闂� 3銆丆RON 琛ㄨ揪寮�', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'back_off' GO EXEC sp_addextendedproperty 'MS_Description', N'闂撮殧鏃堕暱', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'trigger_interval' GO EXEC sp_addextendedproperty 'MS_Description', N'Deadline Request 璋冪敤閾捐秴鏃� 鍗曚綅姣', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'deadline_request' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟鎵ц瓒呮椂鏃堕棿锛屽崟浣嶇', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'executor_timeout' GO EXEC sp_addextendedproperty 'MS_Description', N'璺敱绛栫暐', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'route_key' GO EXEC sp_addextendedproperty 'MS_Description', N'鎻忚堪', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'description' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config', + 'TABLE', N'sj_retry_scene_config', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'鍦烘櫙閰嶇疆', 'SCHEMA', N'dbo', - 'TABLE', N'er_scene_config' + 'TABLE', N'sj_retry_scene_config' GO --- er_sequence_alloc -CREATE TABLE er_sequence_alloc +-- sj_server_node +CREATE TABLE sj_server_node ( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL DEFAULT '', - max_id bigint NOT NULL DEFAULT '1', - step int NOT NULL DEFAULT '100', - update_dt datetime2 NOT NULL DEFAULT GETDATE() -) -GO - -CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name ON er_sequence_alloc (namespace_id ASC, group_name ASC) -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓婚敭', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc', - 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍛藉悕绌洪棿id', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc', - 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'缁勫悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc', - 'COLUMN', N'group_name' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏈�澶d', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc', - 'COLUMN', N'max_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'姝ラ暱', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc', - 'COLUMN', N'step' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鏇存柊鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍙锋妯″紡搴忓彿ID鍒嗛厤琛�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_sequence_alloc' -GO - --- er_server_node -CREATE TABLE er_server_node -( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', group_name nvarchar(64) NOT NULL, host_id nvarchar(64) NOT NULL, host_ip nvarchar(64) NOT NULL, - context_path nvarchar(256) NOT NULL DEFAULT '/', host_port int NOT NULL, expire_at datetime2 NOT NULL, node_type tinyint NOT NULL, ext_attrs nvarchar(256) NULL DEFAULT '', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE UNIQUE NONCLUSTERED INDEX uk_host_id_host_ip ON er_server_node (host_id ASC, host_ip ASC) +CREATE UNIQUE INDEX uk_sj_server_node_01 ON sj_server_node (host_id, host_ip) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_server_node (namespace_id ASC, group_name ASC) + +CREATE INDEX idx_sj_server_node_01 ON sj_server_node (namespace_id, group_name) GO -CREATE NONCLUSTERED INDEX idx_expire_at_node_type ON er_server_node (expire_at ASC, node_type ASC) +CREATE INDEX idx_sj_server_node_02 ON sj_server_node (expire_at, node_type) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'涓绘満id', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'host_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鏈哄櫒ip', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'host_ip' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'瀹㈡埛绔笂涓嬫枃璺緞 server.servlet.context-path', - 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', - 'COLUMN', N'context_path' GO EXEC sp_addextendedproperty 'MS_Description', N'鏈哄櫒绔彛', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'host_port' GO EXEC sp_addextendedproperty 'MS_Description', N'杩囨湡鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'expire_at' GO EXEC sp_addextendedproperty 'MS_Description', N'鑺傜偣绫诲瀷 1銆佸鎴风 2銆佹槸鏈嶅姟绔�', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'node_type' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵╁睍瀛楁', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'ext_attrs' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node', + 'TABLE', N'sj_server_node', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'鏈嶅姟鍣ㄨ妭鐐�', 'SCHEMA', N'dbo', - 'TABLE', N'er_server_node' + 'TABLE', N'sj_server_node' GO --- er_system_user -CREATE TABLE er_system_user +-- sj_distributed_lock +CREATE TABLE sj_distributed_lock ( - id bigint PRIMARY KEY IDENTITY, - username nvarchar(64) NOT NULL, - password nvarchar(128) NOT NULL, - role tinyint NOT NULL DEFAULT '0', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + id bigint NOT NULL PRIMARY KEY IDENTITY, + name nvarchar(64) NOT NULL, + lock_until datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + locked_at datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + locked_by nvarchar(255) NOT NULL, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) -GO - -CREATE UNIQUE NONCLUSTERED INDEX uk_username ON er_system_user (username ASC) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閿佸悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閿佸畾鏃堕暱', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'lock_until' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閿佸畾鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'locked_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閿佸畾鑰�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'locked_by' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閿佸畾琛�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_distributed_lock' +GO + +-- sj_system_user +CREATE TABLE sj_system_user +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + username nvarchar(64) NOT NULL, + password nvarchar(128) NOT NULL, + role tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_system_user', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'璐﹀彿', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user', + 'TABLE', N'sj_system_user', 'COLUMN', N'username' GO EXEC sp_addextendedproperty 'MS_Description', N'瀵嗙爜', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user', + 'TABLE', N'sj_system_user', 'COLUMN', N'password' GO EXEC sp_addextendedproperty 'MS_Description', N'瑙掕壊锛�1-鏅�氱敤鎴枫��2-绠$悊鍛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user', + 'TABLE', N'sj_system_user', 'COLUMN', N'role' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user', + 'TABLE', N'sj_system_user', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user', + 'TABLE', N'sj_system_user', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'绯荤粺鐢ㄦ埛琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user' + 'TABLE', N'sj_system_user' GO -- pwd: admin -INSERT INTO er_system_user(username, password, role, create_dt, update_dt) VALUES (N'admin', N'465c194afb65670f38322df087f0a9bb225cc257e43eb4ac5a0c98ef5b3173ac', N'2', getdate(), getdate()); +INSERT INTO sj_system_user(username, password, role, create_dt, update_dt) VALUES (N'admin', N'465c194afb65670f38322df087f0a9bb225cc257e43eb4ac5a0c98ef5b3173ac', N'2', getdate(), getdate()) GO --- er_system_user_permission -CREATE TABLE er_system_user_permission +-- sj_system_user_permission +CREATE TABLE sj_system_user_permission ( - id bigint PRIMARY KEY IDENTITY, + id bigint NOT NULL PRIMARY KEY IDENTITY, group_name nvarchar(64) NOT NULL, namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', system_user_id bigint NOT NULL, - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE() + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE UNIQUE NONCLUSTERED INDEX uk_namespace_id_group_name_system_user_id ON er_system_user_permission (namespace_id ASC, group_name ASC, system_user_id ASC) +CREATE UNIQUE INDEX uk_sj_system_user_permission_01 ON sj_system_user_permission (namespace_id, group_name, system_user_id) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission', + 'TABLE', N'sj_system_user_permission', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission', + 'TABLE', N'sj_system_user_permission', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission', + 'TABLE', N'sj_system_user_permission', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'绯荤粺鐢ㄦ埛id', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission', + 'TABLE', N'sj_system_user_permission', 'COLUMN', N'system_user_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission', + 'TABLE', N'sj_system_user_permission', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission', + 'TABLE', N'sj_system_user_permission', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'绯荤粺鐢ㄦ埛鏉冮檺琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_system_user_permission' + 'TABLE', N'sj_system_user_permission' GO - --- er_workflow -CREATE TABLE er_workflow +-- sj_sequence_alloc +CREATE TABLE sj_sequence_alloc ( - id bigint IDENTITY, - workflow_name nvarchar(64) NOT NULL, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - workflow_status tinyint NOT NULL DEFAULT '1', - trigger_type tinyint NOT NULL, - trigger_interval nvarchar(255) NOT NULL, - next_trigger_at bigint NOT NULL, - block_strategy tinyint NOT NULL DEFAULT '1', - executor_timeout int NOT NULL DEFAULT '0', - description nvarchar(256) NOT NULL DEFAULT '', - flow_info nvarchar(max) NULL DEFAULT NULL, - bucket_index int NOT NULL DEFAULT '0', - version int NOT NULL, - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE(), - deleted BIT DEFAULT 0, - ext_attrs nvarchar(256) NULL + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL DEFAULT '', + max_id bigint NOT NULL DEFAULT 1, + step int NOT NULL DEFAULT 100, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_workflow (create_dt ASC) +CREATE UNIQUE INDEX uk_sj_sequence_alloc_01 ON sj_sequence_alloc (namespace_id, group_name) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_workflow (namespace_id ASC, group_name ASC) -GO - EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_sequence_alloc', 'COLUMN', N'id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佸悕绉�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'workflow_name' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_sequence_alloc', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_sequence_alloc', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佺姸鎬� 0銆佸叧闂��1銆佸紑鍚�', + 'MS_Description', N'鏈�澶d', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'workflow_status' + 'TABLE', N'sj_sequence_alloc', + 'COLUMN', N'max_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'姝ラ暱', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_sequence_alloc', + 'COLUMN', N'step' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鏇存柊鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_sequence_alloc', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍙锋妯″紡搴忓彿ID鍒嗛厤琛�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_sequence_alloc' +GO + +-- sj_job +CREATE TABLE sj_job +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + job_name nvarchar(64) NOT NULL, + args_str nvarchar(max) NULL DEFAULT NULL, + args_type tinyint NOT NULL DEFAULT 1, + next_trigger_at bigint NOT NULL, + job_status tinyint NOT NULL DEFAULT 1, + task_type tinyint NOT NULL DEFAULT 1, + route_key tinyint NOT NULL DEFAULT 4, + executor_type tinyint NOT NULL DEFAULT 1, + executor_info nvarchar(255) NULL DEFAULT NULL, + trigger_type tinyint NOT NULL, + trigger_interval nvarchar(255) NOT NULL, + block_strategy tinyint NOT NULL DEFAULT 1, + executor_timeout int NOT NULL DEFAULT 0, + max_retry_times int NOT NULL DEFAULT 0, + parallel_num int NOT NULL DEFAULT 1, + retry_interval int NOT NULL DEFAULT 0, + bucket_index int NOT NULL DEFAULT 0, + resident tinyint NOT NULL DEFAULT 0, + description nvarchar(256) NOT NULL DEFAULT '', + ext_attrs nvarchar(256) NULL DEFAULT '', + deleted tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_job_01 ON sj_job (namespace_id, group_name) +GO +CREATE INDEX idx_sj_job_02 ON sj_job (job_status, bucket_index) +GO +CREATE INDEX idx_sj_job_03 ON sj_job (create_dt) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍚嶇О', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'job_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц鏂规硶鍙傛暟', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'args_str' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍙傛暟绫诲瀷 ', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'args_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓嬫瑙﹀彂鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'next_trigger_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鐘舵�� 0銆佸叧闂��1銆佸紑鍚�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'job_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟绫诲瀷 1銆侀泦缇� 2銆佸箍鎾� 3銆佸垏鐗�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'task_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'璺敱绛栫暐', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'route_key' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц鍣ㄧ被鍨�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'executor_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц鍣ㄥ悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'executor_info' GO EXEC sp_addextendedproperty 'MS_Description', N'瑙﹀彂绫诲瀷 1.CRON 琛ㄨ揪寮� 2. 鍥哄畾鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'trigger_type' GO EXEC sp_addextendedproperty 'MS_Description', N'闂撮殧鏃堕暱', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'trigger_interval' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'涓嬫瑙﹀彂鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'next_trigger_at' GO EXEC sp_addextendedproperty 'MS_Description', N'闃诲绛栫暐 1銆佷涪寮� 2銆佽鐩� 3銆佸苟琛�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'block_strategy' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟鎵ц瓒呮椂鏃堕棿锛屽崟浣嶇', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'executor_timeout' GO EXEC sp_addextendedproperty - 'MS_Description', N'鎻忚堪', + 'MS_Description', N'鏈�澶ч噸璇曟鏁�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'description' + 'TABLE', N'sj_job', + 'COLUMN', N'max_retry_times' GO EXEC sp_addextendedproperty - 'MS_Description', N'娴佺▼淇℃伅', + 'MS_Description', N'骞惰鏁�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'flow_info' + 'TABLE', N'sj_job', + 'COLUMN', N'parallel_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閲嶈瘯闂撮殧 ( s ) ', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'retry_interval' GO EXEC sp_addextendedproperty 'MS_Description', N'bucket', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'bucket_index' GO EXEC sp_addextendedproperty - 'MS_Description', N'鐗堟湰鍙�', + 'MS_Description', N'鏄惁鏄父椹讳换鍔�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'version' + 'TABLE', N'sj_job', + 'COLUMN', N'resident' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎻忚堪', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'description' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵╁睍瀛楁', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'ext_attrs' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job', + 'COLUMN', N'deleted' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', + 'TABLE', N'sj_job', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty - 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'MS_Description', N'浠诲姟淇℃伅', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'deleted' + 'TABLE', N'sj_job' GO -EXEC sp_addextendedproperty - 'MS_Description', N'鎵╁睍瀛楁', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow', - 'COLUMN', N'ext_attrs' +INSERT INTO sj_job (namespace_id, group_name, job_name, args_str, args_type, next_trigger_at, job_status, task_type, route_key, executor_type, executor_info, trigger_type, trigger_interval, block_strategy,executor_timeout, max_retry_times, parallel_num, retry_interval, bucket_index, resident, description, ext_attrs, deleted, create_dt, update_dt) VALUES (N'dev', N'ruoyi_group', N'demo-job', null, 1, 1710344035622, 1, 1, 4, 1, N'testJobExecutor', 2, N'60', 1, 60, 3, 1, 1, 116, 0, N'', N'', 0, getdate(), getdate()) GO -EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow' -GO - --- er_workflow_node -CREATE TABLE er_workflow_node +-- sj_job_log_message +CREATE TABLE sj_job_log_message ( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - node_name nvarchar(64) NOT NULL, - group_name nvarchar(64) NOT NULL, - job_id bigint NOT NULL, - workflow_id bigint NOT NULL, - node_type tinyint NOT NULL DEFAULT '1', - expression_type tinyint NOT NULL DEFAULT '0', - fail_strategy tinyint NOT NULL DEFAULT '1', - workflow_node_status tinyint NOT NULL DEFAULT '1', - priority_level int NOT NULL DEFAULT '1', - node_info nvarchar(max) NULL DEFAULT NULL, - version int NOT NULL, - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE(), - deleted BIT DEFAULT 0, - ext_attrs nvarchar(256) NULL DEFAULT '' + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + job_id bigint NOT NULL, + task_batch_id bigint NOT NULL, + task_id bigint NOT NULL, + message nvarchar(max) NOT NULL, + log_num int NOT NULL DEFAULT 1, + real_time bigint NOT NULL DEFAULT 0, + ext_attrs nvarchar(256) NULL DEFAULT '', + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_workflow_node (create_dt ASC) +CREATE INDEX idx_sj_job_log_message_01 ON sj_job_log_message (task_batch_id, task_id) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_workflow_node (namespace_id ASC, group_name ASC) +CREATE INDEX idx_sj_job_log_message_02 ON sj_job_log_message (create_dt) +GO +CREATE INDEX idx_sj_job_log_message_03 ON sj_job_log_message (namespace_id, group_name) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', + 'TABLE', N'sj_job_log_message', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', + 'TABLE', N'sj_job_log_message', 'COLUMN', N'namespace_id' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鑺傜偣鍚嶇О', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'node_name' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', + 'TABLE', N'sj_job_log_message', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty 'MS_Description', N'浠诲姟淇℃伅id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', + 'TABLE', N'sj_job_log_message', 'COLUMN', N'job_id' GO EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴両D', + 'MS_Description', N'浠诲姟鎵规id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'workflow_id' + 'TABLE', N'sj_job_log_message', + 'COLUMN', N'task_batch_id' GO EXEC sp_addextendedproperty - 'MS_Description', N'1銆佷换鍔¤妭鐐� 2銆佹潯浠惰妭鐐�', + 'MS_Description', N'璋冨害浠诲姟id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'node_type' + 'TABLE', N'sj_job_log_message', + 'COLUMN', N'task_id' GO EXEC sp_addextendedproperty - 'MS_Description', N'1銆丼pEl銆�2銆丄viator 3銆丵L', + 'MS_Description', N'璋冨害淇℃伅', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'expression_type' + 'TABLE', N'sj_job_log_message', + 'COLUMN', N'message' GO EXEC sp_addextendedproperty - 'MS_Description', N'澶辫触绛栫暐 1銆佽烦杩� 2銆侀樆濉�', + 'MS_Description', N'鏃ュ織鏁伴噺', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'fail_strategy' + 'TABLE', N'sj_job_log_message', + 'COLUMN', N'log_num' GO EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佽妭鐐圭姸鎬� 0銆佸叧闂��1銆佸紑鍚�', + 'MS_Description', N'涓婃姤鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'workflow_node_status' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'浼樺厛绾�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'priority_level' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鑺傜偣淇℃伅 ', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'node_info' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鐗堟湰鍙�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'version' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'鍒涘缓鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'create_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'淇敼鏃堕棿', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'update_dt' -GO - -EXEC sp_addextendedproperty - 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', - 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', - 'COLUMN', N'deleted' + 'TABLE', N'sj_job_log_message', + 'COLUMN', N'real_time' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵╁睍瀛楁', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node', + 'TABLE', N'sj_job_log_message', 'COLUMN', N'ext_attrs' GO EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佽妭鐐�', + 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_node' + 'TABLE', N'sj_job_log_message', + 'COLUMN', N'create_dt' GO --- er_workflow_task_batch -CREATE TABLE er_workflow_task_batch +EXEC sp_addextendedproperty + 'MS_Description', N'璋冨害鏃ュ織', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_log_message' +GO + +-- sj_job_task +CREATE TABLE sj_job_task ( - id bigint PRIMARY KEY IDENTITY, - namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', - group_name nvarchar(64) NOT NULL, - workflow_id bigint NOT NULL, - task_batch_status tinyint NOT NULL DEFAULT '0', - operation_reason tinyint NOT NULL DEFAULT '0', - flow_info nvarchar(max) NULL DEFAULT NULL, - execution_at bigint NOT NULL DEFAULT '0', - create_dt datetime2 NOT NULL DEFAULT GETDATE(), - update_dt datetime2 NOT NULL DEFAULT GETDATE(), - deleted BIT DEFAULT 0, - ext_attrs nvarchar(256) NULL DEFAULT '' + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + job_id bigint NOT NULL, + task_batch_id bigint NOT NULL, + parent_id bigint NOT NULL DEFAULT 0, + task_status tinyint NOT NULL DEFAULT 0, + retry_count int NOT NULL DEFAULT 0, + client_info nvarchar(128) NULL DEFAULT NULL, + result_message nvarchar(max) NOT NULL, + args_str nvarchar(max) NULL DEFAULT NULL, + args_type tinyint NOT NULL DEFAULT 1, + ext_attrs nvarchar(256) NULL DEFAULT '', + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP ) GO -CREATE NONCLUSTERED INDEX idx_job_id_task_batch_status ON er_workflow_task_batch (workflow_id ASC, task_batch_status ASC) +CREATE INDEX idx_sj_job_task_01 ON sj_job_task (task_batch_id, task_status) GO -CREATE NONCLUSTERED INDEX idx_create_dt ON er_workflow_task_batch (create_dt ASC) +CREATE INDEX idx_sj_job_task_02 ON sj_job_task (create_dt) GO -CREATE NONCLUSTERED INDEX idx_namespace_id_group_name ON er_workflow_task_batch (namespace_id ASC, group_name ASC) +CREATE INDEX idx_sj_job_task_03 ON sj_job_task (namespace_id, group_name) GO EXEC sp_addextendedproperty 'MS_Description', N'涓婚敭', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', + 'TABLE', N'sj_job_task', 'COLUMN', N'id' GO EXEC sp_addextendedproperty 'MS_Description', N'鍛藉悕绌洪棿id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', + 'TABLE', N'sj_job_task', 'COLUMN', N'namespace_id' GO EXEC sp_addextendedproperty 'MS_Description', N'缁勫悕绉�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', + 'TABLE', N'sj_job_task', 'COLUMN', N'group_name' GO EXEC sp_addextendedproperty - 'MS_Description', N'宸ヤ綔娴佷换鍔d', + 'MS_Description', N'浠诲姟淇℃伅id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', - 'COLUMN', N'workflow_id' + 'TABLE', N'sj_job_task', + 'COLUMN', N'job_id' GO EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵规鐘舵�� 0銆佸け璐� 1銆佹垚鍔�', + 'MS_Description', N'璋冨害浠诲姟id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', - 'COLUMN', N'task_batch_status' + 'TABLE', N'sj_job_task', + 'COLUMN', N'task_batch_id' GO EXEC sp_addextendedproperty - 'MS_Description', N'鎿嶄綔鍘熷洜', + 'MS_Description', N'鐖舵墽琛屽櫒id', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', - 'COLUMN', N'operation_reason' + 'TABLE', N'sj_job_task', + 'COLUMN', N'parent_id' GO EXEC sp_addextendedproperty - 'MS_Description', N'娴佺▼淇℃伅', + 'MS_Description', N'鎵ц鐨勭姸鎬� 0銆佸け璐� 1銆佹垚鍔�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', - 'COLUMN', N'flow_info' + 'TABLE', N'sj_job_task', + 'COLUMN', N'task_status' GO EXEC sp_addextendedproperty - 'MS_Description', N'浠诲姟鎵ц鏃堕棿', + 'MS_Description', N'閲嶈瘯娆℃暟', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', - 'COLUMN', N'execution_at' + 'TABLE', N'sj_job_task', + 'COLUMN', N'retry_count' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'瀹㈡埛绔湴鍧� clientId#ip:port', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task', + 'COLUMN', N'client_info' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц缁撴灉', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task', + 'COLUMN', N'result_message' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц鏂规硶鍙傛暟', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task', + 'COLUMN', N'args_str' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍙傛暟绫诲瀷 ', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task', + 'COLUMN', N'args_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵╁睍瀛楁', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task', + 'COLUMN', N'ext_attrs' GO EXEC sp_addextendedproperty 'MS_Description', N'鍒涘缓鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', + 'TABLE', N'sj_job_task', 'COLUMN', N'create_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'淇敼鏃堕棿', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', + 'TABLE', N'sj_job_task', 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty - 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'MS_Description', N'浠诲姟瀹炰緥', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', - 'COLUMN', N'deleted' + 'TABLE', N'sj_job_task' +GO + +-- sj_job_task_batch +CREATE TABLE sj_job_task_batch +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + job_id bigint NOT NULL, + workflow_node_id bigint NOT NULL DEFAULT 0, + parent_workflow_node_id bigint NOT NULL DEFAULT 0, + workflow_task_batch_id bigint NOT NULL DEFAULT 0, + task_batch_status tinyint NOT NULL DEFAULT 0, + operation_reason tinyint NOT NULL DEFAULT 0, + execution_at bigint NOT NULL DEFAULT 0, + system_task_type tinyint NOT NULL DEFAULT 3, + parent_id nvarchar(64) NOT NULL DEFAULT '', + ext_attrs nvarchar(256) NULL DEFAULT '', + deleted tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_job_task_batch_01 ON sj_job_task_batch (job_id, task_batch_status) +GO +CREATE INDEX idx_sj_job_task_batch_02 ON sj_job_task_batch (create_dt) +GO +CREATE INDEX idx_sj_job_task_batch_03 ON sj_job_task_batch (namespace_id, group_name) +GO +CREATE INDEX idx_sj_job_task_batch_04 ON sj_job_task_batch (workflow_task_batch_id, workflow_node_id) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'job_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佽妭鐐筰d', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'workflow_node_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佷换鍔$埗鎵规id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'parent_workflow_node_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佷换鍔℃壒娆d', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'workflow_task_batch_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鎵规鐘舵�� 0銆佸け璐� 1銆佹垚鍔�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'task_batch_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎿嶄綔鍘熷洜', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'operation_reason' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鎵ц鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'execution_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟绫诲瀷 3銆丣OB浠诲姟 4銆乄ORKFLOW浠诲姟', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'system_task_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鐖惰妭鐐�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'parent_id' GO EXEC sp_addextendedproperty 'MS_Description', N'鎵╁睍瀛楁', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch', + 'TABLE', N'sj_job_task_batch', 'COLUMN', N'ext_attrs' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'deleted' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鎵规', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_task_batch' +GO + +-- sj_job_summary +CREATE TABLE sj_job_summary +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL DEFAULT '', + business_id bigint NOT NULL, + system_task_type tinyint NOT NULL DEFAULT 3, + trigger_at datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + success_num int NOT NULL DEFAULT 0, + fail_num int NOT NULL DEFAULT 0, + fail_reason nvarchar(512) NOT NULL DEFAULT '', + stop_num int NOT NULL DEFAULT 0, + stop_reason nvarchar(512) NOT NULL DEFAULT '', + cancel_num int NOT NULL DEFAULT 0, + cancel_reason nvarchar(512) NOT NULL DEFAULT '', + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE UNIQUE INDEX uk_sj_job_summary_01 ON sj_job_summary (trigger_at, system_task_type, business_id) +GO + +CREATE INDEX idx_sj_job_summary_01 ON sj_job_summary (namespace_id, group_name, business_id) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓氬姟id ( job_id鎴杦orkflow_id ) ', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'business_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟绫诲瀷 3銆丣OB浠诲姟 4銆乄ORKFLOW浠诲姟', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'system_task_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁熻鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'trigger_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц鎴愬姛-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'success_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц澶辫触-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'fail_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'澶辫触鍘熷洜', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'fail_reason' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц澶辫触-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'stop_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'澶辫触鍘熷洜', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'stop_reason' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵ц澶辫触-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'cancel_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'澶辫触鍘熷洜', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'cancel_reason' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'DashBoard_Job', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_job_summary' +GO + +-- sj_retry_summary +CREATE TABLE sj_retry_summary +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL DEFAULT '', + scene_name nvarchar(50) NOT NULL DEFAULT '', + trigger_at datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + running_num int NOT NULL DEFAULT 0, + finish_num int NOT NULL DEFAULT 0, + max_count_num int NOT NULL DEFAULT 0, + suspend_num int NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE UNIQUE INDEX uk_sj_retry_summary_01 ON sj_retry_summary (namespace_id, group_name, scene_name, trigger_at) +GO + +CREATE INDEX idx_sj_retry_summary_01 ON sj_retry_summary (trigger_at) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍦烘櫙鍚嶇О', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'scene_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁熻鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'trigger_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閲嶈瘯涓�-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'running_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閲嶈瘯瀹屾垚-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'finish_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閲嶈瘯鍒拌揪鏈�澶ф鏁�-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'max_count_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鏆傚仠閲嶈瘯-鏃ュ織鏁伴噺', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'suspend_num' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'DashBoard_Retry', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_retry_summary' +GO + +-- sj_workflow +CREATE TABLE sj_workflow +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + workflow_name nvarchar(64) NOT NULL, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + workflow_status tinyint NOT NULL DEFAULT 1, + trigger_type tinyint NOT NULL, + trigger_interval nvarchar(255) NOT NULL, + next_trigger_at bigint NOT NULL, + block_strategy tinyint NOT NULL DEFAULT 1, + executor_timeout int NOT NULL DEFAULT 0, + description nvarchar(256) NOT NULL DEFAULT '', + flow_info nvarchar(max) NULL DEFAULT NULL, + bucket_index int NOT NULL DEFAULT 0, + version int NOT NULL, + ext_attrs nvarchar(256) NULL DEFAULT '', + deleted tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_workflow_01 ON sj_workflow (create_dt) +GO +CREATE INDEX idx_sj_workflow_02 ON sj_workflow (namespace_id, group_name) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佸悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'workflow_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佺姸鎬� 0銆佸叧闂��1銆佸紑鍚�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'workflow_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'瑙﹀彂绫诲瀷 1.CRON 琛ㄨ揪寮� 2. 鍥哄畾鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'trigger_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'闂撮殧鏃堕暱', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'trigger_interval' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓嬫瑙﹀彂鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'next_trigger_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'闃诲绛栫暐 1銆佷涪寮� 2銆佽鐩� 3銆佸苟琛�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'block_strategy' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鎵ц瓒呮椂鏃堕棿锛屽崟浣嶇', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'executor_timeout' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎻忚堪', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'description' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'娴佺▼淇℃伅', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'flow_info' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'bucket', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'bucket_index' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鐗堟湰鍙�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'version' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵╁睍瀛楁', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'ext_attrs' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'deleted' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow' +GO + +-- sj_workflow_node +CREATE TABLE sj_workflow_node +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + node_name nvarchar(64) NOT NULL, + group_name nvarchar(64) NOT NULL, + job_id bigint NOT NULL, + workflow_id bigint NOT NULL, + node_type tinyint NOT NULL DEFAULT 1, + expression_type tinyint NOT NULL DEFAULT 0, + fail_strategy tinyint NOT NULL DEFAULT 1, + workflow_node_status tinyint NOT NULL DEFAULT 1, + priority_level int NOT NULL DEFAULT 1, + node_info nvarchar(max) NULL DEFAULT NULL, + version int NOT NULL, + ext_attrs nvarchar(256) NULL DEFAULT '', + deleted tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_workflow_node_01 ON sj_workflow_node (create_dt) +GO +CREATE INDEX idx_sj_workflow_node_02 ON sj_workflow_node (namespace_id, group_name) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鑺傜偣鍚嶇О', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'node_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟淇℃伅id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'job_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴両D', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'workflow_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'1銆佷换鍔¤妭鐐� 2銆佹潯浠惰妭鐐�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'node_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'1銆丼pEl銆�2銆丄viator 3銆丵L', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'expression_type' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'澶辫触绛栫暐 1銆佽烦杩� 2銆侀樆濉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'fail_strategy' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佽妭鐐圭姸鎬� 0銆佸叧闂��1銆佸紑鍚�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'workflow_node_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浼樺厛绾�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'priority_level' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鑺傜偣淇℃伅 ', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'node_info' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鐗堟湰鍙�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'version' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵╁睍瀛楁', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'ext_attrs' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'deleted' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node', + 'COLUMN', N'update_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佽妭鐐�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_node' +GO + +-- sj_workflow_task_batch +CREATE TABLE sj_workflow_task_batch +( + id bigint NOT NULL PRIMARY KEY IDENTITY, + namespace_id nvarchar(64) NOT NULL DEFAULT '764d604ec6fc45f68cd92514c40e9e1a', + group_name nvarchar(64) NOT NULL, + workflow_id bigint NOT NULL, + task_batch_status tinyint NOT NULL DEFAULT 0, + operation_reason tinyint NOT NULL DEFAULT 0, + flow_info nvarchar(max) NULL DEFAULT NULL, + execution_at bigint NOT NULL DEFAULT 0, + ext_attrs nvarchar(256) NULL DEFAULT '', + deleted tinyint NOT NULL DEFAULT 0, + create_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_dt datetime2 NOT NULL DEFAULT CURRENT_TIMESTAMP +) +GO + +CREATE INDEX idx_sj_workflow_task_batch_01 ON sj_workflow_task_batch (workflow_id, task_batch_status) +GO +CREATE INDEX idx_sj_workflow_task_batch_02 ON sj_workflow_task_batch (create_dt) +GO +CREATE INDEX idx_sj_workflow_task_batch_03 ON sj_workflow_task_batch (namespace_id, group_name) +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'涓婚敭', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍛藉悕绌洪棿id', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'namespace_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'缁勫悕绉�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'group_name' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'宸ヤ綔娴佷换鍔d', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'workflow_id' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鎵规鐘舵�� 0銆佸け璐� 1銆佹垚鍔�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'task_batch_status' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎿嶄綔鍘熷洜', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'operation_reason' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'娴佺▼淇℃伅', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'flow_info' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'浠诲姟鎵ц鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'execution_at' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鎵╁睍瀛楁', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'ext_attrs' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'閫昏緫鍒犻櫎 1銆佸垹闄�', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'deleted' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'鍒涘缓鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'create_dt' +GO + +EXEC sp_addextendedproperty + 'MS_Description', N'淇敼鏃堕棿', + 'SCHEMA', N'dbo', + 'TABLE', N'sj_workflow_task_batch', + 'COLUMN', N'update_dt' GO EXEC sp_addextendedproperty 'MS_Description', N'宸ヤ綔娴佹壒娆�', 'SCHEMA', N'dbo', - 'TABLE', N'er_workflow_task_batch' + 'TABLE', N'sj_workflow_task_batch' GO + -- Gitblit v1.9.3