com.dtstack.dtcenter.loader.client

接口 ITable

所有已知实现类:

TableClientProxy

public interface ITable

提供表相关操作接口

作者:

：wangchuan date：Created in 10:17 上午 2020/11/12 company: www.dtstack.com

方法概要

限定符和类型	方法和说明
Boolean	alterTableParams(ISourceDTO source, String tableName, Map<String,String> params) 修改表参数
Boolean	dropTable(ISourceDTO source, String tableName) 删除表，成功返回true，失败返回false
List<Map<String,Object>>	executeQuery(ISourceDTO source, String sql) 执行sql查询
Boolean	executeSqlWithoutResultSet(ISourceDTO source, String sql) 执行sql，不需要结果
Connection	getCon(ISourceDTO source) rdbms数据库获取连接唯一入口，对抛出异常进行统一处理
Long	getTableSize(ISourceDTO source, String schema, String tableName) 获取表占用存储
Boolean	isView(ISourceDTO source, String schema, String tableName) 已过时。
Boolean	renameTable(ISourceDTO source, String oldTableName, String newTableName) 重命名表，成功返回true，失败返回false
List<String>	showPartitions(ISourceDTO source, String tableName) 获取所有分区，格式同sql返回值，不错额外处理，如：pt1=name1/pt2=name2/pt3=name3 非分区表返回null
Boolean	upsertTableColumn(ISourceDTO source, UpsertColumnMetaDTO columnMetaDTO) 新增或者修改表的列

方法详细资料

getCon

Connection getCon(ISourceDTO source)

rdbms数据库获取连接唯一入口，对抛出异常进行统一处理

参数:

source - 数据源信息

返回:

连接

抛出:

Exception - 异常

executeQuery

List<Map<String,Object>> executeQuery(ISourceDTO source,
                                      String sql)

执行sql查询

参数:

source - 数据源信息

sql - 查询sql

返回:

查询结果

抛出:

Exception - 异常

executeSqlWithoutResultSet

Boolean executeSqlWithoutResultSet(ISourceDTO source,
                                   String sql)

执行sql，不需要结果

参数:

source - 数据源信息

sql - 查询sql

返回:

执行成功与否

抛出:

Exception - 异常

showPartitions

List<String> showPartitions(ISourceDTO source,
                            String tableName)

获取所有分区，格式同sql返回值，不错额外处理，如：pt1=name1/pt2=name2/pt3=name3 非分区表返回null

返回:

所有分区

dropTable

Boolean dropTable(ISourceDTO source,
                  String tableName)

删除表，成功返回true，失败返回false

参数:

source -

tableName -

返回:

删除结果

renameTable

Boolean renameTable(ISourceDTO source,
                    String oldTableName,
                    String newTableName)

重命名表，成功返回true，失败返回false

参数:

source - 数据源信息

oldTableName - 旧表名

newTableName - 新表名

返回:

重命名结果

alterTableParams

Boolean alterTableParams(ISourceDTO source,
                         String tableName,
                         Map<String,String> params)

修改表参数

参数:

source - 数据源信息

tableName - 表名

params - 修改的参数，map集合

返回:

修改结果

getTableSize

Long getTableSize(ISourceDTO source,
                  String schema,
                  String tableName)

获取表占用存储

参数:

source - 数据源信息

schema - schema信息

tableName - 表名

返回:

占用存储

isView

@Deprecated
Boolean isView(ISourceDTO source,
                           String schema,
                           String tableName)

已过时。

判断表是否是分区表

参数:

source - 数据源信息

schema - schema名称

tableName - 表名

返回:

是否是分区表

upsertTableColumn

Boolean upsertTableColumn(ISourceDTO source,
                          UpsertColumnMetaDTO columnMetaDTO)

新增或者修改表的列

参数:

source - 数据源信息

columnMetaDTO - 列信息

返回: