[ISSUE apache#5050] prepare for createTask, verify data (apache#5051)

* fix checkstyle and license

* more admin

* more admin

* more admin

* fix license and checkstyle

* fix checkstyle

* fix region sql type

Author: sodaRyCN

eventmesh-admin-server/conf/eventmesh.sql

@@ -15,13 +15,6 @@
 -- specific language governing permissions and limitations
 -- under the License.
 
--- --------------------------------------------------------
--- 主机:                           127.0.0.1
--- 服务器版本:                        8.0.36 - MySQL Community Server - GPL
--- 服务器操作系统:                      Win64
--- HeidiSQL 版本:                  11.3.0.6295
--- --------------------------------------------------------
-
 /*!40101 SET @OLD_CHARACTER_SET_CLIENT=@@CHARACTER_SET_CLIENT */;
 /*!40101 SET NAMES utf8 */;
 /*!50503 SET NAMES utf8mb4 */;
@@ -37,11 +30,12 @@ USE `eventmesh`;
 -- 导出  表 eventmesh.event_mesh_data_source 结构
 CREATE TABLE IF NOT EXISTS `event_mesh_data_source` (
   `id` int unsigned NOT NULL AUTO_INCREMENT,
-  `dataType` int unsigned NOT NULL,
+  `dataType` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `description` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
   `configuration` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
-  `createUid` int NOT NULL,
-  `updateUid` int NOT NULL,
+  `region` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `createUid` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `updateUid` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   `updateTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
   PRIMARY KEY (`id`) USING BTREE
@@ -51,47 +45,51 @@ CREATE TABLE IF NOT EXISTS `event_mesh_data_source` (
 
 -- 导出  表 eventmesh.event_mesh_job_info 结构
 CREATE TABLE IF NOT EXISTS `event_mesh_job_info` (
-  `jobID` int unsigned NOT NULL AUTO_INCREMENT,
-  `name` varchar(50) COLLATE utf8mb4_general_ci NOT NULL,
-  `transportType` int unsigned DEFAULT NULL COMMENT 'JobTransportType',
-  `sourceData` int unsigned DEFAULT NULL COMMENT 'data_source表',
-  `targetData` int unsigned DEFAULT NULL,
-  `state` tinyint unsigned NOT NULL COMMENT 'JobState',
-  `jobType` tinyint unsigned NOT NULL COMMENT 'connector,mesh,func,...',
-  `createUid` int unsigned NOT NULL,
-  `updateUid` int unsigned NOT NULL,
+  `id` int unsigned NOT NULL AUTO_INCREMENT,
+  `jobID` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
+  `desc` varchar(50) COLLATE utf8mb4_general_ci NOT NULL,
+  `taskID` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `transportType` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `sourceData` int NOT NULL DEFAULT '0',
+  `targetData` int NOT NULL DEFAULT '0',
+  `state` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `jobType` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `fromRegion` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `createUid` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `updateUid` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
   `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   `updateTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
-  PRIMARY KEY (`jobID`) USING BTREE
+  PRIMARY KEY (`id`) USING BTREE,
+  UNIQUE KEY `jobID` (`jobID`)
 ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
 
 -- 数据导出被取消选择。
 
 -- 导出  表 eventmesh.event_mesh_mysql_position 结构
 CREATE TABLE IF NOT EXISTS `event_mesh_mysql_position` (
   `id` int unsigned NOT NULL AUTO_INCREMENT,
-  `jobID` int unsigned NOT NULL,
+  `jobID` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `serverUUID` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
   `address` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
   `position` bigint DEFAULT NULL,
   `gtid` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
   `currentGtid` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
   `timestamp` bigint DEFAULT NULL,
-  `journalName` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `journalName` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci DEFAULT NULL,
   `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   `updateTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
   PRIMARY KEY (`id`),
   UNIQUE KEY `jobID` (`jobID`)
-) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
+) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci ROW_FORMAT=DYNAMIC;
 
 -- 数据导出被取消选择。
 
 -- 导出  表 eventmesh.event_mesh_position_reporter_history 结构
 CREATE TABLE IF NOT EXISTS `event_mesh_position_reporter_history` (
   `id` bigint NOT NULL AUTO_INCREMENT,
-  `job` int NOT NULL,
+  `job` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `record` text CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
-  `address` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `address` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   PRIMARY KEY (`id`),
   KEY `job` (`job`),
@@ -105,8 +103,8 @@ CREATE TABLE IF NOT EXISTS `event_mesh_runtime_heartbeat` (
   `id` bigint unsigned NOT NULL AUTO_INCREMENT,
   `adminAddr` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
   `runtimeAddr` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
-  `jobID` int unsigned DEFAULT NULL,
-  `reportTime` varchar(50) COLLATE utf8mb4_general_ci NOT NULL COMMENT 'runtime本地上报时间',
+  `jobID` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `reportTime` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL COMMENT 'runtime本地上报时间',
   `updateTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
   `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   PRIMARY KEY (`id`),
@@ -119,7 +117,7 @@ CREATE TABLE IF NOT EXISTS `event_mesh_runtime_heartbeat` (
 -- 导出  表 eventmesh.event_mesh_runtime_history 结构
 CREATE TABLE IF NOT EXISTS `event_mesh_runtime_history` (
   `id` bigint NOT NULL AUTO_INCREMENT,
-  `job` int NOT NULL,
+  `job` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `address` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
   `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
   PRIMARY KEY (`id`),
@@ -128,6 +126,39 @@ CREATE TABLE IF NOT EXISTS `event_mesh_runtime_history` (
 
 -- 数据导出被取消选择。
 
+-- 导出  表 eventmesh.event_mesh_task_info 结构
+CREATE TABLE IF NOT EXISTS `event_mesh_task_info` (
+  `id` int unsigned NOT NULL AUTO_INCREMENT,
+  `taskID` varchar(50) COLLATE utf8mb4_general_ci NOT NULL,
+  `name` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci NOT NULL,
+  `desc` varchar(50) COLLATE utf8mb4_general_ci NOT NULL,
+  `state` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '' COMMENT 'TaskState',
+  `fromRegion` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `createUid` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `updateUid` varchar(50) COLLATE utf8mb4_general_ci NOT NULL DEFAULT '',
+  `createTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
+  `updateTime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
+  PRIMARY KEY (`id`) USING BTREE,
+  UNIQUE KEY `taskID` (`taskID`)
+) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+
+-- 数据导出被取消选择。
+
+-- 导出  表 eventmesh.event_mesh_verify 结构
+CREATE TABLE IF NOT EXISTS `event_mesh_verify` (
+  `id` int NOT NULL,
+  `taskID` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `recordID` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `recordSig` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `connectorName` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `connectorStage` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `position` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL,
+  `createTime` timestamp NULL DEFAULT CURRENT_TIMESTAMP,
+  PRIMARY KEY (`id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_general_ci;
+
+-- 数据导出被取消选择。
+
 /*!40101 SET SQL_MODE=IFNULL(@OLD_SQL_MODE, '') */;
 /*!40014 SET FOREIGN_KEY_CHECKS=IFNULL(@OLD_FOREIGN_KEY_CHECKS, 1) */;
 /*!40101 SET CHARACTER_SET_CLIENT=@OLD_CHARACTER_SET_CLIENT */;

eventmesh-admin-server/conf/mapper/EventMeshDataSourceMapper.xml

@@ -1,39 +1,43 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<!--
-  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
+<!--
+* 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.
+*/
+-->
 
-  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.
-  -->
 <!DOCTYPE mapper
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="org.apache.eventmesh.admin.server.web.db.mapper.EventMeshDataSourceMapper">
 
     <resultMap id="BaseResultMap" type="org.apache.eventmesh.admin.server.web.db.entity.EventMeshDataSource">
             <id property="id" column="id" jdbcType="INTEGER"/>
-            <result property="dataType" column="dataType" jdbcType="INTEGER"/>
+            <result property="dataType" column="dataType" jdbcType="VARCHAR"/>
             <result property="description" column="description" jdbcType="VARCHAR"/>
             <result property="configuration" column="configuration" jdbcType="VARCHAR"/>
-            <result property="createUid" column="createUid" jdbcType="INTEGER"/>
-            <result property="updateUid" column="updateUid" jdbcType="INTEGER"/>
+            <result property="region" column="region" jdbcType="VARCHAR"/>
+            <result property="createUid" column="createUid" jdbcType="VARCHAR"/>
+            <result property="updateUid" column="updateUid" jdbcType="VARCHAR"/>
             <result property="createTime" column="createTime" jdbcType="TIMESTAMP"/>
             <result property="updateTime" column="updateTime" jdbcType="TIMESTAMP"/>
     </resultMap>
 
     <sql id="Base_Column_List">
-        id,dataType,address,
-        description,configuration,createUid,
-        updateUid,createTime,updateTime
+        id,dataType,description,
+        configuration,region,createUid,updateUid,
+        createTime,updateTime
     </sql>
 </mapper>

eventmesh-admin-server/conf/mapper/EventMeshJobInfoMapper.xml

@@ -1,43 +1,49 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<!--
-  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
+<!--
+* 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.
+*/
+-->
 
-  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.
-  -->
 <!DOCTYPE mapper
         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="org.apache.eventmesh.admin.server.web.db.mapper.EventMeshJobInfoMapper">
 
     <resultMap id="BaseResultMap" type="org.apache.eventmesh.admin.server.web.db.entity.EventMeshJobInfo">
-            <id property="jobID" column="jobID" jdbcType="INTEGER"/>
-            <result property="name" column="name" jdbcType="VARCHAR"/>
-            <result property="transportType" column="transportType" jdbcType="INTEGER"/>
+            <id property="id" column="id" jdbcType="INTEGER"/>
+            <result property="jobID" column="jobID" jdbcType="VARCHAR"/>
+            <result property="desc" column="desc" jdbcType="VARCHAR"/>
+            <result property="taskID" column="taskID" jdbcType="VARCHAR"/>
+            <result property="transportType" column="transportType" jdbcType="VARCHAR"/>
             <result property="sourceData" column="sourceData" jdbcType="INTEGER"/>
             <result property="targetData" column="targetData" jdbcType="INTEGER"/>
-            <result property="state" column="state" jdbcType="TINYINT"/>
-            <result property="jobType" column="jobType" jdbcType="TINYINT"/>
-            <result property="createUid" column="createUid" jdbcType="INTEGER"/>
-            <result property="updateUid" column="updateUid" jdbcType="INTEGER"/>
+            <result property="state" column="state" jdbcType="VARCHAR"/>
+            <result property="jobType" column="jobType" jdbcType="VARCHAR"/>
+            <result property="fromRegion" column="fromRegion" jdbcType="VARCHAR"/>
+            <result property="createUid" column="createUid" jdbcType="VARCHAR"/>
+            <result property="updateUid" column="updateUid" jdbcType="VARCHAR"/>
             <result property="createTime" column="createTime" jdbcType="TIMESTAMP"/>
             <result property="updateTime" column="updateTime" jdbcType="TIMESTAMP"/>
     </resultMap>
 
     <sql id="Base_Column_List">
-        jobID,name,transportType,
-        sourceData,targetData,state,
-        runtimeType,createUid,
-        updateUid,createTime,updateTime
+        id,jobID,desc,
+        taskID,transportType,sourceData,
+        targetData,state,jobType,
+        fromRegion,createTime,updateTime
     </sql>
 </mapper>

eventmesh-admin-server/conf/mapper/EventMeshMysqlPositionMapper.xml

@@ -1,43 +1,46 @@
 <?xml version="1.0" encoding="UTF-8"?>
-<!--
-  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
+<!--
+* 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.
+*/
+-->
 
-  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.
-  -->
 <!DOCTYPE mapper
-    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
-    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="org.apache.eventmesh.admin.server.web.db.mapper.EventMeshMysqlPositionMapper">
 
     <resultMap id="BaseResultMap" type="org.apache.eventmesh.admin.server.web.db.entity.EventMeshMysqlPosition">
-        <id property="id" column="id" jdbcType="INTEGER"/>
-        <result property="jobID" column="jobID" jdbcType="INTEGER"/>
-        <result property="serverUUID" column="serverUUID" jdbcType="VARCHAR"/>
-        <result property="address" column="address" jdbcType="VARCHAR"/>
-        <result property="position" column="position" jdbcType="BIGINT"/>
-        <result property="gtid" column="gtid" jdbcType="VARCHAR"/>
-        <result property="currentGtid" column="currentGtid" jdbcType="VARCHAR"/>
-        <result property="timestamp" column="timestamp" jdbcType="BIGINT"/>
-        <result property="journalName" column="journalName" jdbcType="VARCHAR"/>
-        <result property="createTime" column="createTime" jdbcType="TIMESTAMP"/>
-        <result property="updateTime" column="updateTime" jdbcType="TIMESTAMP"/>
+            <id property="id" column="id" jdbcType="INTEGER"/>
+            <result property="jobID" column="jobID" jdbcType="VARCHAR"/>
+            <result property="serverUUID" column="serverUUID" jdbcType="VARCHAR"/>
+            <result property="address" column="address" jdbcType="VARCHAR"/>
+            <result property="position" column="position" jdbcType="BIGINT"/>
+            <result property="gtid" column="gtid" jdbcType="VARCHAR"/>
+            <result property="currentGtid" column="currentGtid" jdbcType="VARCHAR"/>
+            <result property="timestamp" column="timestamp" jdbcType="BIGINT"/>
+            <result property="journalName" column="journalName" jdbcType="VARCHAR"/>
+            <result property="createTime" column="createTime" jdbcType="TIMESTAMP"/>
+            <result property="updateTime" column="updateTime" jdbcType="TIMESTAMP"/>
     </resultMap>
 
     <sql id="Base_Column_List">
-        id
-        ,jobID,serverUUID,address,
-        position,gtid,currentGtid,timestamp,journalName,
+        id,jobID,serverUUID,
+        address,position,gtid,
+        currentGtid,timestamp,journalName,
         createTime,updateTime
     </sql>
 </mapper>