sql

May 27, 2024

Changes in this version

+ func WithTransactionId(id string) databases.TransactionOption

Jan 12, 2024

Changes in this version

type Arguments

+ func (arguments *Arguments) UnmarshalAvro(p []byte) (err error)

+ func (arguments Arguments) MarshalAvro() (p []byte, err error)

type Rows

+ func (rows *Rows) UnmarshalAvro(p []byte) (err error)

+ func (rows Rows) MarshalAvro() (p []byte, err error)

Dec 19, 2023

Changes in this version

type Config

+ SSL SSLConfig

type Option

+ func WithTLS(fn RegisterTLSFunc) Option

+ type RegisterTLSFunc func(config *tls.Config) (err error)

+ type SSLConfig struct

+ Enable bool

Dec 17, 2023

Changes in this version

+ func Begin(ctx context.Context, options ...databases.TransactionOption) (err error)

+ func Commit(ctx context.Context) (err error)

+ func Disuse(ctx context.Context) context.Context

+ func FAG() []modules.FnAnnotationCodeWriter

+ func ForceDialect(ctx context.Context, dialect string) context.Context

+ func New(options ...Option) (v services.Service)

+ func Readonly() databases.TransactionOption

+ func Rollback(ctx context.Context)

+ func Use(ctx context.Context, endpointName []byte) context.Context

+ func WithIsolation(isolation databases.Isolation) databases.TransactionOption

+ type Argument struct

+ Name string

+ Nil bool

+ Type string

+ Value []byte

+ func NewArgument(v any) (argument Argument, err error)

+ func (argument Argument) Interface() (v any, err error)

type Arguments

+ func (arguments Arguments) Len() (n int)

type Column

+ Valid bool

+ func (c *Column) Bool() (v bool, err error)

+ func (c *Column) Byte() (v byte, err error)

+ func (c *Column) Bytes() (v []byte, err error)

+ func (c *Column) Date() (v times.Date, err error)

+ func (c *Column) Datetime() (v time.Time, err error)

+ func (c *Column) Float() (v float64, err error)

+ func (c *Column) Int() (v int64, err error)

+ func (c *Column) Reset()

+ func (c *Column) String() (v string, err error)

+ func (c *Column) Time() (v times.Time, err error)

type ColumnType

+ DatabaseType string

+ Name string

+ Type string

+ func NewColumnType(name string, databaseType string, scanType reflect.Type) (v ColumnType)

+ func (ct ColumnType) ScanValue() (sv any)

+ type Columns []any

type Config

+ DebugLog bool

+ Isolation databases.Isolation

+ Kind string

+ Options json.RawMessage

+ TransactionMaxAge int

+ type NullBool struct

+ func NewNullBool(b bool) NullBool

+ func (n *NullBool) UnmarshalJSON(p []byte) error

+ func (n NullBool) MarshalJSON() (p []byte, err error)

+ type NullByte struct

+ func NewNullByte(b byte) NullByte

+ func (n *NullByte) UnmarshalJSON(p []byte) error

+ func (n NullByte) MarshalJSON() (p []byte, err error)

+ type NullBytes struct

+ Bytes []byte

+ Valid bool

+ func NewNullBytes(p []byte) NullBytes

+ func (n *NullBytes) Scan(src any) error

+ func (n *NullBytes) UnmarshalJSON(p []byte) error

+ func (n NullBytes) MarshalJSON() ([]byte, error)

+ func (n NullBytes) Value() (driver.Value, error)

type NullDate

+ Date times.Date

+ func NewNullDate(v times.Date) NullDate

+ func (n *NullDate) UnmarshalJSON(p []byte) error

+ func (n NullDate) MarshalJSON() (p []byte, err error)

+ type NullDatetime struct

+ func NewNullDatetime(t time.Time) NullDatetime

+ func (n *NullDatetime) UnmarshalJSON(p []byte) error

+ func (n NullDatetime) MarshalJSON() (p []byte, err error)

+ type NullFloat64 struct

+ func NewNullFloat64(n float64) NullFloat64

+ func (n *NullFloat64) UnmarshalJSON(p []byte) error

+ func (n NullFloat64) MarshalJSON() (p []byte, err error)

+ type NullInt16 struct

+ func NewNullInt16(n int16) NullInt16

+ func (n *NullInt16) UnmarshalJSON(p []byte) error

+ func (n NullInt16) MarshalJSON() (p []byte, err error)

+ type NullInt32 struct

+ func NewNullInt32(n int32) NullInt32

+ func (n *NullInt32) UnmarshalJSON(p []byte) error

+ func (n NullInt32) MarshalJSON() (p []byte, err error)

+ type NullInt64 struct

+ func NewNullInt64(n int64) NullInt64

+ func (n *NullInt64) UnmarshalJSON(p []byte) error

+ func (n NullInt64) MarshalJSON() (p []byte, err error)

type NullJson

+ E E

+ func NewNullJson[E any](e E) NullJson[E]

+ func (n *NullJson[E]) UnmarshalJSON(p []byte) error

+ func (n NullJson[E]) MarshalJSON() ([]byte, error)

+ func (n NullJson[E]) Value() (driver.Value, error)

+ type NullString struct

+ func NewNullString(s string) NullString

+ func (n *NullString) UnmarshalJSON(p []byte) error

+ func (n NullString) MarshalJSON() (p []byte, err error)

type NullTime

+ Time times.Time

+ func NewNullTime(v times.Time) NullTime

+ func (n *NullTime) UnmarshalJSON(p []byte) error

+ func (n NullTime) MarshalJSON() (p []byte, err error)

+ type Option func(options *Options)

+ func WithDatabase(db databases.Database) Option

+ func WithDialect(dialect string) Option

+ func WithName(name string) Option

+ type Options struct

type Rows

+ func (rows *Rows) Close() error

+ func (rows *Rows) Columns() []ColumnType

+ type Scanner interface

Mar 20, 2023

Changes in this version

+ func Dialect(ctx context.Context) (dialect string, err errors.CodeError)

+ func RegisterType(vt ValueType)

+ func WithOptions(ctx context.Context, options ...ProxyOption) context.Context

+ type Arguments struct

+ func NewArguments() *Arguments

+ func (t *Arguments) Append(values ...interface{}) *Arguments

+ func (t *Arguments) MarshalJSON() (p []byte, err error)

+ func (t *Arguments) Merge(v *Arguments) *Arguments

+ func (t *Arguments) Size() (n int)

+ func (t *Arguments) UnmarshalJSON(p []byte) (err error)

+ func (t *Arguments) Values() (args []interface{})

type Column

+ DatabaseType func() (dbt string)

+ type Date struct

+ Day int

+ Month time.Month

+ Year int

+ func DateNow() Date

+ func NewDate(year int, month time.Month, day int) Date

+ func NewDateFromJsonDate(d json.Date) Date

+ func NewDateFromTime(t time.Time) Date

+ func NewTimeFromTime(t time.Time) Date

+ func TimeNow() Date

+ func (d *Date) IsZero() (ok bool)

+ func (d *Date) MarshalJSON() ([]byte, error)

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

+ func (d *Date) String() string

+ func (d *Date) ToTime() time.Time

+ func (d *Date) UnmarshalJSON(p []byte) error

+ type NullDate struct

+ Valid bool

+ Value Date

+ func (t *NullDate) Scan(src interface{}) error

+ type NullRawBytes struct

+ Raw stdsql.RawBytes

+ Valid bool

+ func (v *NullRawBytes) Scan(src interface{}) error

+ type NullTime struct

+ Valid bool

+ Value Time

+ func (t *NullTime) Scan(src interface{}) error

+ type ProxyOption func(*ProxyOptions)

+ func Database(name string) ProxyOption

+ type ProxyOptions struct

+ type Time struct

+ Hour int

+ Minutes int

+ Second int

+ func NewTime(hour int, min int, sec int) Time

+ func (t *Time) IsZero() (ok bool)

+ func (t *Time) MarshalJSON() ([]byte, error)

+ func (t *Time) Scan(src interface{}) error

+ func (t *Time) String() string

+ func (t *Time) ToTime() time.Time

+ func (t *Time) UnmarshalJSON(p []byte) error

+ type ValueScanner interface

+ Reset func()

+ Value func() (value any)

+ type ValueType interface

+ ColumnType func() (ct string)

+ DatabaseTypes func() (types []string)

+ Decode func(p []byte) (v any, err error)

+ Encode func(src any) (p []byte, err error)

+ Scanner func() (scanner ValueScanner)

+ Type func() (typ reflect.Type)

+ func BoolValueType() ValueType

+ func BytesValueType() ValueType

+ func DateValueType() ValueType

+ func DatetimeValueType() ValueType

+ func FloatValueType() ValueType

+ func IntValueType() ValueType

+ func JsonValueType() ValueType

+ func StringValueType() ValueType

+ func TimeValueType() ValueType

Jun 22, 2022

Changes in this version

type Column

+ Get func(v interface{}) (err error)

+ IsNil func() (ok bool)

+ RawValue func() (raw []byte)

type ColumnScanner

+ func (c ColumnScanner) Get(v interface{}) (err error)

+ func (c ColumnScanner) IsNil() (ok bool)

+ func (c ColumnScanner) Name() (v string)

+ func (c ColumnScanner) RawValue() (raw []byte)

+ func (c ColumnScanner) Type() (typ string)

Feb 20, 2022

Changes in this version

type BeginTransactionParam

+ ReadOnly bool

Jan 20, 2022

Changes in this version

type Tuple

+ func (t Tuple) String() (s string)

Jan 19, 2022

Changes in this version

type Column

+ func (c *Column) Decode(v interface{}) (err error)

+ type ColumnScanner struct

+ func NewColumnScanner(ct *db.ColumnType) (scanner *ColumnScanner)

+ func (c *ColumnScanner) Scan(src interface{}) error

type Row

+ func (r *Row) Column(name string, value interface{}) (has bool, err error)

+ func (r *Row) Empty() (ok bool)

+ func (r *Row) MarshalJSON() (p []byte, err error)

+ func (r *Row) UnmarshalJSON(p []byte) (err error)

type Rows

+ func (r *Rows) MarshalJSON() (p []byte, err error)

+ func (r *Rows) Next() (v *Row, has bool)

+ func (r *Rows) UnmarshalJSON(p []byte) (err error)

type Tuple

+ func (t *Tuple) Merge(v *Tuple) *Tuple

+ func (t *Tuple) Size() (n int)

Jan 12, 2022

Changes in this version

type Config

+ LettersCase string

Jan 9, 2022

Changes in this version

+ func BeginTransaction(ctx fns.Context) (err errors.CodeError)

+ func BeginTransactionWithOption(ctx fns.Context, param BeginTransactionParam) (err errors.CodeError)

+ func CommitTransaction(ctx fns.Context) (err errors.CodeError)

+ func RollbackTransaction(ctx fns.Context) (err errors.CodeError)

+ type BeginTransactionParam struct

+ Isolation db.IsolationLevel

+ Timeout time.Duration

+ func DefaultTransactionOption() (v BeginTransactionParam)

+ func TransactionOption(timeout string, isolation db.IsolationLevel) (v BeginTransactionParam)

Sep 29, 2021

Changes in this version

+ func RegisterDialect(name string)

type Config

+ DAO DAOConfig

+ EnableDebugLog bool

+ type DAOConfig struct

+ CacheKind string

+ Raw json.RawMessage

+ type DaoCache interface

+ Clean func()

+ GetAndFill func(row TableRow) (has bool, synced bool)

+ Remove func(row TableRow)

+ Set func(row TableRow, synced bool)

+ type DatabaseAccessObject interface

+ Close func()

+ Count func(ctx fns.Context, param *QueryParam, row TableRow) (num int, err errors.CodeError)

+ Delete func(ctx fns.Context, rows ...TableRow) (affected int, err errors.CodeError)

+ Exist func(ctx fns.Context, row TableRow) (has bool, err errors.CodeError)

+ Get func(ctx fns.Context, row TableRow) (has bool, err errors.CodeError)

+ Insert func(ctx fns.Context, rows ...TableRow) (affected int, err errors.CodeError)

+ Page func(ctx fns.Context, param *QueryParam, rows interface{}) (page Paged, err errors.CodeError)

+ Query func(ctx fns.Context, param *QueryParam, rows interface{}) (has bool, err errors.CodeError)

+ Save func(ctx fns.Context, rows ...TableRow) (affected int, err errors.CodeError)

+ Update func(ctx fns.Context, rows ...TableRow) (affected int, err errors.CodeError)

+ func DAO(ctx fns.Context) (v DatabaseAccessObject)

+ type Paged struct

+ No int

+ Num int

+ Total int

+ type QueryCondition struct

+ type QueryConditions struct

+ func NewQueryConditions() *QueryConditions

+ func (c *QueryConditions) Between(column string, beg interface{}, end interface{}) *QueryConditions

+ func (c *QueryConditions) Eq(column string, value interface{}) *QueryConditions

+ func (c *QueryConditions) GT(column string, value interface{}) *QueryConditions

+ func (c *QueryConditions) GTE(column string, value interface{}) *QueryConditions

+ func (c *QueryConditions) In(column string, values ...interface{}) *QueryConditions

+ func (c *QueryConditions) LT(column string, value interface{}) *QueryConditions

+ func (c *QueryConditions) LTE(column string, value interface{}) *QueryConditions

+ func (c *QueryConditions) Like(column string, value interface{}) *QueryConditions

+ func (c *QueryConditions) NotEq(column string, value interface{}) *QueryConditions

+ type QueryParam struct

+ func NewQueryParam() *QueryParam

+ func (p *QueryParam) ASC(column string) *QueryParam

+ func (p *QueryParam) Conditions() *QueryConditions

+ func (p *QueryParam) DESC(column string) *QueryParam

+ func (p *QueryParam) Page(no int, size int) *QueryParam

+ func (p *QueryParam) Range(offset int, length int) *QueryParam

+ type QuerySort struct

+ type TableRow interface

+ Table func() (namespace string, name string, alias string)

Sep 11, 2021

Changes in this version

type GlobalTransactionManagement

+ func (gtm *GlobalTransactionManagement) Begin(ctx fns.Context, db0 *db.DB, isolation db.IsolationLevel, ...) (err error)

+ func (gtm *GlobalTransactionManagement) Commit(ctx fns.Context) (err error)

+ func (gtm *GlobalTransactionManagement) GetTx(ctx fns.Context) (tx *db.Tx, has bool)

+ func (gtm *GlobalTransactionManagement) Rollback(ctx fns.Context)

Sep 9, 2021

Changes in this version

+ type FieldColumn struct

+ Column *Column

+ FieldType reflect.Type

+ Kind string

Sep 6, 2021

Changes in this version

+ const BoolType

+ const BytesType

+ const ExecuteFn

+ const FloatType

+ const IntType

+ const JsonType

+ const Namespace

+ const QueryFn

+ const StringType

+ const TimeType

+ const TxBeginFn

+ const TxCommitFn

+ const TxRollbackFn

+ const UnknownType

+ func Service() fns.Service

+ func TxBegin(ctx fns.Context, param TxBeginParam) (err errors.CodeError)

+ func TxCommit(ctx fns.Context) (err errors.CodeError)

+ func TxRollback(ctx fns.Context) (err errors.CodeError)

+ type Client interface

+ Close func() (err error)

+ Reader func() (v *db.DB)

+ Writer func() (v *db.DB)

+ type Cluster struct

+ func NewCluster(databases []*db.DB) (client *Cluster)

+ func (client *Cluster) Close() (err error)

+ func (client *Cluster) Reader() (v *db.DB)

+ func (client *Cluster) Writer() (v *db.DB)

+ type Column struct

+ Name string

+ Nil bool

+ Type ColumnType

+ Value json.RawMessage

+ func (c *Column) Scan(src interface{}) error

+ type ColumnType string

+ type Config struct

+ DSN []string

+ Driver string

+ MasterSlaverMode bool

+ MaxIdles int

+ MaxOpens int

+ func (config *Config) CreateClient() (client Client, err error)

+ type ExecResult struct

+ Affected int64

+ LastInsertId int64

+ func Execute(ctx fns.Context, param Param) (result *ExecResult, err errors.CodeError)

+ type Executor interface

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

+ type GlobalTransaction struct

+ type GlobalTransactionManagement struct

+ func NewGlobalTransactionManagement() *GlobalTransactionManagement

+ func (gtm *GlobalTransactionManagement) Close()

+ func (gtm *GlobalTransactionManagement) Del(ctx fns.Context)

+ func (gtm *GlobalTransactionManagement) Get(ctx fns.Context) (tx *sql.Tx, has bool)

+ func (gtm *GlobalTransactionManagement) Set(ctx fns.Context, tx *sql.Tx, timeout time.Duration) (err error)

+ type KDB struct

+ func (k *KDB) Key() string

+ type MasterSlaver struct

+ func NewMasterSlaver(master *db.DB, slavers []*db.DB) (client *MasterSlaver)

+ func (client *MasterSlaver) Close() (err error)

+ func (client *MasterSlaver) Reader() (v *db.DB)

+ func (client *MasterSlaver) Writer() (v *db.DB)

+ type NullJson struct

+ Json json.RawMessage

+ Valid bool

+ func (v *NullJson) Scan(src interface{}) error

+ type NullSQLRaw struct

+ Raw db.RawBytes

+ Valid bool

+ func (v *NullSQLRaw) Scan(src interface{}) error

+ type Param struct

+ Args *Tuple

+ InTx bool

+ Query string

+ type QueryAble interface

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

+ type Row struct

+ Columns []*Column

+ func (r *Row) Scan(v interface{}) (err error)

+ type Rows struct

+ Values []*Row

+ func NewRows(raws *db.Rows) (r *Rows, err error)

+ func Query(ctx fns.Context, param Param) (rows *Rows, err errors.CodeError)

+ func (r *Rows) Empty() (ok bool)

+ func (r *Rows) Scan(v interface{}) (err error)

+ func (r *Rows) Size() int

+ type Standalone struct

+ func NewStandalone(v *db.DB) (client *Standalone)

+ func (client *Standalone) Close() (err error)

+ func (client *Standalone) Reader() (v *db.DB)

+ func (client *Standalone) Writer() (v *db.DB)

+ type Tuple struct

+ func NewTuple() *Tuple

+ func (t *Tuple) Append(values ...interface{})

+ func (t *Tuple) UnmarshalJSON(p []byte) (err error)

+ func (t Tuple) MarshalJSON() (p []byte, err error)

+ type TxAddress struct

+ Address string

+ type TxBeginParam struct

+ Isolation db.IsolationLevel

+ Timeout time.Duration