merge

Documentation

Index

• func NewMergeExecutor(dialect *info.Dialect, cfg info.MergeConfig) (io.MergeExecutor, error)
• type Executor
  • func (e *Executor) Exec(ctx context.Context, srcData interface{}, db *sql.DB, tableName string, ...) (info.MergeResult, error)

Functions

func NewMergeExecutor

func NewMergeExecutor(dialect *info.Dialect, cfg info.MergeConfig) (io.MergeExecutor, error)

NewMergeExecutor returns new MySQL session

Types

type Executor

type Executor struct {
	*io.Transaction
	// contains filtered or unexported fields
}

Executor represents MySQL merger session

func (*Executor) Exec

func (e *Executor) Exec(ctx context.Context, srcData interface{}, db *sql.DB, tableName string, options ...moption.Option) (info.MergeResult, error)

Exec merges data to database table