sql2avro

README

go-sql2avro

database/sql.Rows -> AVRO records(e.g, SQLite -> AVRO records)

Documentation

Index

• Variables
• func SqlRowsToMaps(r *sql.Rows) iter.Seq2[map[string]any, error]
• type AnyColumn
  • func (a *AnyColumn) Scan(src any) error
  • func (a AnyColumn) String() string
• type AnyRow
  • func (a AnyRow) ToMap(m map[string]any)

Variables

var (
	ErrUnexpectedInputValue error = errors.New("unexpected input value")
)

Functions

func SqlRowsToMaps

func SqlRowsToMaps(r *sql.Rows) iter.Seq2[map[string]any, error]

Converts the *sql.Rows to an iterator and closes it.

Types

type AnyColumn

type AnyColumn struct {
	Value       any
	Name        string
	RawTypeName string
}

func (*AnyColumn) Scan

func (a *AnyColumn) Scan(src any) error

func (AnyColumn) String

func (a AnyColumn) String() string

type AnyRow

type AnyRow []*AnyColumn

func (AnyRow) ToMap

func (a AnyRow) ToMap(m map[string]any)