config

Documentation

Index

• func Columns(ctx context.Context, session *sink.Session, db *sql.DB, table string, ...) ([]sink.Column, error)
• func Dialect(ctx context.Context, db *sql.DB, opts ...option.Option) (*info.Dialect, error)
• func LoadSession(dialect *info.Dialect) io.LoadExecutor
• func MergeExecutor(dialect *info.Dialect, config info.MergeConfig) (io.MergeExecutor, error)
• func Session(ctx context.Context, db *sql.DB, options ...option.Option) (*sink.Session, error)
• type Config
  • func New(tableName string) *Config
  • func (c *Config) ApplyOption(ctx context.Context, db *sql.DB, options ...option.Option) error

Functions

func Columns

func Columns(ctx context.Context, session *sink.Session, db *sql.DB, table string, options ...option.Option) ([]sink.Column, error)

Columns returns table columns

func Dialect

func Dialect(ctx context.Context, db *sql.DB, opts ...option.Option) (*info.Dialect, error)

Dialect returns a dialect

func LoadSession

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

LoadSession Returns new session for specified Dialect

func MergeExecutor

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

MergeExecutor returns new merge executor for specified dialect

func Session

func Session(ctx context.Context, db *sql.DB, options ...option.Option) (*sink.Session, error)

Session retrieve basic data from the database connection

Types

type Config

type Config struct {
	TableName         string
	Identity          string
	Columns           io.Columns
	Dialect           *info.Dialect
	Mapper            io.ColumnMapper
	Builder           io.Builder
	OnDuplicateKeySql string
}

Config represents general config

func New

func New(tableName string) *Config

New creates a config

func (*Config) ApplyOption

func (c *Config) ApplyOption(ctx context.Context, db *sql.DB, options ...option.Option) error

ApplyOption applied config option