2.0.0项目初始化

datax-modules/data-factory-service-parent/data-factory-service-sql-console/src/main/java/cn/datax/service/data/factory/sql/console/concurrent/DateHander.java

@@ -30,6 +30,7 @@ public class DateHander extends CallableTemplate<SqlConsoleVo> {
         ResultSet rs = null;
         // 将查询数据存储到数据中
         List<Map<String, Object>> dataList = new ArrayList<>();
+        // 存储列名的数组
         List<String> columnList = new LinkedList<>();
         // 新增、修改、删除受影响行数
         Integer updateCount = null;
@@ -50,12 +51,15 @@ public class DateHander extends CallableTemplate<SqlConsoleVo> {
                 ResultSetMetaData rsmd = rs.getMetaData();
                 // 获取列字段的个数
                 int colunmCount = rsmd.getColumnCount();
+                for (int i = 1; i <= colunmCount; i++) {
+                    // 获取所有的字段名称
+                    columnList.add(rsmd.getColumnName(i));
+                }
                 while(rs.next()){
                     Map<String, Object> map = new HashMap<>();
                     for (int i = 1; i <= colunmCount; i++) {
                         // 获取列名
                         String columnName = rsmd.getColumnName(i);
-                        columnList.add(columnName);
                         Object val = null;
                         switch (rsmd.getColumnType(i)) {
                             case Types.ARRAY:

datax-ui/src/views/factory/console/index.vue

@@ -117,11 +117,11 @@ export default {
     },
     runData () {
       if (!this.sqlDataSource) {
-        this.$message.error("数据源不能为空")
+        this.$message.error('数据源不能为空')
         return
       }
       if (!this.sqlText) {
-        this.$message.error("查询SQL不能为空")
+        this.$message.error('查询SQL不能为空')
         return
       }
       this.sqlExecuting = true