diff --git a/scaleph-api/src/main/java/cn/sliew/scaleph/api/controller/dataservice/DataserviceConfigController.java b/scaleph-api/src/main/java/cn/sliew/scaleph/api/controller/dataservice/DataserviceConfigController.java
index d412f9b55..18f5f85de 100644
--- a/scaleph-api/src/main/java/cn/sliew/scaleph/api/controller/dataservice/DataserviceConfigController.java
+++ b/scaleph-api/src/main/java/cn/sliew/scaleph/api/controller/dataservice/DataserviceConfigController.java
@@ -21,9 +21,8 @@
 import cn.sliew.scaleph.api.annotation.Logging;
 import cn.sliew.scaleph.dataservice.service.DataserviceConfigService;
 import cn.sliew.scaleph.dataservice.service.dto.DataserviceConfigDTO;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigAddParam;
 import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigListParam;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigUpdateParam;
+import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigSaveParam;
 import cn.sliew.scaleph.system.model.ResponseVO;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import io.swagger.v3.oas.annotations.Operation;
@@ -48,23 +47,24 @@ public class DataserviceConfigController {
     @Logging
     @GetMapping
     @Operation(summary = "查询 config 列表", description = "查询 config 列表")
-    public ResponseEntity<ResponseVO<Page<DataserviceConfigDTO>>> get(@Valid DataserviceConfigListParam param) throws ParseException {
+    public ResponseEntity<Page<DataserviceConfigDTO>> get(@Valid DataserviceConfigListParam param) throws ParseException {
         Page<DataserviceConfigDTO> result = dataserviceConfigService.list(param);
-        return new ResponseEntity<>(ResponseVO.success(result), HttpStatus.OK);
+        return new ResponseEntity<>(result, HttpStatus.OK);
     }
 
     @Logging
     @PutMapping
     @Operation(summary = "新增 config", description = "新增 config")
-    public ResponseEntity<ResponseVO> insert(@Valid @RequestBody DataserviceConfigAddParam param) throws ParseException {
+    public ResponseEntity<ResponseVO> insert(@Valid @RequestBody DataserviceConfigSaveParam param) throws ParseException {
         dataserviceConfigService.insert(param);
         return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
     }
 
     @Logging
-    @PostMapping
+    @PostMapping("{id}")
     @Operation(summary = "修改 config", description = "修改 config")
-    public ResponseEntity<ResponseVO> update(@Valid @RequestBody DataserviceConfigUpdateParam param) throws ParseException {
+    public ResponseEntity<ResponseVO> update(@PathVariable("id") Long id, @Valid @RequestBody DataserviceConfigSaveParam param) throws ParseException {
+        param.setId(id);
         dataserviceConfigService.update(param);
         return new ResponseEntity<>(ResponseVO.success(), HttpStatus.OK);
     }
diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/DictType.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/DictType.java
index 9aa0b158f..89d48a574 100644
--- a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/DictType.java
+++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/DictType.java
@@ -23,6 +23,8 @@
 import cn.sliew.scaleph.common.dict.catalog.CatalogFunctionLanguage;
 import cn.sliew.scaleph.common.dict.catalog.CatalogTableKind;
 import cn.sliew.scaleph.common.dict.common.*;
+import cn.sliew.scaleph.common.dict.dataservice.HttpMethod;
+import cn.sliew.scaleph.common.dict.dataservice.QueryType;
 import cn.sliew.scaleph.common.dict.ds.RedisMode;
 import cn.sliew.scaleph.common.dict.flink.*;
 import cn.sliew.scaleph.common.dict.flink.kubernetes.*;
@@ -116,6 +118,9 @@ public enum DictType implements DictDefinition {
     SCHEDULE_STATUS("schedule_status", "Schedule Status", ScheduleStatus.class),
 
     REDIS_MODE("redis_mode", "Redis Mode", RedisMode.class),
+
+    HTTP_METHOD("http_method", "Http Method", HttpMethod.class),
+    QUERY_TYPE("query_type", "Query Type", QueryType.class),
     ;
 
     @JsonCreator
diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/dataservice/HttpMethod.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/dataservice/HttpMethod.java
new file mode 100644
index 000000000..6b356b26a
--- /dev/null
+++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/dataservice/HttpMethod.java
@@ -0,0 +1,61 @@
+/*
+ * 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 cn.sliew.scaleph.common.dict.dataservice;
+
+import cn.sliew.scaleph.common.dict.DictInstance;
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+
+import java.util.Arrays;
+
+@JsonFormat(shape = JsonFormat.Shape.OBJECT)
+public enum HttpMethod implements DictInstance {
+
+    GET("GET", "GET"),
+    POST("POST", "POST"),
+    ;
+
+    @JsonCreator
+    public static HttpMethod of(String value) {
+        return Arrays.stream(values())
+                .filter(instance -> instance.getValue().equals(value))
+                .findAny().orElseThrow(() -> new EnumConstantNotPresentException(HttpMethod.class, value));
+    }
+
+    @EnumValue
+    private String value;
+    private String label;
+
+    HttpMethod(String value, String label) {
+        this.value = value;
+        this.label = label;
+    }
+
+    @Override
+    public String getValue() {
+        return value;
+    }
+
+    @Override
+    public String getLabel() {
+        return label;
+    }
+
+}
diff --git a/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/dataservice/QueryType.java b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/dataservice/QueryType.java
new file mode 100644
index 000000000..0ebdeb82b
--- /dev/null
+++ b/scaleph-common/src/main/java/cn/sliew/scaleph/common/dict/dataservice/QueryType.java
@@ -0,0 +1,64 @@
+/*
+ * 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 cn.sliew.scaleph.common.dict.dataservice;
+
+import cn.sliew.scaleph.common.dict.DictInstance;
+import com.baomidou.mybatisplus.annotation.EnumValue;
+import com.fasterxml.jackson.annotation.JsonCreator;
+import com.fasterxml.jackson.annotation.JsonFormat;
+
+import java.util.Arrays;
+
+@JsonFormat(shape = JsonFormat.Shape.OBJECT)
+public enum QueryType implements DictInstance {
+
+    SELECT("SELECT", "SELECT"),
+    UPSERT("UPSERT", "UPSERT"),
+    INSERT("INSERT", "INSERT"),
+    UPDATE("UPDATE", "UPDATE"),
+    DELETE("DELETE", "DELETE"),
+    ;
+
+    @JsonCreator
+    public static QueryType of(String value) {
+        return Arrays.stream(values())
+                .filter(instance -> instance.getValue().equals(value))
+                .findAny().orElseThrow(() -> new EnumConstantNotPresentException(QueryType.class, value));
+    }
+
+    @EnumValue
+    private String value;
+    private String label;
+
+    QueryType(String value, String label) {
+        this.value = value;
+        this.label = label;
+    }
+
+    @Override
+    public String getValue() {
+        return value;
+    }
+
+    @Override
+    public String getLabel() {
+        return label;
+    }
+
+}
diff --git a/scaleph-dao/src/main/java/cn/sliew/scaleph/dao/entity/master/dataservice/DataserviceConfig.java b/scaleph-dao/src/main/java/cn/sliew/scaleph/dao/entity/master/dataservice/DataserviceConfig.java
index 1a2303f4c..d5ffa69a4 100644
--- a/scaleph-dao/src/main/java/cn/sliew/scaleph/dao/entity/master/dataservice/DataserviceConfig.java
+++ b/scaleph-dao/src/main/java/cn/sliew/scaleph/dao/entity/master/dataservice/DataserviceConfig.java
@@ -64,6 +64,12 @@ public class DataserviceConfig extends BaseDO {
     @TableField(exist = false)
     private DataserviceResultMap resultMap;
 
+    @TableField("`type`")
+    private String type;
+
+    @TableField("query")
+    private String query;
+
     @TableField("remark")
     private String remark;
 
diff --git a/scaleph-dao/src/main/resources/cn/sliew/scaleph/dao/mapper/master/dataservice/DataserviceConfigMapper.xml b/scaleph-dao/src/main/resources/cn/sliew/scaleph/dao/mapper/master/dataservice/DataserviceConfigMapper.xml
index a7897143f..98e6681cf 100644
--- a/scaleph-dao/src/main/resources/cn/sliew/scaleph/dao/mapper/master/dataservice/DataserviceConfigMapper.xml
+++ b/scaleph-dao/src/main/resources/cn/sliew/scaleph/dao/mapper/master/dataservice/DataserviceConfigMapper.xml
@@ -50,6 +50,8 @@
         <result column="status" property="status"/>
         <result column="parameter_map_id" property="parameterMapId"/>
         <result column="result_map_id" property="resultMapId"/>
+        <result column="type" property="type"/>
+        <result column="query" property="query"/>
         <result column="remark" property="remark"/>
         <association column="parameter_map_id" property="parameterMap"
                      select="cn.sliew.scaleph.dao.mapper.master.dataservice.DataserviceParameterMapMapper.selectById"/>
@@ -64,8 +66,8 @@
         create_time,
         editor,
         update_time,
-        project_id, `name`, path, method, content_type, `status`,
-        parameter_map_id, result_map_id, remark
+        project_id, `name`, `path`, `method`, content_type, `status`,
+        parameter_map_id, result_map_id, `type`, query, remark
     </sql>
 
     <select id="getById" resultMap="DataserviceConfigMap">
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceConfigService.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceConfigService.java
index 4ea95cc57..c94ec4d76 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceConfigService.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceConfigService.java
@@ -19,9 +19,8 @@
 package cn.sliew.scaleph.dataservice.service;
 
 import cn.sliew.scaleph.dataservice.service.dto.DataserviceConfigDTO;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigAddParam;
 import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigListParam;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigUpdateParam;
+import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigSaveParam;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 
 import java.util.List;
@@ -32,9 +31,9 @@ public interface DataserviceConfigService {
 
     DataserviceConfigDTO selectOne(Long id);
 
-    int insert(DataserviceConfigAddParam param);
+    int insert(DataserviceConfigSaveParam param);
 
-    int update(DataserviceConfigUpdateParam param);
+    int update(DataserviceConfigSaveParam param);
 
     int deleteById(Long id);
 
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceParameterMapService.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceParameterMapService.java
index 136868434..a29e7c9ed 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceParameterMapService.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceParameterMapService.java
@@ -36,7 +36,7 @@ public interface DataserviceParameterMapService {
 
     DataserviceParameterMapDTO selectOne(Long id);
 
-    int insert(DataserviceParameterMapAddParam param);
+    DataserviceParameterMapDTO insert(DataserviceParameterMapAddParam param);
 
     int update(DataserviceParameterMapUpdateParam param);
 
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceResultMapService.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceResultMapService.java
index 3b73ec038..fe2b07605 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceResultMapService.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/DataserviceResultMapService.java
@@ -33,7 +33,7 @@ public interface DataserviceResultMapService {
 
     DataserviceResultMapDTO selectOne(Long id);
 
-    int insert(DataserviceResultMapAddParam param);
+    DataserviceResultMapDTO insert(DataserviceResultMapAddParam param);
 
     int update(DataserviceResultMapUpdateParam param);
 
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/dto/DataserviceConfigDTO.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/dto/DataserviceConfigDTO.java
index c324e3505..5ab1e0384 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/dto/DataserviceConfigDTO.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/dto/DataserviceConfigDTO.java
@@ -57,6 +57,12 @@ public class DataserviceConfigDTO extends BaseDTO {
     @Schema(description = "result map")
     private DataserviceResultMapDTO resultMap;
 
+    @Schema(description = "type")
+    private String type;
+
+    @Schema(description = "query")
+    private String query;
+
     @Schema(description = "备注")
     private String remark;
 
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceConfigServiceImpl.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceConfigServiceImpl.java
index 44c4dcbee..8b8b07eec 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceConfigServiceImpl.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceConfigServiceImpl.java
@@ -18,20 +18,25 @@
 
 package cn.sliew.scaleph.dataservice.service.impl;
 
+import cn.sliew.scaleph.common.dict.common.YesOrNo;
 import cn.sliew.scaleph.common.util.BeanUtil;
+import cn.sliew.scaleph.common.util.UUIDUtil;
 import cn.sliew.scaleph.dao.entity.master.dataservice.DataserviceConfig;
 import cn.sliew.scaleph.dao.mapper.master.dataservice.DataserviceConfigMapper;
 import cn.sliew.scaleph.dataservice.service.DataserviceConfigService;
+import cn.sliew.scaleph.dataservice.service.DataserviceParameterMapService;
+import cn.sliew.scaleph.dataservice.service.DataserviceResultMapService;
 import cn.sliew.scaleph.dataservice.service.convert.DataserviceConfigConvert;
 import cn.sliew.scaleph.dataservice.service.dto.DataserviceConfigDTO;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigAddParam;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigListParam;
-import cn.sliew.scaleph.dataservice.service.param.DataserviceConfigUpdateParam;
+import cn.sliew.scaleph.dataservice.service.dto.DataserviceParameterMapDTO;
+import cn.sliew.scaleph.dataservice.service.dto.DataserviceResultMapDTO;
+import cn.sliew.scaleph.dataservice.service.param.*;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
 import org.springframework.util.StringUtils;
 
 import java.util.List;
@@ -43,6 +48,10 @@ public class DataserviceConfigServiceImpl implements DataserviceConfigService {
 
     @Autowired
     private DataserviceConfigMapper dataserviceConfigMapper;
+    @Autowired
+    private DataserviceParameterMapService dataserviceParameterMapService;
+    @Autowired
+    private DataserviceResultMapService dataserviceResultMapService;
 
     @Override
     public Page<DataserviceConfigDTO> list(DataserviceConfigListParam param) {
@@ -66,14 +75,50 @@ public DataserviceConfigDTO selectOne(Long id) {
     }
 
     @Override
-    public int insert(DataserviceConfigAddParam param) {
+    public int insert(DataserviceConfigSaveParam param) {
         DataserviceConfig record = BeanUtil.copy(param, new DataserviceConfig());
+        record.setStatus(YesOrNo.NO.getValue());
+        if (CollectionUtils.isEmpty(param.getParameterMappings()) == false) {
+            DataserviceParameterMapAddParam addParam = new DataserviceParameterMapAddParam();
+            addParam.setProjectId(param.getProjectId());
+            addParam.setName(UUIDUtil.randomUUId());
+            DataserviceParameterMapDTO parameterMapDTO = dataserviceParameterMapService.insert(addParam);
+            DataserviceParameterMappingReplaceParam replaceParam = new DataserviceParameterMappingReplaceParam();
+            replaceParam.setParameterMapId(parameterMapDTO.getId());
+            replaceParam.setMappings(param.getParameterMappings());
+            dataserviceParameterMapService.replaceMappings(replaceParam);
+            record.setParameterMapId(parameterMapDTO.getId());
+        }
+        if (CollectionUtils.isEmpty(param.getResultMappings()) == false) {
+            DataserviceResultMapAddParam addParam = new DataserviceResultMapAddParam();
+            addParam.setProjectId(param.getProjectId());
+            addParam.setName(UUIDUtil.randomUUId());
+            DataserviceResultMapDTO resultMapDTO = dataserviceResultMapService.insert(addParam);
+            DataserviceResultMappingReplaceParam replaceParam = new DataserviceResultMappingReplaceParam();
+            replaceParam.setResultMapId(resultMapDTO.getId());
+            replaceParam.setMappings(param.getResultMappings());
+            dataserviceResultMapService.replaceMappings(replaceParam);
+            record.setResultMapId(resultMapDTO.getId());
+        }
         return dataserviceConfigMapper.insert(record);
     }
 
     @Override
-    public int update(DataserviceConfigUpdateParam param) {
+    public int update(DataserviceConfigSaveParam param) {
+        DataserviceConfigDTO dto = selectOne(param.getId());
         DataserviceConfig record = BeanUtil.copy(param, new DataserviceConfig());
+        if (CollectionUtils.isEmpty(param.getParameterMappings()) == false) {
+            DataserviceParameterMappingReplaceParam replaceParam = new DataserviceParameterMappingReplaceParam();
+            replaceParam.setParameterMapId(dto.getParameterMap().getId());
+            replaceParam.setMappings(param.getParameterMappings());
+            dataserviceParameterMapService.replaceMappings(replaceParam);
+        }
+        if (CollectionUtils.isEmpty(param.getResultMappings()) == false) {
+            DataserviceResultMappingReplaceParam replaceParam = new DataserviceResultMappingReplaceParam();
+            replaceParam.setResultMapId(dto.getResultMap().getId());
+            replaceParam.setMappings(param.getResultMappings());
+            dataserviceResultMapService.replaceMappings(replaceParam);
+        }
         return dataserviceConfigMapper.updateById(record);
     }
 
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceParameterMapServiceImpl.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceParameterMapServiceImpl.java
index cfe285437..7add767e6 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceParameterMapServiceImpl.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceParameterMapServiceImpl.java
@@ -82,9 +82,10 @@ public DataserviceParameterMapDTO selectOne(Long id) {
     }
 
     @Override
-    public int insert(DataserviceParameterMapAddParam param) {
+    public DataserviceParameterMapDTO insert(DataserviceParameterMapAddParam param) {
         DataserviceParameterMap record = BeanUtil.copy(param, new DataserviceParameterMap());
-        return dataserviceParameterMapMapper.insert(record);
+        dataserviceParameterMapMapper.insert(record);
+        return selectOne(record.getId());
     }
 
     @Override
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceResultMapServiceImpl.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceResultMapServiceImpl.java
index 453e36218..c78a0c686 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceResultMapServiceImpl.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/impl/DataserviceResultMapServiceImpl.java
@@ -80,9 +80,10 @@ public DataserviceResultMapDTO selectOne(Long id) {
     }
 
     @Override
-    public int insert(DataserviceResultMapAddParam param) {
+    public DataserviceResultMapDTO insert(DataserviceResultMapAddParam param) {
         DataserviceResultMap record = BeanUtil.copy(param, new DataserviceResultMap());
-        return dataserviceResultMapMapper.insert(record);
+        dataserviceResultMapMapper.insert(record);
+        return selectOne(record.getId());
     }
 
     @Override
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigAddParam.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigSaveParam.java
similarity index 76%
rename from scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigAddParam.java
rename to scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigSaveParam.java
index 47e2e9866..fbe33c0d6 100644
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigAddParam.java
+++ b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigSaveParam.java
@@ -23,9 +23,13 @@
 
 import javax.validation.constraints.NotBlank;
 import javax.validation.constraints.NotNull;
+import java.util.List;
 
 @Data
-public class DataserviceConfigAddParam {
+public class DataserviceConfigSaveParam {
+
+    @Schema(description = "id")
+    private Long id;
 
     @NotNull
     @Schema(description = "project id")
@@ -47,10 +51,20 @@ public class DataserviceConfigAddParam {
     @Schema(description = "http content type")
     private String contentType;
 
-    @NotBlank
-    @Schema(description = "status, disabled or enabled")
-    private String status;
-
     @Schema(description = "备注")
     private String remark;
+
+    @Schema(description = "参数映射")
+    private List<DataserviceParameterMappingParam> parameterMappings;
+
+    @Schema(description = "结果映射")
+    private List<DataserviceResultMappingParam> resultMappings;
+
+    @NotBlank
+    @Schema(description = "类型")
+    private String type;
+
+    @NotBlank
+    @Schema(description = "sql")
+    private String query;
 }
diff --git a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigUpdateParam.java b/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigUpdateParam.java
deleted file mode 100644
index 300ea3aa1..000000000
--- a/scaleph-dataservice/src/main/java/cn/sliew/scaleph/dataservice/service/param/DataserviceConfigUpdateParam.java
+++ /dev/null
@@ -1,50 +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 cn.sliew.scaleph.dataservice.service.param;
-
-import io.swagger.v3.oas.annotations.media.Schema;
-import lombok.Data;
-
-import javax.validation.constraints.NotNull;
-
-@Data
-public class DataserviceConfigUpdateParam {
-
-    @NotNull
-    @Schema(description = "id")
-    private Long id;
-
-    @Schema(description = "name")
-    private String name;
-
-    @Schema(description = "uri path")
-    private String path;
-
-    @Schema(description = "http method")
-    private String method;
-
-    @Schema(description = "http content type")
-    private String contentType;
-
-    @Schema(description = "status, disabled or enabled")
-    private String status;
-
-    @Schema(description = "备注")
-    private String remark;
-}
diff --git a/scaleph-ui-react2/config/routes.ts b/scaleph-ui-react2/config/routes.ts
index e52c56033..aa20b1b20 100644
--- a/scaleph-ui-react2/config/routes.ts
+++ b/scaleph-ui-react2/config/routes.ts
@@ -212,6 +212,26 @@ export default [
           },
         ]
       },
+      {
+        name: 'project.dataservice',
+        path: '/workspace/dataservice',
+        icon: 'solution',
+        routes: [
+          {
+            path: '/workspace/dataservice',
+            redirect: '/workspace/dataservice/config',
+          },
+          {
+            name: 'config',
+            path: '/workspace/dataservice/config',
+            component: './Project/Workspace/DataService/Config',
+          },
+          {
+            path: '/workspace/dataservice/config/steps',
+            component: './Project/Workspace/DataService/Config/Steps',
+          },
+        ]
+      },
     ]
   },
   {
diff --git a/scaleph-ui-react2/src/locales/zh-CN/menu.ts b/scaleph-ui-react2/src/locales/zh-CN/menu.ts
index 49cdb5390..d6a5dff17 100644
--- a/scaleph-ui-react2/src/locales/zh-CN/menu.ts
+++ b/scaleph-ui-react2/src/locales/zh-CN/menu.ts
@@ -15,6 +15,8 @@ export default {
   'menu.project.doris': 'Doris',
   'menu.project.doris.template': 'Template',
   'menu.project.doris.instance': 'Instance',
+  'menu.project.dataservice': '数据服务',
+  'menu.project.dataservice.config': '接口配置',
 
   'menu.resource': '资源',
   'menu.resource.jar': '公共 Jar',
diff --git a/scaleph-ui-react2/src/locales/zh-CN/pages/project.ts b/scaleph-ui-react2/src/locales/zh-CN/pages/project.ts
index 591f4c2bf..acce365e6 100644
--- a/scaleph-ui-react2/src/locales/zh-CN/pages/project.ts
+++ b/scaleph-ui-react2/src/locales/zh-CN/pages/project.ts
@@ -998,6 +998,32 @@ export default {
   'pages.project.doris.instance.detail.metrics': 'Metrics',
   'pages.project.doris.instance.detail.logs': 'Logs',
 
+  'pages.project.dataservice.config': '服务配置',
+  'pages.project.dataservice.config.name': '名称',
+  'pages.project.dataservice.config.path': '路径',
+  'pages.project.dataservice.config.method': '方法',
+  'pages.project.dataservice.config.contentType': 'Content Type',
+  'pages.project.dataservice.config.status': '状态',
+  'pages.project.dataservice.config.steps.base': '基础信息',
+  'pages.project.dataservice.config.steps.config': '配置信息',
+  'pages.project.dataservice.config.steps.config.parameterMap': '请求参数',
+  'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping': '参数映射',
+  'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.property': '参数',
+  'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.javaType': 'Java 类型',
+  'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.jdbcType': 'Jdbc 类型',
+  'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.typeHandler': '类型处理器',
+  'pages.project.dataservice.config.steps.config.resultMap': '响应结果',
+  'pages.project.dataservice.config.steps.config.resultMap.resultMapping': '结果映射',
+  'pages.project.dataservice.config.steps.config.resultMap.resultMapping.property': '参数',
+  'pages.project.dataservice.config.steps.config.resultMap.resultMapping.column': '列',
+  'pages.project.dataservice.config.steps.config.resultMap.resultMapping.javaType': 'Java 类型',
+  'pages.project.dataservice.config.steps.config.resultMap.resultMapping.jdbcType': 'Jdbc 类型',
+  'pages.project.dataservice.config.steps.config.resultMap.resultMapping.typeHandler': '类型处理器',
+  'pages.project.dataservice.config.steps.config.sql': 'SQL',
+  'pages.project.dataservice.config.steps.config.sql.type': '类型',
+  'pages.project.dataservice.config.steps.config.sql.query': '语句',
+  'pages.project.dataservice.config.detail': '配置详情',
+
   'Run': '运行',
   'Save': '保存',
   'Format': '格式化',
diff --git a/scaleph-ui-react2/src/models/project/workspace/dataservice/config/dataserviceConfigSteps.ts b/scaleph-ui-react2/src/models/project/workspace/dataservice/config/dataserviceConfigSteps.ts
new file mode 100644
index 000000000..0d472fc62
--- /dev/null
+++ b/scaleph-ui-react2/src/models/project/workspace/dataservice/config/dataserviceConfigSteps.ts
@@ -0,0 +1,50 @@
+import {Effect, Reducer} from "@umijs/max";
+import {DataserviceConfigSaveParam} from "@/services/dataservice/typings";
+
+export interface StateType {
+  config: DataserviceConfigSaveParam | null
+}
+
+export interface ModelType {
+  namespace: string;
+
+  state: StateType;
+
+  effects: {
+    editConfig: Effect;
+  };
+
+  reducers: {
+    updateConfig: Reducer<StateType>;
+  };
+}
+
+const model: ModelType = {
+  namespace: "dataserviceConfigSteps",
+
+  state: {
+    config: null,
+  },
+
+  effects: {
+    *editConfig({payload}, {call, put}) {
+      yield put({
+        type: 'updateConfig',
+        payload: {
+          config: payload
+        }
+      });
+    },
+  },
+
+  reducers: {
+    updateConfig(state, {payload}) {
+      return {
+        ...state,
+        config: payload.config,
+      };
+    },
+  },
+};
+
+export default model;
diff --git a/scaleph-ui-react2/src/pages/DataService/index.tsx b/scaleph-ui-react2/src/pages/DataService/index.tsx
deleted file mode 100644
index 490f3bc1d..000000000
--- a/scaleph-ui-react2/src/pages/DataService/index.tsx
+++ /dev/null
@@ -1,183 +0,0 @@
-import {ActionType, EditableProTable, ProColumns, ProFormInstance, useRefFunction} from "@ant-design/pro-components";
-import {useRef, useState} from "react";
-import {useAccess, useIntl} from "@umijs/max";
-
-const waitTime = (time: number = 100) => {
-  return new Promise((resolve) => {
-    setTimeout(() => {
-      resolve(true);
-    }, time);
-  });
-};
-
-type DataSourceType = {
-  id: React.Key;
-  title?: string;
-  decs?: string;
-  state?: string;
-  created_at?: string;
-  update_at?: string;
-  children?: DataSourceType[];
-};
-
-const defaultData: DataSourceType[] = [
-  {
-    id: 624748504,
-    title: '活动名称一',
-    decs: '这个活动真好玩',
-    state: 'open',
-    created_at: '1590486176000',
-    update_at: '1590486176000',
-    children: [
-      {
-        id: 6246912293,
-        title: '活动名称二',
-        decs: '这个活动真好玩',
-        state: 'closed',
-        created_at: '1590481162000',
-        update_at: '1590481162000',
-      },
-    ],
-  },
-  {
-    id: 624691229,
-    title: '活动名称二',
-    decs: '这个活动真好玩',
-    state: 'closed',
-    created_at: '1590481162000',
-    update_at: '1590481162000',
-  },
-];
-
-const loopDataSourceFilter = (
-  data: readonly DataSourceType[],
-  id: React.Key | undefined,
-): DataSourceType[] => {
-  return data
-    .map((item) => {
-      if (item.id !== id) {
-        if (item.children) {
-          const newChildren = loopDataSourceFilter(item.children, id);
-          return {
-            ...item,
-            children: newChildren.length > 0 ? newChildren : undefined,
-          };
-        }
-        return item;
-      }
-      return null;
-    })
-    .filter(Boolean) as DataSourceType[];
-};
-
-const DataServiceWeb: React.FC = () => {
-  const intl = useIntl();
-  const access = useAccess();
-  const actionRef = useRef<ActionType>();
-  const formRef = useRef<ProFormInstance>();
-
-  const [editableKeys, setEditableRowKeys] = useState<React.Key[]>([]);
-  const [dataSource, setDataSource] = useState<DataSourceType[]>(() => defaultData);
-
-  const removeRow = useRefFunction((record: DataSourceType) => {
-    setDataSource(loopDataSourceFilter(dataSource, record.id));
-  });
-
-  const columns: ProColumns<DataSourceType>[] = [
-    {
-      title: '活动名称',
-      dataIndex: 'title',
-      formItemProps: (form, {rowIndex}) => {
-        return {
-          rules: rowIndex > 2 ? [{required: true, message: '此项为必填项'}] : [],
-        };
-      },
-      editable: (text, record, index) => {
-        return true
-      },
-      width: '30%',
-    },
-    {
-      title: '状态',
-      key: 'state',
-      dataIndex: 'state',
-      valueType: 'select',
-      valueEnum: {
-        all: {text: '全部', status: 'Default'},
-        open: {
-          text: '未解决',
-          status: 'Error',
-        },
-        closed: {
-          text: '已解决',
-          status: 'Success',
-        },
-      },
-    },
-    {
-      title: '描述',
-      dataIndex: 'decs',
-      fieldProps: (form, {rowKey, rowIndex}) => {
-        if (form.getFieldValue([rowKey || '', 'title']) === '不好玩') {
-          return {
-            disabled: true,
-          };
-        }
-        if (rowIndex > 9) {
-          return {
-            disabled: true,
-          };
-        }
-        return {};
-      },
-    },
-    {
-      title: '活动时间',
-      dataIndex: 'created_at',
-      valueType: 'date',
-    },
-    {
-      title: '操作',
-      valueType: 'option',
-      width: 200,
-      render: (text, record, _, action) => [
-        <a key="editable" onClick={() => action?.startEditable?.(record.id)}>编辑</a>,
-        <a key="delete" onClick={() => removeRow(record)}>删除</a>,
-      ],
-    },
-  ];
-
-
-  return (
-    <EditableProTable<DataSourceType>
-      rowKey="id"
-      actionRef={actionRef}
-      formRef={formRef}
-      columns={columns}
-      value={dataSource}
-
-      headerTitle="可编辑表格"
-      scroll={{x: 960}}
-      maxLength={5}
-      expandable={{defaultExpandAllRows: true}}
-      onChange={setDataSource}
-      recordCreatorProps={{
-        position: 'bottom',
-        newRecordType: 'dataSource',
-        parentKey: () => 624748504,
-        record: () => ({id: (Math.random() * 1000000).toFixed(0)}),
-      }}
-      editable={{
-        type: 'multiple',
-        editableKeys,
-        onSave: async (rowKey, data, row) => {
-          console.log(rowKey, data, row);
-          await waitTime(2000);
-        },
-        onChange: setEditableRowKeys,
-      }}
-    />
-  );
-}
-
-export default DataServiceWeb;
diff --git a/scaleph-ui-react2/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/node/steps/fields.tsx b/scaleph-ui-react2/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/node/steps/fields.tsx
index 372308fb7..92c16a5e7 100644
--- a/scaleph-ui-react2/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/node/steps/fields.tsx
+++ b/scaleph-ui-react2/src/pages/Project/Workspace/Artifact/DI/DiJobFlow/Dag/node/steps/fields.tsx
@@ -9,7 +9,7 @@ const FieldItem: React.FC = () => {
 
   return (
     <ProFormGroup
-      label={intl.formatMessage({id: 'pages.project.di.step.schema'})}
+      title={intl.formatMessage({id: 'pages.project.di.step.schema'})}
       tooltip={{
         title: intl.formatMessage({id: 'pages.project.di.step.schema.tooltip'}),
         icon: <InfoCircleOutlined/>,
diff --git a/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/BaseStepForm.tsx b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/BaseStepForm.tsx
new file mode 100644
index 000000000..de12f6fb1
--- /dev/null
+++ b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/BaseStepForm.tsx
@@ -0,0 +1,39 @@
+import React from "react";
+import {ProCard, ProFormDigit, ProFormText, ProFormTextArea} from "@ant-design/pro-components";
+import {useIntl} from "@umijs/max";
+
+const DataserviceConfigBaseStep: React.FC = () => {
+  const intl = useIntl();
+
+  return (
+    <ProCard>
+      <ProFormDigit name={"id"} hidden/>
+      <ProFormText
+        name={"name"}
+        label={intl.formatMessage({id: 'pages.project.dataservice.config.name'})}
+        rules={[{required: true}]}
+      />
+      <ProFormText
+        name={"path"}
+        label={intl.formatMessage({id: 'pages.project.dataservice.config.path'})}
+        rules={[{required: true}]}
+      />
+      <ProFormText
+        name={"method"}
+        label={intl.formatMessage({id: 'pages.project.dataservice.config.method'})}
+        rules={[{required: true}]}
+      />
+      <ProFormText
+        name={"contentType"}
+        label={intl.formatMessage({id: 'pages.project.dataservice.config.contentType'})}
+        rules={[{required: true}]}
+      />
+      <ProFormTextArea
+        name={"remark"}
+        label={intl.formatMessage({id: 'app.common.data.remark'})}
+      />
+    </ProCard>
+  );
+}
+
+export default DataserviceConfigBaseStep;
diff --git a/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/ConfigStepForm.tsx b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/ConfigStepForm.tsx
new file mode 100644
index 000000000..be1a9306a
--- /dev/null
+++ b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/ConfigStepForm.tsx
@@ -0,0 +1,120 @@
+import React from "react";
+import {
+  ProCard,
+  ProFormGroup,
+  ProFormList,
+  ProFormSelect,
+  ProFormText,
+  ProFormTextArea
+} from "@ant-design/pro-components";
+import {useIntl} from "@umijs/max";
+
+const DataserviceConfigConfigStep: React.FC = () => {
+  const intl = useIntl();
+
+  return (
+    <ProCard>
+      <ProFormGroup
+        title={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.parameterMap'})}
+      >
+        <ProFormList
+          name={"parameterMappings"}
+          copyIconProps={false}
+          creatorButtonProps={{
+            creatorButtonText: intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping'}),
+            type: 'text',
+          }}
+        >
+          <ProFormGroup>
+            <ProFormText
+              name={"property"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.property'})}
+              colProps={{span: 4, offset: 1}}
+              rules={[{required: true}]}
+            />
+            <ProFormText
+              name={"javaType"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.javaType'})}
+              colProps={{span: 4, offset: 1}}
+              rules={[{required: true}]}
+            />
+            <ProFormText
+              name={"jdbcType"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.jdbcType'})}
+              colProps={{span: 4, offset: 1}}
+            />
+            <ProFormText
+              name={"typeHandler"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.parameterMap.parameterMapping.typeHandler'})}
+              colProps={{span: 8, offset: 1}}
+            />
+          </ProFormGroup>
+        </ProFormList>
+      </ProFormGroup>
+
+      <ProFormGroup
+        title={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap'})}
+      >
+        <ProFormList
+          name={"resultMappings"}
+          copyIconProps={false}
+          creatorButtonProps={{
+            creatorButtonText: intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap.resultMapping'}),
+            type: 'text',
+          }}
+        >
+          <ProFormGroup>
+            <ProFormText
+              name={"property"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap.resultMapping.property'})}
+              colProps={{span: 3, offset: 1}}
+              rules={[{required: true}]}
+            />
+            <ProFormText
+              name={"column"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap.resultMapping.column'})}
+              colProps={{span: 3, offset: 1}}
+              rules={[{required: true}]}
+            />
+            <ProFormText
+              name={"javaType"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap.resultMapping.javaType'})}
+              colProps={{span: 3, offset: 1}}
+            />
+            <ProFormText
+              name={"jdbcType"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap.resultMapping.jdbcType'})}
+              colProps={{span: 3, offset: 1}}
+            />
+            <ProFormText
+              name={"typeHandler"}
+              label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.resultMap.resultMapping.typeHandler'})}
+              colProps={{span: 7, offset: 1}}
+            />
+          </ProFormGroup>
+        </ProFormList>
+      </ProFormGroup>
+
+      <ProFormGroup
+        title={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.sql'})}
+      >
+        <ProFormSelect
+          name={"type"}
+          label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.sql.type'})}
+          rules={[{required: true}]}
+          options={["select", "upsert", "insert", "update", "delete"]}
+        />
+        <ProFormTextArea
+          name={"query"}
+          label={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config.sql.query'})}
+          rules={[{required: true}]}
+          fieldProps={{
+            rows: 15
+          }}
+        />
+      </ProFormGroup>
+    </ProCard>
+  );
+}
+
+export default DataserviceConfigConfigStep;
diff --git a/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/index.tsx b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/index.tsx
new file mode 100644
index 000000000..aeb468801
--- /dev/null
+++ b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/Steps/index.tsx
@@ -0,0 +1,99 @@
+import React, {useRef} from "react";
+import {ProCard, ProFormInstance, StepsForm} from "@ant-design/pro-components";
+import {connect, useIntl} from "@umijs/max";
+import {WORKSPACE_CONF} from "@/constants/constant";
+import {DataserviceConfig, DataserviceConfigSaveParam} from "@/services/dataservice/typings";
+import DataserviceConfigBaseStep from "@/pages/Project/Workspace/DataService/Config/Steps/BaseStepForm";
+import DataserviceConfigConfigStep from "@/pages/Project/Workspace/DataService/Config/Steps/ConfigStepForm";
+import {DataserviceConfigService} from "@/services/dataservice/DataserviceConfigService";
+import {history} from "@@/core/history";
+
+const DataserviceConfigSteps: React.FC = (props: any) => {
+  const intl = useIntl();
+  const formRef = useRef<ProFormInstance>();
+  const localProjectId = localStorage.getItem(WORKSPACE_CONF.projectId);
+
+  const onBaseStepFinish = (values: Record<string, any>) => {
+    const config: DataserviceConfigSaveParam = {
+      id: values.id,
+      projectId: localProjectId,
+      name: values.name,
+      path: values.path,
+      method: values.method,
+      contentType: values.contentType,
+      remark: values.remark,
+    }
+    editDataserviceConfig(config)
+    return Promise.resolve(true)
+  }
+
+  const onConfigStepFinish = (values: Record<string, any>) => {
+    const config: DataserviceConfigSaveParam = {
+      ...props.dataserviceConfigSteps.config,
+      parameterMappings: values.parameterMappings,
+      resultMappings: values.resultMappings,
+      type: values.type,
+      sql: values.sql
+    }
+    editDataserviceConfig(config)
+    return Promise.resolve(true)
+  }
+
+  const onAllFinish = (values: Record<string, any>) => {
+    const config: DataserviceConfigSaveParam = {
+      ...values,
+      projectId: localProjectId
+    }
+    if (config.id) {
+      return DataserviceConfigService.update(config).then((response) => {
+        if (response.success) {
+          history.back()
+        }
+      })
+    } else {
+      return DataserviceConfigService.add(config).then((response) => {
+        if (response.success) {
+          history.back()
+        }
+      })
+    }
+  }
+
+  const editDataserviceConfig = (config: DataserviceConfig) => {
+    props.dispatch({
+      type: 'dataserviceConfigSteps/editConfig',
+      payload: config
+    })
+  }
+
+  return (
+    <ProCard className={'step-form-submitter'}>
+      <StepsForm
+        formRef={formRef}
+        formProps={{
+          grid: true,
+          rowProps: {gutter: [16, 8]}
+        }}
+        onFinish={onAllFinish}
+      >
+        <StepsForm.StepForm
+          name="base"
+          title={intl.formatMessage({id: 'pages.project.dataservice.config.steps.base'})}
+          style={{width: 1000}}
+          onFinish={onBaseStepFinish}>
+          <DataserviceConfigBaseStep/>
+        </StepsForm.StepForm>
+        <StepsForm.StepForm
+          name="config"
+          title={intl.formatMessage({id: 'pages.project.dataservice.config.steps.config'})}
+          style={{width: 1000}}
+          onFinish={onConfigStepFinish}>
+          <DataserviceConfigConfigStep/>
+        </StepsForm.StepForm>
+      </StepsForm>
+    </ProCard>
+  )
+}
+
+const mapModelToProps = ({dataserviceConfigSteps}: any) => ({dataserviceConfigSteps})
+export default connect(mapModelToProps)(DataserviceConfigSteps);
diff --git a/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/index.tsx b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/index.tsx
new file mode 100644
index 000000000..d4ec6749a
--- /dev/null
+++ b/scaleph-ui-react2/src/pages/Project/Workspace/DataService/Config/index.tsx
@@ -0,0 +1,198 @@
+import React, {useRef, useState} from "react";
+import {Button, message, Modal, Space, Tooltip} from "antd";
+import {DeleteOutlined, EditOutlined, NodeIndexOutlined} from "@ant-design/icons";
+import {ActionType, ProColumns, ProFormInstance, ProTable} from "@ant-design/pro-components";
+import {history, useAccess, useIntl} from "@umijs/max";
+import {WORKSPACE_CONF} from "@/constants/constant";
+import {PRIVILEGE_CODE} from "@/constants/privilegeCode";
+import {DataserviceConfig} from "@/services/dataservice/typings";
+import {DataserviceConfigService} from "@/services/dataservice/DataserviceConfigService";
+
+const DataServiceConfigWeb: React.FC = () => {
+  const intl = useIntl();
+  const access = useAccess();
+  const actionRef = useRef<ActionType>();
+  const formRef = useRef<ProFormInstance>();
+  const [selectedRows, setSelectedRows] = useState<DataserviceConfig[]>([]);
+  const [dataserviceConfigFormData, setDataserviceConfigFormData] = useState<{
+    visiable: boolean;
+    data: DataserviceConfig;
+  }>({visiable: false, data: {}});
+  const projectId = localStorage.getItem(WORKSPACE_CONF.projectId);
+
+  const tableColumns: ProColumns<DataserviceConfig>[] = [
+    {
+      title: intl.formatMessage({id: 'pages.project.dataservice.config.name'}),
+      dataIndex: 'name'
+    },
+    {
+      title: intl.formatMessage({id: 'pages.project.dataservice.config.path'}),
+      dataIndex: 'path',
+      hideInSearch: true,
+    },
+    {
+      title: intl.formatMessage({id: 'pages.project.dataservice.config.method'}),
+      dataIndex: 'method',
+      hideInSearch: true,
+    },
+    {
+      title: intl.formatMessage({id: 'pages.project.dataservice.config.contentType'}),
+      dataIndex: 'contentType',
+      hideInSearch: true,
+    },
+    {
+      title: intl.formatMessage({id: 'pages.project.dataservice.config.status'}),
+      dataIndex: 'status',
+      hideInSearch: true,
+    },
+    {
+      title: intl.formatMessage({id: 'app.common.data.remark'}),
+      dataIndex: 'remark',
+      hideInSearch: true,
+    },
+    {
+      title: intl.formatMessage({id: 'app.common.data.createTime'}),
+      dataIndex: 'createTime',
+      hideInSearch: true,
+      width: 180,
+    },
+    {
+      title: intl.formatMessage({id: 'app.common.data.updateTime'}),
+      dataIndex: 'updateTime',
+      hideInSearch: true,
+      width: 180,
+    },
+    {
+      title: intl.formatMessage({id: 'app.common.operate.label'}),
+      dataIndex: 'actions',
+      align: 'center',
+      width: 120,
+      fixed: 'right',
+      valueType: 'option',
+      render: (_, record) => (
+        <Space>
+          {access.canAccess(PRIVILEGE_CODE.datadevProjectEdit) && (
+            <Tooltip title={intl.formatMessage({id: 'app.common.operate.edit.label'})}>
+              <Button
+                shape="default"
+                type="link"
+                icon={<EditOutlined/>}
+                onClick={() => {
+                  setDataserviceConfigFormData({visiable: true, data: record});
+                }}
+              />
+            </Tooltip>
+          )}
+          {access.canAccess(PRIVILEGE_CODE.datadevJobEdit) && (
+            <Tooltip title={intl.formatMessage({id: 'pages.project.dataservice.config.detail'})}>
+              <Button
+                shape="default"
+                type="link"
+                icon={<NodeIndexOutlined/>}
+                onClick={() => {
+                  // history.push("/workspace/doris/template/detail", record)
+                }}
+              />
+            </Tooltip>
+          )}
+          {access.canAccess(PRIVILEGE_CODE.datadevDatasourceDelete) && (
+            <Tooltip title={intl.formatMessage({id: 'app.common.operate.delete.label'})}>
+              <Button
+                shape="default"
+                type="link"
+                danger
+                icon={<DeleteOutlined/>}
+                onClick={() => {
+                  Modal.confirm({
+                    title: intl.formatMessage({id: 'app.common.operate.delete.confirm.title'}),
+                    content: intl.formatMessage({id: 'app.common.operate.delete.confirm.content'}),
+                    okText: intl.formatMessage({id: 'app.common.operate.confirm.label'}),
+                    okButtonProps: {danger: true},
+                    cancelText: intl.formatMessage({id: 'app.common.operate.cancel.label'}),
+                    onOk() {
+                      DataserviceConfigService.deleteOne(record).then((d) => {
+                        if (d.success) {
+                          message.success(intl.formatMessage({id: 'app.common.operate.delete.success'}));
+                          actionRef.current?.reload();
+                        }
+                      });
+                    },
+                  });
+                }}
+              />
+            </Tooltip>
+          )}
+        </Space>
+      ),
+    },
+  ];
+
+  return (<div>
+    <ProTable<DataserviceConfig>
+      search={{
+        labelWidth: 'auto',
+        span: {xs: 24, sm: 12, md: 8, lg: 6, xl: 6, xxl: 4},
+      }}
+      rowKey="id"
+      actionRef={actionRef}
+      formRef={formRef}
+      options={false}
+      columns={tableColumns}
+      request={(params, sorter, filter) =>
+        DataserviceConfigService.list({...params, projectId: projectId})
+      }
+      toolbar={{
+        actions: [
+          access.canAccess(PRIVILEGE_CODE.datadevResourceAdd) && (
+            <Button
+              key="new"
+              type="primary"
+              onClick={() => {
+                history.push("/workspace/dataservice/config/steps")
+              }}
+            >
+              {intl.formatMessage({id: 'app.common.operate.new.label'})}
+            </Button>
+          ),
+          access.canAccess(PRIVILEGE_CODE.datadevResourceDelete) && (
+            <Button
+              key="del"
+              type="default"
+              disabled={selectedRows.length < 1}
+              onClick={() => {
+                Modal.confirm({
+                  title: intl.formatMessage({id: 'app.common.operate.delete.confirm.title'}),
+                  content: intl.formatMessage({id: 'app.common.operate.delete.confirm.content'}),
+                  okText: intl.formatMessage({id: 'app.common.operate.confirm.label'}),
+                  okButtonProps: {danger: true},
+                  cancelText: intl.formatMessage({id: 'app.common.operate.cancel.label'}),
+                  onOk() {
+                    DataserviceConfigService.deleteBatch(selectedRows).then((d) => {
+                      if (d.success) {
+                        message.success(intl.formatMessage({id: 'app.common.operate.delete.success'}));
+                        actionRef.current?.reload();
+                      }
+                    });
+                  },
+                });
+              }}
+            >
+              {intl.formatMessage({id: 'app.common.operate.delete.label'})}
+            </Button>
+          )
+        ],
+      }}
+      pagination={{showQuickJumper: true, showSizeChanger: true, defaultPageSize: 10}}
+      rowSelection={{
+        fixed: true,
+        onChange(selectedRowKeys, selectedRows, info) {
+          setSelectedRows(selectedRows);
+        },
+      }}
+      tableAlertRender={false}
+      tableAlertOptionRender={false}
+    />
+  </div>);
+}
+
+export default DataServiceConfigWeb;
diff --git a/scaleph-ui-react2/src/services/dataservice/DataserviceConfigService.ts b/scaleph-ui-react2/src/services/dataservice/DataserviceConfigService.ts
new file mode 100644
index 000000000..e30e50449
--- /dev/null
+++ b/scaleph-ui-react2/src/services/dataservice/DataserviceConfigService.ts
@@ -0,0 +1,50 @@
+import {PageResponse, ResponseBody} from '@/typings';
+import {request} from '@umijs/max';
+import {DataserviceConfig, DataserviceConfigParam, DataserviceConfigSaveParam} from './typings';
+
+export const DataserviceConfigService = {
+  url: '/api/dataservice/config',
+
+  list: async (queryParam: DataserviceConfigParam) => {
+    return request<PageResponse<DataserviceConfig>>(`${DataserviceConfigService.url}`, {
+      method: 'GET',
+      params: queryParam,
+    }).then((res) => {
+      const result = {
+        data: res.records,
+        total: res.total,
+        pageSize: res.size,
+        current: res.current,
+      };
+      return result;
+    });
+  },
+
+  add: async (param: DataserviceConfigSaveParam) => {
+    return request<ResponseBody<any>>(`${DataserviceConfigService.url}`, {
+      method: 'PUT',
+      data: param,
+    });
+  },
+
+  update: async (param: DataserviceConfigSaveParam) => {
+    return request<ResponseBody<any>>(`${DataserviceConfigService.url}/${param.id}`, {
+      method: 'POST',
+      data: param,
+    });
+  },
+
+  deleteOne: async (row: DataserviceConfig) => {
+    return request<ResponseBody<any>>(`${DataserviceConfigService.url}/${row.id}`, {
+      method: 'DELETE',
+    });
+  },
+
+  deleteBatch: async (rows: DataserviceConfig[]) => {
+    const params = rows.map((row) => row.id);
+    return request<ResponseBody<any>>(`${DataserviceConfigService.url}/batch`, {
+      method: 'DELETE',
+      data: params,
+    });
+  },
+};
diff --git a/scaleph-ui-react2/src/services/dataservice/typings.d.ts b/scaleph-ui-react2/src/services/dataservice/typings.d.ts
index 99b557f61..7e1895a4f 100644
--- a/scaleph-ui-react2/src/services/dataservice/typings.d.ts
+++ b/scaleph-ui-react2/src/services/dataservice/typings.d.ts
@@ -1,9 +1,76 @@
-export type DsSchema = {
-  id: number;
+import {Dict, QueryParam} from "@/typings";
+
+export type DataserviceConfig = {
+  id?: number;
+  projectId: number | string;
+  name: string;
+  path: string;
+  method: string;
+  contentType: string;
+  status?: string;
+  parameterMap?: DataserviceParameterMap;
+  resultMap?: DataserviceResultMap;
+  remark?: string;
+  createTime?: Date;
+  updateTime?: Date;
+}
+
+export type DataserviceConfigParam = QueryParam & {
+  name?: number;
+}
+
+export type DataserviceConfigSaveParam = {
+  id?: number;
+  projectId: number | string;
+  name: string;
+  path: string;
+  method: string;
+  contentType: string;
+  parameterMappings?: Array<DataserviceParameterMapping>;
+  resultMappings?: Array<DataserviceResultMapping>;
+  type: string;
+  query: string;
+  remark?: string;
+}
+
+export type DataserviceParameterMap = {
+  id?: number;
+  projectId: number | string;
+  name?: string;
+  parameterMappings?: Array<DataserviceParameterMapping>
+  remark?: string;
+  createTime?: Date;
+  updateTime?: Date;
+}
+
+export type DataserviceParameterMapping = {
+  id?: number;
+  parameterMapId?: number | string;
+  property: string;
+  javaType: string;
+  jdbcType: string;
+  typeHandler: string;
+  createTime?: Date;
+  updateTime?: Date;
+}
+
+export type DataserviceResultMap = {
+  id?: number;
+  projectId: number | string;
   name?: string;
-  type?: number;
+  resultMappings?: Array<DataserviceResultMapping>
   remark?: string;
   createTime?: Date;
   updateTime?: Date;
 }
 
+export type DataserviceResultMapping = {
+  id?: number;
+  resultMapId?: number | string;
+  property: string;
+  javaType: string;
+  jdbcType: string;
+  typeHandler: string;
+  createTime?: Date;
+  updateTime?: Date;
+}
diff --git a/tools/docker/mysql/init.d/scaleph-dataserivce-mysql.sql b/tools/docker/mysql/init.d/scaleph-dataserivce-mysql.sql
index 93556154d..11be29331 100644
--- a/tools/docker/mysql/init.d/scaleph-dataserivce-mysql.sql
+++ b/tools/docker/mysql/init.d/scaleph-dataserivce-mysql.sql
@@ -13,14 +13,16 @@ create table dataservice_config
     status           varchar(4)  not null comment 'status, disabled or enabled',
     parameter_map_id bigint comment 'paramter map id',
     result_map_id    bigint comment 'result map id',
+    type             varchar(8) comment 'query type',
+    query            text comment 'query',
     remark           varchar(256) comment '备注',
     creator          varchar(32) comment '创建人',
     create_time      timestamp default current_timestamp comment '创建时间',
     editor           varchar(32) comment '修改人',
     update_time      timestamp default current_timestamp on update current_timestamp comment '修改时间',
     primary key (id),
-    unique key uniq_name (project_id, name),
-    unique key uniq_path (project_id, path)
+    unique key uniq_name (project_id, `name`),
+    unique key uniq_path (project_id, `path`, `method`)
 ) engine = innodb comment = '数据服务 配置';
 
 drop table if exists dataservice_parameter_map;
diff --git a/tools/docker/mysql/init.d/scaleph-security-mysql.sql b/tools/docker/mysql/init.d/scaleph-security-mysql.sql
index 42e5e884b..5cef6e1c6 100644
--- a/tools/docker/mysql/init.d/scaleph-security-mysql.sql
+++ b/tools/docker/mysql/init.d/scaleph-security-mysql.sql
@@ -544,7 +544,8 @@ INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`,
 VALUES (65, '2', 64, NULL, '/workspace/doris', '/workspace/doris/template', NULL, NULL, NULL, NULL, 'sys', 'sys');
 INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
                                 `remark`, `creator`, `editor`)
-VALUES (66, '2', 64, 'template', '/workspace/doris/template', NULL, NULL, NULL, './Project/Workspace/Doris/OperatorTemplate',
+VALUES (66, '2', 64, 'template', '/workspace/doris/template', NULL, NULL, NULL,
+        './Project/Workspace/Doris/OperatorTemplate',
         NULL, 'sys', 'sys');
 INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
                                 `remark`, `creator`, `editor`)
@@ -556,7 +557,8 @@ VALUES (68, '2', 64, NULL, '/workspace/doris/template/detail', NULL, NULL, NULL,
         './Project/Workspace/Doris/OperatorTemplate/Detail', NULL, 'sys', 'sys');
 INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
                                 `remark`, `creator`, `editor`)
-VALUES (69, '2', 64, 'instance', '/workspace/doris/instance', NULL, NULL, NULL, './Project/Workspace/Doris/OperatorInstance',
+VALUES (69, '2', 64, 'instance', '/workspace/doris/instance', NULL, NULL, NULL,
+        './Project/Workspace/Doris/OperatorInstance',
         NULL, 'sys', 'sys');
 INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
                                 `remark`, `creator`, `editor`)
@@ -578,6 +580,22 @@ INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`,
                                 `remark`, `creator`, `editor`)
 VALUES (74, '2', 21, NULL, '/workspace/flink/kubernetes/deployment/steps/update', NULL, NULL, NULL,
         './Project/Workspace/Kubernetes/Deployment/Steps/Update', NULL, 'sys', 'sys');
+INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
+                                `remark`, `creator`, `editor`)
+VALUES (75, '1', 11, 'project.dataservice', '/workspace/dataservice', NULL, NULL, 'FunctionOutlined', NULL, NULL, 'sys',
+        'sys');
+INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
+                                `remark`, `creator`, `editor`)
+VALUES (76, '2', 75, NULL, '/workspace/dataservice', '/workspace/dataservice/config', NULL, NULL, NULL, NULL, 'sys',
+        'sys');
+INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
+                                `remark`, `creator`, `editor`)
+VALUES (77, '2', 75, 'config', '/workspace/dataservice/config', NULL, NULL, NULL,
+        './Project/Workspace/DataService/Config', NULL, 'sys', 'sys');
+INSERT INTO `sec_resource_web` (`id`, `type`, `pid`, `name`, `path`, `redirect`, `layout`, `icon`, `component`,
+                                `remark`, `creator`, `editor`)
+VALUES (78, '2', 75, NULL, '/workspace/dataservice/config/steps', NULL, NULL, NULL,
+        './Project/Workspace/DataService/Config/Steps', NULL, 'sys', 'sys');
 
 drop table if exists sec_resource_web_role;
 create table sec_resource_web_role