2.0.0项目初始化

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/AbstractDbDialect.java

@@ -17,7 +17,8 @@ public abstract class AbstractDbDialect implements DbDialect {
 
     @Override
     public String tables(String dbName) {
-        return "show tables";
+//        return "select table_name name, table_comment comment from information_schema.tables where table_schema = '" + dbName + "' and table_type = 'BASE TABLE' ";
+        return "SELECT table_name name FROM information_schema.tables WHERE table_schema = '" + dbName + "' AND table_type = 'BASE TABLE' ";
     }
 
     @Override

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/OracleDialect.java

@@ -20,7 +20,7 @@ public class OracleDialect extends AbstractDbDialect {
 
     @Override
     public String tables(String dbName) {
-        return "SELECT u.TABLE_NAME FROM user_tables u";
+        return "SELECT table_name name FROM user_tables";
     }
 
     @Override

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/PostgreDialect.java

@@ -26,7 +26,7 @@ public class PostgreDialect extends AbstractDbDialect {
                 "pg_attribute a\n" +
                 "LEFT OUTER JOIN pg_description b ON a.attrelid=b.objoid AND a.attnum = b.objsubid,\n" +
                 "pg_type t\n" +
-                "WHERE c.relname = 'teble_a'\n" +
+                "WHERE c.relname = 'tableName'\n" +
                 "and a.attnum > 0\n" +
                 "and a.attrelid = c.oid\n" +
                 "and a.atttypid = t.oid\n" +
@@ -36,7 +36,7 @@ public class PostgreDialect extends AbstractDbDialect {
 
     @Override
     public String tables(String dbName) {
-        return "select tablename from pg_tables WHERE schemaname = 'public' AND tableowner = '" + dbName + "'";
+        return "SELECT tablename name FROM pg_tables WHERE schemaname = 'public' AND tableowner = '" + dbName + "' ";
     }
 
     @Override

datax-common/datax-common-database/src/main/java/cn/datax/common/database/dialect/SQLServer2008Dialect.java

@@ -21,7 +21,7 @@ public class SQLServer2008Dialect extends AbstractDbDialect {
 
     @Override
     public String tables(String dbName) {
-        return "SELECT Name FROM " + dbName + "..SysObjects Where XType='U' ";
+        return "SELECT name FROM sysobjects WHERE xtype='U' ";
     }
 
     private static String getOrderByPart(String sql) {