redisclient

Documentation

Index

• func NewRedis(host, port, usr, pwd, database string) (storage.DI, error)
• type Redis
  • func (r *Redis) AddColumn(tableName string, column *storage.Column) error
  • func (r *Redis) Close()
  • func (r *Redis) CreateTable(sql string) error
  • func (r *Redis) DelByCondition(cName string, delselector interface{}) error
  • func (r *Redis) DropColumn(tableName, field string) error
  • func (r *Redis) DropTable(tableName string) error
  • func (r *Redis) ExecSql(cmd interface{}) error
  • func (r *Redis) GetCntByCondition(cName string, selector interface{}) (cnt int, err error)
  • func (m *Redis) GetIncID(cName string) (int64, error)
  • func (r *Redis) GetMutilByCondition(cName string, fields []string, selector, results interface{}, sort string, ...) error
  • func (r *Redis) GetOneByCondition(cName string, fields []string, selector, results interface{}) error
  • func (r *Redis) GetSession() interface{}
  • func (r *Redis) GetType() string
  • func (r *Redis) HasFields(tableName, field string) (bool, error)
  • func (r *Redis) HasTable(tableName string) (bool, error)
  • func (r *Redis) Index(tableName string, index *storage.Index) error
  • func (r *Redis) Insert(cName string, data interface{}) (int, error)
  • func (r *Redis) InsertMuti(cName string, data ...interface{}) error
  • func (r *Redis) IsDuplicateErr(err error) bool
  • func (r *Redis) ModifyColumn(tableName, oldName, newColumn string) error
  • func (r *Redis) Open() error
  • func (m *Redis) Ping() error
  • func (r *Redis) UpdateByCondition(cName string, oldobj, newobj interface{}) error

Functions

func NewRedis

func NewRedis(host, port, usr, pwd, database string) (storage.DI, error)

Types

type Redis

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

func (*Redis) AddColumn

func (r *Redis) AddColumn(tableName string, column *storage.Column) error

新加字段， 表名，字段名,字段类型, 附加描述（是否为空， 默认值）

func (*Redis) Close

func (r *Redis) Close()

Close close session

func (*Redis) CreateTable

func (r *Redis) CreateTable(sql string) error

func (*Redis) DelByCondition

func (r *Redis) DelByCondition(cName string, delselector interface{}) error

func (*Redis) DropColumn

func (r *Redis) DropColumn(tableName, field string) error

func (*Redis) DropTable

func (r *Redis) DropTable(tableName string) error

func (*Redis) ExecSql

func (r *Redis) ExecSql(cmd interface{}) error

执行原始的sql语句，并不会返回数据， 只会是否执行出错

func (*Redis) GetCntByCondition

func (r *Redis) GetCntByCondition(cName string, selector interface{}) (cnt int, err error)

func (*Redis) GetIncID

func (m *Redis) GetIncID(cName string) (int64, error)

func (*Redis) GetMutilByCondition

func (r *Redis) GetMutilByCondition(cName string, fields []string, selector, results interface{}, sort string, skip, limit int) error

func (*Redis) GetOneByCondition

func (r *Redis) GetOneByCondition(cName string, fields []string, selector, results interface{}) error

func (*Redis) GetSession

func (r *Redis) GetSession() interface{}

GetSession

func (*Redis) GetType

func (r *Redis) GetType() string

GetType 获取操作db的类

func (*Redis) HasFields

func (r *Redis) HasFields(tableName, field string) (bool, error)

func (*Redis) HasTable

func (r *Redis) HasTable(tableName string) (bool, error)

判断表是否存在

func (*Redis) Index

func (r *Redis) Index(tableName string, index *storage.Index) error

func (*Redis) Insert

func (r *Redis) Insert(cName string, data interface{}) (int, error)

func (*Redis) InsertMuti

func (r *Redis) InsertMuti(cName string, data ...interface{}) error

func (*Redis) IsDuplicateErr

func (r *Redis) IsDuplicateErr(err error) bool

IsDuplicateErr returns whether err is duplicate error

func (*Redis) ModifyColumn

func (r *Redis) ModifyColumn(tableName, oldName, newColumn string) error

func (*Redis) Open

func (r *Redis) Open() error

open con

func (*Redis) Ping

func (m *Redis) Ping() error

Ping will ping the db server

func (*Redis) UpdateByCondition

func (r *Redis) UpdateByCondition(cName string, oldobj, newobj interface{}) error