Package com.amazonaws.athena.connectors.saphana

Class SaphanaQueryStringBuilder

java.lang.Object

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

com.amazonaws.athena.connectors.saphana.SaphanaQueryStringBuilder

public class SaphanaQueryStringBuilder
extends JdbcSplitQueryBuilder

Field Summary

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

emptyString

Constructor Summary

Constructors

Constructor	Description
SaphanaQueryStringBuilder(String quoteCharacters, FederationExpressionParser federationExpressionParser)

Method Summary

Modifier and Type	Method	Description
PreparedStatement	buildSql(Connection jdbcConnection, String catalog, String schema, String table, org.apache.arrow.vector.types.pojo.Schema tableSchema, Constraints constraints, Split split)	Common logic to build Split SQL including constraints translated in where clause.
protected String	getFromClauseWithSplit(String catalog, String schema, String table, Split split)
protected List<String>	getPartitionWhereClauses(Split split)
protected org.apache.calcite.sql.SqlDialect	getSqlDialect()
protected org.apache.calcite.sql.SqlDialect	getSqlDialect(boolean catalogCasingFilterApplied)	Returns the SQL dialect to use for query generation with catalog casing filter support.
protected String	quote(String name)
protected String	toPredicate(String columnName, String operator, Object value, org.apache.arrow.vector.types.pojo.ArrowType type, List<TypeAndValue> accumulator)

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

addPartitionWhereClauses, appendLimitOffset, appendLimitOffset, appendLimitOffsetWithValue, buildSQLStringLiteral, extractOrderByClause, prepareStatementWithCalciteSql, prepareStatementWithSql

Methods inherited from class java.lang.Object

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

Constructor Detail

SaphanaQueryStringBuilder

public SaphanaQueryStringBuilder(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

buildSql

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

Description copied from class: JdbcSplitQueryBuilder

Common logic to build Split SQL including constraints translated in where clause.

Overrides:

buildSql in class JdbcSplitQueryBuilder

Parameters:

jdbcConnection - JDBC connection. See Connection.

catalog - Athena provided catalog name.

schema - table schema name.

table - table name.

tableSchema - table schema (column and type information).

constraints - constraints passed by Athena to push down.

split - table split.

Returns:

prepated statement with SQL. See PreparedStatement.

Throws:

SQLException - JDBC database exception.

quote

protected String quote(String name)

Overrides:

quote in class JdbcSplitQueryBuilder

getSqlDialect

protected org.apache.calcite.sql.SqlDialect getSqlDialect()

Overrides:

getSqlDialect in class JdbcSplitQueryBuilder

getSqlDialect

protected org.apache.calcite.sql.SqlDialect getSqlDialect(boolean catalogCasingFilterApplied)

Description copied from class: JdbcSplitQueryBuilder

Returns the SQL dialect to use for query generation with catalog casing filter support. Subclasses should override to return a database-specific dialect.

Overrides:

getSqlDialect in class JdbcSplitQueryBuilder

Parameters:

catalogCasingFilterApplied - whether to apply catalog casing to quoted identifiers

Returns:

the SqlDialect instance

toPredicate

protected String toPredicate(String columnName,
                             String operator,
                             Object value,
                             org.apache.arrow.vector.types.pojo.ArrowType type,
                             List<TypeAndValue> accumulator)

Overrides:

toPredicate in class JdbcSplitQueryBuilder