diff --git a/docker/build/hooks/build b/docker/build/hooks/build index a4aaaf7433..70ea260dea 100755 --- a/docker/build/hooks/build +++ b/docker/build/hooks/build @@ -39,8 +39,8 @@ echo "Repo: $DOCKER_REPO" echo -e "Current Directory is $(pwd)\n" # maven package(Project Directory) -echo -e "mvn -B clean package -Prelease -Dmaven.test.skip=true -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120" -mvn -B clean package -Prelease -Dmaven.test.skip=true -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120 +echo -e "./mvnw -B clean package -Prelease -Dmaven.test.skip=true -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120" +./mvnw -B clean package -Prelease -Dmaven.test.skip=true -Dhttp.keepAlive=false -Dmaven.wagon.http.pool=false -Dmaven.wagon.httpconnectionManager.ttlSeconds=120 # mv dolphinscheduler-bin.tar.gz file to docker/build directory echo -e "mv $(pwd)/dolphinscheduler-dist/target/apache-dolphinscheduler-${VERSION}-bin.tar.gz $(pwd)/docker/build/\n" diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DbType.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DbType.java index 46d59d11fc..b994afb5f5 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DbType.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/enums/DbType.java @@ -14,65 +14,45 @@ * See the License for the specific language governing permissions and * limitations under the License. */ + package org.apache.dolphinscheduler.common.enums; -import com.baomidou.mybatisplus.annotation.EnumValue; +import static java.util.stream.Collectors.toMap; -import java.util.HashMap; +import java.util.Arrays; +import java.util.Map; -/** - * data base types - */ -public enum DbType { - /** - * 0 mysql - * 1 postgresql - * 2 hive - * 3 spark - * 4 clickhouse - * 5 oracle - * 6 sqlserver - * 7 db2 - * 8 presto - */ - MYSQL(0, "mysql"), - POSTGRESQL(1, "postgresql"), - HIVE(2, "hive"), - SPARK(3, "spark"), - CLICKHOUSE(4, "clickhouse"), - ORACLE(5, "oracle"), - SQLSERVER(6, "sqlserver"), - DB2(7, "db2"), - PRESTO(8, "presto"); +import com.baomidou.mybatisplus.annotation.EnumValue; +import com.google.common.base.Functions; - DbType(int code, String descp) { +public enum DbType { + MYSQL(0), + POSTGRESQL(1), + HIVE(2), + SPARK(3), + CLICKHOUSE(4), + ORACLE(5), + SQLSERVER(6), + DB2(7), + PRESTO(8), + H2(9); + + DbType(int code) { this.code = code; - this.descp = descp; } @EnumValue private final int code; - private final String descp; public int getCode() { return code; } - public String getDescp() { - return descp; - } - - - private static HashMap DB_TYPE_MAP =new HashMap<>(); - - static { - for (DbType dbType:DbType.values()){ - DB_TYPE_MAP.put(dbType.getCode(),dbType); - } - } + private static final Map DB_TYPE_MAP = + Arrays.stream(DbType.values()).collect(toMap(DbType::getCode, Functions.identity())); - public static DbType of(int type){ - if(DB_TYPE_MAP.containsKey(type)){ + public static DbType of(int type) { + if (DB_TYPE_MAP.containsKey(type)) { return DB_TYPE_MAP.get(type); } return null; diff --git a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/PropertyUtils.java b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/PropertyUtils.java index 065d7bc2ea..53a97d9755 100644 --- a/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/PropertyUtils.java +++ b/dolphinscheduler-common/src/main/java/org/apache/dolphinscheduler/common/utils/PropertyUtils.java @@ -34,15 +34,7 @@ import java.util.Set; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -/** - * property utils - * single instance - */ public class PropertyUtils { - - /** - * logger - */ private static final Logger logger = LoggerFactory.getLogger(PropertyUtils.class); private static final Properties properties = new Properties(); @@ -55,9 +47,6 @@ public class PropertyUtils { loadPropertyFile(COMMON_PROPERTIES_PATH); } - /** - * init properties - */ public static synchronized void loadPropertyFile(String... propertyFiles) { for (String fileName : propertyFiles) { try (InputStream fis = PropertyUtils.class.getResourceAsStream(fileName);) { @@ -68,6 +57,13 @@ public class PropertyUtils { System.exit(1); } } + + // Override from system properties + System.getProperties().forEach((k, v) -> { + final String key = String.valueOf(k); + logger.info("Overriding property from system property: {}", key); + PropertyUtils.setValue(key, String.valueOf(v)); + }); } /** diff --git a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/SpringConnectionFactory.java b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/SpringConnectionFactory.java index a58955da19..ca4a7e20bd 100644 --- a/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/SpringConnectionFactory.java +++ b/dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/datasource/SpringConnectionFactory.java @@ -166,6 +166,7 @@ public class SpringConnectionFactory { Properties properties = new Properties(); properties.setProperty("MySQL", "mysql"); properties.setProperty("PostgreSQL", "pg"); + properties.setProperty("h2", "h2"); databaseIdProvider.setProperties(properties); return databaseIdProvider; } diff --git a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml index b78113b66f..0004f1dc67 100644 --- a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml +++ b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/WorkFlowLineageMapper.xml @@ -64,8 +64,7 @@ and project_code = #{projectCode} - select tepd.id as work_flow_id,tepd.name as work_flow_name, "" as source_work_flow_id, tepd.release_state as work_flow_publish_status, diff --git a/dolphinscheduler-dist/pom.xml b/dolphinscheduler-dist/pom.xml index 33a711cb89..e999a498ab 100644 --- a/dolphinscheduler-dist/pom.xml +++ b/dolphinscheduler-dist/pom.xml @@ -37,6 +37,11 @@ dolphinscheduler-server + + org.apache.dolphinscheduler + dolphinscheduler-standalone-server + + org.apache.dolphinscheduler dolphinscheduler-api @@ -377,4 +382,4 @@ - \ No newline at end of file + diff --git a/dolphinscheduler-dist/release-docs/LICENSE b/dolphinscheduler-dist/release-docs/LICENSE index 2308359cdf..19da58bec9 100644 --- a/dolphinscheduler-dist/release-docs/LICENSE +++ b/dolphinscheduler-dist/release-docs/LICENSE @@ -249,6 +249,7 @@ The text of each license is also included at licenses/LICENSE-[project].txt. curator-client 4.3.0: https://mvnrepository.com/artifact/org.apache.curator/curator-client/4.3.0, Apache 2.0 curator-framework 4.3.0: https://mvnrepository.com/artifact/org.apache.curator/curator-framework/4.3.0, Apache 2.0 curator-recipes 4.3.0: https://mvnrepository.com/artifact/org.apache.curator/curator-recipes/4.3.0, Apache 2.0 + curator-test 2.12.0: https://mvnrepository.com/artifact/org.apache.curator/curator-test/2.12.0, Apache 2.0 datanucleus-api-jdo 4.2.1: https://mvnrepository.com/artifact/org.datanucleus/datanucleus-api-jdo/4.2.1, Apache 2.0 datanucleus-core 4.1.6: https://mvnrepository.com/artifact/org.datanucleus/datanucleus-core/4.1.6, Apache 2.0 datanucleus-rdbms 4.1.7: https://mvnrepository.com/artifact/org.datanucleus/datanucleus-rdbms/4.1.7, Apache 2.0 @@ -557,4 +558,4 @@ Apache 2.0 licenses ======================================== BSD licenses ======================================== - d3 3.5.17: https://github.com/d3/d3 BSD-3-Clause \ No newline at end of file + d3 3.5.17: https://github.com/d3/d3 BSD-3-Clause diff --git a/dolphinscheduler-standalone-server/pom.xml b/dolphinscheduler-standalone-server/pom.xml new file mode 100644 index 0000000000..505a3b56e2 --- /dev/null +++ b/dolphinscheduler-standalone-server/pom.xml @@ -0,0 +1,52 @@ + + + + + dolphinscheduler + org.apache.dolphinscheduler + 1.3.6-SNAPSHOT + + 4.0.0 + + dolphinscheduler-standalone-server + + + + org.apache.dolphinscheduler + dolphinscheduler-server + + + org.apache.dolphinscheduler + dolphinscheduler-api + + + org.apache.curator + curator-test + ${curator.test} + + + org.javassist + javassist + + + + + + diff --git a/dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/server/StandaloneServer.java b/dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/server/StandaloneServer.java new file mode 100644 index 0000000000..3b92b7f7cb --- /dev/null +++ b/dolphinscheduler-standalone-server/src/main/java/org/apache/dolphinscheduler/server/StandaloneServer.java @@ -0,0 +1,82 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.dolphinscheduler.server; + +import static org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_DRIVER_CLASS_NAME; +import static org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_PASSWORD; +import static org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_URL; +import static org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_USERNAME; + +import org.apache.dolphinscheduler.api.ApiApplicationServer; +import org.apache.dolphinscheduler.common.utils.ScriptRunner; +import org.apache.dolphinscheduler.dao.datasource.ConnectionFactory; +import org.apache.dolphinscheduler.server.master.MasterServer; +import org.apache.dolphinscheduler.server.worker.WorkerServer; + +import org.apache.curator.test.TestingServer; + +import java.io.FileReader; +import java.nio.file.Files; +import java.nio.file.Path; + +import javax.sql.DataSource; + +import org.h2.tools.Server; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; +import org.springframework.boot.autoconfigure.SpringBootApplication; +import org.springframework.boot.builder.SpringApplicationBuilder; + +@SpringBootApplication +public class StandaloneServer { + private static final Logger LOGGER = LoggerFactory.getLogger(StandaloneServer.class); + + public static void main(String[] args) throws Exception { + System.setProperty("spring.profiles.active", "api"); + + final Path temp = Files.createTempDirectory("dolphinscheduler_"); + LOGGER.info("H2 database directory: {}", temp); + System.setProperty( + SPRING_DATASOURCE_DRIVER_CLASS_NAME, + org.h2.Driver.class.getName() + ); + System.setProperty( + SPRING_DATASOURCE_URL, + String.format("jdbc:h2:tcp://localhost/%s", temp.toAbsolutePath()) + ); + System.setProperty(SPRING_DATASOURCE_USERNAME, "sa"); + System.setProperty(SPRING_DATASOURCE_PASSWORD, ""); + + Server.createTcpServer("-ifNotExists").start(); + + final DataSource ds = ConnectionFactory.getInstance().getDataSource(); + final ScriptRunner runner = new ScriptRunner(ds.getConnection(), true, true); + runner.runScript(new FileReader("sql/dolphinscheduler_h2.sql")); + + final TestingServer server = new TestingServer(true); + System.setProperty("registry.servers", server.getConnectString()); + + Thread.currentThread().setName("Standalone-Server"); + + new SpringApplicationBuilder( + ApiApplicationServer.class, + MasterServer.class, + WorkerServer.class + ).run(args); + } +} diff --git a/dolphinscheduler-standalone-server/src/main/resources/registry.properties b/dolphinscheduler-standalone-server/src/main/resources/registry.properties new file mode 100644 index 0000000000..3f557ce033 --- /dev/null +++ b/dolphinscheduler-standalone-server/src/main/resources/registry.properties @@ -0,0 +1,22 @@ +# +# Licensed to the Apache Software Foundation (ASF) under one or more +# contributor license agreements. See the NOTICE file distributed with +# this work for additional information regarding copyright ownership. +# The ASF licenses this file to You under the Apache License, Version 2.0 +# (the "License"); you may not use this file except in compliance with +# the License. You may obtain a copy of the License at +# +# http://www.apache.org/licenses/LICENSE-2.0 +# +# Unless required by applicable law or agreed to in writing, software +# distributed under the License is distributed on an "AS IS" BASIS, +# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. +# See the License for the specific language governing permissions and +# limitations under the License. +# + +# This file is only to override the production configurations in standalone server. + +registry.plugin.dir=./dolphinscheduler-dist/target/dolphinscheduler-dist-1.3.6-SNAPSHOT/lib/plugin/registry/zookeeper +registry.plugin.name=zookeeper +registry.servers=127.0.0.1:2181 diff --git a/pom.xml b/pom.xml index ab518003f3..705a54b95b 100644 --- a/pom.xml +++ b/pom.xml @@ -206,6 +206,11 @@ dolphinscheduler-server ${project.version} + + org.apache.dolphinscheduler + dolphinscheduler-standalone-server + ${project.version} + org.apache.dolphinscheduler dolphinscheduler-common @@ -310,7 +315,6 @@ org.apache.curator curator-test ${curator.test} - test commons-codec @@ -661,7 +665,6 @@ javax.mail 1.6.2 - @@ -1209,5 +1212,6 @@ dolphinscheduler-remote dolphinscheduler-service dolphinscheduler-microbench + dolphinscheduler-standalone-server diff --git a/script/dolphinscheduler-daemon.sh b/script/dolphinscheduler-daemon.sh index cf3aeebe35..81af5fd60c 100755 --- a/script/dolphinscheduler-daemon.sh +++ b/script/dolphinscheduler-daemon.sh @@ -16,7 +16,7 @@ # limitations under the License. # -usage="Usage: dolphinscheduler-daemon.sh (start|stop|status) " +usage="Usage: dolphinscheduler-daemon.sh (start|stop|status) " # if no args specified, show usage if [ $# -le 1 ]; then @@ -87,6 +87,8 @@ elif [ "$command" = "zookeeper-server" ]; then #note: this command just for getting a quick experience，not recommended for production. this operation will start a standalone zookeeper server LOG_FILE="-Dlogback.configurationFile=classpath:logback-zookeeper.xml" CLASS=org.apache.dolphinscheduler.service.zk.ZKServer +elif [ "$command" = "standalone-server" ]; then + CLASS=org.apache.dolphinscheduler.server.StandaloneServer else echo "Error: No command named '$command' was found." exit 1 @@ -159,4 +161,4 @@ case $startStop in esac -echo "End $startStop $command." \ No newline at end of file +echo "End $startStop $command." diff --git a/sql/dolphinscheduler_h2.sql b/sql/dolphinscheduler_h2.sql new file mode 100644 index 0000000000..a5504163b0 --- /dev/null +++ b/sql/dolphinscheduler_h2.sql @@ -0,0 +1,943 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. +*/ + +SET FOREIGN_KEY_CHECKS=0; + +-- ---------------------------- +-- Table structure for QRTZ_JOB_DETAILS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_JOB_DETAILS; +CREATE TABLE QRTZ_JOB_DETAILS ( + SCHED_NAME varchar(120) NOT NULL, + JOB_NAME varchar(200) NOT NULL, + JOB_GROUP varchar(200) NOT NULL, + DESCRIPTION varchar(250) DEFAULT NULL, + JOB_CLASS_NAME varchar(250) NOT NULL, + IS_DURABLE varchar(1) NOT NULL, + IS_NONCONCURRENT varchar(1) NOT NULL, + IS_UPDATE_DATA varchar(1) NOT NULL, + REQUESTS_RECOVERY varchar(1) NOT NULL, + JOB_DATA blob, + PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP) +); + +-- ---------------------------- +-- Table structure for QRTZ_TRIGGERS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_TRIGGERS; +CREATE TABLE QRTZ_TRIGGERS ( + SCHED_NAME varchar(120) NOT NULL, + TRIGGER_NAME varchar(200) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + JOB_NAME varchar(200) NOT NULL, + JOB_GROUP varchar(200) NOT NULL, + DESCRIPTION varchar(250) DEFAULT NULL, + NEXT_FIRE_TIME bigint(13) DEFAULT NULL, + PREV_FIRE_TIME bigint(13) DEFAULT NULL, + PRIORITY int(11) DEFAULT NULL, + TRIGGER_STATE varchar(16) NOT NULL, + TRIGGER_TYPE varchar(8) NOT NULL, + START_TIME bigint(13) NOT NULL, + END_TIME bigint(13) DEFAULT NULL, + CALENDAR_NAME varchar(200) DEFAULT NULL, + MISFIRE_INSTR smallint(2) DEFAULT NULL, + JOB_DATA blob, + PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), + CONSTRAINT QRTZ_TRIGGERS_ibfk_1 FOREIGN KEY (SCHED_NAME, JOB_NAME, JOB_GROUP) REFERENCES QRTZ_JOB_DETAILS (SCHED_NAME, JOB_NAME, JOB_GROUP) +); + +-- ---------------------------- +-- Table structure for QRTZ_BLOB_TRIGGERS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS; +CREATE TABLE QRTZ_BLOB_TRIGGERS ( + SCHED_NAME varchar(120) NOT NULL, + TRIGGER_NAME varchar(200) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + BLOB_DATA blob, + PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), + FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) +); + +-- ---------------------------- +-- Records of QRTZ_BLOB_TRIGGERS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_CALENDARS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_CALENDARS; +CREATE TABLE QRTZ_CALENDARS ( + SCHED_NAME varchar(120) NOT NULL, + CALENDAR_NAME varchar(200) NOT NULL, + CALENDAR blob NOT NULL, + PRIMARY KEY (SCHED_NAME,CALENDAR_NAME) +); + +-- ---------------------------- +-- Records of QRTZ_CALENDARS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_CRON_TRIGGERS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS; +CREATE TABLE QRTZ_CRON_TRIGGERS ( + SCHED_NAME varchar(120) NOT NULL, + TRIGGER_NAME varchar(200) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + CRON_EXPRESSION varchar(120) NOT NULL, + TIME_ZONE_ID varchar(80) DEFAULT NULL, + PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), + CONSTRAINT QRTZ_CRON_TRIGGERS_ibfk_1 FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) +); + +-- ---------------------------- +-- Records of QRTZ_CRON_TRIGGERS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_FIRED_TRIGGERS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS; +CREATE TABLE QRTZ_FIRED_TRIGGERS ( + SCHED_NAME varchar(120) NOT NULL, + ENTRY_ID varchar(200) NOT NULL, + TRIGGER_NAME varchar(200) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + INSTANCE_NAME varchar(200) NOT NULL, + FIRED_TIME bigint(13) NOT NULL, + SCHED_TIME bigint(13) NOT NULL, + PRIORITY int(11) NOT NULL, + STATE varchar(16) NOT NULL, + JOB_NAME varchar(200) DEFAULT NULL, + JOB_GROUP varchar(200) DEFAULT NULL, + IS_NONCONCURRENT varchar(1) DEFAULT NULL, + REQUESTS_RECOVERY varchar(1) DEFAULT NULL, + PRIMARY KEY (SCHED_NAME,ENTRY_ID) +); + +-- ---------------------------- +-- Records of QRTZ_FIRED_TRIGGERS +-- ---------------------------- + +-- ---------------------------- +-- Records of QRTZ_JOB_DETAILS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_LOCKS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_LOCKS; +CREATE TABLE QRTZ_LOCKS ( + SCHED_NAME varchar(120) NOT NULL, + LOCK_NAME varchar(40) NOT NULL, + PRIMARY KEY (SCHED_NAME,LOCK_NAME) +); + +-- ---------------------------- +-- Records of QRTZ_LOCKS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_PAUSED_TRIGGER_GRPS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS; +CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS ( + SCHED_NAME varchar(120) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP) +); + +-- ---------------------------- +-- Records of QRTZ_PAUSED_TRIGGER_GRPS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_SCHEDULER_STATE +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE; +CREATE TABLE QRTZ_SCHEDULER_STATE ( + SCHED_NAME varchar(120) NOT NULL, + INSTANCE_NAME varchar(200) NOT NULL, + LAST_CHECKIN_TIME bigint(13) NOT NULL, + CHECKIN_INTERVAL bigint(13) NOT NULL, + PRIMARY KEY (SCHED_NAME,INSTANCE_NAME) +); + +-- ---------------------------- +-- Records of QRTZ_SCHEDULER_STATE +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_SIMPLE_TRIGGERS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS; +CREATE TABLE QRTZ_SIMPLE_TRIGGERS ( + SCHED_NAME varchar(120) NOT NULL, + TRIGGER_NAME varchar(200) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + REPEAT_COUNT bigint(7) NOT NULL, + REPEAT_INTERVAL bigint(12) NOT NULL, + TIMES_TRIGGERED bigint(10) NOT NULL, + PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), + CONSTRAINT QRTZ_SIMPLE_TRIGGERS_ibfk_1 FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) +); + +-- ---------------------------- +-- Records of QRTZ_SIMPLE_TRIGGERS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for QRTZ_SIMPROP_TRIGGERS +-- ---------------------------- +DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS; +CREATE TABLE QRTZ_SIMPROP_TRIGGERS ( + SCHED_NAME varchar(120) NOT NULL, + TRIGGER_NAME varchar(200) NOT NULL, + TRIGGER_GROUP varchar(200) NOT NULL, + STR_PROP_1 varchar(512) DEFAULT NULL, + STR_PROP_2 varchar(512) DEFAULT NULL, + STR_PROP_3 varchar(512) DEFAULT NULL, + INT_PROP_1 int(11) DEFAULT NULL, + INT_PROP_2 int(11) DEFAULT NULL, + LONG_PROP_1 bigint(20) DEFAULT NULL, + LONG_PROP_2 bigint(20) DEFAULT NULL, + DEC_PROP_1 decimal(13,4) DEFAULT NULL, + DEC_PROP_2 decimal(13,4) DEFAULT NULL, + BOOL_PROP_1 varchar(1) DEFAULT NULL, + BOOL_PROP_2 varchar(1) DEFAULT NULL, + PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), + CONSTRAINT QRTZ_SIMPROP_TRIGGERS_ibfk_1 FOREIGN KEY (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS (SCHED_NAME, TRIGGER_NAME, TRIGGER_GROUP) +); + +-- ---------------------------- +-- Records of QRTZ_SIMPROP_TRIGGERS +-- ---------------------------- + +-- ---------------------------- +-- Records of QRTZ_TRIGGERS +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_access_token +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_access_token; +CREATE TABLE t_ds_access_token ( + id int(11) NOT NULL AUTO_INCREMENT, + user_id int(11) DEFAULT NULL, + token varchar(64) DEFAULT NULL, + expire_time datetime DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +); + +-- ---------------------------- +-- Records of t_ds_access_token +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_alert +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_alert; +CREATE TABLE t_ds_alert ( + id int(11) NOT NULL AUTO_INCREMENT, + title varchar(64) DEFAULT NULL, + content text, + alert_status tinyint(4) DEFAULT '0', + log text, + alertgroup_id int(11) DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_alert +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_alertgroup +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_alertgroup; +CREATE TABLE t_ds_alertgroup( + id int(11) NOT NULL AUTO_INCREMENT, + alert_instance_ids varchar (255) DEFAULT NULL, + create_user_id int(11) DEFAULT NULL, + group_name varchar(255) DEFAULT NULL, + description varchar(255) DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY t_ds_alertgroup_name_un (group_name) +) ; + +-- ---------------------------- +-- Records of t_ds_alertgroup +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_command +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_command; +CREATE TABLE t_ds_command ( + id int(11) NOT NULL AUTO_INCREMENT, + command_type tinyint(4) DEFAULT NULL, + process_definition_id int(11) DEFAULT NULL, + command_param text, + task_depend_type tinyint(4) DEFAULT NULL, + failure_strategy tinyint(4) DEFAULT '0', + warning_type tinyint(4) DEFAULT '0', + warning_group_id int(11) DEFAULT NULL, + schedule_time datetime DEFAULT NULL, + start_time datetime DEFAULT NULL, + executor_id int(11) DEFAULT NULL, + update_time datetime DEFAULT NULL, + process_instance_priority int(11) DEFAULT NULL, + worker_group varchar(64) , + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_command +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_datasource +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_datasource; +CREATE TABLE t_ds_datasource ( + id int(11) NOT NULL AUTO_INCREMENT, + name varchar(64) NOT NULL, + note varchar(255) DEFAULT NULL, + type tinyint(4) NOT NULL, + user_id int(11) NOT NULL, + connection_params text NOT NULL, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY t_ds_datasource_name_un (name, type) +) ; + +-- ---------------------------- +-- Records of t_ds_datasource +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_error_command +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_error_command; +CREATE TABLE t_ds_error_command ( + id int(11) NOT NULL, + command_type tinyint(4) DEFAULT NULL, + executor_id int(11) DEFAULT NULL, + process_definition_id int(11) DEFAULT NULL, + command_param text, + task_depend_type tinyint(4) DEFAULT NULL, + failure_strategy tinyint(4) DEFAULT '0', + warning_type tinyint(4) DEFAULT '0', + warning_group_id int(11) DEFAULT NULL, + schedule_time datetime DEFAULT NULL, + start_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + process_instance_priority int(11) DEFAULT NULL, + worker_group varchar(64) , + message text, + PRIMARY KEY (id) +); + +-- ---------------------------- +-- Records of t_ds_error_command +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_process_definition +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_process_definition; +CREATE TABLE t_ds_process_definition ( + id int(11) NOT NULL AUTO_INCREMENT, + code bigint(20) NOT NULL, + name varchar(255) DEFAULT NULL, + version int(11) DEFAULT NULL, + description text, + project_code bigint(20) NOT NULL, + release_state tinyint(4) DEFAULT NULL, + user_id int(11) DEFAULT NULL, + global_params text, + flag tinyint(4) DEFAULT NULL, + locations text, + connects text, + warning_group_id int(11) DEFAULT NULL, + timeout int(11) DEFAULT '0', + tenant_id int(11) NOT NULL DEFAULT '-1', + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY process_unique (name,project_code) USING BTREE, + UNIQUE KEY code_unique (code) +) ; + +-- ---------------------------- +-- Records of t_ds_process_definition +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_process_definition_log +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_process_definition_log; +CREATE TABLE t_ds_process_definition_log ( + id int(11) NOT NULL AUTO_INCREMENT, + code bigint(20) NOT NULL, + name varchar(200) DEFAULT NULL, + version int(11) DEFAULT NULL, + description text, + project_code bigint(20) NOT NULL, + release_state tinyint(4) DEFAULT NULL, + user_id int(11) DEFAULT NULL, + global_params text, + flag tinyint(4) DEFAULT NULL, + locations text, + connects text, + warning_group_id int(11) DEFAULT NULL, + timeout int(11) DEFAULT '0', + tenant_id int(11) NOT NULL DEFAULT '-1', + operator int(11) DEFAULT NULL, + operate_time datetime DEFAULT NULL, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Table structure for t_ds_task_definition +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_task_definition; +CREATE TABLE t_ds_task_definition ( + id int(11) NOT NULL AUTO_INCREMENT, + code bigint(20) NOT NULL, + name varchar(200) DEFAULT NULL, + version int(11) DEFAULT NULL, + description text, + project_code bigint(20) NOT NULL, + user_id int(11) DEFAULT NULL, + task_type varchar(50) NOT NULL, + task_params longtext, + flag tinyint(2) DEFAULT NULL, + task_priority tinyint(4) DEFAULT NULL, + worker_group varchar(200) DEFAULT NULL, + fail_retry_times int(11) DEFAULT NULL, + fail_retry_interval int(11) DEFAULT NULL, + timeout_flag tinyint(2) DEFAULT '0', + timeout_notify_strategy tinyint(4) DEFAULT NULL, + timeout int(11) DEFAULT '0', + delay_time int(11) DEFAULT '0', + resource_ids varchar(255) DEFAULT NULL, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id,code), + UNIQUE KEY task_unique (name,project_code) USING BTREE +) ; + +-- ---------------------------- +-- Table structure for t_ds_task_definition_log +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_task_definition_log; +CREATE TABLE t_ds_task_definition_log ( + id int(11) NOT NULL AUTO_INCREMENT, + code bigint(20) NOT NULL, + name varchar(200) DEFAULT NULL, + version int(11) DEFAULT NULL, + description text, + project_code bigint(20) NOT NULL, + user_id int(11) DEFAULT NULL, + task_type varchar(50) NOT NULL, + task_params text, + flag tinyint(2) DEFAULT NULL, + task_priority tinyint(4) DEFAULT NULL, + worker_group varchar(200) DEFAULT NULL, + fail_retry_times int(11) DEFAULT NULL, + fail_retry_interval int(11) DEFAULT NULL, + timeout_flag tinyint(2) DEFAULT '0', + timeout_notify_strategy tinyint(4) DEFAULT NULL, + timeout int(11) DEFAULT '0', + delay_time int(11) DEFAULT '0', + resource_ids varchar(255) DEFAULT NULL, + operator int(11) DEFAULT NULL, + operate_time datetime DEFAULT NULL, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Table structure for t_ds_process_task_relation +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_process_task_relation; +CREATE TABLE t_ds_process_task_relation ( + id int(11) NOT NULL AUTO_INCREMENT, + name varchar(200) DEFAULT NULL, + process_definition_version int(11) DEFAULT NULL, + project_code bigint(20) NOT NULL, + process_definition_code bigint(20) NOT NULL, + pre_task_code bigint(20) NOT NULL, + pre_task_version int(11) NOT NULL, + post_task_code bigint(20) NOT NULL, + post_task_version int(11) NOT NULL, + condition_type tinyint(2) DEFAULT NULL, + condition_params text, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Table structure for t_ds_process_task_relation_log +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_process_task_relation_log; +CREATE TABLE t_ds_process_task_relation_log ( + id int(11) NOT NULL AUTO_INCREMENT, + name varchar(200) DEFAULT NULL, + process_definition_version int(11) DEFAULT NULL, + project_code bigint(20) NOT NULL, + process_definition_code bigint(20) NOT NULL, + pre_task_code bigint(20) NOT NULL, + pre_task_version int(11) NOT NULL, + post_task_code bigint(20) NOT NULL, + post_task_version int(11) NOT NULL, + condition_type tinyint(2) DEFAULT NULL, + condition_params text, + operator int(11) DEFAULT NULL, + operate_time datetime DEFAULT NULL, + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Table structure for t_ds_process_instance +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_process_instance; +CREATE TABLE t_ds_process_instance ( + id int(11) NOT NULL AUTO_INCREMENT, + name varchar(255) DEFAULT NULL, + process_definition_version int(11) DEFAULT NULL, + process_definition_code bigint(20) not NULL, + state tinyint(4) DEFAULT NULL, + recovery tinyint(4) DEFAULT NULL, + start_time datetime DEFAULT NULL, + end_time datetime DEFAULT NULL, + run_times int(11) DEFAULT NULL, + host varchar(135) DEFAULT NULL, + command_type tinyint(4) DEFAULT NULL, + command_param text, + task_depend_type tinyint(4) DEFAULT NULL, + max_try_times tinyint(4) DEFAULT '0', + failure_strategy tinyint(4) DEFAULT '0', + warning_type tinyint(4) DEFAULT '0', + warning_group_id int(11) DEFAULT NULL, + schedule_time datetime DEFAULT NULL, + command_start_time datetime DEFAULT NULL, + global_params text, + flag tinyint(4) DEFAULT '1', + update_time timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + is_sub_process int(11) DEFAULT '0', + executor_id int(11) NOT NULL, + history_cmd text, + process_instance_priority int(11) DEFAULT NULL, + worker_group varchar(64) DEFAULT NULL, + timeout int(11) DEFAULT '0', + tenant_id int(11) NOT NULL DEFAULT '-1', + var_pool longtext, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_process_instance +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_project +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_project; +CREATE TABLE t_ds_project ( + id int(11) NOT NULL AUTO_INCREMENT, + name varchar(100) DEFAULT NULL, + code bigint(20) NOT NULL, + description varchar(200) DEFAULT NULL, + user_id int(11) DEFAULT NULL, + flag tinyint(4) DEFAULT '1', + create_time datetime NOT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_project +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_queue +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_queue; +CREATE TABLE t_ds_queue ( + id int(11) NOT NULL AUTO_INCREMENT, + queue_name varchar(64) DEFAULT NULL, + queue varchar(64) DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_queue +-- ---------------------------- +INSERT INTO t_ds_queue VALUES ('1', 'default', 'default', null, null); + +-- ---------------------------- +-- Table structure for t_ds_relation_datasource_user +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_relation_datasource_user; +CREATE TABLE t_ds_relation_datasource_user ( + id int(11) NOT NULL AUTO_INCREMENT, + user_id int(11) NOT NULL, + datasource_id int(11) DEFAULT NULL, + perm int(11) DEFAULT '1', + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_relation_datasource_user +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_relation_process_instance +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_relation_process_instance; +CREATE TABLE t_ds_relation_process_instance ( + id int(11) NOT NULL AUTO_INCREMENT, + parent_process_instance_id int(11) DEFAULT NULL, + parent_task_instance_id int(11) DEFAULT NULL, + process_instance_id int(11) DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_relation_process_instance +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_relation_project_user +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_relation_project_user; +CREATE TABLE t_ds_relation_project_user ( + id int(11) NOT NULL AUTO_INCREMENT, + user_id int(11) NOT NULL, + project_id int(11) DEFAULT NULL, + perm int(11) DEFAULT '1', + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_relation_project_user +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_relation_resources_user +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_relation_resources_user; +CREATE TABLE t_ds_relation_resources_user ( + id int(11) NOT NULL AUTO_INCREMENT, + user_id int(11) NOT NULL, + resources_id int(11) DEFAULT NULL, + perm int(11) DEFAULT '1', + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_relation_resources_user +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_relation_udfs_user +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_relation_udfs_user; +CREATE TABLE t_ds_relation_udfs_user ( + id int(11) NOT NULL AUTO_INCREMENT, + user_id int(11) NOT NULL, + udf_id int(11) DEFAULT NULL, + perm int(11) DEFAULT '1', + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Table structure for t_ds_resources +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_resources; +CREATE TABLE t_ds_resources ( + id int(11) NOT NULL AUTO_INCREMENT, + alias varchar(64) DEFAULT NULL, + file_name varchar(64) DEFAULT NULL, + description varchar(255) DEFAULT NULL, + user_id int(11) DEFAULT NULL, + type tinyint(4) DEFAULT NULL, + size bigint(20) DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + pid int(11) DEFAULT NULL, + full_name varchar(64) DEFAULT NULL, + is_directory tinyint(4) DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY t_ds_resources_un (full_name,type) +) ; + +-- ---------------------------- +-- Records of t_ds_resources +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_schedules +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_schedules; +CREATE TABLE t_ds_schedules ( + id int(11) NOT NULL AUTO_INCREMENT, + process_definition_id int(11) NOT NULL, + start_time datetime NOT NULL, + end_time datetime NOT NULL, + timezone_id varchar(40) DEFAULT NULL, + crontab varchar(255) NOT NULL, + failure_strategy tinyint(4) NOT NULL, + user_id int(11) NOT NULL, + release_state tinyint(4) NOT NULL, + warning_type tinyint(4) NOT NULL, + warning_group_id int(11) DEFAULT NULL, + process_instance_priority int(11) DEFAULT NULL, + worker_group varchar(64) DEFAULT '', + create_time datetime NOT NULL, + update_time datetime NOT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_schedules +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_session +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_session; +CREATE TABLE t_ds_session ( + id varchar(64) NOT NULL, + user_id int(11) DEFAULT NULL, + ip varchar(45) DEFAULT NULL, + last_login_time datetime DEFAULT NULL, + PRIMARY KEY (id) +); + +-- ---------------------------- +-- Records of t_ds_session +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_task_instance +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_task_instance; +CREATE TABLE t_ds_task_instance ( + id int(11) NOT NULL AUTO_INCREMENT, + name varchar(255) DEFAULT NULL, + task_type varchar(50) NOT NULL, + task_code bigint(20) NOT NULL, + task_definition_version int(11) DEFAULT NULL, + process_instance_id int(11) DEFAULT NULL, + state tinyint(4) DEFAULT NULL, + submit_time datetime DEFAULT NULL, + start_time datetime DEFAULT NULL, + end_time datetime DEFAULT NULL, + host varchar(135) DEFAULT NULL, + execute_path varchar(200) DEFAULT NULL, + log_path varchar(200) DEFAULT NULL, + alert_flag tinyint(4) DEFAULT NULL, + retry_times int(4) DEFAULT '0', + pid int(4) DEFAULT NULL, + app_link text, + task_params text, + flag tinyint(4) DEFAULT '1', + retry_interval int(4) DEFAULT NULL, + max_retry_times int(2) DEFAULT NULL, + task_instance_priority int(11) DEFAULT NULL, + worker_group varchar(64) DEFAULT NULL, + executor_id int(11) DEFAULT NULL, + first_submit_time datetime DEFAULT NULL, + delay_time int(4) DEFAULT '0', + var_pool longtext, + PRIMARY KEY (id), + FOREIGN KEY (process_instance_id) REFERENCES t_ds_process_instance (id) ON DELETE CASCADE +) ; + +-- ---------------------------- +-- Records of t_ds_task_instance +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_tenant +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_tenant; +CREATE TABLE t_ds_tenant ( + id int(11) NOT NULL AUTO_INCREMENT, + tenant_code varchar(64) DEFAULT NULL, + description varchar(255) DEFAULT NULL, + queue_id int(11) DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_tenant +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_udfs +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_udfs; +CREATE TABLE t_ds_udfs ( + id int(11) NOT NULL AUTO_INCREMENT, + user_id int(11) NOT NULL, + func_name varchar(100) NOT NULL, + class_name varchar(255) NOT NULL, + type tinyint(4) NOT NULL, + arg_types varchar(255) DEFAULT NULL, + database varchar(255) DEFAULT NULL, + description varchar(255) DEFAULT NULL, + resource_id int(11) NOT NULL, + resource_name varchar(255) NOT NULL, + create_time datetime NOT NULL, + update_time datetime NOT NULL, + PRIMARY KEY (id) +) ; + +-- ---------------------------- +-- Records of t_ds_udfs +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_user +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_user; +CREATE TABLE t_ds_user ( + id int(11) NOT NULL AUTO_INCREMENT, + user_name varchar(64) DEFAULT NULL, + user_password varchar(64) DEFAULT NULL, + user_type tinyint(4) DEFAULT NULL, + email varchar(64) DEFAULT NULL, + phone varchar(11) DEFAULT NULL, + tenant_id int(11) DEFAULT NULL, + create_time datetime DEFAULT NULL, + update_time datetime DEFAULT NULL, + queue varchar(64) DEFAULT NULL, + state int(1) DEFAULT 1, + PRIMARY KEY (id), + UNIQUE KEY user_name_unique (user_name) +) ; + +-- ---------------------------- +-- Records of t_ds_user +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_worker_group +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_worker_group; +CREATE TABLE t_ds_worker_group ( + id bigint(11) NOT NULL AUTO_INCREMENT, + name varchar(255) NOT NULL, + addr_list text NULL DEFAULT NULL, + create_time datetime NULL DEFAULT NULL, + update_time datetime NULL DEFAULT NULL, + PRIMARY KEY (id), + UNIQUE KEY name_unique (name) +) ; + +-- ---------------------------- +-- Records of t_ds_worker_group +-- ---------------------------- + +-- ---------------------------- +-- Table structure for t_ds_version +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_version; +CREATE TABLE t_ds_version ( + id int(11) NOT NULL AUTO_INCREMENT, + version varchar(200) NOT NULL, + PRIMARY KEY (id), + UNIQUE KEY version_UNIQUE (version) +) ; + +-- ---------------------------- +-- Records of t_ds_version +-- ---------------------------- +INSERT INTO t_ds_version VALUES ('1', '1.4.0'); + + +-- ---------------------------- +-- Records of t_ds_alertgroup +-- ---------------------------- +INSERT INTO t_ds_alertgroup(alert_instance_ids, create_user_id, group_name, description, create_time, update_time) +VALUES ('1,2', 1, 'default admin warning group', 'default admin warning group', '2018-11-29 10:20:39', '2018-11-29 10:20:39'); + +-- ---------------------------- +-- Records of t_ds_user +-- ---------------------------- +INSERT INTO t_ds_user +VALUES ('1', 'admin', '7ad2410b2f4c074479a8937a28a22b8f', '0', 'xxx@qq.com', '', '0', '2018-03-27 15:48:50', '2018-10-24 17:40:22', null, 1); + +-- ---------------------------- +-- Table structure for t_ds_plugin_define +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_plugin_define; +CREATE TABLE t_ds_plugin_define ( + id int NOT NULL AUTO_INCREMENT, + plugin_name varchar(100) NOT NULL, + plugin_type varchar(100) NOT NULL, + plugin_params text, + create_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP, + update_time timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + PRIMARY KEY (id), + UNIQUE KEY t_ds_plugin_define_UN (plugin_name,plugin_type) +); + +-- ---------------------------- +-- Table structure for t_ds_alert_plugin_instance +-- ---------------------------- +DROP TABLE IF EXISTS t_ds_alert_plugin_instance; +CREATE TABLE t_ds_alert_plugin_instance ( + id int NOT NULL AUTO_INCREMENT, + plugin_define_id int NOT NULL, + plugin_instance_params text, + create_time timestamp NULL DEFAULT CURRENT_TIMESTAMP, + update_time timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, + instance_name varchar(200) DEFAULT NULL, + PRIMARY KEY (id) +); diff --git a/tools/dependencies/known-dependencies.txt b/tools/dependencies/known-dependencies.txt index 8ff0c29053..a48d40f12e 100755 --- a/tools/dependencies/known-dependencies.txt +++ b/tools/dependencies/known-dependencies.txt @@ -49,6 +49,7 @@ cron-utils-5.0.5.jar curator-client-4.3.0.jar curator-framework-4.3.0.jar curator-recipes-4.3.0.jar +curator-test-2.12.0.jar curvesapi-1.06.jar datanucleus-api-jdo-4.2.1.jar datanucleus-core-4.1.6.jar