Documentation ¶
Index ¶
- type Collection
- func (c *Collection) AddColumn(ctx context.Context, column string, value interface{}) error
- func (c *Collection) AggregateAll(ctx context.Context, pipeline interface{}, result interface{}) error
- func (c *Collection) AggregateOne(ctx context.Context, pipeline interface{}, result interface{}) error
- func (c *Collection) CreateIndex(ctx context.Context, index dal.Index) error
- func (c *Collection) Delete(ctx context.Context, filter dal.Filter) error
- func (c *Collection) DropColumn(ctx context.Context, field string) error
- func (c *Collection) DropIndex(ctx context.Context, indexName string) error
- func (c *Collection) Find(filter dal.Filter) dal.Find
- func (c *Collection) Indexes(ctx context.Context) ([]dal.Index, error)
- func (c *Collection) Insert(ctx context.Context, docs interface{}) error
- func (c *Collection) RenameColumn(ctx context.Context, oldName, newColumn string) error
- func (c *Collection) Update(ctx context.Context, filter dal.Filter, doc interface{}) error
- type Find
- func (f *Find) All(ctx context.Context, result interface{}) error
- func (f *Find) Count(ctx context.Context) (uint64, error)
- func (f *Find) Fields(fields ...string) dal.Find
- func (f *Find) Limit(limit uint64) dal.Find
- func (f *Find) One(ctx context.Context, result interface{}) error
- func (f *Find) Sort(sort string) dal.Find
- func (f *Find) Start(start uint64) dal.Find
- type Idgen
- type Mock
- func (c *Mock) Abort(ctx context.Context) error
- func (c *Mock) Clone() dal.DB
- func (c *Mock) Close() error
- func (c *Mock) Commit(ctx context.Context) error
- func (c *Mock) CreateTable(collName string) error
- func (c *Mock) DropTable(collName string) error
- func (c *Mock) HasTable(collName string) (bool, error)
- func (c *Mock) IsDuplicatedError(err error) bool
- func (c *Mock) IsNotFoundError(err error) bool
- func (c *Mock) Mock(retval MockResult) *Mock
- func (c *Mock) NextSequence(ctx context.Context, sequenceName string) (uint64, error)
- func (c *Mock) Ping() error
- func (c *Mock) StartTransaction(ctx context.Context) (dal.DB, error)
- func (c *Mock) Table(collName string) dal.Table
- func (c *Mock) TxnInfo() *types.Transaction
- type MockCollection
- func (c *MockCollection) AddColumn(ctx context.Context, column string, value interface{}) error
- func (c *MockCollection) AggregateAll(ctx context.Context, pipeline interface{}, result interface{}) error
- func (c *MockCollection) AggregateOne(ctx context.Context, pipeline interface{}, result interface{}) error
- func (c *MockCollection) CreateIndex(ctx context.Context, index dal.Index) error
- func (c *MockCollection) Delete(ctx context.Context, filter dal.Filter) error
- func (c *MockCollection) DropColumn(ctx context.Context, field string) error
- func (c *MockCollection) DropIndex(ctx context.Context, indexName string) error
- func (c *MockCollection) Find(filter dal.Filter) dal.Find
- func (c *MockCollection) Indexes(ctx context.Context) ([]dal.Index, error)
- func (c *MockCollection) Insert(ctx context.Context, docs interface{}) error
- func (c *MockCollection) RenameColumn(ctx context.Context, oldName, newColumn string) error
- func (c *MockCollection) Update(ctx context.Context, filter dal.Filter, doc interface{}) error
- type MockFind
- func (f *MockFind) All(ctx context.Context, result interface{}) error
- func (f *MockFind) Count(ctx context.Context) (uint64, error)
- func (f *MockFind) Fields(fields ...string) dal.Find
- func (f *MockFind) Limit(limit uint64) dal.Find
- func (f *MockFind) One(ctx context.Context, result interface{}) error
- func (f *MockFind) Sort(sort string) dal.Find
- func (f *MockFind) Start(start uint64) dal.Find
- type MockResult
- type Mongo
- func (c *Mongo) Abort(ctx context.Context) error
- func (c *Mongo) Clone() dal.DB
- func (c *Mongo) Close() error
- func (c *Mongo) Commit(ctx context.Context) error
- func (c *Mongo) CreateTable(collName string) error
- func (c *Mongo) DropTable(collName string) error
- func (c *Mongo) HasTable(collName string) (bool, error)
- func (c *Mongo) IsDuplicatedError(err error) bool
- func (c *Mongo) IsNotFoundError(err error) bool
- func (c *Mongo) NextSequence(ctx context.Context, sequenceName string) (uint64, error)
- func (c *Mongo) Ping() error
- func (c *Mongo) StartTransaction(ctx context.Context) (dal.DB, error)
- func (c *Mongo) Table(collName string) dal.Table
- func (c *Mongo) TxnInfo() *types.Transaction
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Collection ¶
type Collection struct { *Mongo // contains filtered or unexported fields }
Collection implement client.Collection interface
func (*Collection) AddColumn ¶
func (c *Collection) AddColumn(ctx context.Context, column string, value interface{}) error
AddColumn add a new column for the collection
func (*Collection) AggregateAll ¶
func (c *Collection) AggregateAll(ctx context.Context, pipeline interface{}, result interface{}) error
AggregateAll aggregate all operation
func (*Collection) AggregateOne ¶
func (c *Collection) AggregateOne(ctx context.Context, pipeline interface{}, result interface{}) error
AggregateOne aggregate one operation
func (*Collection) CreateIndex ¶
CreateIndex 创建索引
func (*Collection) DropColumn ¶
func (c *Collection) DropColumn(ctx context.Context, field string) error
DropColumn remove a column by the name
func (*Collection) DropIndex ¶
func (c *Collection) DropIndex(ctx context.Context, indexName string) error
DropIndex remove index by name
func (*Collection) Find ¶
func (c *Collection) Find(filter dal.Filter) dal.Find
Find 查询多个并反序列化到 Result
func (*Collection) Insert ¶
func (c *Collection) Insert(ctx context.Context, docs interface{}) error
Insert 插入数据, docs 可以为 单个数据 或者 多个数据
func (*Collection) RenameColumn ¶
func (c *Collection) RenameColumn(ctx context.Context, oldName, newColumn string) error
RenameColumn rename a column for the collection
type Find ¶
type Find struct { *Collection // contains filtered or unexported fields }
Find define a find operation
type Mock ¶
type Mock struct {
// contains filtered or unexported fields
}
Mock implement client.DALRDB interface
func (*Mock) IsDuplicatedError ¶
IsDuplicatedError returns whether error is Duplicated Error
func (*Mock) IsNotFoundError ¶
IsNotFoundError returns whether error is Not Found Error
func (*Mock) NextSequence ¶
NextSequence 获取新序列号(非事务)
func (*Mock) StartTransaction ¶
StartTransaction 开启新事务
type MockCollection ¶
type MockCollection struct { *Mock // contains filtered or unexported fields }
MockCollection implement client.Collection interface
func (*MockCollection) AddColumn ¶
func (c *MockCollection) AddColumn(ctx context.Context, column string, value interface{}) error
AddColumn 添加字段
func (*MockCollection) AggregateAll ¶
func (c *MockCollection) AggregateAll(ctx context.Context, pipeline interface{}, result interface{}) error
func (*MockCollection) AggregateOne ¶
func (c *MockCollection) AggregateOne(ctx context.Context, pipeline interface{}, result interface{}) error
func (*MockCollection) CreateIndex ¶
CreateIndex 创建索引
func (*MockCollection) DropColumn ¶
func (c *MockCollection) DropColumn(ctx context.Context, field string) error
DropColumn 移除字段
func (*MockCollection) DropIndex ¶
func (c *MockCollection) DropIndex(ctx context.Context, indexName string) error
DropIndex 移除索引
func (*MockCollection) Find ¶
func (c *MockCollection) Find(filter dal.Filter) dal.Find
Find 查询多个并反序列化到 Result
func (*MockCollection) Insert ¶
func (c *MockCollection) Insert(ctx context.Context, docs interface{}) error
Insert 插入数据, docs 可以为 单个数据 或者 多个数据
func (*MockCollection) RenameColumn ¶
func (c *MockCollection) RenameColumn(ctx context.Context, oldName, newColumn string) error
RenameColumn 重命名字段
type MockFind ¶
type MockFind struct { *MockCollection `json:"-"` // contains filtered or unexported fields }
MockFind define a find operation
type MockResult ¶
type MockResult struct { Err error OK bool RawResult []byte Count uint64 SequenceID uint64 Info types.Transaction Indexs []dal.Index }
MockResult the result mock
type Mongo ¶
type Mongo struct {
// contains filtered or unexported fields
}
Mongo implement client.DALRDB interface
func (*Mongo) IsDuplicatedError ¶
IsDuplicatedError check duplicated error
func (*Mongo) IsNotFoundError ¶
IsNotFoundError check the not found error
func (*Mongo) NextSequence ¶
NextSequence 获取新序列号(非事务)
func (*Mongo) StartTransaction ¶
StartTransaction 开启新事务