From d7c5e05a4d711fa2026a4b6897846e9db416b93c Mon Sep 17 00:00:00 2001
From: xiaohuang <1559741705@qq.com>
Date: Wed, 24 Apr 2024 19:38:32 +0800
Subject: [PATCH] =?UTF-8?q?=E6=95=B0=E6=8D=AE=E8=B5=84=E4=BA=A7=E5=90=8E?=
 =?UTF-8?q?=E5=8F=B0=E5=AE=9E=E7=8E=B0=20=E8=AF=95=E9=AA=8C5=20=E6=8A=8Asq?=
 =?UTF-8?q?l=E8=AF=AD=E5=8F=A5=E6=B7=BB=E5=8A=A0=E5=AE=8C=E6=88=90?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/muyu/etl/mapper/StructureMapper.java  |   8 ++
 .../mapper/BasicConfigInfoMapper.xml          |  16 +--
 .../main/resources/mapper/StructureMapper.xml | 125 ++++++++++++++++++
 3 files changed, 136 insertions(+), 13 deletions(-)

diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StructureMapper.java b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StructureMapper.java
index aa257e2..749da03 100644
--- a/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StructureMapper.java
+++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/java/com/muyu/etl/mapper/StructureMapper.java
@@ -3,6 +3,8 @@ package com.muyu.etl.mapper;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.muyu.etl.domain.Structure;
 
+import java.util.List;
+
 /**
  * 结构 StructureMapper
  *
@@ -17,6 +19,12 @@ public interface StructureMapper extends BaseMapper<Structure> {
     public Structure selectStructureById(Long id);
 
 
+    /**
+     * 查询结构列表
+     */
+    public List<Structure> selectStructureList(Structure structure);
+
+
     /**
      * 新增结构
      */
diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/BasicConfigInfoMapper.xml b/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/BasicConfigInfoMapper.xml
index fa272dd..a0b5235 100644
--- a/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/BasicConfigInfoMapper.xml
+++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/BasicConfigInfoMapper.xml
@@ -4,8 +4,7 @@
         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.muyu.etl.mapper.BasicConfigInfoMapper">
 
-    <resultMap type="com.muyu.etl.domain.BasicConfigInfo"
-               id="BasicConfigInfoResult">
+    <resultMap type="com.muyu.etl.domain.BasicConfigInfo" id="BasicConfigInfoResult">
         <result property="id"    column="id"    />
         <result property="dataResourceName"    column="data_resource_name"    />
         <result property="dataSourcesSystemName"    column="data_sources_system_name"    />
@@ -22,19 +21,10 @@
     </resultMap>
 
     <sql id="selectBasicConfigInfoVo">
-        select id, data_resource_name,username,password,
-               data_sources_system_name,
-               host, port, database_type,
-               database_name,
-               init_link_num,
-               max_link_num, max_wait_time,
-               max_wait_times,connection_params,
-               remark from basic_config_info
+        select id, data_resource_name,username,password, data_sources_system_name, host, port, database_type, database_name, init_link_num, max_link_num, max_wait_time, max_wait_times,connection_params, remark from basic_config_info
     </sql>
 
-    <select id="selectBasicConfigInfoList"
-            parameterType="com.muyu.etl.domain.BasicConfigInfo"
-            resultMap="BasicConfigInfoResult">
+    <select id="selectBasicConfigInfoList" parameterType="com.muyu.etl.domain.BasicConfigInfo" resultMap="BasicConfigInfoResult">
         <include refid="selectBasicConfigInfoVo"/>
         <where>
             <if test="dataResourceName != null  and dataResourceName != ''"> and data_resource_name like concat('%', #{dataResourceName}, '%')</if>
diff --git a/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/StructureMapper.xml b/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/StructureMapper.xml
index 87bf194..60cdc3f 100644
--- a/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/StructureMapper.xml
+++ b/muyu-modules/muyu-etl/muyu-etl-service/src/main/resources/mapper/StructureMapper.xml
@@ -2,5 +2,130 @@
 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.muyu.etl.mapper.StructureMapper">
 
+    <resultMap type="com.muyu.etl.domain.Structure" id="StructureResult">
+        <result property="id"    column="id"    />
+        <result property="tableId"    column="table_id"    />
+        <result property="columnName"    column="column_name"    />
+        <result property="columnRemark"    column="column_remark"    />
+        <result property="isPrimary"    column="is_primary"    />
+        <result property="columnType"    column="column_type"    />
+        <result property="javaType"    column="java_type"    />
+        <result property="columnLength"    column="column_length"    />
+        <result property="columnDecimals"    column="column_decimals"    />
+        <result property="isNull"    column="is_null"    />
+        <result property="defaultValue"    column="default_value"    />
+        <result property="isDictionary"    column="is_dictionary"    />
+        <result property="dictionaryTable"    column="dictionary_table"    />
+        <result property="remark"    column="remark"    />
+        <result property="createBy"    column="create_by"    />
+        <result property="createTime"    column="create_time"    />
+        <result property="updateBy"    column="update_by"    />
+        <result property="updateTime"    column="update_time"    />
+    </resultMap>
 
+    <sql id="selectStructureVo">
+        select id, table_id, column_name, column_remark, is_primary, column_type, java_type, column_length, column_decimals, is_null, default_value, is_dictionary, dictionary_table, remark, create_by, create_time, update_by, update_time from structure
+    </sql>
+
+    <select id="selectStructureList"
+            parameterType="com.muyu.etl.domain.Structure" resultMap="StructureResult">
+        <include refid="selectStructureVo"/>
+        <where>
+            <if test="tableId != null "> and table_id = #{tableId}</if>
+            <if test="columnName != null  and columnName != ''"> and column_name like concat('%', #{columnName}, '%')</if>
+            <if test="columnRemark != null  and columnRemark != ''"> and column_remark = #{columnRemark}</if>
+            <if test="isPrimary != null  and isPrimary != ''"> and is_primary = #{isPrimary}</if>
+            <if test="columnType != null  and columnType != ''"> and column_type = #{columnType}</if>
+            <if test="javaType != null  and javaType != ''"> and java_type = #{javaType}</if>
+            <if test="columnLength != null  and columnLength != ''"> and column_length = #{columnLength}</if>
+            <if test="columnDecimals != null  and columnDecimals != ''"> and column_decimals = #{columnDecimals}</if>
+            <if test="isNull != null  and isNull != ''"> and is_null = #{isNull}</if>
+            <if test="defaultValue != null  and defaultValue != ''"> and default_value = #{defaultValue}</if>
+            <if test="isDictionary != null  and isDictionary != ''"> and is_dictionary = #{isDictionary}</if>
+            <if test="dictionaryTable != null  and dictionaryTable != ''"> and dictionary_table = #{dictionaryTable}</if>
+        </where>
+    </select>
+
+
+    <select id="selectStructureById" parameterType="Long" resultMap="StructureResult">
+        <include refid="selectStructureVo"/>
+        where id = #{id}
+    </select>
+
+    <insert id="insertStructure" parameterType="com.muyu.etl.domain.Structure" useGeneratedKeys="true" keyProperty="id">
+        insert into structure
+        <trim prefix="(" suffix=")" suffixOverrides=",">
+            <if test="tableId != null">table_id,</if>
+            <if test="columnName != null">column_name,</if>
+            <if test="columnRemark != null">column_remark,</if>
+            <if test="isPrimary != null and isPrimary != ''">is_primary,</if>
+            <if test="columnType != null and columnType != ''">column_type,</if>
+            <if test="javaType != null and javaType != ''">java_type,</if>
+            <if test="columnLength != null and columnLength != ''">column_length,</if>
+            <if test="columnDecimals != null and columnDecimals != ''">column_decimals,</if>
+            <if test="isNull != null">is_null,</if>
+            <if test="defaultValue != null and defaultValue != ''">default_value,</if>
+            <if test="isDictionary != null">is_dictionary,</if>
+            <if test="dictionaryTable != null">dictionary_table,</if>
+            <if test="remark != null">remark,</if>
+            <if test="createBy != null">create_by,</if>
+            <if test="createTime != null">create_time,</if>
+            <if test="updateBy != null">update_by,</if>
+            <if test="updateTime != null">update_time,</if>
+        </trim>
+        <trim prefix="values (" suffix=")" suffixOverrides=",">
+            <if test="tableId != null">#{tableId},</if>
+            <if test="columnName != null">#{columnName},</if>
+            <if test="columnRemark != null">#{columnRemark},</if>
+            <if test="isPrimary != null and isPrimary != ''">#{isPrimary},</if>
+            <if test="columnType != null and columnType != ''">#{columnType},</if>
+            <if test="javaType != null and javaType != ''">#{javaType},</if>
+            <if test="columnLength != null and columnLength != ''">#{columnLength},</if>
+            <if test="columnDecimals != null and columnDecimals != ''">#{columnDecimals},</if>
+            <if test="isNull != null">#{isNull},</if>
+            <if test="defaultValue != null and defaultValue != ''">#{defaultValue},</if>
+            <if test="isDictionary != null">#{isDictionary},</if>
+            <if test="dictionaryTable != null">#{dictionaryTable},</if>
+            <if test="remark != null">#{remark},</if>
+            <if test="createBy != null">#{createBy},</if>
+            <if test="createTime != null">#{createTime},</if>
+            <if test="updateBy != null">#{updateBy},</if>
+            <if test="updateTime != null">#{updateTime},</if>
+        </trim>
+    </insert>
+
+    <update id="updateStructure" parameterType="com.muyu.etl.domain.Structure">
+        update structure
+        <trim prefix="SET" suffixOverrides=",">
+            <if test="tableId != null">table_id = #{tableId},</if>
+            <if test="columnName != null">column_name = #{columnName},</if>
+            <if test="columnRemark != null">column_remark = #{columnRemark},</if>
+            <if test="isPrimary != null and isPrimary != ''">is_primary = #{isPrimary},</if>
+            <if test="columnType != null and columnType != ''">column_type = #{columnType},</if>
+            <if test="javaType != null and javaType != ''">java_type = #{javaType},</if>
+            <if test="columnLength != null and columnLength != ''">column_length = #{columnLength},</if>
+            <if test="columnDecimals != null and columnDecimals != ''">column_decimals = #{columnDecimals},</if>
+            <if test="isNull != null">is_null = #{isNull},</if>
+            <if test="defaultValue != null and defaultValue != ''">default_value = #{defaultValue},</if>
+            <if test="isDictionary != null">is_dictionary = #{isDictionary},</if>
+            <if test="dictionaryTable != null">dictionary_table = #{dictionaryTable},</if>
+            <if test="remark != null">remark = #{remark},</if>
+            <if test="createBy != null">create_by = #{createBy},</if>
+            <if test="createTime != null">create_time = #{createTime},</if>
+            <if test="updateBy != null">update_by = #{updateBy},</if>
+            <if test="updateTime != null">update_time = #{updateTime},</if>
+        </trim>
+        where id = #{id}
+    </update>
+
+    <delete id="deleteStructureById" parameterType="Long">
+        delete from structure where id = #{id}
+    </delete>
+
+    <delete id="deleteStructureByIds" parameterType="String">
+        delete from structure where id in
+        <foreach item="id" collection="array" open="(" separator="," close=")">
+            #{id}
+        </foreach>
+    </delete>
 </mapper>