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

Class JdbcDriver

java.lang.Object

org.apache.calcite.avatica.UnregisteredDriver

org.apache.calcite.jdbc.Driver

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

All Implemented Interfaces:

java.sql.Driver

@AutoService(value=java.sql.Driver.class)
public class JdbcDriver
extends org.apache.calcite.jdbc.Driver

Calcite JDBC driver with Beam defaults.

Connection URLs have this form:

jdbc:beam:param1=value1;param2=value2;param3=value3

The querystring-style parameters are parsed as PipelineOptions.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.avatica.UnregisteredDriver

org.apache.calcite.avatica.UnregisteredDriver.JdbcVersion

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BEAM_QUERYSTRING_PREFIX Querystring parameters that begin with "beam." will be interpreted as PipelineOptions.
static java.lang.String	CONNECT_STRING_PREFIX
static JdbcDriver	INSTANCE

Fields inherited from class org.apache.calcite.avatica.UnregisteredDriver

factory, handler

Constructor Summary

Constructors

Constructor and Description
JdbcDriver()

Method Summary

Modifier and Type	Method and Description
java.sql.Connection	connect(java.lang.String url, java.util.Properties info)
static org.apache.calcite.jdbc.CalciteConnection	connect(TableProvider tableProvider)
protected java.lang.String	getConnectStringPrefix()
static org.apache.calcite.schema.SchemaPlus	getDefaultSchema(org.apache.calcite.jdbc.CalciteConnection connection)

Methods inherited from class org.apache.calcite.jdbc.Driver

createDriverVersion, createHandler, createMeta, createPrepareFactory, getConnectionProperties, getFactoryClassName

Methods inherited from class org.apache.calcite.avatica.UnregisteredDriver

acceptsURL, createFactory, getDriverVersion, getMajorVersion, getMinorVersion, getParentLogger, getPropertyInfo, instantiateFactory, jdbcCompliant, register

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final JdbcDriver INSTANCE

CONNECT_STRING_PREFIX

public static final java.lang.String CONNECT_STRING_PREFIX

See Also:

Constant Field Values

BEAM_QUERYSTRING_PREFIX

public static final java.lang.String BEAM_QUERYSTRING_PREFIX

Querystring parameters that begin with "beam." will be interpreted as PipelineOptions.

See Also:

Constant Field Values

Constructor Detail

JdbcDriver

public JdbcDriver()

Method Detail

getConnectStringPrefix

protected java.lang.String getConnectStringPrefix()

Overrides:

getConnectStringPrefix in class org.apache.calcite.jdbc.Driver

connect

public java.sql.Connection connect(java.lang.String url,
                                   java.util.Properties info)
                            throws java.sql.SQLException

Specified by:

connect in interface java.sql.Driver

Overrides:

connect in class org.apache.calcite.avatica.UnregisteredDriver

Throws:

java.sql.SQLException

connect

public static org.apache.calcite.jdbc.CalciteConnection connect(TableProvider tableProvider)

getDefaultSchema

public static org.apache.calcite.schema.SchemaPlus getDefaultSchema(org.apache.calcite.jdbc.CalciteConnection connection)