dao

Sep 25, 2024

Changes in this version

type CurrentDb

+ Name string

type CurrentElastic

+ Name string

type CurrentRedis

+ Name string

type Dao

+ func (d *Dao) ClusterRedisClientV2(opts ...commonoption.Option) (*goredis.ClusterClient, string, error)

+ func (d *Dao) DBClientV2(opts ...commonoption.Option) (*gorm.DB, string, error)

+ func (d *Dao) ElasticClientV2(opts ...commonoption.Option) (*elastic.Client, string, error)

+ func (d *Dao) RedisClientV2(opts ...commonoption.Option) (*goredis.Client, string, error)

+ func (d *Dao) SentinelRedisClientV2(opts ...commonoption.Option) (*goredis.SentinelClient, string, error)

Nov 30, 2023

Changes in this version

type CurrentRedis

+ func (d *CurrentRedis) Warning(r *perf.RunTime, err error)

Jun 26, 2023

Changes in this version

+ type CurrentDb struct

+ func (d *CurrentDb) OK() bool

+ type CurrentElastic struct

+ func (d *CurrentElastic) OK() bool

+ type CurrentRedis struct

+ func (d *CurrentRedis) Expire(ctx context.Context, key string, time time.Duration)

+ func (d *CurrentRedis) ExpireAt(ctx context.Context, key string, time time.Time)

+ func (d *CurrentRedis) Get(ctx context.Context, key string) (string, error)

+ func (d *CurrentRedis) GetInt(ctx context.Context, key string) (int, error)

+ func (d *CurrentRedis) HDel(ctx context.Context, key, field string) (int64, error)

+ func (d *CurrentRedis) HGet(ctx context.Context, key, field string) (string, error)

+ func (d *CurrentRedis) HGetAll(ctx context.Context, key string) (map[string]string, error)

+ func (d *CurrentRedis) HGetInt(ctx context.Context, key, field string) (int, error)

+ func (d *CurrentRedis) HInc(ctx context.Context, key, field string, value int64) (int64, error)

+ func (d *CurrentRedis) HSet(ctx context.Context, key, field string, value interface{}) (int64, error)

+ func (d *CurrentRedis) HSetNX(ctx context.Context, key, field string, value interface{}) (bool, error)

+ func (d *CurrentRedis) Inc(ctx context.Context, key string, value int64) (int64, error)

+ func (d *CurrentRedis) OK() bool

+ func (d *CurrentRedis) Set(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)

+ func (d *CurrentRedis) SetEX(ctx context.Context, key string, value interface{}, expiration time.Duration) (string, error)

+ func (d *CurrentRedis) SetNX(ctx context.Context, key string, value interface{}, expiration time.Duration) (bool, error)

type Dao

+ func (d *Dao) UseDB(opts ...option.Option) CurrentDb

+ func (d *Dao) UseElastic(opts ...option.Option) CurrentElastic

+ func (d *Dao) UseRedis(opts ...option.Option) CurrentRedis

Oct 27, 2022

Changes in this version

type Dao

+ func (d *Dao) ClusterRedisClient() (*goredis.ClusterClient, error)

+ func (d *Dao) SentinelRedisClient() (*goredis.SentinelClient, error)

Oct 13, 2022

Changes in this version

+ const KCreateDatabase

Oct 13, 2022

Changes in this version

type Dao

+ Ctx context.Context

+ func (d *Dao) DBClient() (*gorm.DB, error)

+ func (d *Dao) ElasticClient() (*elastic.Client, error)

+ func (d *Dao) Expire(key string, time time.Duration)

+ func (d *Dao) ExpireAt(key string, time time.Time)

+ func (d *Dao) Get(key string) (string, error)

+ func (d *Dao) GetInt(key string) (int, error)

+ func (d *Dao) HDel(key, field string) (int64, error)

+ func (d *Dao) HGet(key, field string) (string, error)

+ func (d *Dao) HGetAll(key string) (map[string]string, error)

+ func (d *Dao) HGetInt(key, field string) (int, error)

+ func (d *Dao) HInc(key, field string, value int64) (int64, error)

+ func (d *Dao) HSet(key, field string, value interface{}) (int64, error)

+ func (d *Dao) HSetNX(key, field string, value interface{}) (bool, error)

+ func (d *Dao) Inc(key string, value int64) (int64, error)

+ func (d *Dao) RedisClient() (*goredis.Client, error)

+ func (d *Dao) ResetEsClient()

+ func (d *Dao) ResetRdsClient()

+ func (d *Dao) Set(key string, value interface{}, expiration time.Duration) (string, error)

+ func (d *Dao) SetEX(key string, value interface{}, expiration time.Duration) (string, error)

+ func (d *Dao) SetNX(key string, value interface{}, expiration time.Duration) (bool, error)

+ func (d *Dao) WithContext(ctx context.Context) *Dao

Sep 23, 2022

Changes in this version

type Dao

+ Elastic db.EsDatabase

Jun 1, 2022

Changes in this version

+ type Dao struct

+ Redis redis.Client

+ Sql db.SqlDatabase

+ func (d *Dao) Condition(dbname string, data interface{}, call db.ConditionCallback) result.Result

+ func (d *Dao) IsNotFound(db *gorm.DB) int

+ type Page struct

+ Count int

+ No int

+ Total int64

+ type SqlQuery struct

+ func NewSQ(concat string) *SqlQuery

+ func (sq *SqlQuery) AND() *SqlQuery

+ func (sq *SqlQuery) CONCAT() *SqlQuery

+ func (sq *SqlQuery) Concat(concat string) *SqlQuery

+ func (sq *SqlQuery) EQ() *SqlQuery

+ func (sq *SqlQuery) Exec() *SqlQuery

+ func (sq *SqlQuery) IN() *SqlQuery

+ func (sq *SqlQuery) IsExec() bool

+ func (sq *SqlQuery) IsValid() bool

+ func (sq *SqlQuery) OR() *SqlQuery

+ func (sq *SqlQuery) Quot(key string) *SqlQuery

+ func (sq *SqlQuery) To() string

+ func (sq *SqlQuery) Value(v interface{}) *SqlQuery