orm

Documentation

Index

• func Decode(src string) string
• func Encode(src string) string
• func MsSQLOffsetLimit(offset, limit int) string
• func MsSQLTimeFormat(t interface{}) string
• func MsSQLTimeParse(s string) time.Time
• func NewStringSlice(len int, val string) []string
• func PrimaryComparator(a, b interface{}) int
• func SQLOffsetLimit(offset, limit int) string
• func SQLOrderBy(field string, revert bool) string
• func SQLWhere(conditions []string) string
• func SliceJoin(objs []interface{}, sep string) string
• func StringScan(str string, v interface{}) error
• func TimeFormat(t time.Time) string
• func TimeParse(s string) time.Time
• func TimeParseLocalTime(s string) time.Time
• func TimeToLocalTime(c time.Time) string
• func ToFloat64(value interface{}) (float64, error)
• type DB
• type DBStore
  • func NewDBStore(driver, host string, port int, database, username, password string) (*DBStore, error)
  • func NewDBStoreCharset(driver, host string, port int, database, username, password, charset string) (*DBStore, error)
  • func (store *DBStore) BeginTx() (*DBTx, error)
  • func (store *DBStore) Close() error
  • func (store *DBStore) Debug(b bool)
  • func (store *DBStore) Exec(sql string, args ...interface{}) (sql.Result, error)
  • func (store *DBStore) Query(sql string, args ...interface{}) (*sql.Rows, error)
  • func (store *DBStore) SetError(err error)
  • func (store *DBStore) SlowLog(duration time.Duration)
• type DBTx
  • func (tx *DBTx) Close() error
  • func (tx *DBTx) Exec(sql string, args ...interface{}) (sql.Result, error)
  • func (tx *DBTx) Query(sql string, args ...interface{}) (*sql.Rows, error)
  • func (tx *DBTx) SetError(err error)
• type FieldIN
  • func NewFieldIN(field string) *FieldIN
  • func (in *FieldIN) Add(v interface{}) *FieldIN
  • func (in *FieldIN) SQLFormat() string
  • func (in *FieldIN) SQLParams() []interface{}
• type RedisStore
  • func NewRedisClient(host string, port int, password string, db int) (*RedisStore, error)
  • func NewRedisClusterClient(opt *redis.ClusterOptions) (*RedisStore, error)
  • func NewRedisFailoverClient(failoverOpt *redis.FailoverOptions) (*RedisStore, error)
  • func NewRedisRingClient(opt *redis.RingOptions) (*RedisStore, error)
• type VSet
  • func NewVSet() *VSet
  • func (set *VSet) Add(items ...interface{})
  • func (set *VSet) Clear()
  • func (set *VSet) Remove(items ...string)
  • func (set *VSet) SortAdd(times int, items ...interface{})
  • func (set *VSet) Unions(offset int, limit int) []interface{}
  • func (set *VSet) Values(times int, offset int, limit int) []interface{}

Functions

func Decode

func Decode(src string) string

func Encode

func Encode(src string) string

func MsSQLOffsetLimit

func MsSQLOffsetLimit(offset, limit int) string

func MsSQLTimeFormat

func MsSQLTimeFormat(t interface{}) string

func MsSQLTimeParse

func MsSQLTimeParse(s string) time.Time

func NewStringSlice

func NewStringSlice(len int, val string) []string

func PrimaryComparator

func PrimaryComparator(a, b interface{}) int

func SQLOffsetLimit

func SQLOffsetLimit(offset, limit int) string

func SQLOrderBy

func SQLOrderBy(field string, revert bool) string

func SQLWhere

func SQLWhere(conditions []string) string

func SliceJoin

func SliceJoin(objs []interface{}, sep string) string

func StringScan

func StringScan(str string, v interface{}) error

func TimeFormat

func TimeFormat(t time.Time) string

func TimeParse

func TimeParse(s string) time.Time

func TimeParseLocalTime

func TimeParseLocalTime(s string) time.Time

func TimeToLocalTime

func TimeToLocalTime(c time.Time) string

func ToFloat64

func ToFloat64(value interface{}) (float64, error)

Types

type DB

type DB interface {
	Query(sql string, args ...interface{}) (*sql.Rows, error)
	Exec(sql string, args ...interface{}) (sql.Result, error)
	SetError(err error)
}

type DBStore

type DBStore struct {
	*sql.DB
	// contains filtered or unexported fields
}

func NewDBStore

func NewDBStore(driver, host string, port int, database, username, password string) (*DBStore, error)

func NewDBStoreCharset

func NewDBStoreCharset(driver, host string, port int, database, username, password, charset string) (*DBStore, error)

func (*DBStore) BeginTx

func (store *DBStore) BeginTx() (*DBTx, error)

func (*DBStore) Close

func (store *DBStore) Close() error

func (*DBStore) Debug

func (store *DBStore) Debug(b bool)

func (*DBStore) Exec

func (store *DBStore) Exec(sql string, args ...interface{}) (sql.Result, error)

func (*DBStore) Query

func (store *DBStore) Query(sql string, args ...interface{}) (*sql.Rows, error)

func (*DBStore) SetError

func (store *DBStore) SetError(err error)

func (*DBStore) SlowLog

func (store *DBStore) SlowLog(duration time.Duration)

type DBTx

type DBTx struct {
	// contains filtered or unexported fields
}

func (*DBTx) Close

func (tx *DBTx) Close() error

func (*DBTx) Exec

func (tx *DBTx) Exec(sql string, args ...interface{}) (sql.Result, error)

func (*DBTx) Query

func (tx *DBTx) Query(sql string, args ...interface{}) (*sql.Rows, error)

func (*DBTx) SetError

func (tx *DBTx) SetError(err error)

type FieldIN

type FieldIN struct {
	Field  string
	Params []interface{}
	// contains filtered or unexported fields
}

func NewFieldIN

func NewFieldIN(field string) *FieldIN

func (*FieldIN) Add

func (in *FieldIN) Add(v interface{}) *FieldIN

func (*FieldIN) SQLFormat

func (in *FieldIN) SQLFormat() string

func (*FieldIN) SQLParams

func (in *FieldIN) SQLParams() []interface{}

type RedisStore

type RedisStore struct {
	redis.Cmdable
}

func NewRedisClient

func NewRedisClient(host string, port int, password string, db int) (*RedisStore, error)

func NewRedisClusterClient

func NewRedisClusterClient(opt *redis.ClusterOptions) (*RedisStore, error)

func NewRedisFailoverClient

func NewRedisFailoverClient(failoverOpt *redis.FailoverOptions) (*RedisStore, error)

func NewRedisRingClient

func NewRedisRingClient(opt *redis.RingOptions) (*RedisStore, error)

type VSet

type VSet struct {
	// contains filtered or unexported fields
}

func NewVSet

func NewVSet() *VSet

func (*VSet) Add

func (set *VSet) Add(items ...interface{})

func (*VSet) Clear

func (set *VSet) Clear()

func (*VSet) Remove

func (set *VSet) Remove(items ...string)

func (*VSet) SortAdd

func (set *VSet) SortAdd(times int, items ...interface{})

func (*VSet) Unions

func (set *VSet) Unions(offset int, limit int) []interface{}

func (*VSet) Values

func (set *VSet) Values(times int, offset int, limit int) []interface{}