oracle.pgx.api.frames

Class PgxDbFrameReader

java.lang.Object

oracle.pgx.api.frames.PgxFrameReader<PgxDbFrameReader>

oracle.pgx.api.frames.PgxDbFrameReader

public class PgxDbFrameReader
extends PgxFrameReader<PgxDbFrameReader>

Constructor Summary

Constructors

Constructor and Description
PgxDbFrameReader(PgxSession session, oracle.pgx.api.internal.Core core, java.util.function.Supplier<java.lang.String> keystorePathSupplier, java.util.function.Supplier<char[]> keystorePasswordSupplier)

Method Summary

Modifier and Type	Method and Description
PgxDbFrameReader	connections(int numConnections) sets the number of connections to open to load the data in parallel
PgxDbFrameReader	dataSourceId(java.lang.String dataSourceId) sets the dataSourceId to which to connect
PgxDbFrameReader	jdbcUrl(java.lang.String jdbcUrl) sets the jdbcUrl to use for connecting to the DB
PgxDbFrameReader	keystoreAlias(java.lang.String keystoreAlias) sets the keystore alias to retrieve the password from the keystore
PgxFuture<PgxFrame>	loadAsync(java.lang.String... uris) trigger the async loading of the PgxFrame
PgxDbFrameReader	name(java.lang.String frameName) sets the name of the stored frame
PgxDbFrameReader	owner(java.lang.String owner) sets the owner (schema) of the table from which to load the data
PgxDbFrameReader	password(java.lang.String password) sets the password to use for connecting to the database
PgxDbFrameReader	schema(java.lang.String schema) sets the schema from which to load the table
PgxDbFrameReader	tablename(java.lang.String tableName) sets name of the table that should be loaded in DB
PgxDbFrameReader	username(java.lang.String userName) sets the username of the DB user to use to connect to the DB

Methods inherited from class oracle.pgx.api.frames.PgxFrameReader

autodetectColumns, columns, load

Methods inherited from class java.lang.Object

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

Constructor Detail

PgxDbFrameReader

public PgxDbFrameReader(PgxSession session,
                        oracle.pgx.api.internal.Core core,
                        java.util.function.Supplier<java.lang.String> keystorePathSupplier,
                        java.util.function.Supplier<char[]> keystorePasswordSupplier)

Method Detail

connections

public PgxDbFrameReader connections(int numConnections)

sets the number of connections to open to load the data in parallel

Parameters:

numConnections - the number of connections

Returns:

this loader

dataSourceId

public PgxDbFrameReader dataSourceId(java.lang.String dataSourceId)

sets the dataSourceId to which to connect

Parameters:

dataSourceId - the datasourceId

Returns:

this loader

jdbcUrl

public PgxDbFrameReader jdbcUrl(java.lang.String jdbcUrl)

sets the jdbcUrl to use for connecting to the DB

Parameters:

jdbcUrl - the jdbc url

Returns:

this loader

keystoreAlias

public PgxDbFrameReader keystoreAlias(java.lang.String keystoreAlias)

sets the keystore alias to retrieve the password from the keystore

Parameters:

keystoreAlias - the keystore alias

Returns:

this loader

loadAsync

public PgxFuture<PgxFrame> loadAsync(java.lang.String... uris)

trigger the async loading of the PgxFrame

Specified by:

loadAsync in class PgxFrameReader<PgxDbFrameReader>

Parameters:

uris - array denoting the uris

Returns:

the future for the result of the operation

name

public PgxDbFrameReader name(java.lang.String frameName)

sets the name of the stored frame

Specified by:

name in class PgxFrameReader<PgxDbFrameReader>

Parameters:

frameName - string denoting the frameName

Returns:

this loader

owner

public PgxDbFrameReader owner(java.lang.String owner)

sets the owner (schema) of the table from which to load the data

Parameters:

owner - the owner

Returns:

this loader

password

public PgxDbFrameReader password(java.lang.String password)

sets the password to use for connecting to the database

Parameters:

password - the password

Returns:

this loader

schema

public PgxDbFrameReader schema(java.lang.String schema)

sets the schema from which to load the table

Parameters:

schema - the schema

Returns:

this loader

tablename

public PgxDbFrameReader tablename(java.lang.String tableName)

sets name of the table that should be loaded in DB

Parameters:

tableName - name of the table

Returns:

this loader

username

public PgxDbFrameReader username(java.lang.String userName)

sets the username of the DB user to use to connect to the DB

Parameters:

userName - the username

Returns:

this loader