sqlutils

Documentation

Index

• type BatchInsert
  • func NewBatchInsert() *BatchInsert
  • func (b *BatchInsert) AddValues(sqlValues string, args ...interface{}) *BatchInsert
  • func (b *BatchInsert) Count() int
  • func (b *BatchInsert) DoContext(ctx context.Context, sqlClient SQLClient) (sql.Result, error)
  • func (b *BatchInsert) DoContextIfMax(ctx context.Context, sqlClient SQLClient) (sql.Result, error)
  • func (b *BatchInsert) EnableLock() *BatchInsert
  • func (b *BatchInsert) SetInsert(sqlInsert string) *BatchInsert
  • func (b *BatchInsert) WithMaxCount(maxCount int) *BatchInsert
• type Limit
  • func NewLimit() *Limit
  • func (l *Limit) SetMaximum(maximum uint64) *Limit
  • func (l *Limit) WriteLimit(query *strings.Builder, listParameters *protobuf.ListParameters)
• type SQLClient
• type Sorting
  • func NewSorting() *Sorting
  • func (s *Sorting) SetAscDesc(sortingsFields ...string) *Sorting
  • func (s *Sorting) SetCustom(customSortings ...string) *Sorting
  • func (s *Sorting) WriteOrderBy(query *strings.Builder, listParameters *protobuf.ListParameters)

Types

type BatchInsert

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

func NewBatchInsert

func NewBatchInsert() *BatchInsert

func (*BatchInsert) AddValues

func (b *BatchInsert) AddValues(sqlValues string, args ...interface{}) *BatchInsert

func (*BatchInsert) Count

func (b *BatchInsert) Count() int

func (*BatchInsert) DoContext

func (b *BatchInsert) DoContext(ctx context.Context, sqlClient SQLClient) (sql.Result, error)

func (*BatchInsert) DoContextIfMax

func (b *BatchInsert) DoContextIfMax(ctx context.Context, sqlClient SQLClient) (sql.Result, error)

func (*BatchInsert) EnableLock

func (b *BatchInsert) EnableLock() *BatchInsert

func (*BatchInsert) SetInsert

func (b *BatchInsert) SetInsert(sqlInsert string) *BatchInsert

func (*BatchInsert) WithMaxCount

func (b *BatchInsert) WithMaxCount(maxCount int) *BatchInsert

type Limit

type Limit struct {
	Maximum uint64
}

func NewLimit

func NewLimit() *Limit

func (*Limit) SetMaximum

func (l *Limit) SetMaximum(maximum uint64) *Limit

func (*Limit) WriteLimit

func (l *Limit) WriteLimit(query *strings.Builder, listParameters *protobuf.ListParameters)

type SQLClient

type SQLClient interface {
	ExecContext(context.Context, string, ...interface{}) (sql.Result, error)
}

type Sorting

type Sorting struct {
	AscDesc map[string]string
	Custom  map[string]string
}

func NewSorting

func NewSorting() *Sorting

func (*Sorting) SetAscDesc

func (s *Sorting) SetAscDesc(sortingsFields ...string) *Sorting

func (*Sorting) SetCustom

func (s *Sorting) SetCustom(customSortings ...string) *Sorting

func (*Sorting) WriteOrderBy

func (s *Sorting) WriteOrderBy(query *strings.Builder, listParameters *protobuf.ListParameters)