org.apache.beam.sdk.io.jdbc

Class JdbcIO.DataSourceConfiguration

java.lang.Object

org.apache.beam.sdk.io.jdbc.JdbcIO.DataSourceConfiguration

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

JdbcIO

public abstract static class JdbcIO.DataSourceConfiguration
extends java.lang.Object
implements java.io.Serializable

A POJO describing a DataSource, either providing directly a DataSource or all properties allowing to create a DataSource.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DataSourceConfiguration()

Method Summary

Modifier and Type	Method and Description
static JdbcIO.DataSourceConfiguration	create(javax.sql.DataSource dataSource)
static JdbcIO.DataSourceConfiguration	create(java.lang.String driverClassName, java.lang.String url)
static JdbcIO.DataSourceConfiguration	create(ValueProvider<java.lang.String> driverClassName, ValueProvider<java.lang.String> url)
JdbcIO.DataSourceConfiguration	withConnectionProperties(java.lang.String connectionProperties) Sets the connection properties passed to driver.connect(...).
JdbcIO.DataSourceConfiguration	withConnectionProperties(ValueProvider<java.lang.String> connectionProperties) Same as withConnectionProperties(String) but accepting a ValueProvider.
JdbcIO.DataSourceConfiguration	withPassword(java.lang.String password)
JdbcIO.DataSourceConfiguration	withPassword(ValueProvider<java.lang.String> password)
JdbcIO.DataSourceConfiguration	withUsername(java.lang.String username)
JdbcIO.DataSourceConfiguration	withUsername(ValueProvider<java.lang.String> username)

Methods inherited from class java.lang.Object

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

Constructor Detail

DataSourceConfiguration

public DataSourceConfiguration()

Method Detail

create

public static JdbcIO.DataSourceConfiguration create(javax.sql.DataSource dataSource)

create

public static JdbcIO.DataSourceConfiguration create(java.lang.String driverClassName,
                                                    java.lang.String url)

create

public static JdbcIO.DataSourceConfiguration create(ValueProvider<java.lang.String> driverClassName,
                                                    ValueProvider<java.lang.String> url)

withUsername

public JdbcIO.DataSourceConfiguration withUsername(java.lang.String username)

withUsername

public JdbcIO.DataSourceConfiguration withUsername(ValueProvider<java.lang.String> username)

withPassword

public JdbcIO.DataSourceConfiguration withPassword(java.lang.String password)

withPassword

public JdbcIO.DataSourceConfiguration withPassword(ValueProvider<java.lang.String> password)

withConnectionProperties

public JdbcIO.DataSourceConfiguration withConnectionProperties(java.lang.String connectionProperties)

Sets the connection properties passed to driver.connect(...). Format of the string must be [propertyName=property;]*

NOTE - The "user" and "password" properties can be add via withUsername(String), withPassword(String), so they do not need to be included here.

withConnectionProperties

public JdbcIO.DataSourceConfiguration withConnectionProperties(ValueProvider<java.lang.String> connectionProperties)

Same as withConnectionProperties(String) but accepting a ValueProvider.