diff --git a/cloud-etl-common/src/main/java/com/muyu/domain/Structure.java b/cloud-etl-common/src/main/java/com/muyu/domain/Structure.java
index 65aefd7..d20cc4e 100644
--- a/cloud-etl-common/src/main/java/com/muyu/domain/Structure.java
+++ b/cloud-etl-common/src/main/java/com/muyu/domain/Structure.java
@@ -2,6 +2,7 @@ package com.muyu.domain;
 
 import com.baomidou.mybatisplus.annotation.IdType;
 import com.baomidou.mybatisplus.annotation.TableId;
+import com.baomidou.mybatisplus.annotation.TableName;
 import com.muyu.common.core.annotation.Excel;
 import com.muyu.common.core.web.domain.BaseEntity;
 import lombok.AllArgsConstructor;
@@ -19,6 +20,7 @@ import lombok.experimental.SuperBuilder;
 @NoArgsConstructor
 @AllArgsConstructor
 @SuperBuilder
+@TableName(value ="structure",autoResultMap = true) //数据库表相关
 public class Structure extends BaseEntity
 {
     private static final long serialVersionUID = 1L;
diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java
index 084d703..b26255e 100644
--- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java
+++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/service/impl/SourceServiceImpl.java
@@ -144,6 +144,7 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
                 eq(TableInfo::getBasicId, source.getId());
             }});
 
+
             TableInfo tableInfo = tableInfoService.selectTableInfoByName(tableInfoInsert);
 
 
@@ -182,6 +183,7 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
                     eq(TableInfo::getBasicId, source.getId());
                 }});
 
+
                 TableInfo table = tableInfoService.selectTableInfoByName(build);
 
                 //线程池
@@ -259,6 +261,7 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
                     .isNull("YES".equals(isNullable) ? "Y" : "N")
                     .defaultValue(columnDefault)
                     .build();
+
             threadPool.submit(() -> {
                 structureService.saveOrUpdate(build, new LambdaUpdateWrapper<Structure>() {{
                     eq(Structure::getTableId, build.getTableId());
@@ -266,6 +269,7 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
                     eq(Structure::getColumnRemark, build.getColumnRemark());
                 }});
             });
+
         }
         threadPool.shutdown();
         ps.close();
@@ -274,5 +278,4 @@ public class SourceServiceImpl extends ServiceImpl<SourceMapper, Source> impleme
 
 
 
-
 }