Package com.amazonaws.athena.connectors.clickhouse

Class ClickHouseUtil

java.lang.Object

com.amazonaws.athena.connectors.clickhouse.ClickHouseUtil

public final class ClickHouseUtil
extends Object

Clickhouse utilities adapted and ported from JDBCUtil.

Method Summary

Modifier and Type	Method	Description
static PreparedStatement	getSchemaNameQuery(Connection connection, String databaseName)
static TableName	getSchemaTableName(ResultSet resultSet)
static List<TableName>	getTableMetadata(PreparedStatement preparedStatement, String tableType)
static PreparedStatement	getTableNameQuery(Connection connection, String tableName, String databaseName)
static List<TableName>	getTables(Connection connection, String databaseName)
static TableName	informationSchemaCaseInsensitiveTableMatch(Connection connection, String databaseName, String tableName)

Methods inherited from class java.lang.Object

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

Method Detail

informationSchemaCaseInsensitiveTableMatch

public static TableName informationSchemaCaseInsensitiveTableMatch(Connection connection,
                                                                   String databaseName,
                                                                   String tableName)
                                                            throws Exception

Throws:

Exception

getTableNameQuery

public static PreparedStatement getTableNameQuery(Connection connection,
                                                  String tableName,
                                                  String databaseName)
                                           throws SQLException

Throws:

SQLException

getSchemaNameQuery

public static PreparedStatement getSchemaNameQuery(Connection connection,
                                                   String databaseName)
                                            throws SQLException

Throws:

SQLException

getTables

public static List<TableName> getTables(Connection connection,
                                        String databaseName)
                                 throws SQLException

Throws:

SQLException

getTableMetadata

public static List<TableName> getTableMetadata(PreparedStatement preparedStatement,
                                               String tableType)

getSchemaTableName

public static TableName getSchemaTableName(ResultSet resultSet)
                                    throws SQLException

Throws:

SQLException