columntypes

Documentation

Overview

Package columntypes implements functions for converting Vitess/MySQL column types to appropriate Go types.

Index

• Variables
• func ConvertStructureData(columnTypes map[string]string, data sdk.StructuredData) (sdk.StructuredData, error)
• func GetColumnTypes(ctx context.Context, querier Querier, tableName string) (map[string]string, error)
• func TransformValuesToNative(fields []*query.Field, values []sqltypes.Value) (map[string]any, error)
• type Querier

Variables

var (
	// ErrFieldsValuesLenMissmatch occurs when []*query.Field's and []sqltypes.Value's lengths are not equal.
	ErrFieldsValuesLenMissmatch = errors.New("fields and values length missmatch")
	// ErrValueIsNotAString occurs when trying to convert any to string but it fails.
	ErrValueIsNotAString = errors.New("value is not a string")
)

var ErrInvalidTime = errors.New("invalid MySQL time string")

ErrInvalidTime is returned when we fail to parse a datetime string from MySQL. This should never happen unless things are seriously messed up.

Functions

func ConvertStructureData

func ConvertStructureData(columnTypes map[string]string, data sdk.StructuredData) (sdk.StructuredData, error)

ConvertStructureData converts an sdk.StructureData values to a proper database types. For now it's just converts TIMESTAMP, DATETIME, DATE and TIME values.

func GetColumnTypes

func GetColumnTypes(ctx context.Context, querier Querier, tableName string) (map[string]string, error)

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

func TransformValuesToNative

func TransformValuesToNative(fields []*query.Field, values []sqltypes.Value) (map[string]any, error)

TransformValuesToNative converts the values of type sqltypes.Value to appropriate Go types, based on the fields parameter. This is necessary because the underlying raw values are just byte slices.

Types

type Querier

type Querier interface {
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
}

Querier is a database querier interface needed for the GetColumnTypes function.