diff --git a/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java b/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java index aa1bea46..73ba9d77 100644 --- a/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java +++ b/datax-web/src/main/java/com/wugui/tool/query/BaseQueryTool.java @@ -275,4 +275,18 @@ public abstract class BaseQueryTool implements QueryToolInterface { } return columns; } + + @Override + public List getTableNames() { + List res = Lists.newArrayList(); + List> tables = getTables(); + //这里只取表名 + tables.forEach(e -> { + //表名,注释 + List tValues = new ArrayList(e.values()); + //第一个总是表名 + res.add((String) tValues.get(0)); + }); + return res; + } } diff --git a/datax-web/src/main/java/com/wugui/tool/query/QueryToolInterface.java b/datax-web/src/main/java/com/wugui/tool/query/QueryToolInterface.java index e18a9d9d..2efee159 100644 --- a/datax-web/src/main/java/com/wugui/tool/query/QueryToolInterface.java +++ b/datax-web/src/main/java/com/wugui/tool/query/QueryToolInterface.java @@ -52,4 +52,12 @@ public interface QueryToolInterface { * @return2 */ public List getColumnNames(String tableName); + + + /** + * 获取所有可用表名 + * + * @return2 + */ + public List getTableNames(); } diff --git a/datax-web/src/test/java/com/wugui/tool/query/MySQLQueryToolTest.java b/datax-web/src/test/java/com/wugui/tool/query/MySQLQueryToolTest.java index b87ce729..20e3f86a 100644 --- a/datax-web/src/test/java/com/wugui/tool/query/MySQLQueryToolTest.java +++ b/datax-web/src/test/java/com/wugui/tool/query/MySQLQueryToolTest.java @@ -55,4 +55,10 @@ public class MySQLQueryToolTest { List columns = queryTool.getColumnNames("datax_plugin"); log.info(columns.toString()); } + + @Test + public void getTableNames() { + List tableNames = queryTool.getTableNames(); + tableNames.forEach(System.out::println); + } } \ No newline at end of file