mirror of
https://github.com/wahyd4/Martian.git
synced 2026-08-09 05:16:21 +10:00
🎨 性能优化
This commit is contained in:
@@ -1,4 +0,0 @@
|
||||
package com.mars.jdbc.base;
|
||||
|
||||
public class BaseBuilderSql {
|
||||
}
|
||||
@@ -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;
|
||||
}
|
||||
}
|
||||
@@ -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;
|
||||
}
|
||||
}
|
||||
@@ -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+"'";
|
||||
}
|
||||
}
|
||||
@@ -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+"'";
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user