data

Documentation

Index

• type Inserter
  • func NewInserter() *Inserter
  • func (i *Inserter) Insert(ctx context.Context, cn *conn.Connection, table string, ...) (int64, error)
  • func (i *Inserter) Upsert(ctx context.Context, cn *conn.Connection, table *schema.Table, ...) (int64, error)
• type Loader
  • func NewLoader() *Loader
  • func (l *Loader) Load(ctx context.Context, conn *conn.Connection, table string) (TableData, error)
• type TableData
  • func (d *TableData) FilterColumns(filter func(col string) bool) TableData

Types

type Inserter

type Inserter struct {
}

func NewInserter

func NewInserter() *Inserter

func (*Inserter) Insert

func (i *Inserter) Insert(
	ctx context.Context,
	cn *conn.Connection,
	table string,
	dataset []map[string]interface{},
) (int64, error)

func (*Inserter) Upsert

func (i *Inserter) Upsert(
	ctx context.Context,
	cn *conn.Connection,
	table *schema.Table,
	dataset []map[string]interface{},
) (int64, error)

type Loader

type Loader struct{}

func NewLoader

func NewLoader() *Loader

func (*Loader) Load

func (l *Loader) Load(ctx context.Context, conn *conn.Connection, table string) (TableData, error)

type TableData

type TableData []map[string]interface{}

func (*TableData) FilterColumns

func (d *TableData) FilterColumns(filter func(col string) bool) TableData