dbhelper

Jul 7, 2023

Changes in this version

+ func CoalseceByte(v sql.NullByte, dv byte) byte

+ func ParseNullInt16(s string) sql.NullInt16

+ func ParseNullInt32(s string) sql.NullInt32

+ func ParseNullInt64(s string) sql.NullInt64

Jun 8, 2023

Changes in this version

+ func CoalseceBool(v sql.NullBool, dv bool) bool

+ func CoalseceFloat64(v sql.NullFloat64, dv float64) float64

+ func CoalseceInt16(v sql.NullInt16, dv int16) int16

+ func CoalseceInt32(v sql.NullInt32, dv int32) int32

+ func CoalseceInt64(v sql.NullInt64, dv int64) int64

+ func CoalseceInt8(v sql.NullByte, dv byte) byte

+ func CoalseceString(v sql.NullString, dv string) string

+ func CoalseceTime(v sql.NullTime, dv time.Time) time.Time

Jun 2, 2023

Changes in this version

+ type DynamicSqlBuilder struct

+ func (d *DynamicSqlBuilder) Append(sql string) *DynamicSqlBuilder

+ func (d *DynamicSqlBuilder) AppendIf(sql string, p bool) *DynamicSqlBuilder

+ func (d *DynamicSqlBuilder) End() *SqlBuilder

+ type SqlBuilder struct

+ func NewSqlBuilder(sql string) *SqlBuilder

+ func (b *SqlBuilder) Append(sql string) *SqlBuilder

+ func (b *SqlBuilder) AppendIf(sql string, p bool) *SqlBuilder

+ func (b *SqlBuilder) Dynamic(prefix, suffix, joint string) *DynamicSqlBuilder

+ func (b *SqlBuilder) Limit(startRowIndex, maximumRows int) *SqlBuilder

+ func (b *SqlBuilder) OrderBy(sql ...string) *SqlBuilder

+ func (b *SqlBuilder) String() string

+ func (b *SqlBuilder) Where() *DynamicSqlBuilder

May 29, 2023

Changes in this version

+ func CloseTx(ctx context.Context)

+ func CommitTx(ctx context.Context)

May 25, 2023

Changes in this version

+ func BeginTx(ctx context.Context, serializable bool) context.Context

May 18, 2023

Changes in this version

+ var SQL_ARG_PATTERN = regexp.MustCompile(`:[1|2|3|4|5|6|7|8|9](0|1|2|3|4|5|6|7|8|9)?`)

+ func Exec(ctx context.Context, query string, args ...any) (T, error)

+ func ExecLastInsertId(ctx context.Context, query string, args ...any) (T, error)

+ func InitMySqlDb(addr, username, password, dbname string) error

+ func InsertBatch(ctx context.Context, query string, rows ...[]any) (int64, error)

+ func JoinInInt(args []T) string

+ func JoinInString(args []string) string

+ func Query(ctx context.Context, query string, args ...any) (T, error)

+ func QueryKeyValueMap(ctx context.Context, query string, args ...any) (map[string]T, error)

+ func QueryList(ctx context.Context, query string, args ...any) ([]T, error)

+ func QueryObj(ctx context.Context, query string, rh RowHandler[T], args ...any) (*T, error)

+ func QueryObjList(ctx context.Context, query string, rh RowHandler[T], args ...any) ([]*T, error)

+ func Version() string

+ type DbRow interface

+ Scan func(dest ...any) error

+ type KeyValuePairMapper struct

+ func (m *KeyValuePairMapper[T]) Scan(r DbRow) (*KeyValuePairPo[T], error)

+ type KeyValuePairPo struct

+ Key string

+ Value T

+ type RowHandler interface

+ Scan func(sc DbRow) (*T, error)