|
|
|
@ -251,7 +251,7 @@ public class DataEaseModel {
|
|
|
|
|
}
|
|
|
|
|
record.set("dataset_group_id", dataset_group_id);
|
|
|
|
|
Db.save("t_dp_dataset", "id", record);
|
|
|
|
|
System.out.println("添加数据集成功,parent_name=" + parent_name + ",table_name=" + table_name + ",dataset_name=" + dataset_name);
|
|
|
|
|
//System.out.println("添加数据集成功,parent_name=" + parent_name + ",table_name=" + table_name + ",dataset_name=" + dataset_name);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
@ -280,7 +280,7 @@ public class DataEaseModel {
|
|
|
|
|
String sql = "SELECT COLUMN_NAME, DATA_TYPE, COLUMN_DEFAULT, IS_NULLABLE, COLUMN_TYPE, CHARACTER_MAXIMUM_LENGTH, NUMERIC_PRECISION, DATETIME_PRECISION, COLUMN_COMMENT FROM INFORMATION_SCHEMA.COLUMNS WHERE TABLE_SCHEMA = ? AND TABLE_NAME = ?";
|
|
|
|
|
List<Record> list = Db.find(sql, DataEaseModel.DB_NAME, tableName);
|
|
|
|
|
List<String> res = list.stream().map(record -> record.getStr("COLUMN_NAME")).collect(Collectors.toList());
|
|
|
|
|
System.out.println(res);
|
|
|
|
|
//System.out.println(res);
|
|
|
|
|
return res;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
@ -800,9 +800,6 @@ public class DataEaseModel {
|
|
|
|
|
}
|
|
|
|
|
list.add(record);
|
|
|
|
|
}
|
|
|
|
|
for (Record record : list) {
|
|
|
|
|
System.out.println(record);
|
|
|
|
|
}
|
|
|
|
|
Db.use(DB_NAME).batchSave(tableName, list, 100);
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|