数据源类型

cloud-etl-common/src/main/java/com/muyu/domain/SourceType.java

@@ -0,0 +1,23 @@
+package com.muyu.domain;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import com.muyu.common.core.web.domain.BaseEntity;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.NoArgsConstructor;
+import lombok.experimental.SuperBuilder;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@SuperBuilder
+@EqualsAndHashCode(callSuper = true)
+@TableName(value ="SourceType",autoResultMap = true) //数据库表相关
+public class SourceType extends BaseEntity {
+    private static final long serialVersionUID = 1L;
+    //数据源类型ID
+    private Integer id;
+    //数据源类型名称
+    private String name;
+}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/controller/SourceTypeController.java

@@ -0,0 +1,29 @@
+package com.muyu.cloud.etl.controller;
+
+
+import com.muyu.cloud.etl.service.SourceTypeService;
+import com.muyu.common.core.domain.Result;
+import com.muyu.common.core.web.controller.BaseController;
+import com.muyu.common.security.annotation.RequiresPermissions;
+import com.muyu.domain.SourceType;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+@RestController
+@RequestMapping("/SourceType")
+public class SourceTypeController extends BaseController {
+    @Autowired
+    private SourceTypeService sourceTypeService;
+
+    //查询数据源类型
+    @RequiresPermissions("etl:type:list")
+    @GetMapping("/findSourceType")
+    public Result<List<SourceType>> findSourceType() {
+        List<SourceType> sourceTypeList=sourceTypeService.findSourceType();
+        return Result.success(sourceTypeList);
+    }
+}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/mapper/SourceTypeMapper.java

@@ -0,0 +1,9 @@
+package com.muyu.cloud.etl.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.muyu.domain.SourceType;
+import org.apache.ibatis.annotations.Mapper;
+
+@Mapper
+public interface SourceTypeMapper extends BaseMapper<SourceType> {
+}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/SourceTypeService.java

@@ -0,0 +1,13 @@
+package com.muyu.cloud.etl.service;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.muyu.domain.SourceType;
+import java.util.List;
+
+
+public interface SourceTypeService extends IService<SourceType> {
+
+    List<SourceType> findSourceType();
+
+
+}

cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceTypeServiceImpl.java

@@ -0,0 +1,20 @@
+package com.muyu.cloud.etl.service.impl;
+
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.muyu.cloud.etl.mapper.SourceTypeMapper;
+import com.muyu.cloud.etl.service.SourceTypeService;
+import com.muyu.domain.SourceType;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+public class SourceTypeServiceImpl extends ServiceImpl<SourceTypeMapper, SourceType> implements SourceTypeService {
+
+    @Override
+    public List<SourceType> findSourceType() {
+        LambdaQueryWrapper<SourceType> sourceTypeLambdaQueryWrapper = new LambdaQueryWrapper<>();
+        return  this.list(sourceTypeLambdaQueryWrapper);
+    }
+}