'commit'

dsBase/src/main/java/com/dsideal/base/Test/TestDataSet.java

@@ -11,9 +11,33 @@ import com.jfinal.plugin.hikaricp.HikariCpPlugin;
 import com.jfinal.plugin.activerecord.Record;
 
 import java.io.File;
+import java.util.ArrayList;
 import java.util.List;
 
 public class TestDataSet {
+
+    /**
+     * 获取数据集的表名
+     *
+     * @param dataset_group_id 数据集的id
+     * @return 表名
+     */
+    public static String getTableName(long dataset_group_id) {
+        Kv kv = Kv.by("dataset_group_id", dataset_group_id);
+        SqlPara sqlPara = Db.getSqlPara("DataEase.getTableName", kv);
+        return Db.findFirst(sqlPara).getStr("table_name");
+    }
+
+    /**
+     * 获取表字段信息
+     * @param table_name 表名
+     * @return 表的信息
+     */
+    public static List<Record> getColumns(String table_name) {
+        String sql = "desc `"+table_name+"`";
+        return Db.find(sql);
+    }
+
     public static void main(String[] args) {
         //加载配置文件
         String configFile = "application_dataease.yaml";
@@ -46,14 +70,25 @@ public class TestDataSet {
 
         //2、查询有哪些数据集
         Kv kv = Kv.by("id", rootId);
-        kv.set("dataset",true);
+        kv.set("dataset", true);
         sqlPara = Db.getSqlPara("DataEase.getAllDataSet", kv);
-        List<Record> list= Db.find(sqlPara);
+        List<Record> list = Db.find(sqlPara);
 
         for (Record record : list) {
-            long id= record.getLong("id");
-            String name= record.getStr("name");
-            System.out.println(name);
+            long id = record.getLong("id");
+            //数据集名称
+            String dataset_name = record.getStr("name");
+            //对应的表名
+            String table_name = getTableName(id);
+            //表的信息
+            List<Record> columns = getColumns(table_name);
+
+            System.out.println(dataset_name + "   " + table_name);
+            List<String> cols=new ArrayList<>();
+            for (Record column : columns) {
+                cols.add(column.getStr("Field"));
+            }
+            System.out.println(cols);
         }
     }
 }

dsBase/src/main/resources/Sql/dataease.sql

@@ -19,4 +19,8 @@
             where node_type='dataset'
         #end
     #end
+    -- 获取表名
+    #sql("getTableName")
+        select  table_name from core_dataset_table where dataset_group_id=#para(dataset_group_id);
+    #end
 #end