Package org.apache.beam.sdk.extensions.sql.impl

Class JdbcConnection

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper

org.apache.beam.sdk.extensions.sql.impl.JdbcConnection

All Implemented Interfaces:

AutoCloseable, Connection, Wrapper, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.jdbc.CalciteConnection, org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.linq4j.QueryProvider

public class JdbcConnection
extends CalciteConnectionWrapper

Beam JDBC Connection.

Implements and delegates to CalciteConnection, adds Beam-specific helper methods. BeamCalciteSchemas keep reference to this connection. Pipeline options are stored here.

Field Summary

Fields inherited from interface java.sql.Connection

TRANSACTION_NONE, TRANSACTION_READ_COMMITTED, TRANSACTION_READ_UNCOMMITTED, TRANSACTION_REPEATABLE_READ, TRANSACTION_SERIALIZABLE

Method Summary

Modifier and Type	Method	Description
org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus	getCurrentSchemaPlus()	Calcite-created SchemaPlus wrapper for the current schema.
PipelineOptions	getPipelineOptions()
void	setPipelineOptions(PipelineOptions pipelineOptions)
void	setPipelineOptionsMap(Map<String,String> pipelineOptionsMap)	Only called from the BeamCalciteSchema.

Methods inherited from class org.apache.beam.sdk.extensions.sql.impl.CalciteConnectionWrapper

abort, clearWarnings, close, commit, config, connection, createArrayOf, createBlob, createClob, createNClob, createPrepareContext, createQuery, createQuery, createSQLXML, createStatement, createStatement, createStatement, createStruct, execute, execute, executeQuery, getAutoCommit, getCatalog, getClientInfo, getClientInfo, getHoldability, getMetaData, getNetworkTimeout, getProperties, getRootSchema, getSchema, getTransactionIsolation, getTypeFactory, getTypeMap, getWarnings, isClosed, isReadOnly, isValid, isWrapperFor, nativeSQL, prepareCall, prepareCall, prepareCall, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, prepareStatement, releaseSavepoint, rollback, rollback, setAutoCommit, setCatalog, setClientInfo, setClientInfo, setHoldability, setNetworkTimeout, setReadOnly, setSavepoint, setSavepoint, setSchema, setTransactionIsolation, setTypeMap, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.sql.Connection

beginRequest, endRequest, setShardingKey, setShardingKey, setShardingKeyIfValid, setShardingKeyIfValid

Method Details

setPipelineOptionsMap

public void setPipelineOptionsMap(Map<String,String> pipelineOptionsMap)

Only called from the BeamCalciteSchema. This is needed to enable the `SET pipelineOption = blah` syntax

setPipelineOptions

public void setPipelineOptions(PipelineOptions pipelineOptions)

getPipelineOptions

public PipelineOptions getPipelineOptions()

getCurrentSchemaPlus

public org.apache.beam.vendor.calcite.v1_40_0.org.apache.calcite.schema.SchemaPlus getCurrentSchemaPlus()

Calcite-created SchemaPlus wrapper for the current schema.