etl
/
cloud-etl-task
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Node增删改查

master
Cui YongXing 2024-08-25 19:03:41 +08:00
parent d2f33b2f0f
commit a6e3cd22bd
4 changed files with 14 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
cloud-task-common/src/main/java/com/muyu/common/domian/Node.java
View File

@ -4,9 +4,7 @@ import com.baomidou.mybatisplus.annotation.TableName;
import com.muyu.common.core.web.domain.BaseEntity; import com.muyu.common.core.web.domain.BaseEntity;
import com.muyu.common.domian.req.NodeAddReq; import com.muyu.common.domian.req.NodeAddReq;
import com.muyu.common.domian.req.NodeUpdReq; import com.muyu.common.domian.req.NodeUpdReq;
import com.muyu.common.domian.req.TaskInfoAddReq;
import com.muyu.common.domian.resp.NodeResp; import com.muyu.common.domian.resp.NodeResp;
import com.muyu.common.domian.resp.TaskInfoResp;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.Data; import lombok.Data;
import lombok.EqualsAndHashCode; import lombok.EqualsAndHashCode;
@ -56,12 +54,12 @@ public class Node extends BaseEntity {
/** /**
* 表字段 * 表字段
*/ */
private String tableField; private String tableFieId;
/** /**
* 表字段别名 * 表字段别名
*/ */
private String tableAsField; private String tableAsFieId;
/** /**
* 字段规则 * 字段规则
@ -76,8 +74,8 @@ public class Node extends BaseEntity {
.databaseId(node.databaseId) .databaseId(node.databaseId)
.tableName(node.tableName) .tableName(node.tableName)
.tableAsName(node.tableAsName) .tableAsName(node.tableAsName)
.tableField(node.tableField) .tableFieId(node.tableFieId)
.tableAsField(node.getTableField()) .tableAsFieId(node.getTableFieId())
.fieldAsEngineId(node.fieldAsEngineId) .fieldAsEngineId(node.fieldAsEngineId)
.build(); .build();
} }
@ -89,8 +87,8 @@ public class Node extends BaseEntity {
.databaseId(req.getDatabaseId()) .databaseId(req.getDatabaseId())
.tableName(req.getTableName()) .tableName(req.getTableName())
.tableAsName(req.getTableAsName()) .tableAsName(req.getTableAsName())
.tableField(req.getTableField()) .tableFieId(req.getTableFieId())
.tableAsField(req.getTableAsField()) .tableAsFieId(req.getTableAsFieId())
.fieldAsEngineId(req.getFieldAsEngineId()) .fieldAsEngineId(req.getFieldAsEngineId())
.build(); .build();
} }
@ -102,8 +100,8 @@ public class Node extends BaseEntity {
.databaseId(req.getDatabaseId()) .databaseId(req.getDatabaseId())
.tableName(req.getTableName()) .tableName(req.getTableName())
.tableAsName(req.getTableAsName()) .tableAsName(req.getTableAsName())
.tableField(req.getTableField()) .tableFieId(req.getTableFieId())
.tableAsField(req.getTableAsField()) .tableAsFieId(req.getTableAsFieId())
.fieldAsEngineId(req.getFieldAsEngineId()) .fieldAsEngineId(req.getFieldAsEngineId())
.build(); .build();
} }

4
cloud-task-common/src/main/java/com/muyu/common/domian/req/NodeAddReq.java
View File

@ -40,12 +40,12 @@ public class NodeAddReq {
/** /**
* 表字段 * 表字段
*/ */
private String tableField; private String tableFieId;
/** /**
* 表字段别名 * 表字段别名
*/ */
private String tableAsField; private String tableAsFieId;
/** /**
* 字段规则 * 字段规则
*/ */

4
cloud-task-common/src/main/java/com/muyu/common/domian/req/NodeUpdReq.java
View File

@ -40,12 +40,12 @@ public class NodeUpdReq {
/** /**
* 表字段 * 表字段
*/ */
private String tableField; private String tableFieId;
/** /**
* 表字段别名 * 表字段别名
*/ */
private String tableAsField; private String tableAsFieId;
/** /**
* 字段规则 * 字段规则
*/ */

4
cloud-task-common/src/main/java/com/muyu/common/domian/resp/NodeResp.java
View File

@ -46,12 +46,12 @@ public class NodeResp {
/** /**
* 表字段 * 表字段
*/ */
private String tableField; private String tableFieId;
/** /**
* 表字段别名 * 表字段别名
*/ */
private String tableAsField; private String tableAsFieId;
/** /**
* 字段规则 * 字段规则