load

Mar 9, 2020

Changes in this version

+ type BatchLoader interface

+ Flush func(ctx context.Context) error

+ InsertValue func(ctx context.Context, query []string) error

+ type CSVBatchLoader struct

+ func NewCSVBatchLoader(f *os.File) *CSVBatchLoader

+ func (b *CSVBatchLoader) Close(ctx context.Context) error

+ func (b *CSVBatchLoader) Flush(ctx context.Context) error

+ func (b *CSVBatchLoader) InsertValue(ctx context.Context, columns []string) error

+ type SQLBatchLoader struct

+ func NewSQLBatchLoader(conn *sql.Conn, hint string) *SQLBatchLoader

+ func (b *SQLBatchLoader) Flush(ctx context.Context) error

+ func (b *SQLBatchLoader) InsertValue(ctx context.Context, query []string) error