columntypes

Documentation

Index

• Constants
• func ConvertStructuredData(columnTypes map[string]string, data opencdc.StructuredData) (opencdc.StructuredData, error)
• func GetColumnTypes(ctx context.Context, db *sqlx.DB, table, schema string) (map[string]string, error)
• func TransformRow(row map[string]any, columnTypes map[string]string) (map[string]any, error)

Constants

const (
	// TimeTypeLayout is a time layout of Redshift Time data type.
	TimeTypeLayout = "15:04:05"
	// TimeTzTypeLayout is a time layout of Redshift Time with timezone data type.
	TimeTzTypeLayout = "15:04:05Z07"
)

Functions

func ConvertStructuredData

func ConvertStructuredData(
	columnTypes map[string]string,
	data opencdc.StructuredData,
) (opencdc.StructuredData, error)

ConvertStructuredData converts a opencdc.StructuredData value to another StructuredData value but with proper database types.

func GetColumnTypes

func GetColumnTypes(ctx context.Context, db *sqlx.DB, table, schema string) (map[string]string, error)

GetColumnTypes returns a map containing all table's columns and their database types.

func TransformRow

func TransformRow(row map[string]any, columnTypes map[string]string) (map[string]any, error)

TransformRow converts row map values to appropriate Go types, based on the columnTypes.