Package com.amazonaws.athena.connectors.snowflake

Class SnowflakeQueryStringBuilder

java.lang.Object

com.amazonaws.athena.connectors.jdbc.manager.JdbcSplitQueryBuilder

com.amazonaws.athena.connectors.snowflake.SnowflakeQueryStringBuilder

public class SnowflakeQueryStringBuilder
extends JdbcSplitQueryBuilder

Extends JdbcSplitQueryBuilder and implements MySql specific SQL clauses for split. MySql provides named partitions which can be used in a FROM clause.

Field Summary

Fields inherited from class com.amazonaws.athena.connectors.jdbc.manager.JdbcSplitQueryBuilder

emptyString

Constructor Summary

Constructors

Constructor	Description
SnowflakeQueryStringBuilder(String quoteCharacters, FederationExpressionParser federationExpressionParser)

Method Summary

Modifier and Type	Method	Description
String	buildSqlString(Connection jdbcConnection, String catalog, String schema, String table, org.apache.arrow.vector.types.pojo.Schema tableSchema, Constraints constraints, Split split)
protected String	getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected static Object	getObjectForWhereClause(String columnName, Object value, org.apache.arrow.vector.types.pojo.ArrowType arrowType)
protected List<String>	getPartitionWhereClauses(Split split)
protected String	quote(String name)
protected String	singleQuote(String name)
protected String	toPredicate(String columnName, String operator, Object value, org.apache.arrow.vector.types.pojo.ArrowType type)

Methods inherited from class com.amazonaws.athena.connectors.jdbc.manager.JdbcSplitQueryBuilder

appendLimitOffset, appendLimitOffset, buildSql, extractOrderByClause, prepareStatementWithSql, toPredicate

Methods inherited from class java.lang.Object

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

Constructor Detail

SnowflakeQueryStringBuilder

public SnowflakeQueryStringBuilder(String quoteCharacters,
                                   FederationExpressionParser federationExpressionParser)

Method Detail

getFromClauseWithSplit

protected String getFromClauseWithSplit(String catalog,
                                        String schema,
                                        String table,
                                        Split split)

Specified by:

getFromClauseWithSplit in class JdbcSplitQueryBuilder

getPartitionWhereClauses

protected List<String> getPartitionWhereClauses(Split split)

Specified by:

getPartitionWhereClauses in class JdbcSplitQueryBuilder

buildSqlString

public String buildSqlString(Connection jdbcConnection,
                             String catalog,
                             String schema,
                             String table,
                             org.apache.arrow.vector.types.pojo.Schema tableSchema,
                             Constraints constraints,
                             Split split)
                      throws SQLException

Throws:

SQLException

quote

protected String quote(String name)

Overrides:

quote in class JdbcSplitQueryBuilder

singleQuote

protected String singleQuote(String name)

toPredicate

protected String toPredicate(String columnName,
                             String operator,
                             Object value,
                             org.apache.arrow.vector.types.pojo.ArrowType type)

getObjectForWhereClause

protected static Object getObjectForWhereClause(String columnName,
                                                Object value,
                                                org.apache.arrow.vector.types.pojo.ArrowType arrowType)