load

Documentation

Index

• func BuildSQL(config *csv.Config, readerID, tableName string, columns []io.Column, ...) string
• func NewSession(dialect *info.Dialect) io.LoadExecutor
• type Session
  • func (s *Session) Exec(ctx context.Context, data interface{}, db *sql.DB, tableName string, ...) (sql.Result, error)

Functions

func BuildSQL

func BuildSQL(config *csv.Config, readerID, tableName string, columns []io.Column, options ...loption.Option) string

BuildSQL builds "LOAD DATA" statement

func NewSession

func NewSession(dialect *info.Dialect) io.LoadExecutor

NewSession returns new MySQL session

Types

type Session

type Session struct {
	*io.Transaction

	loption.Options
	// contains filtered or unexported fields
}

Session represents MySQL session

func (*Session) Exec

func (s *Session) Exec(ctx context.Context, data interface{}, db *sql.DB, tableName string, options ...loption.Option) (sql.Result, error)

Exec inserts given data to database using "LOAD DATA LOCAL INFILE" note: local_infile=1 must be enabled on database