diff --git a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/base/BaseBuilderSql.java b/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/base/BaseBuilderSql.java deleted file mode 100644 index d088001..0000000 --- a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/base/BaseBuilderSql.java +++ /dev/null @@ -1,4 +0,0 @@ -package com.mars.jdbc.base; - -public class BaseBuilderSql { -} diff --git a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/enums/SqlEnums.java b/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/enums/SqlEnums.java deleted file mode 100644 index bf6189a..0000000 --- a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/enums/SqlEnums.java +++ /dev/null @@ -1,29 +0,0 @@ -package com.mars.jdbc.enums; - -/** - * sql类型 - */ -public enum SqlEnums { - - MYSQL("mysql"),ORACLE("oracle"); - - private String code; - - SqlEnums(String code){ - this.code = code; - } - - /** - * 根据code获取枚举 - * @param code - * @return - */ - public SqlEnums getByCode(String code){ - for(SqlEnums sqlEnums : this.values()){ - if(sqlEnums.code.equals(code)){ - return sqlEnums; - } - } - return MYSQL; - } -} diff --git a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/factory/SqlFactory.java b/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/factory/SqlFactory.java deleted file mode 100644 index feb8786..0000000 --- a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/factory/SqlFactory.java +++ /dev/null @@ -1,27 +0,0 @@ -package com.mars.jdbc.factory; - -import com.mars.jdbc.base.BaseSql; -import com.mars.jdbc.enums.SqlEnums; -import com.mars.jdbc.sql.MySql; -import com.mars.jdbc.sql.Oracle; - -/** - * sql工厂 - */ -public class SqlFactory { - - /** - * 获取sql对象 - * @param sqlEnums - * @return - */ - public static BaseSql getSqlObject(SqlEnums sqlEnums){ - switch (sqlEnums){ - case MYSQL: - return new MySql(); - case ORACLE: - return new Oracle(); - } - return null; - } -} diff --git a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/sql/MySql.java b/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/sql/MySql.java deleted file mode 100644 index 0f5bd76..0000000 --- a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/sql/MySql.java +++ /dev/null @@ -1,27 +0,0 @@ -package com.mars.jdbc.sql; - -import com.mars.jdbc.base.BaseSql; - -public class MySql extends BaseSql { - - /** - * 查询所有表名 - * @param dbName - * @return - */ - @Override - public String getTableNames(String dbName) { - return "select table_name from information_schema.tables where table_schema='"+dbName+"' and table_type='base table'"; - } - - /** - * 查询所有列名 - * @param dbName - * @param tableName - * @return - */ - @Override - public String getTableCloums(String dbName,String tableName) { - return "select column_name from information_schema.columns where table_schema='"+dbName+"' and table_name='"+tableName+"'"; - } -} diff --git a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/sql/Oracle.java b/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/sql/Oracle.java deleted file mode 100644 index b9dabf7..0000000 --- a/mars-jdbc/mars-jdbc-base/src/main/java/com/mars/jdbc/sql/Oracle.java +++ /dev/null @@ -1,27 +0,0 @@ -package com.mars.jdbc.sql; - -import com.mars.jdbc.base.BaseSql; - -public class Oracle extends BaseSql { - - /** - * 查询所有表名 - * @param dbName - * @return - */ - @Override - public String getTableNames(String dbName) { - return "select * from user_tab_comments"; - } - - /** - * 查询所有列名 - * @param dbName - * @param tableName - * @return - */ - @Override - public String getTableCloums(String dbName, String tableName) { - return "select * from user_col_comments where Table_Name='"+tableName+"'"; - } -}