no message

database/mcb/update.sql

@@ -3,4 +3,5 @@ alter table dmp_develop_task add SOURCE_DB_NAME varchar(64) default NULL COMMENT
 alter table dmp_develop_task add SOURCE_TABLE_NAME varchar(64) default NULL COMMENT'源数据表名称';
 alter table dmp_develop_task add TARGET_DB_NAME varchar(64) default NULL COMMENT'目标数据库名称';
 alter table dmp_develop_task add TARGET_TABLE_NAME varchar(64) default NULL COMMENT'目标数据表名称';
-alter table dmp_syncing_datasource_type add DB_ATTRS json default null comment '数据库属性';
\ No newline at end of file
+alter table dmp_syncing_datasource_type add DB_ATTRS json default null comment '数据库属性';
+alter table dmp_syncing_datasource add NETWORK_CONNECTION_TYPE varchar(64) default null comment '网络连接类型';
\ No newline at end of file

src/main/java/com/jz/dmp/modules/controller/DataIntegration/bean/DmpSyncingDatasourceReq.java

@@ -8,7 +8,7 @@ import javax.validation.constraints.NotNull;
 import java.io.Serializable;
 
 /**
- * 数据源配置(DmpSyncingDatasource)实体类
+ * 保存数据源配置(DmpSyncingDatasource)实体类
  *
  * @author Bellamy
  * @since 2020-12-21 17:47:18
@@ -118,6 +118,9 @@ public class DmpSyncingDatasourceReq implements Serializable {
 
     private String isHaveHeader;
 
+    @ApiModelProperty(value = "网络连接类型")
+    private String networkConnectionType;
+
     public String getId() {
         return id;
     }
@@ -278,4 +281,11 @@ public class DmpSyncingDatasourceReq implements Serializable {
         this.isHaveHeader = isHaveHeader;
     }
 
+    public String getNetworkConnectionType() {
+        return networkConnectionType;
+    }
+
+    public void setNetworkConnectionType(String networkConnectionType) {
+        this.networkConnectionType = networkConnectionType;
+    }
 }
\ No newline at end of file

src/main/java/com/jz/dmp/modules/model/DmpSyncingDatasource.java

@@ -139,6 +139,9 @@ public class DmpSyncingDatasource implements Serializable {
 
     private String targetFileName;
 
+    @ApiModelProperty(value = "网络连接类型")
+    private String networkConnectionType;
+
     public Integer getId() {
         return id;
     }
@@ -354,4 +357,12 @@ public class DmpSyncingDatasource implements Serializable {
     public void setTargetFileName(String targetFileName) {
         this.targetFileName = targetFileName;
     }
+
+    public String getNetworkConnectionType() {
+        return networkConnectionType;
+    }
+
+    public void setNetworkConnectionType(String networkConnectionType) {
+        this.networkConnectionType = networkConnectionType;
+    }
 }
\ No newline at end of file

src/main/resources/mapper/dmp/DmpSyncingDatasourceDao.xml

@@ -126,8 +126,10 @@
 
     <!--新增所有列-->
     <insert id="insert" keyProperty="id" useGeneratedKeys="true">
-        insert into dmp_syncing_datasource(DATASOURCE_TYPE, DATASOURCE_NAME, DATASOURCE_DESC, JDBC_URL, DB_NAME, USER_NAME, PASSWORD, ENDPOINT, BUCKET, ACCESS_ID, ACCESS_KEY, PROTOCOL, HOST, PORT, DEFAULT_FS, TABLE_SCHEMA, DATA_STATUS, CREATE_USER_ID, CREATE_TIME, UPDATE_USER_ID, UPDATE_TIME, PROJECT_ID)
-        values (#{datasourceType}, #{datasourceName}, #{datasourceDesc}, #{jdbcUrl}, #{dbName}, #{userName}, #{password}, #{endpoint}, #{bucket}, #{accessId}, #{accessKey}, #{protocol}, #{host}, #{port}, #{defaultFs}, #{tableSchema}, #{dataStatus}, #{createUserId}, #{createTime}, #{updateUserId}, #{updateTime}, #{projectId})
+        insert into dmp_syncing_datasource(DATASOURCE_TYPE, DATASOURCE_NAME, DATASOURCE_DESC, JDBC_URL, DB_NAME, USER_NAME, PASSWORD, ENDPOINT, BUCKET, ACCESS_ID
+        , ACCESS_KEY, PROTOCOL, HOST, PORT, DEFAULT_FS, TABLE_SCHEMA, DATA_STATUS, CREATE_USER_ID, CREATE_TIME, UPDATE_USER_ID, UPDATE_TIME, PROJECT_ID, NETWORK_CONNECTION_TYPE)
+        values (#{datasourceType}, #{datasourceName}, #{datasourceDesc}, #{jdbcUrl}, #{dbName}, #{userName}, #{password}, #{endpoint}, #{bucket}, #{accessId}, #{accessKey}
+        , #{protocol}, #{host}, #{port}, #{defaultFs}, #{tableSchema}, #{dataStatus}, #{createUserId}, #{createTime}, #{updateUserId}, #{updateTime}, #{projectId}, #{networkConnectionType})
     </insert>
 
     <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true">