hey

package module

Go to main page

Versions in this module

v1

v1.4.0

Aug 27, 2024

Changes in this version

+ const SqlAll

+ const SqlAny

+ const SqlDistinct

+ const SqlExpect

+ const SqlGreaterThan

+ const SqlGreaterThanEqual

+ const SqlIntersect

+ const SqlJoinCross

+ const SqlLeftSmallBracket

+ const SqlNot

+ const SqlRightSmallBracket

+ func BuildCount(s *Get, countColumns ...string) (prepare string, args []interface{})

+ func BuildGet(s *Get) (prepare string, args []interface{})

+ func BuildOrderByLimitOffset(s *Get) (prepare string)

+ func BuildTable(s *Get) (prepare string, args []interface{})

+ func BuildUnion(withs []*GetWith, unionType string, gets []*Get) (prepare string, args []interface{})

+ func BuildWith(withs []*GetWith) (prepare string, args []interface{})

+ func EqualAll(f Filter, column string, subquery *Get)

+ func EqualAny(f Filter, column string, subquery *Get)

+ func ExpectGet(gets ...*Get) (prepare string, args []interface{})

+ func GetCount(get *Get, countColumns ...string) (count int64, err error)

+ func GetCountGet(get *Get, result interface{}, countColumn ...string) (int64, error)

+ func GetCountQuery(get *Get, query func(rows *sql.Rows) (err error), countColumn ...string) (int64, error)

+ func GetExists(get *Get) (exists bool, err error)

+ func GetGet(get *Get, result interface{}) error

+ func GetQuery(get *Get, query func(rows *sql.Rows) (err error)) error

+ func GetScanAll(get *Get, fc func(rows *sql.Rows) error) error

+ func GetScanOne(get *Get, dest ...interface{}) error

+ func GetViewMap(get *Get) (result []map[string]interface{}, err error)

+ func GreaterThanAll(f Filter, column string, subquery *Get)

+ func GreaterThanAny(f Filter, column string, subquery *Get)

+ func GreaterThanEqualAll(f Filter, column string, subquery *Get)

+ func GreaterThanEqualAny(f Filter, column string, subquery *Get)

+ func IntersectGet(gets ...*Get) (prepare string, args []interface{})

+ func LessThanAll(f Filter, column string, subquery *Get)

+ func LessThanAny(f Filter, column string, subquery *Get)

+ func LessThanEqualAll(f Filter, column string, subquery *Get)

+ func LessThanEqualAny(f Filter, column string, subquery *Get)

+ func NotEqualAll(f Filter, column string, subquery *Get)

+ func NotEqualAny(f Filter, column string, subquery *Get)

+ func PrefixColumn(table string, column ...string) []string

+ func PutCase(i *Case)

+ func PutFilter(f Filter)

+ func PutIdent(i *Ident)

type Add

+ func (s *Add) Default(fc func(o *Add)) *Add

+ func (s *Add) Permit(permit ...string) *Add

+ type Case struct

+ func GetCase() *Case

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

+ func (s *Case) Else(elseExpr string, elseArgs ...interface{}) *Case

+ func (s *Case) If(when func(f Filter), then string, thenArgs ...interface{}) *Case

+ func (s *Case) SQL() (prepare string, args []interface{})

type Filter

+ func GetFilter() Filter

+ Clean func() Filter

+ ExistsGet func(get *Get) Filter

+ GreaterThan func(column string, value interface{}) Filter

+ GreaterThanEqual func(column string, value interface{}) Filter

+ InColsSql func(columns []string, prepare string, args ...interface{}) Filter

+ InSql func(column string, prepare string, args ...interface{}) Filter

+ New func(fs ...Filter) Filter

+ Not func() Filter

+ Use func(fs ...Filter) Filter

type Get

+ func (s *Get) AddColCase(caseList ...func(c *Case)) *Get

+ func (s *Get) CrossJoin(fs ...func(j *GetJoin)) *Get

+ func (s *Get) Distinct(distinct bool) *Get

+ func (s *Get) Raw(prepare string, args []interface{}) *Get

type GetJoin

+ func CrossJoin(table ...string) *GetJoin

+ type GetWith struct

+ func NewWith() *GetWith

+ func (s *GetWith) Recursive(recursive bool) *GetWith

+ func (s *GetWith) SQL() (prepare string, args []interface{})

+ func (s *GetWith) With(alias string, prepare string, args []interface{}) *GetWith

+ func (s *GetWith) WithGet(alias string, get *Get) *GetWith

type Ident

+ func GetIdent(alias ...string) *Ident

type Mod

+ func (s *Mod) Default(fc func(o *Mod)) *Mod

+ func (s *Mod) Permit(permit ...string) *Mod

+ func (s *Mod) SetCase(field string, value func(c *Case)) *Mod

type Way

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

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

+ func (s *Way) Commit() error

+ func (s *Way) Rollback() error

v1.3.4

Aug 9, 2024

v1.3.3

Aug 8, 2024

Changes in this version

+ type LogSQL struct

+ Args *LogArgs

+ Error error

+ Prepare string

+ TxId string

+ TxMsg string

+ type LogTrans struct

+ EndAt time.Time

+ Error error

+ StartAt time.Time

+ State string

+ TxId string

+ TxMsg string

type PrepareArgs

+ Args []interface{}

+ Prepare string

v1.3.2

Aug 7, 2024

Changes in this version

+ func MakeCacheQueryMutexIndex(key string, length int) int

+ type CacheQuery interface

+ Exist func(ctx context.Context, key string) (exists bool, err error)

+ Flush func(ctx context.Context) error

+ Get func(ctx context.Context, key string) (value interface{}, exists bool, err error)

+ Mutex func(key string) sync.Locker

+ Remove func(ctx context.Context, key string) error

+ Set func(ctx context.Context, key string, value interface{}) error

+ SetTtl func(ctx context.Context, key string, value interface{}, ttl time.Duration) error

v1.3.1

Jul 2, 2024

Changes in this version

+ type Args struct

+ Args []interface{}

+ EndAt time.Time

+ StartAt time.Time

+ type CacheValue struct

+ UnixMilli int64

+ Value interface{}

type Filter

+ IsEmpty func() bool

type Get

+ func (s *Get) Exists() (exists bool, err error)

type GetJoin

+ func (s *GetJoin) Column(column ...string) *GetJoin

+ func (s *GetJoin) GetColumn() []string

type Ident

+ func (s *Ident) Field(field ...string) []string

+ type SQL struct

+ Args *Args

+ Error error

+ Prepare string

+ TxId string

+ TxMsg string

+ type Trans struct

+ EndAt time.Time

+ Error error

+ StartAt time.Time

+ State string

+ TxId string

+ TxMsg string

+ type WindowFunc struct

+ func NewWindowFunc(alias ...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(column string) *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, offset int64, defaultValue any) *WindowFunc

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

+ func (s *WindowFunc) Lead(column string, offset int64, defaultValue any) *WindowFunc

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

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

+ func (s *WindowFunc) NthValue(column string, LineNumber int64) *WindowFunc

+ func (s *WindowFunc) Ntile(buckets int64) *WindowFunc

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

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

+ func (s *WindowFunc) Result() string

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

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

+ func (s *WindowFunc) WindowFrame(windowFrame string) *WindowFunc

+ func (s *WindowFunc) WithFunc(withFunc string) *WindowFunc

v1.3.0

Jun 7, 2024

Changes in this version

+ func PrepareString(prepare string, args []interface{}) string

+ func ScanAll(rows *sql.Rows, fc func(rows *sql.Rows) error) (err error)

+ func ScanOne(rows *sql.Rows, dest ...interface{}) error

+ func ScanViewMap(rows *sql.Rows) ([]map[string]interface{}, error)

+ type Commander interface

+ SQL func() (prepare string, args []interface{})

type Get

+ func (s *Get) ScanAll(fc func(rows *sql.Rows) error) error

+ func (s *Get) ScanOne(dest ...interface{}) error

+ func (s *Get) ViewMap() (result []map[string]interface{}, err error)

type Opts

+ func WithReader(reader Reader) Opts

+ func WithScan(scan func(rows *sql.Rows, result interface{}, tag string) error) Opts

+ type Reader interface

+ Read func() *Way

+ func NewReader(choose func(n int) int, reads []*Way) Reader

type Stmt

+ func (s *Stmt) TakeAll(result interface{}, args ...interface{}) error

+ func (s *Stmt) TakeAllContext(ctx context.Context, result interface{}, args ...interface{}) error

+ type TxArgs struct

+ Conn *sql.Conn

+ Opts *sql.TxOptions

+ Times int

type Way

+ func (s *Way) IsRead() bool

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

+ func (s *Way) ScanOne(rows *sql.Rows, dest ...interface{}) error

+ func (s *Way) TakeAll(result interface{}, prepare string, args ...interface{}) error

+ func (s *Way) TakeAllContext(ctx context.Context, result interface{}, prepare string, args ...interface{}) error

v1.2.2

Jun 4, 2024

Changes in this version

+ func Md5(text []byte) string

+ func Sha256(text []byte) string

+ type Cache interface

+ DelCtx func(ctx context.Context, key string) error

+ GetCtx func(ctx context.Context, key string) (value interface{}, exists bool, err error)

+ Locker func(key string) sync.Locker

+ SetCtx func(ctx context.Context, key string, value interface{}, duration ...time.Duration) error

+ func NewCache(lockers int, del func(ctx context.Context, key string) error, ...) Cache

type Get

+ func (s *Get) Cache(key string, duration time.Duration) *Get

type Opts

+ func WithCache(cache Cache) Opts

type Way

+ func (s *Way) Cache() Cache

v1.2.1

May 27, 2024

Changes in this version

type Add

+ func (s *Add) Returning(fc func(row *sql.Row) error, returning ...string) error

+ func (s *Add) UseResult(fc func(result sql.Result) error) *Add

type Stmt

+ func (s *Stmt) Execute(args ...interface{}) (sql.Result, error)

+ func (s *Stmt) ExecuteContext(ctx context.Context, args ...interface{}) (result sql.Result, err error)

+ func (s *Stmt) QueryRow(ctx context.Context, query func(rows *sql.Row) error, args ...interface{}) (err error)

+ func (s *Stmt) QueryRowContext(ctx context.Context, query func(rows *sql.Row) error, args ...interface{}) (err error)

type Way

+ func (s *Way) Execute(prepare string, args ...interface{}) (sql.Result, error)

+ func (s *Way) ExecuteContext(ctx context.Context, prepare string, args ...interface{}) (sql.Result, error)

+ func (s *Way) QueryRow(query func(row *sql.Row) error, prepare string, args ...interface{}) error

+ func (s *Way) QueryRowContext(ctx context.Context, query func(row *sql.Row) error, prepare string, ...) error

v1.2.0

Apr 28, 2024

Changes in this version

+ const AliasA

+ const AliasB

+ const AliasC

+ const AliasD

+ const AliasE

+ const AliasF

+ const AliasG

+ const EmptyString

+ const Id

+ const SqlAnd

+ const SqlAvg

+ const SqlCount

+ const SqlDollar

+ const SqlEqual

+ const SqlGreater

+ const SqlGreaterEqual

+ const SqlLessThan

+ const SqlLessThanEqual

+ const SqlMax

+ const SqlMin

+ const SqlNotEqual

+ const SqlNull

+ const SqlOr

+ const SqlPlaceholder

+ const SqlPoint

+ const SqlSpace

+ const SqlStar

+ const SqlSum

+ const State0

+ const State1

+ const StateNo

+ const StateOff

+ const StateOn

+ const StateYes

+ var ErrNoAffectedRows = errors.New("hey: there are no affected rows")

+ func EvenSlice2Map[K MapKey](elems ...K) map[K]K

+ func MergeMap[K MapKey, V interface{}](elems ...map[K]V) map[K]V

+ func MergeSlice[V interface{}](elems ...[]V) []V

+ func MustAffectedRows(affectedRows int64, err error) error

+ func Slice2MapNewKey[K MapKey](elems []K, createKey func(v K) K) map[K]K

+ func Slice2MapNewVal[K MapKey, V interface{}](elems []K, createValue func(v K) V) map[K]V

+ func SliceIter[V interface{}](iter func(v V) V, elems []V) []V

+ func SliceMatchMap[K MapKey, X interface{}, Y interface{}](kx map[K]X, handle func(x X, y Y), key func(y Y) K, elems []Y)

type Add

+ func (s *Add) Way() *Way

type Del

+ func (s *Del) F(filter ...Filter) Filter

+ func (s *Del) Way() *Way

type Filter

+ func F() Filter

type Get

+ func (s *Get) F(filter ...Filter) Filter

+ func (s *Get) Way() *Way

+ type Ident struct

+ func (s *Ident) AVG(field string) string

+ func (s *Ident) Avg(field string, alias ...string) string

+ func (s *Ident) COUNT(field string, alias ...string) string

+ func (s *Ident) MAX(field string) string

+ func (s *Ident) MIN(field string) string

+ func (s *Ident) Max(field string, alias ...string) string

+ func (s *Ident) Min(field string, alias ...string) string

+ func (s *Ident) SUM(field string) string

+ func (s *Ident) Sum(field string, alias ...string) string

+ func (s *Ident) V(sss ...string) string

+ type MapKey interface

type Mod

+ func (s *Mod) F(filter ...Filter) Filter

+ func (s *Mod) Way() *Way

type Way

+ func (s *Way) AliasA() *Ident

+ func (s *Way) AliasB() *Ident

+ func (s *Way) AliasC() *Ident

+ func (s *Way) AliasD() *Ident

+ func (s *Way) AliasE() *Ident

+ func (s *Way) AliasF() *Ident

+ func (s *Way) AliasG() *Ident

+ func (s *Way) Ident(prefix ...string) *Ident

v1.1.4

Apr 7, 2024

v1.1.3

Mar 20, 2024

Changes in this version

type Way

+ func (s *Way) Tx(fc func(tx *Way) error, conn ...*sql.Conn) error

+ func (s *Way) TxCtx(ctx context.Context, fc func(tx *Way) error, conn ...*sql.Conn) error

v1.1.2

Feb 22, 2024

Changes in this version

+ func SliceAny121(values ...interface{}) []interface

v1.1.1

Feb 18, 2024

Changes in this version

+ func RemoveSliceMemberByIndex[...](indexList []int, elementList []T) []T

+ func ValuesInGroup[...](values ...[]T) [][]interface

+ func ValuesIn[...](values ...T) []interface

v1.1.0

Feb 3, 2024

Changes in this version

+ const Dollar

+ const Point

+ const SqlUnion

+ const SqlUnionAll

+ var DefaultConfig = &Config

+ var DefaultPgsql = &Pgsql

+ func ArgString(i interface{}) string

+ func BasicTypeValue(value interface{}) interface

+ func ConcatString(sss ...string) string

+ func LastNotEmptyString(sss []string) string

+ func PrepareArgs(prepare string, args []interface{}) string

+ func RemoveDuplicates[...](dynamic ...T) (result []T)

+ func RowsNext(rows *sql.Rows, fc func() error) (err error)

+ func RowsNextRow(rows *sql.Rows, dest ...interface{}) error

+ func SqlAlias(name string, alias string) string

+ func SqlPrefix(prefix string, name string) string

+ func StructObtain(object interface{}, tag string, except ...string) (fields []string, values []interface{})

type Add

+ func (s *Add) DefaultFieldValue(field string, value interface{}) *Add

+ func (s *Add) FieldValue(field string, value interface{}) *Add

+ func (s *Add) Fields(fields []string) *Add

+ func (s *Add) FieldsValues(fields []string, values [][]interface{}) *Add

+ func (s *Add) OnConflict(prepare string, args []interface{}) *Add

+ type Caller interface

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ type Config struct

+ DeleteMustUseWhere bool

+ UpdateMustUseWhere bool

type Filter

+ Copy func(filter ...Filter) Filter

+ Exists func(fc func() (prepare string, args []interface{})) Filter

+ Greater func(column string, value interface{}) Filter

+ GreaterEqual func(column string, value interface{}) Filter

+ InCols func(columns []string, values ...[]interface{}) Filter

+ InColsGet func(columns []string, preparer Preparer) Filter

+ InColsQuery func(columns []string, fc func() (prepare string, args []interface{})) Filter

+ InGet func(column string, preparer Preparer) Filter

+ InInt func(column string, values []int) Filter

+ InInt64 func(column string, values []int64) Filter

+ InQuery func(column string, fc func() (prepare string, args []interface{})) Filter

+ InString func(column string, values []string) Filter

+ NotExists func(fc func() (prepare string, args []interface{})) Filter

+ NotInCols func(columns []string, values ...[]interface{}) Filter

+ NotInColsGet func(columns []string, preparer Preparer) Filter

+ NotInColsQuery func(columns []string, fc func() (prepare string, args []interface{})) Filter

+ NotInGet func(column string, preparer Preparer) Filter

+ NotInInt func(column string, values []int) Filter

+ NotInInt64 func(column string, values []int64) Filter

+ NotInQuery func(column string, fc func() (prepare string, args []interface{})) Filter

+ NotInString func(column string, values []string) Filter

+ OrExists func(fc func() (prepare string, args []interface{})) Filter

+ OrGreater func(column string, value interface{}) Filter

+ OrGreaterEqual func(column string, value interface{}) Filter

+ OrInCols func(columns []string, values ...[]interface{}) Filter

+ OrInColsGet func(columns []string, preparer Preparer) Filter

+ OrInColsQuery func(columns []string, fc func() (prepare string, args []interface{})) Filter

+ OrInGet func(column string, preparer Preparer) Filter

+ OrInInt func(column string, values []int) Filter

+ OrInInt64 func(column string, values []int64) Filter

+ OrInQuery func(column string, fc func() (prepare string, args []interface{})) Filter

+ OrInString func(column string, values []string) Filter

+ OrNotExists func(fc func() (prepare string, args []interface{})) Filter

+ OrNotInCols func(columns []string, values ...[]interface{}) Filter

+ OrNotInColsGet func(columns []string, preparer Preparer) Filter

+ OrNotInColsQuery func(columns []string, fc func() (prepare string, args []interface{})) Filter

+ OrNotInGet func(column string, preparer Preparer) Filter

+ OrNotInInt func(column string, values []int) Filter

+ OrNotInInt64 func(column string, values []int64) Filter

+ OrNotInQuery func(column string, fc func() (prepare string, args []interface{})) Filter

+ OrNotInString func(column string, values []string) Filter

type Get

+ func (s *Get) AppendColumn(column ...string) *Get

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

+ func (s *Get) CountGet(result interface{}, countColumn ...string) (int64, error)

+ func (s *Get) CountQuery(query func(rows *sql.Rows) (err error), countColumn ...string) (int64, error)

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

+ func (s *Get) Joins(joins ...*GetJoin) *Get

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

+ func (s *Get) RowsNextRow(dest ...interface{}) error

+ func (s *Get) SubQuery(prepare string, args ...interface{}) *Get

+ func (s *Get) SubQueryGet(get *Get, alias ...string) *Get

+ func (s *Get) Union(prepare string, args ...interface{}) *Get

+ func (s *Get) UnionAll(prepare string, args ...interface{}) *Get

+ func (s *Get) UnionAllGet(get ...*Get) *Get

+ func (s *Get) UnionGet(get ...*Get) *Get

+ func (s *Get) With(alias string, prepare string, args ...interface{}) *Get

+ func (s *Get) WithGet(alias string, get *Get) *Get

type GetJoin

+ func (s *GetJoin) SubQuery(prepare string, args ...interface{}) *GetJoin

+ func (s *GetJoin) SubQueryGet(get *Get, alias ...string) *GetJoin

+ func (s *GetJoin) Using(fields ...string) *GetJoin

+ type Identifier struct

+ func (s *Identifier) Avg(field string, alias ...string) string

+ func (s *Identifier) Avg1(field string) string

+ func (s *Identifier) Count(field string, alias ...string) string

+ func (s *Identifier) Max(field string, alias ...string) string

+ func (s *Identifier) Max1(field string) string

+ func (s *Identifier) Min(field string, alias ...string) string

+ func (s *Identifier) Min1(field string) string

+ func (s *Identifier) Sum(field string, alias ...string) string

+ func (s *Identifier) Sum1(field string) string

+ func (s *Identifier) V(sss ...string) string

+ type Limiter interface

+ GetLimit func() int64

+ GetOffset func() int64

+ type LogArgs struct

+ Args []interface{}

+ EndAt time.Time

+ Error error

+ StartAt time.Time

+ type LogPrepareArgs struct

+ Args *LogArgs

+ Prepare string

+ TxId string

+ TxMsg string

+ type LogTransaction struct

+ EndAt time.Time

+ Error error

+ StartAt time.Time

+ State string

+ TxId string

+ TxMsg string

type Mod

+ func (s *Mod) DefaultDecr(field string, value interface{}) *Mod

+ func (s *Mod) DefaultExpr(field string, expr string, args ...interface{}) *Mod

+ func (s *Mod) DefaultIncr(field string, value interface{}) *Mod

+ func (s *Mod) DefaultSet(field string, value interface{}) *Mod

+ func (s *Mod) Expr(field string, expr string, args ...interface{}) *Mod

+ func (s *Mod) FieldsValues(fields []string, values []interface{}) *Mod

+ func (s *Mod) Modify(modify interface{}) *Mod

+ func (s *Mod) SetSQL() (prepare string, args []interface{})

+ func (s *Mod) Update(originObject interface{}, latestObject interface{}) *Mod

+ type Opts func(s *Way)

+ func WithConfig(config *Config) Opts

+ func WithLogger(log func(log *LogPrepareArgs)) Opts

+ func WithPrepare(fix func(prepare string) string) Opts

+ func WithTag(tag string) Opts

+ func WithTxLogger(txLog func(log *LogTransaction)) Opts

+ func WithTxOpts(txOpts *sql.TxOptions) Opts

+ type Pgsql struct

+ func (s *Pgsql) CloneTableStruct(dst string, src string, seq string) (create []string, drop []string)

+ func (s *Pgsql) InsertOnConflict(onConflictColumns []string, updateColumns []string) (prepare string, args []interface{})

+ func (s *Pgsql) Prepare(str string) string

+ type Preparer interface

+ SQL func() (prepare string, args []interface{})

+ type Stmt struct

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

+ func (s *Stmt) Exec(args ...interface{}) (int64, error)

+ func (s *Stmt) ExecContext(ctx context.Context, args ...interface{}) (rowsAffected int64, err error)

+ func (s *Stmt) Query(query func(rows *sql.Rows) error, args ...interface{}) error

+ func (s *Stmt) QueryContext(ctx context.Context, query func(rows *sql.Rows) error, args ...interface{}) (err error)

+ func (s *Stmt) ScanAll(result interface{}, args ...interface{}) error

+ func (s *Stmt) ScanAllContext(ctx context.Context, result interface{}, args ...interface{}) error

type Way

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

+ func (s *Way) Getter(query func(rows *sql.Rows) error, prepare string, caller ...Caller) error

+ func (s *Way) GetterContext(ctx context.Context, query func(rows *sql.Rows) error, prepare string, ...) (err error)

+ func (s *Way) Identifier(prefix ...string) *Identifier

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

+ func (s *Way) PrepareContext(ctx context.Context, prepare string, caller ...Caller) (*Stmt, error)

+ func (s *Way) RowsNext(rows *sql.Rows, fc func() error) error

+ func (s *Way) RowsNextRow(rows *sql.Rows, dest ...interface{}) error

+ func (s *Way) ScanAllContext(ctx context.Context, result interface{}, prepare string, args ...interface{}) error

+ func (s *Way) Setter(prepare string, caller ...Caller) (int64, error)

+ func (s *Way) SetterContext(ctx context.Context, prepare string, caller ...Caller) (int64, error)

+ func (s *Way) TxMsg(msg string) *Way

+ func (s *Way) TxTry(fn func(tx *Way) error, times int, conn ...*sql.Conn) error

+ func (s *Way) TxTryCtx(ctx context.Context, fn func(tx *Way) error, times int, conn ...*sql.Conn) (err error)

+ type WayWriterReader interface

+ R func() *Way

+ W func() *Way

+ func NewWayWriterReader(choose func(n int) int, writer []*Way, reader []*Way) (WayWriterReader, error)

+ type WithQuery struct

+ func (s *WithQuery) SQL() (prepare string, args []interface{})

v1.0.1

Jul 18, 2023

Changes in this version

+ const DefaultTag

+ const SqlAs

+ const SqlAsc

+ const SqlDesc

+ func FixPgsql(str string) string

+ func StructInsert(insert interface{}, tag string, except ...string) (column []string, values []interface{})

+ func StructUpdate(origin interface{}, latest interface{}, tag string) (modify map[string]interface{})

+ type Add struct

+ func NewAdd(way *Way) *Add

+ func (s *Add) Add() (int64, error)

+ func (s *Add) AppendValues(values ...[]interface{}) *Add

+ func (s *Add) Column(column ...string) *Add

+ func (s *Add) ColumnValues(column []string, values ...[]interface{}) *Add

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

+ func (s *Add) Context(ctx context.Context) *Add

+ func (s *Add) Create(creates ...interface{}) *Add

+ func (s *Add) Except(except ...string) *Add

+ func (s *Add) Map(columnValue map[string]interface{}) *Add

+ func (s *Add) SQL() (prepare string, args []interface{})

+ func (s *Add) Table(table string) *Add

+ func (s *Add) Values(values ...[]interface{}) *Add

+ func (s *Add) ValuesSubQuery(prepare string, args ...interface{}) *Add

+ func (s *Add) ValuesSubQueryGet(get *Get) *Add

+ type Del struct

+ func NewDel(way *Way) *Del

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

+ func (s *Del) Context(ctx context.Context) *Del

+ func (s *Del) Del() (int64, error)

+ func (s *Del) SQL() (prepare string, args []interface{})

+ func (s *Del) Table(table string) *Del

+ func (s *Del) Where(where Filter) *Del

+ func (s *Del) WhereEqual(column string, values interface{}) *Del

+ func (s *Del) WhereFunc(where func(f Filter)) *Del

+ func (s *Del) WhereIn(column string, values ...interface{}) *Del

type Filter

+ SQL func() (prepare string, args []interface{})

+ type Get struct

+ func NewGet(way *Way) *Get

+ func (s *Get) AddCol(column ...string) *Get

+ func (s *Get) Alias(name string, alias string) string

+ func (s *Get) Column(column ...string) *Get

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

+ func (s *Get) Context(ctx context.Context) *Get

+ func (s *Get) Count(column ...string) (count int64, err error)

+ func (s *Get) FullJoin() *GetJoin

+ func (s *Get) Get(result interface{}) error

+ func (s *Get) Group(group ...string) *Get

+ func (s *Get) Having(having Filter) *Get

+ func (s *Get) HavingFunc(having func(f Filter)) *Get

+ func (s *Get) InnerJoin() *GetJoin

+ func (s *Get) Join(joins ...*GetJoin) *Get

+ func (s *Get) LeftJoin() *GetJoin

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

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

+ func (s *Get) Order(column string, order string) *Get

+ func (s *Get) OrderAsc(column string) *Get

+ func (s *Get) OrderDesc(column string) *Get

+ func (s *Get) Prefix(prefix string, name string) string

+ func (s *Get) Query(query func(rows *sql.Rows) (err error)) error

+ func (s *Get) RightJoin() *GetJoin

+ func (s *Get) SQL() (prepare string, args []interface{})

+ func (s *Get) SQLCount(column ...string) (prepare string, args []interface{})

+ func (s *Get) Table(table string) *Get

+ func (s *Get) TableAlias(alias string) *Get

+ func (s *Get) TableSubQuery(prepare string, args ...interface{}) *Get

+ func (s *Get) TableSubQueryGet(get *Get) *Get

+ func (s *Get) Where(where Filter) *Get

+ func (s *Get) WhereFunc(where func(f Filter)) *Get

+ type GetJoin struct

+ func NewGetJoin(joinType JoinType) *GetJoin

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

+ func (s *GetJoin) On(on string) *GetJoin

+ func (s *GetJoin) OnEqual(left string, right string) *GetJoin

+ func (s *GetJoin) SQL() (prepare string, args []interface{})

+ func (s *GetJoin) Table(table string) *GetJoin

+ func (s *GetJoin) TableSubQuery(prepare string, args ...interface{}) *GetJoin

+ func (s *GetJoin) TableSubQueryGet(get *Get) *GetJoin

type JoinType

+ const SqlJoinFull

+ const SqlJoinInner

+ const SqlJoinLeft

+ const SqlJoinRight

+ type Mod struct

+ func NewMod(way *Way) *Mod

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

+ func (s *Mod) Compare(origin interface{}, latest interface{}) *Mod

+ func (s *Mod) Context(ctx context.Context) *Mod

+ func (s *Mod) Decr(column string, value interface{}) *Mod

+ func (s *Mod) Except(except ...string) *Mod

+ func (s *Mod) Incr(column string, value interface{}) *Mod

+ func (s *Mod) Map(columnValue map[string]interface{}) *Mod

+ func (s *Mod) Mod() (int64, error)

+ func (s *Mod) SQL() (prepare string, args []interface{})

+ func (s *Mod) Set(column string, value interface{}) *Mod

+ func (s *Mod) Slice(column []string, value []interface{}) *Mod

+ func (s *Mod) Table(table string) *Mod

+ func (s *Mod) Where(where Filter) *Mod

+ func (s *Mod) WhereEqual(column string, value interface{}) *Mod

+ func (s *Mod) WhereFunc(where func(f Filter)) *Mod

+ func (s *Mod) WhereIn(column string, values ...interface{}) *Mod

type SubQuery

+ func NewSubQuery(prepare string, args ...interface{}) *SubQuery

+ func (s *SubQuery) SQL() (prepare string, args []interface{})

+ type Tab struct

type Way

+ func Choose(way *Way, items ...*Way) *Way

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

+ func (s *Way) Clone() *Way

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

+ func (s *Way) ExecAll(ctx context.Context, script string, args ...interface{}) (int64, error)

+ func (s *Way) Fix(fix func(string) string) *Way

+ func (s *Way) Get() *Get

+ func (s *Way) Log(log Logger) *Way

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

+ func (s *Way) ScanAll(ctx context.Context, result interface{}, prepare string, args ...interface{}) error

+ func (s *Way) Slow(slow time.Duration) *Way

+ func (s *Way) Tag(tag string) *Way

+ func (s *Way) Trans(fn func(tx *Way) (err error)) error

v1.0.0

Jun 3, 2023

Changes in this version

+ const DefaultColumnName

+ const DefaultCountAliasName

+ const DefaultUnionResultTableAliasName

+ const Placeholder

+ func Alias(prepare string, alias ...string) string

+ func FieldMerge(fields ...[]string) (result []string)

+ func ForRowsNextScan(rows *sql.Rows, rowsScan func(rows *sql.Rows) (err error)) (err error)

+ func PreparePostgresql(prepare string) string

+ func RemoveDuplicate(dynamic ...interface{}) (result []interface{})

+ func ScanSliceStruct(rows *sql.Rows, result interface{}, structTag string) (err error)

+ func StructAssign(origin interface{}, latest interface{})

+ func StructAttributeIndex(rt reflect.Type) map[string]int

+ func StructModify(origin interface{}, latest interface{})

+ func StructTagIndex(rt reflect.Type, tag string) map[string]int

+ func SubQuery(prepare string) string

+ type Delete struct

+ func NewDelete(way *Way) *Delete

+ func (s *Delete) Force() *Delete

+ func (s *Delete) Result() (string, []interface{})

+ func (s *Delete) Table(table string) *Delete

+ func (s *Delete) Tag(tag string) *Delete

+ func (s *Delete) Where(where Filter) *Delete

+ func (s *Delete) WithContext(ctx context.Context) *Delete

+ type Filter interface

+ And func(prepare string, args ...interface{}) Filter

+ Between func(column string, start interface{}, end interface{}) Filter

+ Equal func(column string, value interface{}) Filter

+ Filter func(filters ...Filter) Filter

+ Group func(group func(filter Filter) Filter) Filter

+ In func(column string, values ...interface{}) Filter

+ IsNotNull func(column string) Filter

+ IsNull func(column string) Filter

+ LessThan func(column string, value interface{}) Filter

+ LessThanEqual func(column string, value interface{}) Filter

+ Like func(column string, value interface{}) Filter

+ MoreThan func(column string, value interface{}) Filter

+ MoreThanEqual func(column string, value interface{}) Filter

+ NotBetween func(column string, start interface{}, end interface{}) Filter

+ NotEqual func(column string, value interface{}) Filter

+ NotIn func(column string, values ...interface{}) Filter

+ NotLike func(column string, value interface{}) Filter

+ Or func(prepare string, args ...interface{}) Filter

+ OrBetween func(column string, start interface{}, end interface{}) Filter

+ OrEqual func(column string, value interface{}) Filter

+ OrFilter func(filters ...Filter) Filter

+ OrGroup func(group func(filter Filter) Filter) Filter

+ OrIn func(column string, values ...interface{}) Filter

+ OrIsNotNull func(column string) Filter

+ OrIsNull func(column string) Filter

+ OrLessThan func(column string, value interface{}) Filter

+ OrLessThanEqual func(column string, value interface{}) Filter

+ OrLike func(column string, value interface{}) Filter

+ OrMoreThan func(column string, value interface{}) Filter

+ OrMoreThanEqual func(column string, value interface{}) Filter

+ OrNotBetween func(column string, start interface{}, end interface{}) Filter

+ OrNotEqual func(column string, value interface{}) Filter

+ OrNotIn func(column string, values ...interface{}) Filter

+ OrNotLike func(column string, value interface{}) Filter

+ Result func() (prepare string, args []interface{})

+ func NewFilter() Filter

+ type Insert struct

+ func NewInsert(way *Way) *Insert

+ func (s *Insert) Field(field ...string) *Insert

+ func (s *Insert) ForMap(fieldValue map[string]interface{}) *Insert

+ func (s *Insert) ForSlice(field []string, value []interface{}) *Insert

+ func (s *Insert) Result() (string, []interface{})

+ func (s *Insert) Table(table string) *Insert

+ func (s *Insert) Tag(tag string) *Insert

+ func (s *Insert) Value(value ...[]interface{}) *Insert

+ func (s *Insert) ValuesFromQuery(prepare string, args ...interface{}) *Insert

+ func (s *Insert) ValuesFromSelect(selector *Select) *Insert

+ func (s *Insert) WithContext(ctx context.Context) *Insert

+ type Join struct

+ func (s *Join) Alias() string

+ func (s *Join) As(as string) Joiner

+ func (s *Join) Asa() Joiner

+ func (s *Join) Asb() Joiner

+ func (s *Join) Asc() Joiner

+ func (s *Join) Asd() Joiner

+ func (s *Join) Ase() Joiner

+ func (s *Join) Asf() Joiner

+ func (s *Join) Field(field string) string

+ func (s *Join) Name() string

+ func (s *Join) On(joinOn string, joinOnFilter ...Filter) Joiner

+ func (s *Join) OnEqual(left string, right string, filter ...Filter) Joiner

+ func (s *Join) Query(field ...string) Joiner

+ func (s *Join) QueryFields() []string

+ func (s *Join) Result() (prepare string, args []interface{})

+ func (s *Join) Table() string

+ type JoinType string

+ const JoinFull

+ const JoinInner

+ const JoinLeft

+ const JoinMaster

+ const JoinRight

+ type Joiner interface

+ Alias func() string

+ As func(as string) Joiner

+ Asa func() Joiner

+ Asb func() Joiner

+ Asc func() Joiner

+ Asd func() Joiner

+ Ase func() Joiner

+ Asf func() Joiner

+ Field func(field string) string

+ Name func() string

+ On func(on string, filter ...Filter) Joiner

+ OnEqual func(left string, right string, filter ...Filter) Joiner

+ Query func(field ...string) Joiner

+ QueryFields func() []string

+ Result func() (prepare string, args []interface{})

+ Table func() string

+ func FullJoin(table string, args ...interface{}) Joiner

+ func InnerJoin(table string, args ...interface{}) Joiner

+ func LeftJoin(table string, args ...interface{}) Joiner

+ func MasterJoin(table string, args ...interface{}) Joiner

+ func RightJoin(table string, args ...interface{}) Joiner

+ type Logger interface

+ Error func(v ...interface{})

+ Errorf func(format string, v ...interface{})

+ Info func(v ...interface{})

+ Infof func(format string, v ...interface{})

+ Warn func(v ...interface{})

+ Warnf func(format string, v ...interface{})

+ type Order struct

+ Order []string

+ func NewOrder() *Order

+ func (s *Order) Asc(columns ...string) *Order

+ func (s *Order) Desc(columns ...string) *Order

+ func (s *Order) Result() string

+ type Select struct

+ func NewSelect(way *Way) *Select

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

+ func (s *Select) Asc(field ...string) *Select

+ func (s *Select) Count() (result int64, err error)

+ func (s *Select) Desc(field ...string) *Select

+ func (s *Select) Field(field ...string) *Select

+ func (s *Select) FromSelect(selector *Select, alias string) *Select

+ func (s *Select) Get(forRowsNextScan func(rows *sql.Rows) (err error)) error

+ func (s *Select) Group(group ...string) *Select

+ func (s *Select) Having(having Filter) *Select

+ func (s *Select) Join(join ...Joiner) *Select

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

+ func (s *Select) Master(master Joiner) *Select

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

+ func (s *Select) Order(order *Order) *Select

+ func (s *Select) Result() (string, []interface{})

+ func (s *Select) ResultForCount() (string, []interface{})

+ func (s *Select) Scan(result interface{}) error

+ func (s *Select) Table(table string, args ...interface{}) *Select

+ func (s *Select) Tag(tag string) *Select

+ func (s *Select) Union(c ...*Select) *Select

+ func (s *Select) UnionAll(c ...*Select) *Select

+ func (s *Select) Where(where Filter) *Select

+ func (s *Select) WithContext(ctx context.Context) *Select

+ type Table struct

+ func (s *Table) Delete(fn func(tmp *Delete)) (int64, error)

+ func (s *Table) Insert(fn func(tmp *Insert)) (int64, error)

+ func (s *Table) Select() *Select

+ func (s *Table) Update(fn func(tmp *Update)) (int64, error)

+ type TypeUnion string

+ const Union

+ const UnionAll

+ const UnknownUnion

+ type Update struct

+ func NewUpdate(way *Way) *Update

+ func (s *Update) Decr(field string, value interface{}) *Update

+ func (s *Update) Expr(expr string, args ...interface{}) *Update

+ func (s *Update) ForMap(fieldValue map[string]interface{}) *Update

+ func (s *Update) ForSlice(field []string, value []interface{}) *Update

+ func (s *Update) Force() *Update

+ func (s *Update) Incr(field string, value interface{}) *Update

+ func (s *Update) Result() (string, []interface{})

+ func (s *Update) Set(field string, value interface{}) *Update

+ func (s *Update) Table(table string) *Update

+ func (s *Update) Tag(tag string) *Update

+ func (s *Update) Where(where Filter) *Update

+ func (s *Update) WithContext(ctx context.Context) *Update

+ type Way struct

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

+ func (s *Way) CallTakeWarn(milliseconds int64) *Way

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

+ func (s *Way) Exec(prepare string, args ...interface{}) (int64, error)

+ func (s *Way) ExecContext(ctx context.Context, prepare string, args ...interface{}) (rowsAffected int64, err error)

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

+ func (s *Way) Prepare(fn func(prepare string) (result string)) *Way

+ func (s *Way) Query(handlingRows func(rows *sql.Rows) (err error), prepare string, ...) error

+ func (s *Way) QueryContext(ctx context.Context, handlingRows func(rows *sql.Rows) (err error), ...) (err error)

+ func (s *Way) Scan(result interface{}, prepare string, args ...interface{}) error

+ func (s *Way) ScanContext(ctx context.Context, result interface{}, prepare string, args ...interface{}) error

+ func (s *Way) Scanner(fn func(rows *sql.Rows, result interface{}) error) *Way

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

+ func (s *Way) Transaction(fn func(tx *Way) (err error)) error

+ func (s *Way) TransactionContext(ctx context.Context, opts *sql.TxOptions, fn func(tx *Way) (err error)) (err error)

+ func (s *Way) TxNil() bool

Other modules containing this package

github.com/cd365/hey/v2

github.com/cd365/hey/v3

github.com/cd365/hey/v5

github.com/cd365/hey/v6

github.com/cd365/hey/v7

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