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)
JdbcIO.DataSourceConfiguration	withConnectionProperties(java.lang.String connectionProperties) Sets the connection properties passed to driver.connect(...).
JdbcIO.DataSourceConfiguration	withPassword(java.lang.String password)
JdbcIO.DataSourceConfiguration	withUsername(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)

withUsername

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

withPassword

public JdbcIO.DataSourceConfiguration withPassword(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.