generator

Documentation

Index

• type Builder
  • func NewBuilder(columns []sink.Column, batchSize int) *Builder
  • func (b Builder) Build(options ...option.Option) string
• type Default
  • func NewDefault(ctx context.Context, dialect *info.Dialect, db *sql.DB, session *sink.Session) (*Default, error)
  • func (d *Default) Apply(ctx context.Context, any interface{}, table string, batchSize int) error

Types

type Builder

type Builder struct {
	// contains filtered or unexported fields
}

Builder represent default value builder

func NewBuilder

func NewBuilder(columns []sink.Column, batchSize int) *Builder

NewBuilder returns default values builder

func (Builder) Build

func (b Builder) Build(options ...option.Option) string

Build builds default values statement

type Default

type Default struct {
	// contains filtered or unexported fields
}

Default represents generator for default strategy TODO: Add order to union TODO: Refresh session when rType changes

func NewDefault

func NewDefault(ctx context.Context, dialect *info.Dialect, db *sql.DB, session *sink.Session) (*Default, error)

NewDefault creates a default generator

func (*Default) Apply

func (d *Default) Apply(ctx context.Context, any interface{}, table string, batchSize int) error

Apply generated values to the any