hey

package module

Go to main page

Versions in this module

v5

v5.2.0

Oct 25, 2025

Changes in this version

+ const ErrMethodNotImplemented

+ func QuickScan(rows *sql.Rows, ...) ([]map[string]any, error)

+ type AdjustColumnAnyValue func(columnTypes []*sql.ColumnType, results []map[string]any) error

type Cfg

+ MapScan MapScanner

+ type MapScanner interface

+ AdjustColumnAnyValue func(adjust AdjustColumnAnyValue) MapScanner

+ Scan func(rows *sql.Rows, adjusts ...AdjustColumnAnyValue) ([]map[string]any, error)

+ func NewMapScanner() MapScanner

type Table

+ func (s *Table) MapScan(ctx context.Context, adjusts ...AdjustColumnAnyValue) ([]map[string]any, error)

type Way

+ func (s *Way) MapScan(ctx context.Context, maker Maker, adjusts ...AdjustColumnAnyValue) (result []map[string]any, err error)

v5.1.1

Oct 19, 2025

Changes in this version

type SQLUpdateSet

+ SetNull func(column string) SQLUpdateSet

v5.1.0

Oct 18, 2025

Changes in this version

+ const StrId

+ func LikeSearch(filter Filter, value any, columns ...string)

+ func WayContext(ctx context.Context, way *Way) context.Context

+ type MyContext string

+ const MyAffectedRows

+ const MyInsertAll

+ const MyInsertData

+ const MyInsertId

+ const MyInsertOne

+ const MyInsertQuery

+ const MyTable

+ const MyTableName

+ const MyWay

+ type MyDelete interface

+ AfterDelete func(fc func(ctx context.Context) (context.Context, error))

+ AfterDeleteValue func() func(ctx context.Context) (context.Context, error)

+ BeforeDelete func(fc func(ctx context.Context) (context.Context, error))

+ BeforeDeleteValue func() func(ctx context.Context) (context.Context, error)

+ Delete func(ctx context.Context, where Filter) (affectedRows int64, err error)

+ DeleteById func(ctx context.Context, ids any) (affectedRows int64, err error)

+ DeleteFilter func(fc func(f Filter))

+ DeleteFilterValue func() func(f Filter)

+ ResetDelete func(fc func(ctx context.Context, where Filter) (affectedRows int64, err error))

+ type MyHidden interface

+ AfterHidden func(fc func(ctx context.Context) (context.Context, error))

+ AfterHiddenValue func() func(ctx context.Context) (context.Context, error)

+ BeforeHidden func(fc func(ctx context.Context) (context.Context, error))

+ BeforeHiddenValue func() func(ctx context.Context) (context.Context, error)

+ Hidden func(ctx context.Context, where Filter) (affectedRows int64, err error)

+ HiddenById func(ctx context.Context, ids any) (affectedRows int64, err error)

+ HiddenFilter func(fc func(f Filter))

+ HiddenFilterValue func() func(f Filter)

+ HiddenUpdate func(fc func(u SQLUpdateSet))

+ ResetHidden func(fc func(ctx context.Context, where Filter) (affectedRows int64, err error))

+ type MyInsert interface

+ AfterInsert func(fc func(ctx context.Context) (context.Context, error))

+ AfterInsertValue func() func(ctx context.Context) (context.Context, error)

+ BeforeInsert func(fc func(ctx context.Context) (context.Context, error))

+ BeforeInsertValue func() func(ctx context.Context) (context.Context, error)

+ InsertAll func(ctx context.Context, insert any) (affectedRows int64, err error)

+ InsertFromQuery func(ctx context.Context, columns []string, query Maker) (affectedRows int64, err error)

+ InsertOne func(ctx context.Context, insert any) (id int64, err error)

+ ResetInsertAll func(fc func(ctx context.Context, insert any) (affectedRows int64, err error))

+ ResetInsertFromQuery func(...)

+ ResetInsertOne func(fc func(ctx context.Context, insert any) (id int64, err error))

+ type MySchema interface

+ type MySelect interface

+ Columns func() []string

+ Equal func(column any, value any) Filter

+ F func() Filter

+ IdEqual func(value any) Filter

+ IdIn func(values ...any) Filter

+ In func(column any, values ...any) Filter

+ InGroup func(columns any, values any) Filter

+ LikeSearch func(keyword string, columns ...string) Filter

+ ResetSelect func(...)

+ SelectAll func(ctx context.Context, receiver any, options ...func(o *Table)) error

+ SelectAllById func(ctx context.Context, ids any, receiver any, options ...func(o *Table)) error

+ SelectCount func(ctx context.Context, options ...func(o *Table)) (count int64, err error)

+ SelectCountFetch func(ctx context.Context, receiver any, options ...func(o *Table)) (count int64, err error)

+ SelectExists func(ctx context.Context, options ...func(o *Table)) (bool, error)

+ SelectFilter func(fc func(f Filter))

+ SelectFilterValue func() func(f Filter)

+ SelectOne func(ctx context.Context, receiver any, options ...func(o *Table)) error

+ SelectOneById func(ctx context.Context, id any, receiver any, options ...func(o *Table)) error

+ SelectSQL func(options ...func(o *Table)) *SQL

+ Table func() string

+ type MyUpdate interface

+ AfterUpdate func(fc func(ctx context.Context) (context.Context, error))

+ AfterUpdateValue func() func(ctx context.Context) (context.Context, error)

+ BeforeUpdate func(fc func(ctx context.Context) (context.Context, error))

+ BeforeUpdateValue func() func(ctx context.Context) (context.Context, error)

+ Modify func(ctx context.Context, where Filter, modify any) (affectedRows int64, err error)

+ ModifyById func(ctx context.Context, id any, modify any) (affectedRows int64, err error)

+ ResetUpdate func(...)

+ Update func(ctx context.Context, where Filter, update func(u SQLUpdateSet)) (affectedRows int64, err error)

+ UpdateById func(ctx context.Context, ids any, update func(u SQLUpdateSet)) (affectedRows int64, err error)

+ UpdateFilter func(fc func(f Filter))

+ UpdateFilterValue func() func(f Filter)

type Table

+ func (s *Table) CountFetch(ctx context.Context, result any, counts ...string) (count int64, err error)

+ func (s *Table) ToCount(counts ...string) *SQL

type Way

+ func ContextWay(ctx context.Context, defaultWay *Way) *Way

+ func (s *Way) Create(ctx context.Context, table any, values any, options ...func(t *Table)) (int64, error)

+ func (s *Way) Delete(ctx context.Context, table any, column string, values any, ...) (int64, error)

+ func (s *Way) DeleteById(ctx context.Context, table any, values any, options ...func(f Filter)) (int64, error)

+ func (s *Way) MyDelete(table string) MyDelete

+ func (s *Way) MyHidden(table string, update func(u SQLUpdateSet)) MyHidden

+ func (s *Way) MyInsert(table string) MyInsert

+ func (s *Way) MySchema(table string, columns []string) MySchema

+ func (s *Way) MySelect(table string, columns []string) MySelect

+ func (s *Way) MyUpdate(table string) MyUpdate

+ func (s *Way) Update(ctx context.Context, table any, column string, value any, update any, ...) (int64, error)

+ func (s *Way) UpdateById(ctx context.Context, table any, value any, update any, ...) (int64, error)

v5.0.0

Sep 27, 2025

Changes in this version

+ const DefaultAliasNameCount

+ const ErrEmptyPrepare

+ const ErrNoRows

+ const ErrNoRowsAffected

+ const ErrTransactionIsNil

+ const Str36

+ const Str37

+ const Str39

+ const Str43

+ const Str45

+ const Str47

+ const Str63

+ const StrAll

+ const StrAnd

+ const StrAny

+ const StrAs

+ const StrAsc

+ const StrAvg

+ const StrBetween

+ const StrCase

+ const StrCoalesce

+ const StrComma

+ const StrCommaSpace

+ const StrConflict

+ const StrCount

+ const StrDefaultTag

+ const StrDelete

+ const StrDesc

+ const StrDistinct

+ const StrDo

+ const StrElse

+ const StrEmpty

+ const StrEnd

+ const StrEqual

+ const StrExcluded

+ const StrExists

+ const StrExpect

+ const StrExpectAll

+ const StrFrom

+ const StrGroupBy

+ const StrHaving

+ const StrIn

+ const StrInsert

+ const StrIntersect

+ const StrIntersectAll

+ const StrInto

+ const StrIs

+ const StrJoinInner

+ const StrJoinLeft

+ const StrJoinRight

+ const StrLeftSmallBracket

+ const StrLessThan

+ const StrLessThanEqual

+ const StrLike

+ const StrLimit

+ const StrMax

+ const StrMin

+ const StrMoreThan

+ const StrMoreThanEqual

+ const StrNot

+ const StrNotEqual

+ const StrNothing

+ const StrNull

+ const StrOffset

+ const StrOn

+ const StrOr

+ const StrOrderBy

+ const StrOver

+ const StrPartitionBy

+ const StrPlaceholder

+ const StrPoint

+ const StrRange

+ const StrRecursive

+ const StrReturning

+ const StrRightSmallBracket

+ const StrRows

+ const StrSelect

+ const StrSet

+ const StrSpace

+ const StrStar

+ const StrSum

+ const StrTableMethodName

+ const StrThen

+ const StrUnion

+ const StrUnionAll

+ const StrUpdate

+ const StrUsing

+ const StrValues

+ const StrWhen

+ const StrWhere

+ const StrWith

+ func AnyAny[T any](slice []T) []any

+ func ArrayDiscard[V any](values []V, discard func(k int, v V) bool) []V

+ func ArrayToArray[V any, W any](values []V, fc func(k int, v V) W) []W

+ func ArrayToAssoc[V any, K comparable, W any](values []V, fc func(v V) (K, W)) map[K]W

+ func AssocDiscard[K comparable, V any](values map[K]V, discard func(k K, v V) bool) map[K]V

+ func AssocToArray[K comparable, V any, W any](values map[K]V, fc func(k K, v V) W) []W

+ func AssocToAssoc[K comparable, V any, X comparable, Y any](values map[K]V, fc func(k K, v V) (X, Y)) map[X]Y

+ func DiscardDuplicate[T comparable](discard func(tmp T) bool, dynamic ...T) (result []T)

+ func DropTable(ctx context.Context, db *sql.DB, tables ...string) error

+ func ExecuteScript(ctx context.Context, db *sql.DB, execute string, args ...any) error

+ func InGroupValues[T any](values []T, fc func(tmp T) []any) [][]any

+ func InValues[T any](values []T, fc func(tmp T) any) []any

+ func LastNotEmptyString(sss []string) string

+ func MakerScanAll[V any](ctx context.Context, way *Way, maker Maker, ...) ([]*V, error)

+ func MakerScanOne[V any](ctx context.Context, way *Way, maker Maker, ...) (*V, error)

+ func MergeArray[V any](values ...[]V) []V

+ func MergeAssoc[K comparable, V any](values ...map[K]V) map[K]V

+ func MustAffectedRows(affectedRows int64, err error) error

+ func ParcelCancelPrepare(prepare string) string

+ func ParcelPrepare(prepare string) string

+ func Prefix(prefix string, name string) string

+ func RowsScan(rows *sql.Rows, result any, tag string) error

+ func SQLString(value string) string

+ func SQLToString(script *SQL) string

+ func ScanMap(rows *sql.Rows) ([]map[string]any, error)

+ func Strings(elements ...string) string

+ func StructInsert(object any, tag string, except []string, allow []string) (fields []string, values [][]any)

+ func StructModify(object any, tag string, except ...string) (fields []string, values []any)

+ func StructObtain(object any, tag string, except ...string) (fields []string, values []any)

+ func StructUpdate(origin any, latest any, tag string, except ...string) (fields []string, values []any)

+ func TruncateTable(ctx context.Context, db *sql.DB, tables ...string) error

+ type Cache struct

+ func NewCache(cacher Cacher) *Cache

+ func (s *Cache) Del(key string) error

+ func (s *Cache) DurationRange(duration time.Duration, minValue int, maxValue int) time.Duration

+ func (s *Cache) Exists(key string) (exists bool, err error)

+ func (s *Cache) Get(key string) (value []byte, exists bool, err error)

+ func (s *Cache) GetBool(key string) (value bool, exists bool, err error)

+ func (s *Cache) GetCacher() Cacher

+ func (s *Cache) GetFloat(key string) (value float64, exists bool, err error)

+ func (s *Cache) GetInt(key string) (value int64, exists bool, err error)

+ func (s *Cache) GetString(key string) (value string, exists bool, err error)

+ func (s *Cache) GetUnmarshal(key string, value any) (exists bool, err error)

+ func (s *Cache) MarshalSet(key string, value any, duration ...time.Duration) error

+ func (s *Cache) Set(key string, value []byte, duration ...time.Duration) error

+ func (s *Cache) SetBool(key string, value bool, duration ...time.Duration) error

+ func (s *Cache) SetCacher(cacher Cacher) *Cache

+ func (s *Cache) SetFloat(key string, value float64, duration ...time.Duration) error

+ func (s *Cache) SetInt(key string, value int64, duration ...time.Duration) error

+ func (s *Cache) SetString(key string, value string, duration ...time.Duration) error

+ type CacheMaker interface

+ Del func() error

+ Exists func() (exists bool, err error)

+ Get func() (value []byte, exists bool, err error)

+ GetBool func() (bool, bool, error)

+ GetCacheKey func() (string, error)

+ GetFloat func() (float64, bool, error)

+ GetInt func() (int64, bool, error)

+ GetString func() (string, bool, error)

+ GetUnmarshal func(value any) (exists bool, err error)

+ MarshalSet func(value any, duration ...time.Duration) error

+ Reset func(maker ...Maker) CacheMaker

+ Set func(value []byte, duration ...time.Duration) error

+ SetBool func(value bool, duration ...time.Duration) error

+ SetFloat func(value float64, duration ...time.Duration) error

+ SetInt func(value int64, duration ...time.Duration) error

+ SetString func(value string, duration ...time.Duration) error

+ UseCacheKey func(cacheKey func(maker Maker) (string, error)) CacheMaker

+ func NewCacheMaker(cache *Cache, maker Maker) CacheMaker

+ type Cacher interface

+ Del func(key string) error

+ Exists func(key string) (exists bool, err error)

+ Get func(key string) (value []byte, exists bool, err error)

+ Key func(key string) string

+ Marshal func(v any) ([]byte, error)

+ Set func(key string, value []byte, duration ...time.Duration) error

+ Unmarshal func(data []byte, v any) error

+ type Cfg struct

+ Debug DebugMaker

+ DeleteMustUseWhere bool

+ Manual *Manual

+ Scan func(rows *sql.Rows, result any, tag string) error

+ ScanTag string

+ TableMethodName string

+ TransactionMaxDuration time.Duration

+ TransactionOptions *sql.TxOptions

+ UpdateMustUseWhere bool

+ WarnDuration time.Duration

+ func DefaultCfg() Cfg

+ type DatabaseReader interface

+ Read func() *Way

+ func NewDatabaseReader(choose func(n int) int, reads []*Way) DatabaseReader

+ type DebugMaker interface

+ Debug func(maker Maker) DebugMaker

+ GetLogger func() *logger.Logger

+ SetLogger func(log *logger.Logger) DebugMaker

+ func NewDebugMaker() DebugMaker

+ type Err string

+ func (s Err) Error() string

+ type Filter interface

+ AllQuantifier func(fc func(q Quantifier)) Filter

+ And func(script *SQL) Filter

+ AnyQuantifier func(fc func(q Quantifier)) Filter

+ Between func(column any, start any, end any) Filter

+ CompareEqual func(column1 any, column2 any) Filter

+ CompareLessThan func(column1 any, column2 any) Filter

+ CompareLessThanEqual func(column1 any, column2 any) Filter

+ CompareMoreThan func(column1 any, column2 any) Filter

+ CompareMoreThanEqual func(column1 any, column2 any) Filter

+ CompareNotEqual func(column1 any, column2 any) Filter

+ Equal func(column any, value any, null ...bool) Filter

+ Exists func(subquery Maker) Filter

+ GetReplacer func() Replacer

+ Group func(group func(g Filter)) Filter

+ In func(column any, values ...any) Filter

+ InGroup func(columns any, values any) Filter

+ IsEmpty func() bool

+ IsNotNull func(column any) Filter

+ IsNull func(column any) Filter

+ LessThan func(column any, value any) Filter

+ LessThanEqual func(column any, value any) Filter

+ Like func(column any, value any) Filter

+ MoreThan func(column any, value any) Filter

+ MoreThanEqual func(column any, value any) Filter

+ New func(filters ...Filter) Filter

+ Not func() Filter

+ NotBetween func(column any, start any, end any) Filter

+ NotEqual func(column any, value any, null ...bool) Filter

+ NotExists func(subquery Maker) Filter

+ NotIn func(column any, values ...any) Filter

+ NotInGroup func(columns any, values any) Filter

+ NotLike func(column any, value any) Filter

+ Num func() int

+ Or func(script *SQL) Filter

+ OrGroup func(group func(g Filter)) Filter

+ SetReplacer func(replacer Replacer) Filter

+ ToEmpty func() Filter

+ Use func(filters ...Filter) Filter

+ func F() Filter

+ func ParcelFilter(tmp Filter) Filter

+ type Limiter interface

+ GetLimit func() int64

+ GetOffset func() int64

+ type Maker interface

+ ToSQL func() *SQL

+ func JoinMaker(separator string, makers ...Maker) Maker

+ type Manual struct

+ Prepare func(prepare string) string

+ Replacer Replacer

+ func Mysql() *Manual

+ func Postgresql() *Manual

+ func Sqlite() *Manual

+ type MinMaxDuration struct

+ func NewMinMaxDuration(duration time.Duration, minValue int, maxValue int) *MinMaxDuration

+ func (s *MinMaxDuration) Get() time.Duration

+ type Quantifier interface

+ Equal func(column any, subquery Maker) Quantifier

+ GetQuantifier func() string

+ LessThan func(column any, subquery Maker) Quantifier

+ LessThanEqual func(column any, subquery Maker) Quantifier

+ MoreThan func(column any, subquery Maker) Quantifier

+ MoreThanEqual func(column any, subquery Maker) Quantifier

+ NotEqual func(column any, subquery Maker) Quantifier

+ SetQuantifier func(quantifierString string) Quantifier

+ type Replacer interface

+ Del func(key string) Replacer

+ Get func(key string) string

+ GetAll func(keys []string) []string

+ Map func() map[string]string

+ Set func(key string, value string) Replacer

+ func NewReplacer() Replacer

+ type RowsScanMakeSliceLength string

+ const MakerScanAllMakeSliceLength

+ type SQL struct

+ Args []any

+ Prepare string

+ func Avg(values ...any) *SQL

+ func Coalesce(values ...any) *SQL

+ func CopySQL(src *SQL) (dst *SQL)

+ func Count(values ...any) *SQL

+ func ExceptAllSQL(scripts ...*SQL) *SQL

+ func ExceptSQL(scripts ...*SQL) *SQL

+ func FuncSQL(funcName string, funcArgs ...any) *SQL

+ func IntersectAllSQL(scripts ...*SQL) *SQL

+ func IntersectSQL(scripts ...*SQL) *SQL

+ func JoinSQL(separator string, values ...any) *SQL

+ func JoinSQLComma(values ...any) *SQL

+ func JoinSQLCommaSpace(values ...any) *SQL

+ func JoinSQLEmpty(values ...any) *SQL

+ func JoinSQLSpace(values ...any) *SQL

+ func Max(values ...any) *SQL

+ func Min(values ...any) *SQL

+ func NewEmptySQL() *SQL

+ func NewSQL(prepare string, args ...any) *SQL

+ func ParcelCancelSQL(script *SQL) *SQL

+ func ParcelSQL(script *SQL) *SQL

+ func Sum(values ...any) *SQL

+ func UnionAllSQL(scripts ...*SQL) *SQL

+ func UnionSQL(scripts ...*SQL) *SQL

+ func (s *SQL) Copy() *SQL

+ func (s *SQL) IsEmpty() bool

+ func (s *SQL) ToEmpty() *SQL

+ func (s *SQL) ToSQL() *SQL

+ type SQLAlias interface

+ GetAlias func() string

+ GetSQL func() *SQL

+ IsEmpty func() bool

+ SetAlias func(alias string) SQLAlias

+ SetSQL func(script any) SQLAlias

+ ToEmpty func() SQLAlias

+ func Alias(script any, aliases ...string) SQLAlias

+ type SQLCase interface

+ Alias func(alias string) SQLCase

+ Case func(value any) SQLCase

+ Else func(value any) SQLCase

+ WhenThen func(when, then any) SQLCase

+ func NewSQLCase(way *Way) SQLCase

+ type SQLComment interface

+ Comment func(comment string) SQLComment

+ type SQLGroupBy interface

+ Group func(group ...any) SQLGroupBy

+ Having func(having func(having Filter)) SQLGroupBy

+ type SQLInsert interface

+ Column func(columns ...string) SQLInsert

+ ColumnValue func(column string, value any) SQLInsert

+ Create func(create any) SQLInsert

+ Default func(column string, value any) SQLInsert

+ Forbid func(columns ...string) SQLInsert

+ GetColumn func(excludes ...string) []string

+ GetForbid func() []string

+ OnConflict func(fc func(o SQLOnConflict)) SQLInsert

+ Remove func(columns ...string) SQLInsert

+ Returning func(fc func(r SQLReturning)) SQLInsert

+ Select func(columns ...string) SQLInsert

+ Subquery func(subquery Maker) SQLInsert

+ Table func(table Maker) SQLInsert

+ Values func(values ...[]any) SQLInsert

+ type SQLJoin interface

+ GetTable func() SQLAlias

+ InnerJoin func(table1 SQLAlias, table2 SQLAlias, on SQLJoinAssoc) SQLJoin

+ Join func(joinType string, table1 SQLAlias, table2 SQLAlias, on SQLJoinAssoc) SQLJoin

+ LeftJoin func(table1 SQLAlias, table2 SQLAlias, on SQLJoinAssoc) SQLJoin

+ On func(on func(on SQLJoinOn, table1alias string, table2alias string)) SQLJoinAssoc

+ OnEqual func(table1column string, table2column string) SQLJoinAssoc

+ Prefix func(prefix SQLAlias, column string, aliases ...string) string

+ PrefixSelect func(prefix SQLAlias, columns ...string) SQLJoin

+ RightJoin func(table1 SQLAlias, table2 SQLAlias, on SQLJoinAssoc) SQLJoin

+ Select func(columns ...any) SQLJoin

+ SetTable func(table SQLAlias) SQLJoin

+ Table func(table any, alias string) SQLAlias

+ Using func(columns ...string) SQLJoinAssoc

+ type SQLJoinAssoc func(table1alias string, table2alias string) SQLJoinOn

+ type SQLJoinOn interface

+ Equal func(table1alias string, table1column string, table2alias string, ...) SQLJoinOn

+ On func(on func(f Filter)) SQLJoinOn

+ Using func(columns ...string) SQLJoinOn

+ type SQLLimit interface

+ Limit func(limit int64) SQLLimit

+ Offset func(offset int64) SQLLimit

+ Page func(page int64, limit ...int64) SQLLimit

+ type SQLOnConflict interface

+ Do func(maker Maker) SQLOnConflict

+ DoUpdateSet func(fc func(u SQLOnConflictUpdateSet)) SQLOnConflict

+ OnConflict func(onConflicts ...string) SQLOnConflict

+ type SQLOnConflictUpdateSet interface

+ Excluded func(columns ...string) SQLOnConflictUpdateSet

+ type SQLOrderBy interface

+ Asc func(columns ...string) SQLOrderBy

+ Desc func(columns ...string) SQLOrderBy

+ type SQLReturning interface

+ Execute func(...) SQLReturning

+ Prepare func(prepare func(tmp *SQL)) SQLReturning

+ Returning func(columns ...string) SQLReturning

+ type SQLSelect interface

+ Add func(maker Maker) SQLSelect

+ Del func(columns ...string) SQLSelect

+ Distinct func() SQLSelect

+ Get func() (columns []string, args map[int][]any)

+ Has func(column string) bool

+ IsEmpty func() bool

+ Len func() int

+ Select func(columns ...any) SQLSelect

+ Set func(columns []string, args map[int][]any) SQLSelect

+ type SQLUpdateSet interface

+ Assign func(dst string, src string) SQLUpdateSet

+ Compare func(old, new any, except ...string) SQLUpdateSet

+ Decr func(column string, decr any) SQLUpdateSet

+ Default func(column string, value any) SQLUpdateSet

+ Forbid func(columns ...string) SQLUpdateSet

+ GetForbid func() []string

+ GetUpdate func() ([]string, [][]any)

+ Incr func(column string, incr any) SQLUpdateSet

+ Len func() int

+ Remove func(columns ...string) SQLUpdateSet

+ Select func(columns ...string) SQLUpdateSet

+ Set func(column string, value any) SQLUpdateSet

+ SetMap func(columnValue map[string]any) SQLUpdateSet

+ SetSlice func(columns []string, values []any) SQLUpdateSet

+ SetUpdate func(updates []string, params [][]any) SQLUpdateSet

+ Update func(update any) SQLUpdateSet

+ type SQLValues interface

+ IsEmpty func() bool

+ Subquery func(subquery Maker) SQLValues

+ Values func(values ...[]any) SQLValues

+ type SQLWindowFuncFrame interface

+ Between func(fc func(ff SQLWindowFuncFrame) (*SQL, *SQL)) SQLWindowFuncFrame

+ CurrentRow func() *SQL

+ NFollowing func(n int) *SQL

+ NPreceding func(n int) *SQL

+ SQL func(value any) SQLWindowFuncFrame

+ UnboundedFollowing func() *SQL

+ UnboundedPreceding func() *SQL

+ func NewSQLWindowFuncFrame(frame string) SQLWindowFuncFrame

+ type SQLWith interface

+ Del func(alias string) SQLWith

+ Recursive func() SQLWith

+ Set func(alias string, maker Maker, columns ...string) SQLWith

+ type Stmt struct

+ func (s *Stmt) Close() (err error)

+ func (s *Stmt) Exec(ctx context.Context, args ...any) (sql.Result, error)

+ func (s *Stmt) Execute(ctx context.Context, args ...any) (int64, error)

+ func (s *Stmt) Fetch(ctx context.Context, result any, args ...any) error

+ func (s *Stmt) Query(ctx context.Context, query func(rows *sql.Rows) error, args ...any) error

+ func (s *Stmt) QueryRow(ctx context.Context, query func(row *sql.Row) error, args ...any) error

+ type StringMutex struct

+ func NewStringMutex(length int) *StringMutex

+ func (s *StringMutex) Get(key string) *sync.Mutex

+ func (s *StringMutex) Len() int

+ type Table struct

+ func (s *Table) Alias(alias string) *Table

+ func (s *Table) Asc(column string) *Table

+ func (s *Table) Comment(comment string) *Table

+ func (s *Table) Count(ctx context.Context, counts ...string) (int64, error)

+ func (s *Table) Create(ctx context.Context, create any) (int64, error)

+ func (s *Table) Delete(ctx context.Context) (int64, error)

+ func (s *Table) Desc(column string) *Table

+ func (s *Table) Distinct() *Table

+ func (s *Table) F(filters ...Filter) Filter

+ func (s *Table) Fetch(ctx context.Context, result any) error

+ func (s *Table) GROUP(fc func(g SQLGroupBy)) *Table

+ func (s *Table) Group(groups ...any) *Table

+ func (s *Table) HAVING(fc func(h Filter)) *Table

+ func (s *Table) Having(filters ...Filter) *Table

+ func (s *Table) INSERT(fc func(i SQLInsert)) *Table

+ func (s *Table) InnerJoin(fc func(j SQLJoin) (left SQLAlias, right SQLAlias, assoc SQLJoinAssoc)) *Table

+ func (s *Table) Insert(ctx context.Context) (int64, error)

+ func (s *Table) JOIN(fc func(j SQLJoin)) *Table

+ func (s *Table) LIMIT(fc func(o SQLLimit)) *Table

+ func (s *Table) LeftJoin(fc func(j SQLJoin) (left SQLAlias, right SQLAlias, assoc SQLJoinAssoc)) *Table

+ func (s *Table) Limit(limit int64) *Table

+ func (s *Table) Limiter(limiter Limiter) *Table

+ func (s *Table) Modify(ctx context.Context, modify any) (int64, error)

+ func (s *Table) ORDER(fc func(o SQLOrderBy)) *Table

+ func (s *Table) Offset(offset int64) *Table

+ func (s *Table) Page(page int64, limit ...int64) *Table

+ func (s *Table) Query(ctx context.Context, query func(rows *sql.Rows) error) error

+ func (s *Table) RightJoin(fc func(j SQLJoin) (left SQLAlias, right SQLAlias, assoc SQLJoinAssoc)) *Table

+ func (s *Table) SELECT(fc func(q SQLSelect)) *Table

+ func (s *Table) Select(selects ...any) *Table

+ func (s *Table) TABLE(fc func(t SQLAlias)) *Table

+ func (s *Table) Table(table any) *Table

+ func (s *Table) ToDelete() *SQL

+ func (s *Table) ToEmpty() *Table

+ func (s *Table) ToInsert() *SQL

+ func (s *Table) ToSQL() *SQL

+ func (s *Table) ToSelect() *SQL

+ func (s *Table) ToUpdate() *SQL

+ func (s *Table) UPDATE(fc func(f Filter, u SQLUpdateSet)) *Table

+ func (s *Table) Update(ctx context.Context) (int64, error)

+ func (s *Table) V(values ...*Way) *Table

+ func (s *Table) W() *Way

+ func (s *Table) WHERE(fc func(f Filter)) *Table

+ func (s *Table) WITH(fc func(w SQLWith)) *Table

+ func (s *Table) Where(filters ...Filter) *Table

+ func (s *Table) With(alias string, maker Maker, columns ...string) *Table

+ type TableColumn struct

+ func NewTableColumn(way *Way, aliases ...string) *TableColumn

+ func (s *TableColumn) AVG(column string, aliases ...string) string

+ func (s *TableColumn) Adjust(adjust func(column string) string, columns ...string) []string

+ func (s *TableColumn) Alias() string

+ func (s *TableColumn) Avg(column string, aliases ...string) string

+ func (s *TableColumn) Column(column string, aliases ...string) string

+ func (s *TableColumn) ColumnAll(columns ...string) []string

+ func (s *TableColumn) Count(counts ...string) string

+ func (s *TableColumn) MAX(column string, aliases ...string) string

+ func (s *TableColumn) MIN(column string, aliases ...string) string

+ func (s *TableColumn) Max(column string, aliases ...string) string

+ func (s *TableColumn) Min(column string, aliases ...string) string

+ func (s *TableColumn) SUM(column string, aliases ...string) string

+ func (s *TableColumn) SetAlias(alias string) *TableColumn

+ func (s *TableColumn) Sum(column string, aliases ...string) string

+ type TableNamer interface

+ Table func() string

+ type ToEmpty interface

+ ToEmpty func()

+ type Way struct

+ func NewWay(db *sql.DB) *Way

+ func (s *Way) Alias(script any, aliases ...string) SQLAlias

+ func (s *Way) Begin(ctx context.Context, opts ...*sql.TxOptions) (*Way, error)

+ func (s *Way) BeginConn(ctx context.Context, conn *sql.Conn, opts ...*sql.TxOptions) (*Way, error)

+ func (s *Way) Case() SQLCase

+ func (s *Way) Commit() error

+ func (s *Way) Debug(maker Maker) *Way

+ func (s *Way) Exec(ctx context.Context, maker Maker) (sql.Result, error)

+ func (s *Way) Execute(ctx context.Context, maker Maker) (int64, error)

+ func (s *Way) F(filters ...Filter) Filter

+ func (s *Way) Fetch(ctx context.Context, maker Maker, result any) error

+ func (s *Way) Func(funcName string, funcArgs ...any) *SQL

+ func (s *Way) GetCfg() *Cfg

+ func (s *Way) GetDatabase() *sql.DB

+ func (s *Way) GetDatabaseReader() DatabaseReader

+ func (s *Way) GetLogger() *logger.Logger

+ func (s *Way) IsInTransaction() bool

+ func (s *Way) IsRead() bool

+ func (s *Way) MultiExecute(ctx context.Context, makers []Maker) (affectedRows int64, err error)

+ func (s *Way) MultiFetch(ctx context.Context, makers []Maker, results []any) (err error)

+ func (s *Way) MultiStmtExecute(ctx context.Context, prepare string, lists [][]any) (affectedRows int64, err error)

+ func (s *Way) MultiStmtFetch(ctx context.Context, prepare string, lists [][]any, results []any) (err error)

+ func (s *Way) Now() time.Time

+ func (s *Way) Prepare(ctx context.Context, prepare string) (stmt *Stmt, err error)

+ func (s *Way) Query(ctx context.Context, maker Maker, query func(rows *sql.Rows) error) error

+ func (s *Way) QueryRow(ctx context.Context, maker Maker, query func(row *sql.Row) error) error

+ func (s *Way) Read() *Way

+ func (s *Way) Replace(key string) string

+ func (s *Way) ReplaceAll(keys []string) []string

+ func (s *Way) Rollback() error

+ func (s *Way) SetCfg(cfg *Cfg) *Way

+ func (s *Way) SetDatabase(db *sql.DB) *Way

+ func (s *Way) SetDatabaseReader(reader DatabaseReader) *Way

+ func (s *Way) SetLogger(log *logger.Logger) *Way

+ func (s *Way) T() *TableColumn

+ func (s *Way) Table(table any) *Table

+ func (s *Way) Transaction(ctx context.Context, fc func(tx *Way) error, opts ...*sql.TxOptions) error

+ func (s *Way) TransactionMessage(message string) *Way

+ func (s *Way) TransactionNew(ctx context.Context, fc func(tx *Way) error, opts ...*sql.TxOptions) error

+ func (s *Way) TransactionRetry(ctx context.Context, retries int, fc func(tx *Way) error, ...) (err error)

+ func (s *Way) V(values ...*Way) *Way

+ func (s *Way) WindowFunc(alias string) *WindowFunc

+ type WindowFunc struct

+ func NewWindowFunc(way *Way, aliases ...string) *WindowFunc

+ func (s *WindowFunc) Alias(alias string) *WindowFunc

+ func (s *WindowFunc) Asc(column string) *WindowFunc

+ func (s *WindowFunc) Avg(column string) *WindowFunc

+ func (s *WindowFunc) Count(columns ...string) *WindowFunc

+ func (s *WindowFunc) CumeDist() *WindowFunc

+ func (s *WindowFunc) DenseRank() *WindowFunc

+ func (s *WindowFunc) Desc(column string) *WindowFunc

+ func (s *WindowFunc) FirstValue(column string) *WindowFunc

+ func (s *WindowFunc) Lag(column string, args ...any) *WindowFunc

+ func (s *WindowFunc) LastValue(column string) *WindowFunc

+ func (s *WindowFunc) Lead(column string, args ...any) *WindowFunc

+ func (s *WindowFunc) Max(column string) *WindowFunc

+ func (s *WindowFunc) Min(column string) *WindowFunc

+ func (s *WindowFunc) NTile(buckets int64, args ...any) *WindowFunc

+ func (s *WindowFunc) NthValue(column string, args ...any) *WindowFunc

+ func (s *WindowFunc) Partition(column ...string) *WindowFunc

+ func (s *WindowFunc) PercentRank() *WindowFunc

+ func (s *WindowFunc) Range(fc func(frame SQLWindowFuncFrame)) *WindowFunc

+ func (s *WindowFunc) Rank() *WindowFunc

+ func (s *WindowFunc) RowNumber() *WindowFunc

+ func (s *WindowFunc) Rows(fc func(frame SQLWindowFuncFrame)) *WindowFunc

+ func (s *WindowFunc) Sum(column string) *WindowFunc

+ func (s *WindowFunc) ToSQL() *SQL

+ func (s *WindowFunc) Window(funcName string, funcArgs ...any) *WindowFunc

Other modules containing this package

github.com/cd365/hey

github.com/cd365/hey/v2

github.com/cd365/hey/v3

github.com/cd365/hey/v6

github.com/cd365/hey/v7

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL