package com.iplatform.base;
|
|
import com.walker.connector.LocalAddress;
|
import com.walker.db.DatabaseType;
|
import com.walker.db.TableInfo;
|
import com.walker.db.page.GenericPager;
|
import com.walker.dbmeta.DatabaseMetaEngine;
|
import com.walker.dbmeta.FieldInfo;
|
import com.walker.dbmeta.support.DamengMetaEngine;
|
import com.walker.dbmeta.support.MySQLMetaEngine;
|
import com.walker.dbmeta.support.OracleMetaEngine;
|
import com.walker.dbmeta.support.PostgresMetaEngine;
|
import com.walker.dbmeta.support.SqlserverMetaEngine;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* 定义本地数据库元数据引擎对象。<p></p>
|
* 用于查询数据库中表和字段记录。
|
* @author 时克英
|
* @date 2022-11-22
|
*/
|
public class LocalDatabaseMetaEngine {
|
|
private DatabaseMetaEngine engine;
|
|
private LocalAddress localAddress;
|
|
public void setLocalAddress(LocalAddress localAddress) {
|
if(localAddress == null){
|
throw new IllegalArgumentException("LocalAddress 必须提供");
|
}
|
this.localAddress = localAddress;
|
}
|
|
public void setDatabaseType(DatabaseType databaseType){
|
if(databaseType == DatabaseType.DERBY){
|
throw new UnsupportedOperationException("不支持该数据库：" + databaseType.name());
|
} else if(databaseType == DatabaseType.MYSQL){
|
engine = new MySQLMetaEngine();
|
|
} else if(databaseType == DatabaseType.ORACLE){
|
engine = new OracleMetaEngine();
|
|
} else if(databaseType == DatabaseType.POSTGRES){
|
engine = new PostgresMetaEngine();
|
|
} else if(databaseType == DatabaseType.SQLSERVER){
|
engine = new SqlserverMetaEngine();
|
|
} else if(databaseType == DatabaseType.DAMENG){
|
// 2023-03-03
|
engine = new DamengMetaEngine();
|
|
} else
|
throw new IllegalArgumentException("unsupported database type: " + databaseType.name());
|
System.out.println("创建:" + engine.getClass().getName());
|
}
|
|
public List<FieldInfo> getFieldsObject(String tableName){
|
return engine.getFieldsObject(this.localAddress, tableName);
|
}
|
|
public List<String> getTableNamesByLike(String tableNameLike){
|
return engine.getTableNamesByLike(this.localAddress, tableNameLike);
|
}
|
|
/**
|
* 分页返回表信息集合。当前页信息通过对象: ListPageContext.getCurrentPageIndex()方法获得。
|
* @param tableNameLike 表名模糊查询，如果为空字符串则查询所有。
|
* @return
|
* @date 2022-11-22
|
*/
|
public GenericPager<TableInfo> queryPageTableNamesByLike(String tableNameLike
|
// , int pageIndex, int pageSize
|
){
|
return this.engine.queryPageTableNamesByLike(this.localAddress, tableNameLike);
|
}
|
|
/**
|
* 返回指定表元数据信息。
|
* @param tableName 表名称
|
* @return
|
* @date 2022-11-26
|
*/
|
public TableInfo queryOneTableInfo(String tableName){
|
List<String> tableList = new ArrayList<>(2);
|
tableList.add(tableName);
|
Map<String, TableInfo> map = this.engine.getTableRows(this.localAddress, tableList);
|
if(map == null || map.size() == 0){
|
return null;
|
}
|
return map.get(tableName);
|
}
|
}
|
