Package com.amazonaws.athena.connectors.postgresql

Class PostGreSqlQueryStringBuilder

java.lang.Object

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

com.amazonaws.athena.connectors.postgresql.PostGreSqlQueryStringBuilder

Direct Known Subclasses:

RedshiftSqlQueryStringBuilder

public class PostGreSqlQueryStringBuilder
extends JdbcSplitQueryBuilder

Extends JdbcSplitQueryBuilder and implements PostGreSql specific SQL clauses for split. PostGreSql partitions through child tables that 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
PostGreSqlQueryStringBuilder(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 catalogCasingFilterUpperCase)	Returns the SQL dialect to use for query generation with catalog casing filter support.

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

appendLimitOffset, appendLimitOffset, appendLimitOffsetWithValue, buildSQLStringLiteral, extractOrderByClause, prepareStatementWithCalciteSql, prepareStatementWithSql, quote, toPredicate

Methods inherited from class java.lang.Object

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

Constructor Detail

PostGreSqlQueryStringBuilder

public PostGreSqlQueryStringBuilder(String quoteCharacters,
                                    FederationExpressionParser federationExpressionParser)

Method Detail

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.

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

getSqlDialect

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

Overrides:

getSqlDialect in class JdbcSplitQueryBuilder

getSqlDialect

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

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:

catalogCasingFilterUpperCase - whether to apply catalog casing to quoted identifiers

Returns:

the SqlDialect instance