Package org.apache.flink.table.jdbc

Class FlinkDriver

java.lang.Object

org.apache.flink.table.jdbc.FlinkDriver

All Implemented Interfaces:

Driver

public class FlinkDriver
extends Object
implements Driver

Jdbc Driver for flink sql gateway. Only Batch Mode queries are supported. If you force to submit streaming queries, you may get unrecognized updates, deletions and other results in result set.

Constructor Summary

Constructors

Constructor	Description
FlinkDriver()

Method Summary

Modifier and Type	Method	Description
boolean	acceptsURL(String url)
Connection	connect(String url, Properties driverProperties)
int	getMajorVersion()	Major version of flink.
int	getMinorVersion()	Minor version of flink.
Logger	getParentLogger()
DriverPropertyInfo[]	getPropertyInfo(String url, Properties info)
boolean	jdbcCompliant()

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkDriver

public FlinkDriver()

Method Detail

connect

public Connection connect(String url,
                          Properties driverProperties)
                   throws SQLException

Specified by:

connect in interface Driver

Throws:

SQLException

acceptsURL

public boolean acceptsURL(String url)
                   throws SQLException

Specified by:

acceptsURL in interface Driver

Throws:

SQLException

getPropertyInfo

public DriverPropertyInfo[] getPropertyInfo(String url,
                                            Properties info)
                                     throws SQLException

Specified by:

getPropertyInfo in interface Driver

Throws:

SQLException

getMajorVersion

public int getMajorVersion()

Major version of flink.

Specified by:

getMajorVersion in interface Driver

Returns:

the major version

getMinorVersion

public int getMinorVersion()

Minor version of flink.

Specified by:

getMinorVersion in interface Driver

Returns:

the minor version

jdbcCompliant

public boolean jdbcCompliant()

Specified by:

jdbcCompliant in interface Driver

getParentLogger

public Logger getParentLogger()
                       throws SQLFeatureNotSupportedException

Specified by:

getParentLogger in interface Driver

Throws:

SQLFeatureNotSupportedException