类的使用
com.dtstack.dtcenter.loader.dto.SqlQueryDTO

使用SqlQueryDTO的程序包

程序包	说明
com.dtstack.dtcenter.loader.client
com.dtstack.dtcenter.loader.client.hdfs
com.dtstack.dtcenter.loader.client.mq
com.dtstack.dtcenter.loader.client.sql
com.dtstack.dtcenter.loader.utils

com.dtstack.dtcenter.loader.client中SqlQueryDTO的使用

参数类型为SqlQueryDTO的com.dtstack.dtcenter.loader.client中的方法

限定符和类型	方法和说明
List<Map<String,Object>>	IClient.executeQuery(ISourceDTO source, SqlQueryDTO queryDTO) 执行查询
Boolean	IClient.executeSqlWithoutResultSet(ISourceDTO source, SqlQueryDTO queryDTO) 执行查询，无需结果集
List<String>	IClient.getAllDatabases(ISourceDTO source, SqlQueryDTO queryDTO) 获取所有的 DB
List<String>	IClient.getColumnClassInfo(ISourceDTO source, SqlQueryDTO queryDTO) 返回字段 Java 类的标准名称 字段名若不填则默认全部
List<ColumnMetaDTO>	IHdfsFile.getColumnList(ISourceDTO source, SqlQueryDTO queryDTO, String fileFormat) 获取hdfs上存储文件的字段信息
List<ColumnMetaDTO>	IClient.getColumnMetaData(ISourceDTO source, SqlQueryDTO queryDTO) 获取表字段属性 字段名若不填则默认全部, 是否过滤分区字段 不填默认不过滤
List<ColumnMetaDTO>	IClient.getColumnMetaDataWithSql(ISourceDTO source, SqlQueryDTO queryDTO) 根据自定义sql获取表字段属性
String	IClient.getCreateTableSql(ISourceDTO source, SqlQueryDTO queryDTO) 获取建表语句
IDownloader	IClient.getDownloader(ISourceDTO source, SqlQueryDTO queryDTO) 获取对应的downloader
List<ColumnMetaDTO>	IClient.getFlinkColumnMetaData(ISourceDTO source, SqlQueryDTO queryDTO) 获取flinkSql字段名称
IDownloader	IHdfsFile.getLogDownloader(ISourceDTO iSource, SqlQueryDTO queryDTO) 日志下载器
List<ColumnMetaDTO>	IClient.getPartitionColumn(ISourceDTO source, SqlQueryDTO queryDTO) 获取分区字段
List<List<Object>>	IKafka.getPreview(ISourceDTO source, SqlQueryDTO queryDTO) 已过时。 since 1.4.0 in favor of IKafka.getPreview(ISourceDTO source, SqlQueryDTO queryDTO, String prevMode)
List<List<Object>>	IClient.getPreview(ISourceDTO source, SqlQueryDTO queryDTO) 获取预览数据
List<List<Object>>	IKafka.getPreview(ISourceDTO source, SqlQueryDTO queryDTO, String prevMode) 获取预览数据
List<String>	IClient.getRootDatabases(ISourceDTO source, SqlQueryDTO queryDTO) 获取所有的db，此方法目的为获取所有的 database，为了解决一些遗留问题。
Table	IClient.getTable(ISourceDTO source, SqlQueryDTO queryDTO) 获取表信息
List<String>	IClient.getTableList(ISourceDTO source, SqlQueryDTO queryDTO) 返回所有的表字段名称 是否视图表，默认不过滤
List<String>	IClient.getTableListBySchema(ISourceDTO source, SqlQueryDTO queryDTO) 根据schema/db获取表
String	IClient.getTableMetaComment(ISourceDTO source, SqlQueryDTO queryDTO) 获取表注释

com.dtstack.dtcenter.loader.client.hdfs中SqlQueryDTO的使用

参数类型为SqlQueryDTO的com.dtstack.dtcenter.loader.client.hdfs中的方法

限定符和类型	方法和说明
List<ColumnMetaDTO>	HdfsFileProxy.getColumnList(ISourceDTO source, SqlQueryDTO queryDTO, String fileFormat)
IDownloader	HdfsFileProxy.getLogDownloader(ISourceDTO source, SqlQueryDTO queryDTO)

com.dtstack.dtcenter.loader.client.mq中SqlQueryDTO的使用

参数类型为SqlQueryDTO的com.dtstack.dtcenter.loader.client.mq中的方法

限定符和类型	方法和说明
List<List<Object>>	KafkaClientProxy.getPreview(ISourceDTO source, SqlQueryDTO queryDTO)
List<List<Object>>	KafkaClientProxy.getPreview(ISourceDTO source, SqlQueryDTO queryDTO, String prevMode)

com.dtstack.dtcenter.loader.client.sql中SqlQueryDTO的使用

参数类型为SqlQueryDTO的com.dtstack.dtcenter.loader.client.sql中的方法

限定符和类型	方法和说明
List<Map<String,Object>>	DataSourceClientProxy.executeQuery(ISourceDTO source, SqlQueryDTO queryDTO)
Boolean	DataSourceClientProxy.executeSqlWithoutResultSet(ISourceDTO source, SqlQueryDTO queryDTO)
List<String>	DataSourceClientProxy.getAllDatabases(ISourceDTO source, SqlQueryDTO queryDTO)
List<String>	DataSourceClientProxy.getColumnClassInfo(ISourceDTO source, SqlQueryDTO queryDTO)
List<ColumnMetaDTO>	DataSourceClientProxy.getColumnMetaData(ISourceDTO source, SqlQueryDTO queryDTO)
List<ColumnMetaDTO>	DataSourceClientProxy.getColumnMetaDataWithSql(ISourceDTO source, SqlQueryDTO queryDTO)
String	DataSourceClientProxy.getCreateTableSql(ISourceDTO source, SqlQueryDTO queryDTO)
IDownloader	DataSourceClientProxy.getDownloader(ISourceDTO source, SqlQueryDTO queryDTO)
List<ColumnMetaDTO>	DataSourceClientProxy.getFlinkColumnMetaData(ISourceDTO source, SqlQueryDTO queryDTO)
List<ColumnMetaDTO>	DataSourceClientProxy.getPartitionColumn(ISourceDTO source, SqlQueryDTO queryDTO)
List<List<Object>>	DataSourceClientProxy.getPreview(ISourceDTO source, SqlQueryDTO queryDTO)
List<String>	DataSourceClientProxy.getRootDatabases(ISourceDTO source, SqlQueryDTO queryDTO)
Table	DataSourceClientProxy.getTable(ISourceDTO source, SqlQueryDTO queryDTO)
List<String>	DataSourceClientProxy.getTableList(ISourceDTO source, SqlQueryDTO queryDTO)
List<String>	DataSourceClientProxy.getTableListBySchema(ISourceDTO source, SqlQueryDTO queryDTO)
String	DataSourceClientProxy.getTableMetaComment(ISourceDTO source, SqlQueryDTO queryDTO)

com.dtstack.dtcenter.loader.utils中SqlQueryDTO的使用

参数类型为SqlQueryDTO的com.dtstack.dtcenter.loader.utils中的方法

限定符和类型	方法和说明
static String[]	DBUtil.getTableTypes(SqlQueryDTO queryDTO) 重置表类型 DatabaseMetaData.getTableTypes()