dorm

package
v1.0.48 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 20, 2022 License: MIT Imports: 45 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AttrExpr = "expr" // 过期时间
	AttrNx   = "nx"   // 设置Nx
)
View Source
const (
	SerializerJson   = "json"
	SerializerString = "string"
)

Variables

This section is empty.

Functions

func JsonDecodeNoError

func JsonDecodeNoError(b []byte) map[string]interface{}

JsonDecodeNoError Json解码,不报错

func XmlDecodeNoError

func XmlDecodeNoError(b []byte) map[string]interface{}

XmlDecodeNoError Xml解码,不报错

Types

type BeegoClient

type BeegoClient struct {
	Db *orm.Ormer // 驱动
	// contains filtered or unexported fields
}

BeegoClient https://beego.vip/

func NewBeegoMysqlClient

func NewBeegoMysqlClient(config *ConfigBeegoClient) (*BeegoClient, error)

func NewBeegoOracleClient

func NewBeegoOracleClient(config *ConfigBeegoClient) (*BeegoClient, error)

func NewBeegoPgsqlClient

func NewBeegoPgsqlClient(config *ConfigBeegoClient) (*BeegoClient, error)

func NewBeegoTidbClient

func NewBeegoTidbClient(config *ConfigBeegoClient) (*BeegoClient, error)

type BsonTime

type BsonTime time.Time

BsonTime 类型

func (BsonTime) MarshalBSONValue

func (t BsonTime) MarshalBSONValue() (bsontype.Type, []byte, error)

MarshalBSONValue 实现bson序列化

func (BsonTime) MarshalJSON

func (t BsonTime) MarshalJSON() ([]byte, error)

MarshalJSON 实现json序列化

func (*BsonTime) UnmarshalBSONValue

func (t *BsonTime) UnmarshalBSONValue(t2 bsontype.Type, data []byte) error

UnmarshalBSONValue 实现bson反序列化

func (*BsonTime) UnmarshalJSON

func (t *BsonTime) UnmarshalJSON(data []byte) (err error)

UnmarshalJSON 实现json反序列化

func (BsonTime) Value

func (t BsonTime) Value() string

Value 时间类型

type BunClient

type BunClient struct {
	Db *bun.DB // 驱动
	// contains filtered or unexported fields
}

BunClient https://bun.uptrace.dev/

func NewBunMssqlClient

func NewBunMssqlClient(config *ConfigBunClient) (*BunClient, error)

func NewBunMysqlClient

func NewBunMysqlClient(config *ConfigBunClient) (*BunClient, error)

func NewBunPgsqlClient

func NewBunPgsqlClient(config *ConfigBunClient) (*BunClient, error)

type ConfigBeegoClient

type ConfigBeegoClient struct {
	Dns string // 地址
}

type ConfigBunClient

type ConfigBunClient struct {
	Dns string // 地址
}

type ConfigGormClient

type ConfigGormClient struct {
	Dns    string // 地址
	Log    bool   // 日志
	LogUrl string // 日志路径
}

type ConfigMongoClient

type ConfigMongoClient struct {
	Dns          string // 地址
	Opts         *options.ClientOptions
	DatabaseName string // 库名
}

type ConfigRedisClient

type ConfigRedisClient struct {
	Addr     string // 地址
	Password string // 密码
	DB       int    // 数据库
	PoolSize int    // 连接池大小
}

type ConfigXormClient

type ConfigXormClient struct {
	Dns string // 地址
}

type ConfigZormClient

type ConfigZormClient struct {
	Dns string // 地址
}

type DBGttFunc

type DBGttFunc func() string

type DBGttInterfaceFunc

type DBGttInterfaceFunc func() interface{}

type DBGttJsonFunc

type DBGttJsonFunc func() interface{}

type DBGttStringFunc

type DBGttStringFunc func() string

type FindManyResult

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

func (*FindManyResult) Many

func (f *FindManyResult) Many(result interface{}) error

type FindManyResultI

type FindManyResultI interface {
	Many(result interface{}) error
}

type FindOneResult

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

func (*FindOneResult) One

func (f *FindOneResult) One(result interface{}) error

type FindOneResultI

type FindOneResultI interface {
	One(result interface{}) error
}

type FindResult

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

func (*FindResult) Many

func (f *FindResult) Many(result interface{}) error

type FindResultI

type FindResultI interface {
	Many(result interface{}) error
}

type GormClient

type GormClient struct {
	Db *gorm.DB // 驱动
	// contains filtered or unexported fields
}

GormClient https://gorm.io/

func NewGormMysqlClient

func NewGormMysqlClient(config *ConfigGormClient) (*GormClient, error)

func NewGormPostgresClient

func NewGormPostgresClient(config *ConfigGormClient) (*GormClient, error)

func NewGormPostgresqlClient

func NewGormPostgresqlClient(config *ConfigGormClient) (*GormClient, error)

func NewGormSqlServerClient

func NewGormSqlServerClient(config *ConfigGormClient) (*GormClient, error)

func (*GormClient) Begin

func (c *GormClient) Begin() *gorm.DB

Begin 开始事务,不需要创建 Session 对象

func (*GormClient) Commit

func (c *GormClient) Commit() *gorm.DB

Commit 提交事务

func (*GormClient) GetDb

func (c *GormClient) GetDb() *gorm.DB

func (*GormClient) Rollback

func (c *GormClient) Rollback() *gorm.DB

Rollback 回滚事务

type HashOperation

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

func NewHashOperation

func NewHashOperation(db *redis.Client, ctx context.Context) *HashOperation

NewHashOperation hash类型数据操作 https://www.tizi365.com/archives/296.html

func (*HashOperation) Get

func (cl *HashOperation) Get(key, field string) *redis.StringCmd

Get 根据key和field字段设置,field字段的值

func (*HashOperation) Set

func (cl *HashOperation) Set(key string, value interface{}) *redis.IntCmd

Set 根据key和field字段设置,field字段的值

type Iterator

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

func NewIterator

func NewIterator(data []interface{}) *Iterator

NewIterator 构造函数

func (*Iterator) HasNext

func (i *Iterator) HasNext() bool

HasNext 是否有下一个

func (*Iterator) Next

func (i *Iterator) Next() (Ret interface{})

Next 循环下一个

type JsonGttFunc

type JsonGttFunc func() interface{}

type ListOperation

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

func (*ListOperation) Index

func (cl *ListOperation) Index(key string, index int64) *redis.StringCmd

Index 根据索引坐标,查询key中的数据

func (*ListOperation) Insert

func (cl *ListOperation) Insert(key, op string, pivot, value interface{}) *redis.IntCmd

Insert 在指定位置插入数据

func (*ListOperation) LPop

func (cl *ListOperation) LPop(key string) *redis.StringCmd

LPop 从列表左边删除第一个数据,并返回删除的数据

func (*ListOperation) LPush

func (cl *ListOperation) LPush(key string, value interface{}) *redis.IntCmd

LPush 从列表左边插入数据

func (*ListOperation) LPushX

func (cl *ListOperation) LPushX(key string, value interface{}) *redis.IntCmd

LPushX 跟LPush的区别是,仅当列表存在的时候才插入数据

func (*ListOperation) Len

func (cl *ListOperation) Len(key string) *redis.IntCmd

Len 返回列表的大小

func (*ListOperation) RPop

func (cl *ListOperation) RPop(key string) *redis.StringCmd

RPop 从列表的右边删除第一个数据,并返回删除的数据

func (*ListOperation) RPush

func (cl *ListOperation) RPush(key string, value interface{}) *redis.IntCmd

RPush 从列表右边插入数据

func (*ListOperation) RPushX

func (cl *ListOperation) RPushX(key string, value interface{}) *redis.IntCmd

RPushX 跟RPush的区别是,仅当列表存在的时候才插入数据

func (*ListOperation) Range

func (cl *ListOperation) Range(key string, start, stop int64) *redis.StringSliceCmd

Range 返回列表的一个范围内的数据,也可以返回全部数据

func (*ListOperation) RangeAli

func (cl *ListOperation) RangeAli(key string) *redis.StringSliceCmd

RangeAli 返回key全部数据

func (*ListOperation) Rem

func (cl *ListOperation) Rem(key string, count int64, value interface{}) *redis.IntCmd

Rem 删除key中的数据

type MongoClient

type MongoClient struct {
	Db *mongo.Client // 驱动
	// contains filtered or unexported fields
}

func NewMongoClient

func NewMongoClient(config *ConfigMongoClient) (*MongoClient, error)

func (*MongoClient) AggregateByFiltersSort

func (c *MongoClient) AggregateByFiltersSort(pipeline interface{}) (result *mongo.Cursor, err error)

AggregateByFiltersSort 统计分析

func (*MongoClient) Begin

func (c *MongoClient) Begin() (ms MongoTransaction, err error)

Begin 开始事务,会同时创建开始会话需要在退出时关闭会话

func (*MongoClient) Close

func (c *MongoClient) Close() error

Close 关闭

func (*MongoClient) Collection

func (c *MongoClient) Collection(collectionName string) *MongoClient

Collection 设置表名

func (*MongoClient) CollectionCount

func (c *MongoClient) CollectionCount() (name string, size int64)

CollectionCount 查询集合里有多少数据

func (*MongoClient) CollectionDocuments

func (c *MongoClient) CollectionDocuments(Skip, Limit int64, sort int, key string, value interface{}) (result *mongo.Cursor, err error)

CollectionDocuments 按选项查询集合 Skip 跳过 Limit 读取数量 sort 1 ,-1 . 1 为升序 , -1 为降序

func (*MongoClient) CountDocumentsByFilters

func (c *MongoClient) CountDocumentsByFilters(filter interface{}) (count int64, err error)

CountDocumentsByFilters 统计数量

func (*MongoClient) Database

func (c *MongoClient) Database(databaseName string) *MongoClient

Database 设置库名

func (*MongoClient) Delete

func (c *MongoClient) Delete(filter interface{}) (err error)

Delete 删除文档

func (*MongoClient) DeleteId

func (c *MongoClient) DeleteId(id interface{}) (err error)

DeleteId 删除文档

func (*MongoClient) DeleteMany

func (c *MongoClient) DeleteMany(filter interface{}) (result *mongo.DeleteResult, err error)

DeleteMany 删除多个文档

func (*MongoClient) Find

func (c *MongoClient) Find(filter interface{}) (*mongo.Cursor, error)

Find 查询

func (*MongoClient) FindCollection

func (c *MongoClient) FindCollection(Limit int64) (result *mongo.Cursor, err error)

FindCollection 查询集合文档

func (*MongoClient) FindCollectionSort

func (c *MongoClient) FindCollectionSort(Sort interface{}, Limit int64) (result *mongo.Cursor, err error)

FindCollectionSort 查询集合文档支持排序

func (*MongoClient) FindMany

func (c *MongoClient) FindMany(filter interface{}) (*mongo.Cursor, error)

FindMany 查询多个文档

func (*MongoClient) FindManyByFilters

func (c *MongoClient) FindManyByFilters(filter interface{}) (result *mongo.Cursor, err error)

FindManyByFilters 多条件查询

func (*MongoClient) FindManyByFiltersSort

func (c *MongoClient) FindManyByFiltersSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

FindManyByFiltersSort 多条件查询支持排序

func (*MongoClient) FindManyCollectionSort

func (c *MongoClient) FindManyCollectionSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

FindManyCollectionSort 查询集合文档支持排序支持条件

func (*MongoClient) FindOne

func (c *MongoClient) FindOne(filter interface{}) *mongo.SingleResult

FindOne 查询单个文档

func (*MongoClient) GetDb

func (c *MongoClient) GetDb() *mongo.Client

GetDb 获取驱动

func (*MongoClient) InsertMany

func (c *MongoClient) InsertMany(documents []interface{}) (result *mongo.InsertManyResult, err error)

InsertMany 插入多个文档

func (*MongoClient) InsertOne

func (c *MongoClient) InsertOne(document interface{}) (result *mongo.InsertOneResult, err error)

InsertOne 插入一个文档

func (*MongoClient) Model

func (c *MongoClient) Model(value interface{}) *MongoClient

Model 传入模型自动获取库名和表名

func (*MongoClient) UpdateId

func (c *MongoClient) UpdateId(id interface{}, update interface{}) (err error)

UpdateId 更新单个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

func (*MongoClient) UpdateMany

func (c *MongoClient) UpdateMany(filter interface{}, update interface{}) (result *mongo.UpdateResult, err error)

UpdateMany 更新多个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

func (*MongoClient) UpdateOne

func (c *MongoClient) UpdateOne(filter interface{}, update interface{}) (err error)

UpdateOne 更新单个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

type MongoTransaction

type MongoTransaction struct {
	Session mongo.SessionContext
	// contains filtered or unexported fields
}

func (*MongoTransaction) AggregateByFiltersSort

func (ms *MongoTransaction) AggregateByFiltersSort(pipeline interface{}) (result *mongo.Cursor, err error)

AggregateByFiltersSort 统计分析

func (*MongoTransaction) Close

func (ms *MongoTransaction) Close()

Close 关闭会话

func (*MongoTransaction) Collection

func (ms *MongoTransaction) Collection(collectionName string) *MongoTransaction

Collection 设置表名

func (*MongoTransaction) CollectionCount

func (ms *MongoTransaction) CollectionCount(ctx context.Context) (name string, size int64)

CollectionCount 查询集合里有多少数据

func (*MongoTransaction) CollectionDocuments

func (ms *MongoTransaction) CollectionDocuments(Skip, Limit int64, sort int, key string, value interface{}) (result *mongo.Cursor, err error)

CollectionDocuments 按选项查询集合 Skip 跳过 Limit 读取数量 sort 1 ,-1 . 1 为升序 , -1 为降序

func (*MongoTransaction) Commit

func (ms *MongoTransaction) Commit() error

Commit 提交事务

func (*MongoTransaction) CountDocumentsByFilters

func (ms *MongoTransaction) CountDocumentsByFilters(filter interface{}) (count int64, err error)

CountDocumentsByFilters 统计数量

func (*MongoTransaction) Database

func (ms *MongoTransaction) Database(databaseName string) *MongoTransaction

Database 设置库名

func (*MongoTransaction) Delete

func (ms *MongoTransaction) Delete(filter interface{}) (err error)

Delete 删除文档

func (*MongoTransaction) DeleteId

func (ms *MongoTransaction) DeleteId(id interface{}) (err error)

DeleteId 删除文档

func (*MongoTransaction) DeleteMany

func (ms *MongoTransaction) DeleteMany(key string, value interface{}) (result *mongo.DeleteResult, err error)

DeleteMany 删除多个文档

func (*MongoTransaction) Find

func (ms *MongoTransaction) Find(filter interface{}) (*mongo.Cursor, error)

Find 查询

func (*MongoTransaction) FindCollection

func (ms *MongoTransaction) FindCollection(Limit int64) (result *mongo.Cursor, err error)

FindCollection 查询集合文档

func (*MongoTransaction) FindCollectionSort

func (ms *MongoTransaction) FindCollectionSort(Sort interface{}, Limit int64) (result *mongo.Cursor, err error)

FindCollectionSort 查询集合文档支持排序

func (*MongoTransaction) FindMany

func (ms *MongoTransaction) FindMany(filter interface{}) (*mongo.Cursor, error)

FindMany 查询多个文档

func (*MongoTransaction) FindManyByFilters

func (ms *MongoTransaction) FindManyByFilters(filter interface{}) (result *mongo.Cursor, err error)

FindManyByFilters 多条件查询

func (*MongoTransaction) FindManyByFiltersSort

func (ms *MongoTransaction) FindManyByFiltersSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

FindManyByFiltersSort 多条件查询支持排序

func (*MongoTransaction) FindManyCollectionSort

func (ms *MongoTransaction) FindManyCollectionSort(filter interface{}, Sort interface{}) (result *mongo.Cursor, err error)

FindManyCollectionSort 查询集合文档支持排序支持条件

func (*MongoTransaction) FindOne

func (ms *MongoTransaction) FindOne(filter interface{}) *mongo.SingleResult

FindOne 查询单个文档

func (*MongoTransaction) InsertMany

func (ms *MongoTransaction) InsertMany(documents []interface{}) (result *mongo.InsertManyResult, err error)

InsertMany 插入多个文档

func (*MongoTransaction) InsertOne

func (ms *MongoTransaction) InsertOne(document interface{}) (result *mongo.InsertOneResult, err error)

InsertOne 插入一个文档

func (*MongoTransaction) Model

func (ms *MongoTransaction) Model(value interface{}) *MongoTransaction

Model 传入模型自动获取库名和表名

func (*MongoTransaction) Rollback

func (ms *MongoTransaction) Rollback() error

Rollback 回滚事务

func (*MongoTransaction) UpdateId

func (ms *MongoTransaction) UpdateId(id interface{}, update interface{}) (err error)

UpdateId 更新单个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

func (*MongoTransaction) UpdateMany

func (ms *MongoTransaction) UpdateMany(filter interface{}, update interface{}) (result *mongo.UpdateResult, err error)

UpdateMany 更新多个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

func (*MongoTransaction) UpdateOne

func (ms *MongoTransaction) UpdateOne(filter interface{}, update interface{}) (err error)

UpdateOne 更新单个文档 修改字段的值($set) 字段增加值 inc($inc) 从数组中增加一个元素 push($push) 从数组中删除一个元素 pull($pull)

type OperationAttr

type OperationAttr struct {
	Name  string
	Value interface{}
}

func WithExpire

func WithExpire(t time.Duration) *OperationAttr

WithExpire 过期时间

func WithNX

func WithNX() *OperationAttr

type OperationAttrs

type OperationAttrs []*OperationAttr

func (OperationAttrs) Find

func (a OperationAttrs) Find(name string) interface{}

type RedisClient

type RedisClient struct {
	Db *redis.Client // 驱动
	// contains filtered or unexported fields
}

RedisClient https://redis.uptrace.dev/

func NewRedisClient

func NewRedisClient(config *ConfigRedisClient) (*RedisClient, error)

func (*RedisClient) GetDb

func (c *RedisClient) GetDb() *redis.Client

func (*RedisClient) NewListOperation

func (c *RedisClient) NewListOperation() *ListOperation

NewListOperation 列表(list)类型数据操作 https://www.tizi365.com/archives/299.html

func (*RedisClient) NewSimpleCache

func (c *RedisClient) NewSimpleCache(operation *StringOperation, expire time.Duration, serializer string) *SimpleCache

NewSimpleCache 构造函数

func (*RedisClient) NewSimpleInterfaceCache

func (c *RedisClient) NewSimpleInterfaceCache(operation *SimpleOperation, expire time.Duration) *SimpleInterfaceCache

NewSimpleInterfaceCache 构造函数

func (*RedisClient) NewSimpleJsonCache

func (c *RedisClient) NewSimpleJsonCache(operation *StringOperation, expire time.Duration) *SimpleJsonCache

NewSimpleJsonCache 构造函数

func (*RedisClient) NewSimpleOperation

func (c *RedisClient) NewSimpleOperation() *SimpleOperation

func (*RedisClient) NewSimpleStringCache

func (c *RedisClient) NewSimpleStringCache(operation *StringOperation, expire time.Duration) *SimpleStringCache

NewSimpleStringCache 构造函数

func (*RedisClient) NewStringOperation

func (c *RedisClient) NewStringOperation() *StringOperation

type RedisClient6

type RedisClient6 struct {
	Db *redis.Client // 驱动
	// contains filtered or unexported fields
}

RedisClient6 https://redis.uptrace.dev/

func NewRedisClient6

func NewRedisClient6(config *ConfigRedisClient) (*RedisClient6, error)

NewRedisClient6 Redis 6

func (*RedisClient6) GetDb

func (c *RedisClient6) GetDb() *redis.Client

type RedisClient7

type RedisClient7 struct {
	Db *redis.Client // 驱动
	// contains filtered or unexported fields
}

RedisClient7 https://redis.uptrace.dev/

func NewRedisClient7

func NewRedisClient7(config *ConfigRedisClient) (*RedisClient7, error)

NewRedisClient7 Redis 7

func (*RedisClient7) GetDb

func (c *RedisClient7) GetDb() *redis.Client

type SimpleCache

type SimpleCache struct {
	Operation  *StringOperation // 操作类
	Expire     time.Duration    // 过去时间
	DBGetter   DBGttFunc        // 缓存不存在的操作 DB
	JsonGetter JsonGttFunc      // 缓存不存在的操作 JSON
	Serializer string           // 序列化方式
}

SimpleCache 缓存

func (*SimpleCache) GetCache

func (c *SimpleCache) GetCache(key string) (ret interface{})

GetCache 获取缓存

func (*SimpleCache) SetCache

func (c *SimpleCache) SetCache(key string, value interface{})

SetCache 设置缓存

type SimpleInterfaceCache

type SimpleInterfaceCache struct {
	Operation *SimpleOperation   // 操作类
	Expire    time.Duration      // 过期时间
	DBGetter  DBGttInterfaceFunc // 缓存不存在的操作 DB
}

SimpleInterfaceCache 缓存

func (*SimpleInterfaceCache) GetCache

func (c *SimpleInterfaceCache) GetCache(key string) (ret interface{})

GetCache 获取缓存

func (*SimpleInterfaceCache) SetCache

func (c *SimpleInterfaceCache) SetCache(key string, value interface{})

SetCache 设置缓存

type SimpleJsonCache

type SimpleJsonCache struct {
	Operation *StringOperation // 操作类
	Expire    time.Duration    // 过期时间
	DBGetter  DBGttJsonFunc    // 缓存不存在的操作 DB
}

SimpleJsonCache 缓存

func (*SimpleJsonCache) GetCache

func (c *SimpleJsonCache) GetCache(key string) (ret interface{})

GetCache 获取缓存

func (*SimpleJsonCache) SetCache

func (c *SimpleJsonCache) SetCache(key string, value interface{})

SetCache 设置缓存

type SimpleOperation

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

func (*SimpleOperation) Del

func (o *SimpleOperation) Del(keys ...string) *redis.IntCmd

Del 删除key操作,支持批量删除

func (*SimpleOperation) Get

func (o *SimpleOperation) Get(key string) *SimpleResult

Get 获取单个

func (*SimpleOperation) Set

func (o *SimpleOperation) Set(key string, value interface{}, attrs ...*OperationAttr) *SimpleResult

Set 设置

type SimpleResult

type SimpleResult struct {
	Result interface{}
	Err    error
}

func NewSimpleResult

func NewSimpleResult(result interface{}, err error) *SimpleResult

NewSimpleResult 构造函数

func (*SimpleResult) Unwrap

func (r *SimpleResult) Unwrap() interface{}

Unwrap 空值情况下返回错误

func (*SimpleResult) UnwrapOr

func (r *SimpleResult) UnwrapOr(defaults interface{}) interface{}

UnwrapOr 空值情况下设置返回默认值

func (*SimpleResult) UnwrapOrElse

func (r *SimpleResult) UnwrapOrElse(f func() interface{}) interface{}

UnwrapOrElse 空值情况下设置返回其他

type SimpleStringCache

type SimpleStringCache struct {
	Operation *StringOperation // 操作类
	Expire    time.Duration    // 过期时间
	DBGetter  DBGttStringFunc  // 缓存不存在的操作 DB
}

SimpleStringCache 缓存

func (*SimpleStringCache) GetCache

func (c *SimpleStringCache) GetCache(key string) (ret string)

GetCache 获取缓存

func (*SimpleStringCache) SetCache

func (c *SimpleStringCache) SetCache(key string, value string)

SetCache 设置缓存

type SliceResult

type SliceResult struct {
	Result []interface{}
	Err    error
}

func NewSliceResult

func NewSliceResult(result []interface{}, err error) *SliceResult

NewSliceResult 构造函数

func (*SliceResult) Iter

func (r *SliceResult) Iter() *Iterator

func (*SliceResult) Unwrap

func (r *SliceResult) Unwrap() []interface{}

Unwrap 空值情况下返回错误

func (*SliceResult) UnwrapOr

func (r *SliceResult) UnwrapOr(defaults []interface{}) []interface{}

UnwrapOr 空值情况下设置返回默认值

type StringOperation

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

func (*StringOperation) Del

func (o *StringOperation) Del(keys ...string) *redis.IntCmd

Del 删除key操作,支持批量删除

func (*StringOperation) Get

func (o *StringOperation) Get(key string) *StringResult

Get 获取单个

func (*StringOperation) MGet

func (o *StringOperation) MGet(keys ...string) *SliceResult

MGet 获取多个

func (*StringOperation) Set

func (o *StringOperation) Set(key string, value interface{}, attrs ...*OperationAttr) *StringResult

Set 设置

type StringResult

type StringResult struct {
	Result string // 结果
	Err    error  // 错误
}

func NewStringResult

func NewStringResult(result string, err error) *StringResult

NewStringResult 构造函数

func (*StringResult) Unwrap

func (r *StringResult) Unwrap() string

Unwrap 空值情况下返回错误

func (*StringResult) UnwrapOr

func (r *StringResult) UnwrapOr(defaults string) string

UnwrapOr 空值情况下设置返回默认值

func (*StringResult) UnwrapOrElse

func (r *StringResult) UnwrapOrElse(f func() string) string

UnwrapOrElse 空值情况下设置返回其他

type UpperClient

type UpperClient struct {
	Db *db.Session // 驱动
}

UpperClient https://upper.io/

func NewUpperCockroachdbClient

func NewUpperCockroachdbClient(settings cockroachdb.ConnectionURL) (*UpperClient, error)

func NewUpperMongodbClient

func NewUpperMongodbClient(settings mongo.ConnectionURL) (*UpperClient, error)

func NewUpperMssqlClient

func NewUpperMssqlClient(settings mssql.ConnectionURL) (*UpperClient, error)

func NewUpperMysqlClient

func NewUpperMysqlClient(settings mysql.ConnectionURL) (*UpperClient, error)

func NewUpperPostgresqlClient

func NewUpperPostgresqlClient(settings postgresql.ConnectionURL) (*UpperClient, error)

func NewUpperQlClient

func NewUpperQlClient(settings ql.ConnectionURL) (*UpperClient, error)

type XormClient

type XormClient struct {
	Db *xorm.Engine // 驱动
	// contains filtered or unexported fields
}

XormClient https://xorm.io/

func NewXormMysqlClient

func NewXormMysqlClient(config *ConfigXormClient) (*XormClient, error)

func NewXormPostgresClient

func NewXormPostgresClient(config *ConfigXormClient) (*XormClient, error)

type XormClientSession

type XormClientSession struct {
	*xorm.Session
}

XormClientSession https://xorm.io/zh/docs/chapter-10/readme/

type ZormClient

type ZormClient struct {
	Db *zorm.DBDao // 驱动
	// contains filtered or unexported fields
}

ZormClient https://zorm.cn/ https://www.yuque.com/u27016943/nrgi00

func NewZormClickhouseClient

func NewZormClickhouseClient(config *ConfigZormClient) (*ZormClient, error)

func NewZormDmClient

func NewZormDmClient(config *ConfigZormClient) (*ZormClient, error)

func NewZormMysqlClient

func NewZormMysqlClient(config *ConfigZormClient) (*ZormClient, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL