CodeCow/datax-web
1
0
Fork 0
mirror of https://github.com/WeiYe-Jing/datax-web.git synced 2026-07-03 21:08:58 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

项目结构调整

Browse Source
This commit is contained in:
景文凯 2019-11-08 10:15:57 +08:00
parent 6847fe8e77
commit da5443fed0
8 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
datax-common/src/main/java/database/ColumnInfo.java → datax-common/src/main/java/com/wugui/database/ColumnInfo.java
View File

@ -1,4 +1,4 @@
package database;
package com.wugui.database;
import lombok.Data;

2
datax-common/src/main/java/database/DasColumn.java → datax-common/src/main/java/com/wugui/database/DasColumn.java
View File

@ -1,4 +1,4 @@
package database;
package com.wugui.database;
import lombok.AllArgsConstructor;
import lombok.Data;

2
datax-common/src/main/java/database/TableInfo.java → datax-common/src/main/java/com/wugui/database/TableInfo.java
View File

@ -1,4 +1,4 @@
package database;
package com.wugui.database;
import lombok.Data;

4
datax-web/db/datax_web.sql
View File

@ -66,8 +66,8 @@ CREATE TABLE `job_config` (
-- ----------------------------
INSERT INTO `job_config` VALUES (1, NULL, 'test', 'test', NULL, NULL, NULL, '2019-06-17 21:10:31', 0, NULL, '2019-06-17 21:10:31', NULL);
INSERT INTO `job_config` VALUES (2, NULL, 'testt', 'test', '{\n \"abc\": \"def\"\n}', NULL, NULL, '2019-06-17 22:22:03', 0, NULL, '2019-06-17 21:14:30', NULL);
INSERT INTO `job_config` VALUES (3, NULL, '示例', 'test', '{\n \"job\": {\n \"setting\": {\n \"speed\": {\n \"channel\": 3\n },\n \"errorLimit\": {\n \"record\": 0,\n \"percentage\": 0.02\n }\n },\n \"content\": [\n {\n \"reader\": {\n \"name\": \"mysqlreader\",\n \"parameter\": {\n \"username\": \"root\",\n \"password\": \"root\",\n \"column\": [\n \"id\",\n \"name\"\n ],\n \"splitPk\": \"db_id\",\n \"connection\": [\n {\n \"table\": [\n \"table\"\n ],\n \"jdbcUrl\": [\n \"jdbc:mysql://127.0.0.1:3306/database\"\n ]\n }\n ]\n }\n },\n \"writer\": {\n \"name\": \"streamwriter\",\n \"parameter\": {\n \"print\": true\n }\n }\n }\n ]\n }\n}', NULL, NULL, '2019-06-17 22:28:21', 1, NULL, '2019-06-17 22:05:31', NULL);
INSERT INTO `job_config` VALUES (4, NULL, 'test', '123', '{\n \"job\": {\n \"setting\": {\n \"speed\": {\n \"channel\": 3\n },\n \"errorLimit\": {\n \"record\": 0,\n \"percentage\": 0.02\n }\n },\n \"content\": [\n {\n \"reader\": {\n \"name\": \"mysqlreader\",\n \"parameter\": {\n \"username\": \"root\",\n \"password\": \"root\",\n \"column\": [\n \"id\",\n \"name\"\n ],\n \"splitPk\": \"db_id\",\n \"connection\": [\n {\n \"table\": [\n \"table\"\n ],\n \"jdbcUrl\": [\n \"jdbc:mysql://127.0.0.1:3306/database\"\n ]\n }\n ]\n }\n },\n \"writer\": {\n \"name\": \"streamwriter\",\n \"parameter\": {\n \"print\": true\n }\n }\n }\n ]\n }\n}', NULL, NULL, '2019-06-17 22:28:31', 1, NULL, '2019-06-17 22:28:31', NULL);
INSERT INTO `job_config` VALUES (3, NULL, '示例', 'test', '{\n \"job\": {\n \"setting\": {\n \"speed\": {\n \"channel\": 3\n },\n \"errorLimit\": {\n \"record\": 0,\n \"percentage\": 0.02\n }\n },\n \"content\": [\n {\n \"reader\": {\n \"name\": \"mysqlreader\",\n \"parameter\": {\n \"username\": \"root\",\n \"password\": \"root\",\n \"column\": [\n \"id\",\n \"name\"\n ],\n \"splitPk\": \"db_id\",\n \"connection\": [\n {\n \"table\": [\n \"table\"\n ],\n \"jdbcUrl\": [\n \"jdbc:mysql://127.0.0.1:3306/com.wugui.database\"\n ]\n }\n ]\n }\n },\n \"writer\": {\n \"name\": \"streamwriter\",\n \"parameter\": {\n \"print\": true\n }\n }\n }\n ]\n }\n}', NULL, NULL, '2019-06-17 22:28:21', 1, NULL, '2019-06-17 22:05:31', NULL);
INSERT INTO `job_config` VALUES (4, NULL, 'test', '123', '{\n \"job\": {\n \"setting\": {\n \"speed\": {\n \"channel\": 3\n },\n \"errorLimit\": {\n \"record\": 0,\n \"percentage\": 0.02\n }\n },\n \"content\": [\n {\n \"reader\": {\n \"name\": \"mysqlreader\",\n \"parameter\": {\n \"username\": \"root\",\n \"password\": \"root\",\n \"column\": [\n \"id\",\n \"name\"\n ],\n \"splitPk\": \"db_id\",\n \"connection\": [\n {\n \"table\": [\n \"table\"\n ],\n \"jdbcUrl\": [\n \"jdbc:mysql://127.0.0.1:3306/com.wugui.database\"\n ]\n }\n ]\n }\n },\n \"writer\": {\n \"name\": \"streamwriter\",\n \"parameter\": {\n \"print\": true\n }\n }\n }\n ]\n }\n}', NULL, NULL, '2019-06-17 22:28:31', 1, NULL, '2019-06-17 22:28:31', NULL);
INSERT INTO `job_config` VALUES (5, NULL, NULL, NULL, '{}', NULL, NULL, '2019-06-25 10:28:51', 1, NULL, '2019-06-25 10:28:51', NULL);
INSERT INTO `job_config` VALUES (6, NULL, NULL, NULL, '{}', NULL, NULL, '2019-06-25 10:47:59', 1, NULL, '2019-06-25 10:47:59', NULL);

2
datax-web/src/main/java/com/wugui/tool/meta/DatabaseInterface.java
View File

@ -3,7 +3,7 @@ package com.wugui.tool.meta;
public interface DatabaseInterface {
/**
* Returns the minimal SQL to launch in order to determine the layout of the resultset for a given database table
* Returns the minimal SQL to launch in order to determine the layout of the resultset for a given com.wugui.database table
*
* @param tableName The name of the table to determine the layout for
* @return The SQL to launch.

6
datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java
View File

@ -8,9 +8,9 @@ import com.wugui.dataxweb.entity.JobJdbcDatasource;
import com.wugui.tool.meta.DatabaseInterface;
import com.wugui.tool.meta.DatabaseMetaFactory;
import com.zaxxer.hikari.HikariDataSource;
import database.ColumnInfo;
import database.DasColumn;
import database.TableInfo;
import com.wugui.database.ColumnInfo;
import com.wugui.database.DasColumn;
import com.wugui.database.TableInfo;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

4
datax-web/src/main/java/com/wugui/tool/query/QueryToolInterface.java
View File

@ -1,7 +1,7 @@
package com.wugui.tool.query;
import database.ColumnInfo;
import database.TableInfo;
import com.wugui.database.ColumnInfo;
import com.wugui.database.TableInfo;
import java.util.List;
import java.util.Map;

2
datax-web/src/main/java/com/wugui/tool/util/DasUtil.java
View File

@ -3,7 +3,7 @@ package com.wugui.tool.util;
import com.wugui.dataxweb.entity.JobJdbcDatasource;
import com.wugui.tool.query.BaseQueryTool;
import com.wugui.tool.query.QueryToolFactory;
import database.TableInfo;
import com.wugui.database.TableInfo;
import lombok.extern.slf4j.Slf4j;
/**