sqlca

package module

Go to main page

Versions in this module

v3

v3.8.2

Dec 26, 2025

v3.8.1

Dec 19, 2025

v3.8.0

Dec 18, 2025

v3.7.1

Dec 5, 2025

v3.7.0

Dec 2, 2025

Changes in this version

type Engine

+ func (e *Engine) Lock(key string, expiry time.Duration) (unlock func() error, err error)

+ func (e *Engine) TryLock(key string, expiry, timeout time.Duration) (unlock func() error, err error)

type Option

+ func WithRedisConfig(rc *RedisConfig) Option

+ type RedisConfig struct

+ Address string

+ ClientName string

+ ConnTimeout *time.Duration

+ DB int

+ MaxActive int

+ MaxConnLifetime time.Duration

+ MaxIdle int

+ Password string

+ SkipVerify bool

+ TlsConfig *tls.Config

+ UseTLS bool

v3.6.0

Nov 15, 2025

v3.5.3

Nov 15, 2025

Changes in this version

+ func ConvertPtr[T any](v T) *T

+ func ConvertVal[T any](v *T) (ret T)

v3.5.2

Aug 27, 2025

v3.5.1

Aug 4, 2025

v3.5.0

Aug 1, 2025

Changes in this version

+ func NewExpr(query string, args ...any) *types.Expr

v3.4.0

Jul 30, 2025

Changes in this version

+ type Option func(*dialOption)

+ func WithDebug() Option

+ func WithDefaultLimit(limit int32) Option

+ func WithDisableOffset() Option

+ func WithIdleConn(idle int) Option

+ func WithMaxConn(max int) Option

+ func WithSSH(ssh *SSH) Option

+ func WithSnowFlake(snowflake *SnowFlake) Option

v3.3.3

Jul 25, 2025

v3.3.2

Jul 25, 2025

v3.3.1

Jul 15, 2025

v3.3.0

Jul 15, 2025

v3.2.1

Jul 11, 2025

Changes in this version

+ type Point struct

+ X float64

+ Y float64

+ func (p *Point) Scan(value interface{}) error

+ func (p *Point) UnmarshalJSON(data []byte) error

+ func (p Point) MarshalJSON() ([]byte, error)

+ func (p Point) String() string

+ func (p Point) Value() (driver.Value, error)

v3.2.0

Jul 10, 2025

Changes in this version

type Engine

+ func (e *Engine) Ignore() *Engine

v3.1.1

Jul 10, 2025

v3.1.0

Jul 9, 2025

Changes in this version

+ func NewContext(ctx context.Context, e *Engine) context.Context

type Engine

+ func FromContext(ctx context.Context) *Engine

+ func (e *Engine) CountRows(query string, args ...any) (count int64, err error)

+ func (e *Engine) NewContext(ctx context.Context) context.Context

v3.0.1

Jul 8, 2025

v3.0.0

Jul 7, 2025

Changes in this version

+ const DefaultConnIdle

+ const DefaultConnMax

+ const JoinType_Inner

+ const JoinType_Left

+ const JoinType_Right

+ var ErrRecordNotFound = errors.New("record not found")

+ func NewSqlClause(fmts string, args ...any) *types.SqlClauseValue

+ func Url2MySql(strUrl string) (string, error)

+ type AfterCreateInterface interface

+ AfterCreate func(db *Engine) error

+ type AfterDeleteInterface interface

+ AfterDelete func(db *Engine) error

+ type AfterQueryInterface interface

+ AfterQuery func(db *Engine) error

+ type AfterUpdateInterface interface

+ AfterUpdate func(db *Engine) error

+ type BeforeCreateInterface interface

+ BeforeCreate func(db *Engine) error

+ type BeforeDeleteInterface interface

+ BeforeDelete func(db *Engine) error

+ type BeforeQueryInterface interface

+ BeforeQuery func(db *Engine) error

+ type BeforeUpdateInterface interface

+ BeforeUpdate func(db *Engine) error

+ type CaseWhen struct

+ func (c *CaseWhen) Case(strThen string, strWhen string, args ...interface{}) *CaseWhen

+ func (c *CaseWhen) Else(strElse string) *CaseWhen

+ func (c *CaseWhen) End(strName string) *Engine

+ type Decimal struct

+ func NewDecimal(v interface{}) (d Decimal)

+ func (d *Decimal) FromFloat(v float64)

+ func (d *Decimal) FromInt(v int64)

+ func (d *Decimal) FromString(v string)

+ func (d *Decimal) Scan(src interface{}) error

+ func (d *Decimal) Unmarshal(data []byte) error

+ func (d *Decimal) UnmarshalBSON(data []byte) error

+ func (d *Decimal) UnmarshalBinary(data []byte) error

+ func (d *Decimal) UnmarshalJSON(decimalBytes []byte) error

+ func (d *Decimal) UnmarshalText(text []byte) error

+ func (d Decimal) Abs() Decimal

+ func (d Decimal) Add(d2 interface{}) Decimal

+ func (d Decimal) Amount2Btc() Decimal

+ func (d Decimal) Amount2Coin(prec int) Decimal

+ func (d Decimal) Amount2Ether() Decimal

+ func (d Decimal) Amount2FIL() Decimal

+ func (d Decimal) BigInt() (b *big.Int, ok bool)

+ func (d Decimal) Btc2Amount() Decimal

+ func (d Decimal) Cmp(d2 interface{}) int

+ func (d Decimal) Coin2Amount(prec int) Decimal

+ func (d Decimal) Cos() Decimal

+ func (d Decimal) Div(d2 interface{}) Decimal

+ func (d Decimal) Equal(d2 interface{}) bool

+ func (d Decimal) Ether2Amount() Decimal

+ func (d Decimal) FIL2Amount() Decimal

+ func (d Decimal) Float64() (f float64)

+ func (d Decimal) GetDecimal() decimal.Decimal

+ func (d Decimal) GreaterThan(d2 interface{}) bool

+ func (d Decimal) GreaterThanOrEqual(d2 interface{}) bool

+ func (d Decimal) IntPart() int64

+ func (d Decimal) IsNegative() bool

+ func (d Decimal) IsPositive() bool

+ func (d Decimal) IsZero() bool

+ func (d Decimal) LessThan(d2 interface{}) bool

+ func (d Decimal) LessThanOrEqual(d2 interface{}) bool

+ func (d Decimal) Marshal() ([]byte, error)

+ func (d Decimal) MarshalBSON() ([]byte, error)

+ func (d Decimal) MarshalBinary() (data []byte, err error)

+ func (d Decimal) MarshalJSON() ([]byte, error)

+ func (d Decimal) MarshalText() (text []byte, err error)

+ func (d Decimal) Max(rest ...Decimal) Decimal

+ func (d Decimal) Min(rest ...Decimal) Decimal

+ func (d Decimal) Mod(d2 interface{}) Decimal

+ func (d Decimal) Mul(d2 interface{}) Decimal

+ func (d Decimal) Neg() Decimal

+ func (d Decimal) Pow(d2 interface{}) Decimal

+ func (d Decimal) Round(places int32) Decimal

+ func (d Decimal) Sign() int

+ func (d Decimal) Sin() Decimal

+ func (d Decimal) String() string

+ func (d Decimal) StringFixed(places int32) string

+ func (d Decimal) StringScaled(exp int32) string

+ func (d Decimal) Sub(d2 interface{}) Decimal

+ func (d Decimal) Sum(rest ...Decimal) Decimal

+ func (d Decimal) Tan() Decimal

+ func (d Decimal) Truncate(precision int32) Decimal

+ func (d Decimal) Value() (driver.Value, error)

+ type Engine struct

+ func NewEngine(strUrl string, options ...*Options) (*Engine, error)

+ func (e *Engine) And(query any, args ...any) *Engine

+ func (e *Engine) Asc(columns ...string) *Engine

+ func (e *Engine) Attach(strDatabaseName string, db *sqlx.DB) *Engine

+ func (e *Engine) AutoRollback() *Engine

+ func (e *Engine) Avg(strColumn string, as ...string) *Engine

+ func (e *Engine) Case(strThen string, strWhen string, args ...any) *CaseWhen

+ func (e *Engine) Close() *Engine

+ func (e *Engine) Count(strColumn string, as ...string) *Engine

+ func (e *Engine) Counter() *counter

+ func (e *Engine) Debug(ok bool)

+ func (e *Engine) Delete() (rowsAffected int64, err error)

+ func (e *Engine) Desc(columns ...string) *Engine

+ func (e *Engine) Distinct() *Engine

+ func (e *Engine) Eq(strColumn string, value any) *Engine

+ func (e *Engine) Equal(strColumn string, value any) *Engine

+ func (e *Engine) Exclude(columns ...string) *Engine

+ func (e *Engine) ExecRaw(query string, args ...any) (rowsAffected, lastInsertId int64, err error)

+ func (e *Engine) ForUpdate() *Engine

+ func (e *Engine) Force() *Engine

+ func (e *Engine) From(exprs ...string) *Engine

+ func (e *Engine) GeoHash(lng, lat float64, precision int) (strGeoHash string, strNeighbors []string)

+ func (e *Engine) GetAdapter() types.AdapterType

+ func (e *Engine) GetPkName() string

+ func (e *Engine) GreaterEqual(strColumn string, value any) *Engine

+ func (e *Engine) GreaterThan(strColumn string, value any) *Engine

+ func (e *Engine) GroupBy(columns ...string) *Engine

+ func (e *Engine) Gt(strColumn string, value any) *Engine

+ func (e *Engine) Gte(strColumn string, value any) *Engine

+ func (e *Engine) GteLte(strColumn string, value1, value2 any) *Engine

+ func (e *Engine) Having(strFmt string, args ...any) *Engine

+ func (e *Engine) Id(value any) *Engine

+ func (e *Engine) In(strColumn string, args ...any) *Engine

+ func (e *Engine) InnerJoin(strTableName string) *Join

+ func (e *Engine) Insert() (lastInsertId int64, err error)

+ func (e *Engine) IsNULL(strColumn string) *Engine

+ func (e *Engine) IsNull(strColumn string) *Engine

+ func (e *Engine) JsonEqual(strColumn, strPath string, value any) *Engine

+ func (e *Engine) JsonGreater(strColumn, strPath string, value any) *Engine

+ func (e *Engine) JsonGreaterEqual(strColumn, strPath string, value any) *Engine

+ func (e *Engine) JsonLess(strColumn, strPath string, value any) *Engine

+ func (e *Engine) JsonLessEqual(strColumn, strPath string, value any) *Engine

+ func (e *Engine) JsonMarshal(v any) (strJson string)

+ func (e *Engine) JsonUnmarshal(strJson string, v any) (err error)

+ func (e *Engine) LeftJoin(strTableName string) *Join

+ func (e *Engine) LessEqual(strColumn string, value any) *Engine

+ func (e *Engine) LessThan(strColumn string, value any) *Engine

+ func (e *Engine) Like(strColumn, keyword string) *Engine

+ func (e *Engine) Likes(kvs map[string]any) *Engine

+ func (e *Engine) Limit(args ...int) *Engine

+ func (e *Engine) LockShareMode() *Engine

+ func (e *Engine) Lt(strColumn string, value any) *Engine

+ func (e *Engine) Lte(strColumn string, value any) *Engine

+ func (e *Engine) Max(strColumn string, as ...string) *Engine

+ func (e *Engine) Min(strColumn string, as ...string) *Engine

+ func (e *Engine) Model(args ...interface{}) *Engine

+ func (e *Engine) MustFind() (rowsAffected int64, err error)

+ func (e *Engine) Ne(strColumn string, value any) *Engine

+ func (e *Engine) NearBy(strLngCol, strLatCol, strAS string, lng, lat, distance float64) *Engine

+ func (e *Engine) NewID() ID

+ func (e *Engine) NoVerbose() *Engine

+ func (e *Engine) NotIn(strColumn string, args ...any) *Engine

+ func (e *Engine) NotNULL(strColumn string) *Engine

+ func (e *Engine) Offset(offset int) *Engine

+ func (e *Engine) Omit(columns ...string) *Engine

+ func (e *Engine) OnConflict(columns ...string) *Engine

+ func (e *Engine) Or(query any, args ...any) *Engine

+ func (e *Engine) OrderBy(orders ...string) *Engine

+ func (e *Engine) Page(pageNo, pageSize int) *Engine

+ func (e *Engine) Ping() (err error)

+ func (e *Engine) Query() (rowsAffected int64, err error)

+ func (e *Engine) QueryEx() (rowsAffected, total int64, err error)

+ func (e *Engine) QueryJson() (s string, err error)

+ func (e *Engine) QueryMap(query string, args ...any) (rowsAffected int64, err error)

+ func (e *Engine) QueryRaw(query string, args ...any) (rowsAffected int64, err error)

+ func (e *Engine) RightJoin(strTableName string) *Join

+ func (e *Engine) Round(strColumn string, round int, as ...string) *Engine

+ func (e *Engine) Select(columns ...string) *Engine

+ func (e *Engine) SetCustomTag(tagNames ...string) *Engine

+ func (e *Engine) SetLogFile(strPath string)

+ func (e *Engine) SetPkName(strName string) *Engine

+ func (e *Engine) SetReadOnly(columns ...string)

+ func (e *Engine) SlowQuery(on bool, ms int)

+ func (e *Engine) Sum(strColumn string, as ...string) *Engine

+ func (e *Engine) Table(exprs ...string) *Engine

+ func (e *Engine) ToSQL(operType types.OperType) (strSql string)

+ func (e *Engine) TxBegin() (*Engine, error)

+ func (e *Engine) TxCommit() error

+ func (e *Engine) TxExec(query string, args ...any) (lastInsertId, rowsAffected int64, err error)

+ func (e *Engine) TxFunc(fn func(tx *Engine) error) (err error)

+ func (e *Engine) TxFuncContext(ctx context.Context, fn func(ctx context.Context, tx *Engine) error) (err error)

+ func (e *Engine) TxGet(dest any, strSql string, args ...any) (count int64, err error)

+ func (e *Engine) TxHandle(handler TxHandler) (err error)

+ func (e *Engine) TxRollback() error

+ func (e *Engine) Update() (rowsAffected int64, err error)

+ func (e *Engine) Upsert(strCustomizeUpdates ...string) (lastInsertId int64, err error)

+ func (e *Engine) Use(strDatabaseName string) (*Engine, error)

+ func (e *Engine) Where(query any, args ...any) *Engine

+ type Fetcher struct

+ type ID = snowflake.ID

+ type Id = ID

+ type Join struct

+ func (j *Join) On(strOn string, args ...interface{}) *Engine

+ type JoinType int

+ func (t JoinType) GoString() string

+ func (t JoinType) String() string

+ func (t JoinType) ToKeyWord() string

+ type ModelReflector struct

+ Columns []string

+ Dict map[string]interface{}

+ func (s *ModelReflector) ParseModel(tagNames ...string) *ModelReflector

+ type Options struct

+ Debug bool

+ DefaultLimit int32

+ DisableOffset bool

+ Idle int

+ Max int

+ SSH *SSH

+ SnowFlake *SnowFlake

+ type SSH struct

+ Host string

+ Password string

+ PrivateKey string

+ User string

+ func (s *SSH) GoString() string

+ func (s *SSH) String() string

+ type SnowFlake struct

+ NodeId int64

+ type StringBuilder struct

+ func NewStringBuilder() *StringBuilder

+ func (s *StringBuilder) Append(query string, args ...any) *StringBuilder

+ func (s *StringBuilder) Args() []interface{}

+ func (s *StringBuilder) String() string

+ type TxHandler interface

+ OnTransaction func(tx *Engine) error

+ type UrlInfo struct

+ ForceQuery bool

+ Fragment string

+ Host string

+ Opaque string

+ Password string

+ Path string

+ Queries map[string]string

+ Scheme string

+ User string

+ func ParseUrl(strUrl string) (ui *UrlInfo)

+ func (ui *UrlInfo) Url() string

Other modules containing this package

github.com/civet148/sqlca

github.com/civet148/sqlca/v2

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