This is an automated email from the ASF dual-hosted git repository.
kirs pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git
The following commit(s) were added to refs/heads/dev by this push:
new dc85e1a Add alert server into standalone-server as well and some
minor polish (#6087)
dc85e1a is described below
commit dc85e1a73c5f3497b5ce0753e88298a1a0912d05
Author: kezhenxu94 <[email protected]>
AuthorDate: Thu Sep 2 17:14:18 2021 +0800
Add alert server into standalone-server as well and some minor polish
(#6087)
---
.asf.yaml | 5 +-
.../plugin/alert/email/MailSender.java | 2 +-
.../apache/dolphinscheduler/alert/AlertServer.java | 85 +-
.../alert/plugin/AlertPluginManager.java | 2 +-
.../alert/processor/AlertRequestProcessor.java | 7 +-
.../dolphinscheduler/alert/runner/AlertSender.java | 5 +-
.../dolphinscheduler/alert/utils/FuncUtils.java | 47 -
.../alert/utils/FuncUtilsTest.java | 60 -
.../dao/mapper/PluginDefineMapper.xml | 2 +-
dolphinscheduler-standalone-server/pom.xml | 4 +
.../dolphinscheduler/server/StandaloneServer.java | 67 +-
sql/dolphinscheduler_h2.sql | 1153 ++++++++++----------
12 files changed, 686 insertions(+), 753 deletions(-)
diff --git a/.asf.yaml b/.asf.yaml
index 80760e3..2eca3ad 100644
--- a/.asf.yaml
+++ b/.asf.yaml
@@ -16,10 +16,7 @@
#
github:
- description: >
- Apache DolphinScheduler is a distributed and extensible workflow scheduler
platform with powerful DAG
- visual interfaces, dedicated to solving complex job dependencies in the
data pipeline and providing
- various types of jobs available out of box.
+ description: Apache DolphinScheduler is a distributed and extensible
workflow scheduler platform with powerful DAG visual interfaces, dedicated to
solving complex job dependencies in the data pipeline and providing various
types of jobs available out of box.
homepage: https://dolphinscheduler.apache.org/
labels:
- airflow
diff --git
a/dolphinscheduler-alert-plugin/dolphinscheduler-alert-email/src/main/java/org/apache/dolphinscheduler/plugin/alert/email/MailSender.java
b/dolphinscheduler-alert-plugin/dolphinscheduler-alert-email/src/main/java/org/apache/dolphinscheduler/plugin/alert/email/MailSender.java
index 7afdf86..33701de 100644
---
a/dolphinscheduler-alert-plugin/dolphinscheduler-alert-email/src/main/java/org/apache/dolphinscheduler/plugin/alert/email/MailSender.java
+++
b/dolphinscheduler-alert-plugin/dolphinscheduler-alert-email/src/main/java/org/apache/dolphinscheduler/plugin/alert/email/MailSender.java
@@ -80,7 +80,7 @@ public class MailSender {
private String sslTrust;
private String showType;
private AlertTemplate alertTemplate;
- private String mustNotNull = "must not be null";
+ private String mustNotNull = " must not be null";
public MailSender(Map<String, String> config) {
diff --git
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
index b76cdb7..b0a8c03 100644
---
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
+++
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/AlertServer.java
@@ -24,8 +24,6 @@ import
org.apache.dolphinscheduler.alert.plugin.AlertPluginManager;
import org.apache.dolphinscheduler.alert.processor.AlertRequestProcessor;
import org.apache.dolphinscheduler.alert.runner.AlertSender;
import org.apache.dolphinscheduler.alert.utils.Constants;
-import org.apache.dolphinscheduler.spi.plugin.DolphinPluginLoader;
-import org.apache.dolphinscheduler.spi.plugin.DolphinPluginManagerConfig;
import org.apache.dolphinscheduler.common.thread.Stopper;
import org.apache.dolphinscheduler.common.utils.PropertyUtils;
import org.apache.dolphinscheduler.dao.AlertDao;
@@ -35,6 +33,8 @@ import org.apache.dolphinscheduler.dao.entity.Alert;
import org.apache.dolphinscheduler.remote.NettyRemotingServer;
import org.apache.dolphinscheduler.remote.command.CommandType;
import org.apache.dolphinscheduler.remote.config.NettyServerConfig;
+import org.apache.dolphinscheduler.spi.plugin.DolphinPluginLoader;
+import org.apache.dolphinscheduler.spi.plugin.DolphinPluginManagerConfig;
import org.apache.dolphinscheduler.spi.utils.StringUtils;
import java.util.List;
@@ -44,45 +44,29 @@ import org.slf4j.LoggerFactory;
import com.google.common.collect.ImmutableList;
-/**
- * alert of start
- */
public class AlertServer {
private static final Logger logger =
LoggerFactory.getLogger(AlertServer.class);
- /**
- * Plugin Dao
- */
- private PluginDao pluginDao = DaoFactory.getDaoInstance(PluginDao.class);
+ private final PluginDao pluginDao =
DaoFactory.getDaoInstance(PluginDao.class);
- /**
- * Alert Dao
- */
- private AlertDao alertDao = DaoFactory.getDaoInstance(AlertDao.class);
-
- private AlertSender alertSender;
+ private final AlertDao alertDao =
DaoFactory.getDaoInstance(AlertDao.class);
private AlertPluginManager alertPluginManager;
- private DolphinPluginManagerConfig alertPluginManagerConfig;
-
public static final String ALERT_PLUGIN_BINDING = "alert.plugin.binding";
public static final String ALERT_PLUGIN_DIR = "alert.plugin.dir";
public static final String MAVEN_LOCAL_REPOSITORY =
"maven.local.repository";
- /**
- * netty server
- */
private NettyRemotingServer server;
private static class AlertServerHolder {
private static final AlertServer INSTANCE = new AlertServer();
}
- public static final AlertServer getInstance() {
+ public static AlertServer getInstance() {
return AlertServerHolder.INSTANCE;
}
@@ -98,8 +82,7 @@ public class AlertServer {
}
private void initPlugin() {
- alertPluginManager = new AlertPluginManager();
- alertPluginManagerConfig = new DolphinPluginManagerConfig();
+ DolphinPluginManagerConfig alertPluginManagerConfig = new
DolphinPluginManagerConfig();
alertPluginManagerConfig.setPlugins(PropertyUtils.getString(ALERT_PLUGIN_BINDING));
if (StringUtils.isNotBlank(PropertyUtils.getString(ALERT_PLUGIN_DIR)))
{
alertPluginManagerConfig.setInstalledPluginsDir(PropertyUtils.getString(ALERT_PLUGIN_DIR,
Constants.ALERT_PLUGIN_PATH).trim());
@@ -109,6 +92,7 @@ public class AlertServer {
alertPluginManagerConfig.setMavenLocalRepository(PropertyUtils.getString(MAVEN_LOCAL_REPOSITORY).trim());
}
+ alertPluginManager = new AlertPluginManager();
DolphinPluginLoader alertPluginLoader = new
DolphinPluginLoader(alertPluginManagerConfig,
ImmutableList.of(alertPluginManager));
try {
alertPluginLoader.loadPlugins();
@@ -117,9 +101,6 @@ public class AlertServer {
}
}
- /**
- * init netty remoting server
- */
private void initRemoteServer() {
NettyServerConfig serverConfig = new NettyServerConfig();
serverConfig.setListenPort(ALERT_RPC_PORT);
@@ -128,30 +109,10 @@ public class AlertServer {
this.server.start();
}
- /**
- * Cyclic alert info sending alert
- */
private void runSender() {
- while (Stopper.isRunning()) {
- try {
- Thread.sleep(Constants.ALERT_SCAN_INTERVAL);
- } catch (InterruptedException e) {
- logger.error(e.getMessage(), e);
- Thread.currentThread().interrupt();
- }
- if (alertPluginManager == null ||
alertPluginManager.getAlertChannelMap().size() == 0) {
- logger.warn("No Alert Plugin . Cannot send alert info. ");
- } else {
- List<Alert> alerts = alertDao.listWaitExecutionAlert();
- alertSender = new AlertSender(alerts, alertDao,
alertPluginManager);
- alertSender.run();
- }
- }
+ new Thread(new Sender()).start();
}
- /**
- * start
- */
public void start() {
PropertyUtils.loadPropertyFile(ALERT_PROPERTIES_PATH);
checkTable();
@@ -161,23 +122,35 @@ public class AlertServer {
runSender();
}
- /**
- * stop
- */
public void stop() {
this.server.close();
logger.info("alert server shut down");
}
+ final class Sender implements Runnable {
+ @Override
+ public void run() {
+ while (Stopper.isRunning()) {
+ try {
+ Thread.sleep(Constants.ALERT_SCAN_INTERVAL);
+ } catch (InterruptedException e) {
+ logger.error(e.getMessage(), e);
+ Thread.currentThread().interrupt();
+ }
+ if (alertPluginManager == null ||
alertPluginManager.getAlertChannelMap().size() == 0) {
+ logger.warn("No Alert Plugin . Cannot send alert info. ");
+ } else {
+ List<Alert> alerts = alertDao.listWaitExecutionAlert();
+ new AlertSender(alerts, alertDao,
alertPluginManager).run();
+ }
+ }
+ }
+ }
+
public static void main(String[] args) {
AlertServer alertServer = AlertServer.getInstance();
alertServer.start();
- Runtime.getRuntime().addShutdownHook(new Thread() {
- @Override
- public void run() {
- alertServer.stop();
- }
- });
+ Runtime.getRuntime().addShutdownHook(new Thread(alertServer::stop));
}
}
diff --git
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
index 4fbe2bd..02f4b0f 100644
---
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
+++
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/plugin/AlertPluginManager.java
@@ -56,7 +56,7 @@ public class AlertPluginManager extends
AbstractDolphinPluginManager {
*/
private final Map<Integer, String> pluginDefineMap = new HashMap<>();
- private PluginDao pluginDao = DaoFactory.getDaoInstance(PluginDao.class);
+ private final PluginDao pluginDao =
DaoFactory.getDaoInstance(PluginDao.class);
private void addAlertChannelFactory(AlertChannelFactory
alertChannelFactory) {
requireNonNull(alertChannelFactory, "alertChannelFactory is null");
diff --git
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/processor/AlertRequestProcessor.java
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/processor/AlertRequestProcessor.java
index ec716d9..e576d00 100644
---
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/processor/AlertRequestProcessor.java
+++
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/processor/AlertRequestProcessor.java
@@ -33,14 +33,11 @@ import org.slf4j.LoggerFactory;
import io.netty.channel.Channel;
-/**
- * alert request processor
- */
public class AlertRequestProcessor implements NettyRequestProcessor {
private final Logger logger =
LoggerFactory.getLogger(AlertRequestProcessor.class);
- private AlertDao alertDao;
- private AlertPluginManager alertPluginManager;
+ private final AlertDao alertDao;
+ private final AlertPluginManager alertPluginManager;
public AlertRequestProcessor(AlertDao alertDao, AlertPluginManager
alertPluginManager) {
this.alertDao = alertDao;
diff --git
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/runner/AlertSender.java
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/runner/AlertSender.java
index 114d01a..d7bcc2c 100644
---
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/runner/AlertSender.java
+++
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/runner/AlertSender.java
@@ -38,16 +38,13 @@ import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-/**
- * alert sender
- */
public class AlertSender {
private static final Logger logger =
LoggerFactory.getLogger(AlertSender.class);
private List<Alert> alertList;
private AlertDao alertDao;
- private AlertPluginManager alertPluginManager;
+ private final AlertPluginManager alertPluginManager;
public AlertSender(AlertPluginManager alertPluginManager) {
this.alertPluginManager = alertPluginManager;
diff --git
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/FuncUtils.java
b/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/FuncUtils.java
deleted file mode 100644
index e78b4eb..0000000
---
a/dolphinscheduler-alert/src/main/java/org/apache/dolphinscheduler/alert/utils/FuncUtils.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * 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.alert.utils;
-
-import org.apache.dolphinscheduler.common.utils.StringUtils;
-
-public class FuncUtils {
-
- private FuncUtils() {
- throw new IllegalStateException(FuncUtils.class.getName());
- }
-
- public static String mkString(Iterable<String> list, String split) {
-
- if (null == list || StringUtils.isEmpty(split)) {
- return null;
- }
-
- StringBuilder sb = new StringBuilder();
- boolean first = true;
- for (String item : list) {
- if (first) {
- first = false;
- } else {
- sb.append(split);
- }
- sb.append(item);
- }
- return sb.toString();
- }
-
-}
diff --git
a/dolphinscheduler-alert/src/test/java/org/apache/dolphinscheduler/alert/utils/FuncUtilsTest.java
b/dolphinscheduler-alert/src/test/java/org/apache/dolphinscheduler/alert/utils/FuncUtilsTest.java
deleted file mode 100644
index 818fac9..0000000
---
a/dolphinscheduler-alert/src/test/java/org/apache/dolphinscheduler/alert/utils/FuncUtilsTest.java
+++ /dev/null
@@ -1,60 +0,0 @@
-/*
- * 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.alert.utils;
-
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertNull;
-
-import java.util.Arrays;
-
-import org.junit.Test;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class FuncUtilsTest {
-
- private static final Logger logger =
LoggerFactory.getLogger(FuncUtilsTest.class);
-
- /**
- * Test mkString
- */
- @Test
- public void testMKString() {
-
- //Define users list
- Iterable<String> users = Arrays.asList("user1", "user2", "user3");
- //Define split
- String split = "|";
-
- //Invoke mkString with correctParams
- String result = FuncUtils.mkString(users, split);
- logger.info(result);
-
- //Expected result string
- assertEquals("user1|user2|user3", result);
-
- //Null list expected return null
- result = FuncUtils.mkString(null, split);
- assertNull(result);
-
- //Null split expected return null
- result = FuncUtils.mkString(users, null);
- assertNull(result);
-
- }
-}
\ No newline at end of file
diff --git
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
index 0a105ed..329d2f1 100644
---
a/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
+++
b/dolphinscheduler-dao/src/main/resources/org/apache/dolphinscheduler/dao/mapper/PluginDefineMapper.xml
@@ -46,4 +46,4 @@
where id = #{id}
</select>
-</mapper>
\ No newline at end of file
+</mapper>
diff --git a/dolphinscheduler-standalone-server/pom.xml
b/dolphinscheduler-standalone-server/pom.xml
index 505a3b5..c31334d 100644
--- a/dolphinscheduler-standalone-server/pom.xml
+++ b/dolphinscheduler-standalone-server/pom.xml
@@ -47,6 +47,10 @@
</exclusion>
</exclusions>
</dependency>
+ <dependency>
+ <groupId>org.apache.dolphinscheduler</groupId>
+ <artifactId>dolphinscheduler-alert</artifactId>
+ </dependency>
</dependencies>
</project>
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
index d52e7f5..5360dda 100644
---
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
@@ -22,6 +22,7 @@ import static
org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_PAS
import static
org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_URL;
import static
org.apache.dolphinscheduler.common.Constants.SPRING_DATASOURCE_USERNAME;
+import org.apache.dolphinscheduler.alert.AlertServer;
import org.apache.dolphinscheduler.api.ApiApplicationServer;
import org.apache.dolphinscheduler.common.utils.ScriptRunner;
import org.apache.dolphinscheduler.dao.datasource.ConnectionFactory;
@@ -31,9 +32,11 @@ import
org.apache.dolphinscheduler.server.worker.WorkerServer;
import org.apache.curator.test.TestingServer;
import java.io.FileReader;
+import java.io.IOException;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
+import java.sql.SQLException;
import javax.sql.DataSource;
@@ -48,8 +51,50 @@ public class StandaloneServer {
private static final Logger LOGGER =
LoggerFactory.getLogger(StandaloneServer.class);
public static void main(String[] args) throws Exception {
+ Thread.currentThread().setName("Standalone-Server");
+
System.setProperty("spring.profiles.active", "api");
+ startDatabase();
+
+ startRegistry();
+
+ startAlertServer();
+
+ new SpringApplicationBuilder(
+ ApiApplicationServer.class,
+ MasterServer.class,
+ WorkerServer.class
+ ).run(args);
+ }
+
+ private static void startAlertServer() {
+ final Path alertPluginPath = Paths.get(
+
StandaloneServer.class.getProtectionDomain().getCodeSource().getLocation().getPath(),
+
"../../../dolphinscheduler-alert-plugin/dolphinscheduler-alert-email/pom.xml"
+ ).toAbsolutePath();
+ if (Files.exists(alertPluginPath)) {
+ System.setProperty("alert.plugin.binding",
alertPluginPath.toString());
+ System.setProperty("alert.plugin.dir", "");
+ }
+ AlertServer.getInstance().start();
+ }
+
+ private static void startRegistry() throws Exception {
+ final TestingServer server = new TestingServer(true);
+ System.setProperty("registry.servers", server.getConnectString());
+
+ final Path registryPath = Paths.get(
+
StandaloneServer.class.getProtectionDomain().getCodeSource().getLocation().getPath(),
+
"../../../dolphinscheduler-registry-plugin/dolphinscheduler-registry-zookeeper/pom.xml"
+ ).toAbsolutePath();
+ if (Files.exists(registryPath)) {
+ System.setProperty("registry.plugin.binding",
registryPath.toString());
+ System.setProperty("registry.plugin.dir", "");
+ }
+ }
+
+ private static void startDatabase() throws IOException, SQLException {
final Path temp = Files.createTempDirectory("dolphinscheduler_");
LOGGER.info("H2 database directory: {}", temp);
System.setProperty(
@@ -58,7 +103,7 @@ public class StandaloneServer {
);
System.setProperty(
SPRING_DATASOURCE_URL,
- String.format("jdbc:h2:tcp://localhost/%s",
temp.toAbsolutePath())
+
String.format("jdbc:h2:tcp://localhost/%s;MODE=MySQL;DATABASE_TO_LOWER=true",
temp.toAbsolutePath())
);
System.setProperty(SPRING_DATASOURCE_USERNAME, "sa");
System.setProperty(SPRING_DATASOURCE_PASSWORD, "");
@@ -68,25 +113,5 @@ public class StandaloneServer {
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());
-
- final Path registryPath = Paths.get(
-
StandaloneServer.class.getProtectionDomain().getCodeSource().getLocation().getPath(),
-
"../../../dolphinscheduler-registry-plugin/dolphinscheduler-registry-zookeeper/pom.xml"
- ).toAbsolutePath();
- if (Files.exists(registryPath)) {
- System.setProperty("registry.plugin.binding",
registryPath.toString());
- System.setProperty("registry.plugin.dir", "");
- }
-
- Thread.currentThread().setName("Standalone-Server");
-
- new SpringApplicationBuilder(
- ApiApplicationServer.class,
- MasterServer.class,
- WorkerServer.class
- ).run(args);
}
}
diff --git a/sql/dolphinscheduler_h2.sql b/sql/dolphinscheduler_h2.sql
index a550416..94e1a04 100644
--- a/sql/dolphinscheduler_h2.sql
+++ b/sql/dolphinscheduler_h2.sql
@@ -15,62 +15,66 @@
* limitations under the License.
*/
-SET FOREIGN_KEY_CHECKS=0;
+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)
+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)
+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)
+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)
);
-- ----------------------------
@@ -81,11 +85,12 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -96,14 +101,15 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -114,21 +120,22 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -143,10 +150,11 @@ CREATE TABLE QRTZ_FIRED_TRIGGERS (
-- 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)
+CREATE TABLE QRTZ_LOCKS
+(
+ SCHED_NAME varchar(120) NOT NULL,
+ LOCK_NAME varchar(40) NOT NULL,
+ PRIMARY KEY (SCHED_NAME, LOCK_NAME)
);
-- ----------------------------
@@ -157,10 +165,11 @@ CREATE TABLE 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)
+CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS
+(
+ SCHED_NAME varchar(120) NOT NULL,
+ TRIGGER_GROUP varchar(200) NOT NULL,
+ PRIMARY KEY (SCHED_NAME, TRIGGER_GROUP)
);
-- ----------------------------
@@ -171,12 +180,13 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -187,15 +197,16 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -206,23 +217,24 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -237,14 +249,15 @@ CREATE TABLE QRTZ_SIMPROP_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)
+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)
);
-- ----------------------------
@@ -255,17 +268,18 @@ CREATE TABLE 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)
-) ;
+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
@@ -275,17 +289,18 @@ CREATE TABLE 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)
-) ;
+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
@@ -295,23 +310,24 @@ CREATE TABLE 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)
-) ;
+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
@@ -321,18 +337,19 @@ CREATE TABLE 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)
-) ;
+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
@@ -342,23 +359,24 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -369,28 +387,29 @@ CREATE TABLE 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)
-) ;
+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
@@ -400,171 +419,177 @@ CREATE TABLE 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)
-) ;
+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
-) ;
+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)
-) ;
+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)
-) ;
+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)
-) ;
+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)
-) ;
+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
@@ -574,17 +599,18 @@ CREATE TABLE 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)
-) ;
+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
@@ -594,33 +620,36 @@ CREATE TABLE 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)
-) ;
+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);
+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)
-) ;
+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
@@ -630,13 +659,14 @@ CREATE TABLE 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)
-) ;
+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
@@ -646,15 +676,16 @@ CREATE TABLE 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)
-) ;
+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
@@ -664,15 +695,16 @@ CREATE TABLE 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)
-) ;
+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
@@ -682,36 +714,38 @@ CREATE TABLE 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)
-) ;
+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)
-) ;
+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
@@ -721,24 +755,25 @@ CREATE TABLE 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)
-) ;
+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
@@ -748,12 +783,13 @@ CREATE TABLE 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)
+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)
);
-- ----------------------------
@@ -764,37 +800,38 @@ CREATE TABLE 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
-) ;
+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
@@ -804,15 +841,16 @@ CREATE TABLE 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)
-) ;
+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
@@ -822,21 +860,22 @@ CREATE TABLE 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)
-) ;
+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
@@ -846,21 +885,22 @@ CREATE TABLE 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)
-) ;
+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
@@ -870,15 +910,16 @@ CREATE TABLE 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)
-) ;
+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
@@ -888,56 +929,62 @@ CREATE TABLE 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)
-) ;
+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');
+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');
+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', '[email protected]',
'', '0', '2018-03-27 15:48:50', '2018-10-24 17:40:22', null, 1);
+VALUES ('1', 'admin', '7ad2410b2f4c074479a8937a28a22b8f', '0', '[email protected]',
'', '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)
+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)
+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)
);
