diff --git a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
index 9c0cb26..a1d940b 100644
--- a/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
+++ b/cloud-etl-server/src/main/java/com/muyu/cloud/etl/mysql/MySqlDataSource.java
@@ -129,10 +129,10 @@ public class MySqlDataSource extends BaseDataAbsSource {
                                 .build();
                         map.put(i,build);
 
-     if (c <= one && i <= columnCount) {
-        dataValues[c - 1][i - 1] = build;
-    }
-//                        dataValues[c][i-1]=build;
+//     if (c <= one && i <= columnCount) {
+//        dataValues[c - 1][i - 1] = build;
+//    }
+                        dataValues[c][i-1]=build;
                     }else {
 
                         DataValue build = DataValue.builder()
@@ -141,16 +141,16 @@ public class MySqlDataSource extends BaseDataAbsSource {
                                 .value(resultSet.getObject(i, map.get(i).getType().getTargetType()))
                                 .type(map.get(i).getType())
                                 .build();
-//                        dataValues[c][i-1]=build;
+                        dataValues[c][i-1]=build;
                               if (c <= one && i <= columnCount) {
                                 dataValues[c - 1][i - 1] = build;
                             }
                     }
                 }
-         if (c <= one) {
-        c++;
-    }
-//                c++;
+//         if (c <= one) {
+//        c++;
+//    }
+                c++;
             }
         } catch (SQLException e) {
             throw new RuntimeException(e);