com.dtstack.dtcenter.loader.client.table

类 TableClientProxy

java.lang.Object

com.dtstack.dtcenter.loader.client.table.TableClientProxy

所有已实现的接口:

ITable

public class TableClientProxy
extends Object
implements ITable

表相关操作客户端代理类

作者:

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

构造器概要

构造器

构造器和说明
TableClientProxy(ITable table)

方法概要

限定符和类型	方法和说明
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) 新增或者修改表的列

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

TableClientProxy

public TableClientProxy(ITable table)

方法详细资料

getCon

public Connection getCon(ISourceDTO source)

从接口复制的说明: ITable

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

指定者:

getCon 在接口中 ITable

参数:

source - 数据源信息

返回:

连接

executeQuery

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

从接口复制的说明: ITable

执行sql查询

指定者:

executeQuery 在接口中 ITable

参数:

source - 数据源信息

sql - 查询sql

返回:

查询结果

executeSqlWithoutResultSet

public Boolean executeSqlWithoutResultSet(ISourceDTO source,
                                          String sql)

从接口复制的说明: ITable

执行sql，不需要结果

指定者:

executeSqlWithoutResultSet 在接口中 ITable

参数:

source - 数据源信息

sql - 查询sql

返回:

执行成功与否

showPartitions

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

从接口复制的说明: ITable

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

指定者:

showPartitions 在接口中 ITable

返回:

所有分区

dropTable

public Boolean dropTable(ISourceDTO source,
                         String tableName)

从接口复制的说明: ITable

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

指定者:

dropTable 在接口中 ITable

返回:

删除结果

renameTable

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

从接口复制的说明: ITable

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

指定者:

renameTable 在接口中 ITable

参数:

source - 数据源信息

oldTableName - 旧表名

newTableName - 新表名

返回:

重命名结果

alterTableParams

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

从接口复制的说明: ITable

修改表参数

指定者:

alterTableParams 在接口中 ITable

参数:

source - 数据源信息

tableName - 表名

params - 修改的参数，map集合

返回:

修改结果

getTableSize

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

从接口复制的说明: ITable

获取表占用存储

指定者:

getTableSize 在接口中 ITable

参数:

source - 数据源信息

schema - schema信息

tableName - 表名

返回:

占用存储

isView

public Boolean isView(ISourceDTO source,
                      String schema,
                      String tableName)

从接口复制的说明: ITable

判断表是否是分区表

指定者:

isView 在接口中 ITable

参数:

source - 数据源信息

schema - schema名称

tableName - 表名

返回:

是否是分区表

upsertTableColumn

public Boolean upsertTableColumn(ISourceDTO source,
                                 UpsertColumnMetaDTO columnMetaDTO)

从接口复制的说明: ITable

新增或者修改表的列

指定者:

upsertTableColumn 在接口中 ITable

参数:

source - 数据源信息

columnMetaDTO - 列信息

返回: