org.apache.spark.sql.jdbc

Class JdbcConnectionProvider

Object

org.apache.spark.sql.jdbc.JdbcConnectionProvider

public abstract class JdbcConnectionProvider
extends Object

::DeveloperApi:: Connection provider which opens connection toward various databases (database specific instance needed). If any authentication required then it's the provider's responsibility to set all the parameters. Important to mention connection providers within a JVM used from multiple threads so adding internal state is not advised. If any state added then it must be synchronized properly.

Since:

3.1.0

Constructor Summary

Constructors

Constructor and Description
JdbcConnectionProvider()

Method Summary

Modifier and Type	Method and Description
abstract boolean	canHandle(java.sql.Driver driver, scala.collection.immutable.Map<String,String> options) Checks if this connection provider instance can handle the connection initiated by the driver.
abstract java.sql.Connection	getConnection(java.sql.Driver driver, scala.collection.immutable.Map<String,String> options) Opens connection toward the database.
abstract String	name() Name of the service to provide JDBC connections.

Methods inherited from class Object

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

Constructor Detail

JdbcConnectionProvider

public JdbcConnectionProvider()

Method Detail

canHandle

public abstract boolean canHandle(java.sql.Driver driver,
                                  scala.collection.immutable.Map<String,String> options)

Checks if this connection provider instance can handle the connection initiated by the driver. There must be exactly one active connection provider which can handle the connection for a specific driver. If this requirement doesn't met then IllegalArgumentException will be thrown by the provider framework.

Parameters:

driver - Java driver which initiates the connection

options - Driver options which initiates the connection

Returns:

True if the connection provider can handle the driver with the given options.

getConnection

public abstract java.sql.Connection getConnection(java.sql.Driver driver,
                                                  scala.collection.immutable.Map<String,String> options)

Opens connection toward the database. Since global JVM security configuration change may needed this API is called synchronized by SecurityConfigurationLock to avoid race.

Parameters:

driver - Java driver which initiates the connection

options - Driver options which initiates the connection

Returns:

a Connection object that represents a connection to the URL

name

public abstract String name()

Name of the service to provide JDBC connections. This name should be unique. Spark will internally use this name to differentiate JDBC connection providers.

Returns:

(undocumented)