jdbc

Documentation

Overview

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.