mongodb

package
v0.3.2 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	WhereIs = iota
	WhereNot
	WhereGt
	WhereLt
	WhereOr
	OrderAsc
	OrderDesc
	WhereGte
	WhereLte
)

Variables

This section is empty.

Functions

func ConvertToBSONM added in v0.2.1

func ConvertToBSONM(data any) (bson.M, error)

转换data TO bsonM

func Init

func Init() (orm.ORM, error)

Types

type CtxKey added in v0.1.4

type CtxKey string

type DBConn

type DBConn struct {
	Database      string //连接的数据库
	NearestClient *mongo.Client
	*mongo.Client
}
var ORMConn *DBConn

func (DBConn) Model

func (m DBConn) Model(data any) orm.ORMModel

type IDModel added in v0.0.4

type IDModel struct {
	ID primitive.ObjectID `bson:"_id"`
}

type Model

type Model struct {
	Tx         DBConn
	Data       any
	OpList     *sync.Map // key:操作模式Mode value:操作值
	WhereList  bson.M
	Ctx        *context.Context //上下文
	Collection string
}

func (Model) Asc

func (m Model) Asc(condition any) orm.ORMModel

正序

func (Model) BulkWrite added in v0.1.9

func (m Model) BulkWrite(datas any, order bool) error

func (Model) CheckOID added in v0.1.5

func (m Model) CheckOID()

func (Model) Create

func (m Model) Create(data any) (id string, err error)

func (Model) Delete

func (m Model) Delete(data any) error

删除

func (Model) Desc

func (m Model) Desc(condition any) orm.ORMModel

逆序

func (Model) Find

func (m Model) Find() orm.ORMQuary

查询数据

func (Model) GetCollection

func (m Model) GetCollection(dest any) string

获取集合

func (Model) GetContext added in v0.0.4

func (m Model) GetContext() context.Context

func (Model) GetValue added in v0.1.4

func (m Model) GetValue(key string) (any, bool)

func (Model) Limit

func (m Model) Limit(limit int) orm.ORMModel

限制查询的数量

func (Model) Offset

func (m Model) Offset(offset int) orm.ORMModel

跳过查询的数量

func (Model) Page

func (m Model) Page(page, limit int) orm.ORMModel

func (Model) Save

func (m Model) Save(data any, value ...any) (id string, err error)

更新或插入数据

func (Model) Session added in v0.0.4

func (m Model) Session(transactionFunc func(SessionContext context.Context) error) error

启动事务做函数调用

func (Model) SetContext added in v0.0.4

func (m Model) SetContext(ctx context.Context) orm.ORMModel

func (Model) SetValue added in v0.1.4

func (m Model) SetValue(key string, value any) orm.ORMModel

func (Model) Update

func (m Model) Update(data any, value ...any) error

修改

func (Model) Where

func (m Model) Where(condition any, value ...any) orm.ORMModel

限制条件

func (Model) WhereGt

func (m Model) WhereGt(condition any, value ...any) orm.ORMModel

func (Model) WhereGte added in v0.1.1

func (m Model) WhereGte(condition any, value ...any) orm.ORMModel

func (Model) WhereIs

func (m Model) WhereIs(key string, value any) orm.ORMModel

func (Model) WhereLt

func (m Model) WhereLt(condition any, value ...any) orm.ORMModel

func (Model) WhereLte added in v0.1.1

func (m Model) WhereLte(condition any, value ...any) orm.ORMModel

func (Model) WhereNot

func (m Model) WhereNot(condition any, value ...any) orm.ORMModel

func (Model) WhereOr

func (m Model) WhereOr(condition any, value ...any) orm.ORMModel

type Quary

type Quary struct {
	Where bson.M
	// contains filtered or unexported fields
}

func (Quary) All

func (q Quary) All(data any) error

查询全部

func (Quary) Count

func (q Quary) Count() (int64, error)

func (Quary) Delete added in v0.0.4

func (q Quary) Delete() error

删除查询结果

func (Quary) One

func (q Quary) One(data any) error

type Table

type Table interface {
	TableName() string
}

Jump to

Keyboard shortcuts

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