package jdbc

import "github.com/apache/beam/sdks/v2/go/test/integration/io/xlang/jdbc"

Package jdbc contains integration tests for cross-language JDBC IO transforms.

Index ¶

• func ReadFromPostgres(expansionAddr, tableName, jdbcUrl, username, password string) *beam.Pipeline
• func ReadPipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline
• func WritePipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline
• func WriteToPostgres(expansionAddr, tableName, jdbcUrl, username, password string) *beam.Pipeline
• type JdbcTestRow

Functions ¶

func ReadFromPostgres ¶

func ReadFromPostgres(expansionAddr, tableName, jdbcUrl, username, password string) *beam.Pipeline

ReadFromPostgres creates a pipeline for JDBC IO Read transform.

func ReadPipeline ¶

func ReadPipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline

ReadPipeline creates a pipeline for JDBC IO Read transform.

func WritePipeline ¶

func WritePipeline(expansionAddr, tableName, driverClassName, jdbcUrl, username, password string) *beam.Pipeline

WritePipeline creates a pipeline for JDBC IO Write transform.

func WriteToPostgres ¶

func WriteToPostgres(expansionAddr, tableName, jdbcUrl, username, password string) *beam.Pipeline

WriteToPostgres creates a pipeline for JDBC IO Write transform.

Types ¶

type JdbcTestRow ¶

type JdbcTestRow struct {
	Role_id int32 `beam:"role_id"`
}

JdbcTestRow is the sample schema for read and write transform test.

Source Files ¶

jdbc.go