Package com.amazonaws.athena.connectors.postgresql

Class PostGreSqlRecordHandler

java.lang.Object

com.amazonaws.athena.connector.lambda.handlers.RecordHandler

com.amazonaws.athena.connectors.jdbc.manager.JdbcRecordHandler

com.amazonaws.athena.connectors.postgresql.PostGreSqlRecordHandler

All Implemented Interfaces:

com.amazonaws.services.lambda.runtime.RequestStreamHandler

Direct Known Subclasses:

RedshiftRecordHandler

public class PostGreSqlRecordHandler
extends JdbcRecordHandler

Field Summary

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

queryPassthrough

Fields inherited from class com.amazonaws.athena.connector.lambda.handlers.RecordHandler

configOptions

Constructor Summary

Constructors

Modifier	Constructor	Description
	PostGreSqlRecordHandler(DatabaseConnectionConfig databaseConnectionConfig, Map<String,String> configOptions)
protected	PostGreSqlRecordHandler(DatabaseConnectionConfig databaseConnectionConfig, software.amazon.awssdk.services.s3.S3Client amazonS3, software.amazon.awssdk.services.secretsmanager.SecretsManagerClient secretsManager, software.amazon.awssdk.services.athena.AthenaClient athena, JdbcConnectionFactory jdbcConnectionFactory, JdbcSplitQueryBuilder jdbcSplitQueryBuilder, Map<String,String> configOptions)
	PostGreSqlRecordHandler(Map<String,String> configOptions)	Instantiates handler to be used by Lambda function directly.

Method Summary

Modifier and Type	Method	Description
PreparedStatement	buildSplitSql(Connection jdbcConnection, String catalogName, TableName tableName, org.apache.arrow.vector.types.pojo.Schema schema, Constraints constraints, Split split)	Builds split SQL string and returns prepared statement.

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

buildQueryPassthroughSql, getCredentialProvider, getJdbcConnectionFactory, makeExtractor, makeFactory, readWithConstraint

Methods inherited from class com.amazonaws.athena.connector.lambda.handlers.RecordHandler

doHandleRequest, doReadRecords, getSecret, getSpillConfig, handleRequest, onPing, resolveSecrets

Methods inherited from class java.lang.Object

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

Constructor Detail

PostGreSqlRecordHandler

public PostGreSqlRecordHandler(Map<String,String> configOptions)

Instantiates handler to be used by Lambda function directly. Recommend using PostGreSqlMuxCompositeHandler instead.

PostGreSqlRecordHandler

public PostGreSqlRecordHandler(DatabaseConnectionConfig databaseConnectionConfig,
                               Map<String,String> configOptions)

PostGreSqlRecordHandler

protected PostGreSqlRecordHandler(DatabaseConnectionConfig databaseConnectionConfig,
                                  software.amazon.awssdk.services.s3.S3Client amazonS3,
                                  software.amazon.awssdk.services.secretsmanager.SecretsManagerClient secretsManager,
                                  software.amazon.awssdk.services.athena.AthenaClient athena,
                                  JdbcConnectionFactory jdbcConnectionFactory,
                                  JdbcSplitQueryBuilder jdbcSplitQueryBuilder,
                                  Map<String,String> configOptions)

Method Detail

buildSplitSql

public PreparedStatement buildSplitSql(Connection jdbcConnection,
                                       String catalogName,
                                       TableName tableName,
                                       org.apache.arrow.vector.types.pojo.Schema schema,
                                       Constraints constraints,
                                       Split split)
                                throws SQLException

Description copied from class: JdbcRecordHandler

Builds split SQL string and returns prepared statement.

Specified by:

buildSplitSql in class JdbcRecordHandler

Parameters:

jdbcConnection - jdbc connection. See Connection

catalogName - Athena provided catalog name.

tableName - database table name.

schema - table schema.

constraints - constraints to push down to the database.

split - table split.

Returns:

prepared statement with sql. See PreparedStatement

Throws:

SQLException - JDBC database exception.