mongo

package
v0.0.0-...-d705234 Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source
const (
	PrimaryMode            = readpref.PrimaryMode
	PrimaryPreferredMode   = readpref.PrimaryPreferredMode
	SecondaryMode          = readpref.SecondaryMode
	SecondaryPreferredMode = readpref.SecondaryPreferredMode
	NearestMode            = readpref.NearestMode
)

Mode constants

View Source
const (
	AutoLang  = "1"
	StatusNo  = 0
	StatusYes = 1
)

Variables

View Source
var (
	DefaultSetting = Setting{
		FindByTmmId:     StatusYes,
		FindByPhone:     StatusYes,
		AddFromGroup:    StatusYes,
		AddFromQrCode:   StatusYes,
		AddFromCard:     StatusYes,
		AddFromMoments:  StatusYes,
		AddFromDiscover: StatusYes,
	}
)

Functions

func BeforeCreate

func BeforeCreate(document interface{}) interface{}

BeforeCreate

func BeforeUpdate

func BeforeUpdate(document interface{}) interface{}

BeforeUpdate

func DataIsSaveSuccessfully

func DataIsSaveSuccessfully(err error) bool

func GetMongoFieldsBsonByString

func GetMongoFieldsBsonByString(fields string) bson.M

func IsDuplicateKeyError

func IsDuplicateKeyError(err error) bool

func IsIntn

func IsIntn(p reflect.Kind) bool

IsIntn

func IsNoDocumentErr

func IsNoDocumentErr(err error) bool

func Start

func Start()

Start mongo

Types

type CollectionInfo

type CollectionInfo struct {
	Database   *mongo.Database
	Collection *mongo.Collection
	// contains filtered or unexported fields
}

func Database

func Database(name ...string) *CollectionInfo

func (*CollectionInfo) Aggregate

func (collection *CollectionInfo) Aggregate(pipeline interface{}, documents interface{}) error

func (*CollectionInfo) Count

func (collection *CollectionInfo) Count() (int64, error)

func (*CollectionInfo) Delete

func (collection *CollectionInfo) Delete() (int64, error)

func (CollectionInfo) DeleteField

func (collection CollectionInfo) DeleteField(field string) (*mongo.UpdateResult, error)

func (CollectionInfo) DeleteFields

func (collection CollectionInfo) DeleteFields(fields []string) (*mongo.UpdateResult, error)

func (*CollectionInfo) Fields

func (collection *CollectionInfo) Fields(fields interface{}) *CollectionInfo

Fields

func (*CollectionInfo) FindByID

func (collection *CollectionInfo) FindByID(id interface{}, document interface{}) error

func (*CollectionInfo) FindMany

func (collection *CollectionInfo) FindMany(documents interface{}) error

func (*CollectionInfo) FindOne

func (collection *CollectionInfo) FindOne(document interface{}) error

func (*CollectionInfo) InsertMany

func (collection *CollectionInfo) InsertMany(documents interface{}) ([]string, error)

InsertMany

func (*CollectionInfo) InsertOne

func (collection *CollectionInfo) InsertOne(document interface{}) (string, error)

InsertOne

func (*CollectionInfo) InsertOneOrigin

func (collection *CollectionInfo) InsertOneOrigin(document interface{}) (string, error)

func (*CollectionInfo) LBS

func (collection *CollectionInfo) LBS(pipeline interface{}, documents interface{}) error

func (*CollectionInfo) Limit

func (collection *CollectionInfo) Limit(n int64) *CollectionInfo

Limit

func (*CollectionInfo) SetTable

func (collection *CollectionInfo) SetTable(name string, mode ...Mode) *CollectionInfo

func (*CollectionInfo) Skip

func (collection *CollectionInfo) Skip(n int64) *CollectionInfo

Skip

func (*CollectionInfo) Sort

func (collection *CollectionInfo) Sort(sorts bson.M) *CollectionInfo

Sort bson.M{"create_time":-1}

func (CollectionInfo) UpByID

func (collection CollectionInfo) UpByID(id interface{}, document interface{}) (*mongo.UpdateResult, error)

func (*CollectionInfo) UpdateMany

func (collection *CollectionInfo) UpdateMany(document interface{}) (*mongo.UpdateResult, error)

UpdateMany

func (*CollectionInfo) UpdateOne

func (collection *CollectionInfo) UpdateOne(document interface{}) (*mongo.UpdateResult, error)

UpdateOne

func (*CollectionInfo) UpdateOrInsert

func (collection *CollectionInfo) UpdateOrInsert(documents interface{}) (*mongo.UpdateResult, error)

UpdateOrInsert documents must contain the _id field

func (*CollectionInfo) Upsert

func (collection *CollectionInfo) Upsert(document interface{}) *mongo.SingleResult

func (*CollectionInfo) UpsertByBson

func (collection *CollectionInfo) UpsertByBson(document interface{}) *mongo.SingleResult

func (*CollectionInfo) UpsertMany

func (collection *CollectionInfo) UpsertMany(document interface{}) (*mongo.UpdateResult, error)

func (*CollectionInfo) Where

func (collection *CollectionInfo) Where(m bson.M) *CollectionInfo

Where bson.M{"field": "value"}

type Mode

type Mode = readpref.Mode

type Setting

type Setting struct {
	ID              string `bson:"_id" json:"id"`
	FindByTmmId     int    `bson:"find_f_tid" json:"find_f_tid"`       // search by tmm id
	FindByPhone     uint8  `bson:"find_f_phone" json:"find_f_phone"`   // search by phone
	AddFromGroup    uint8  `bson:"add_f_group" json:"add_f_group"`     // added friend by group
	AddFromQrCode   uint8  `bson:"add_f_qrcode" json:"add_f_qrcode"`   // added friend by qr code
	AddFromCard     uint8  `bson:"add_f_card" json:"add_f_card"`       // added by card
	AddFromMoments  uint8  `bson:"add_f_moments" json:"add_f_moments"` //
	AddFromDiscover uint8  `bson:"add_f_disc" json:"add_f_disc"`
	Language        string `bson:"language" json:"language"`
	SubLang         string `bson:"sub_lang" json:"sub_lang"` // if language equal 1 (auto) ,sub_lang is system language
	CreatedAt       int64  `bson:"create_time" json:"create_time"`
	UpdatedAt       int64  `bson:"update_time" json:"update_time"`
	Seq             int64  `bson:"seq" json:"seq"`
}

func New

func New() *Setting

func (Setting) Add

func (s Setting) Add(data Setting) bool

func (Setting) GetByID

func (s Setting) GetByID(id, fields string) (Setting, error)

func (Setting) GetByIDs

func (s Setting) GetByIDs(ids []string, fields string) []Setting

func (Setting) GetFieldName

func (s Setting) GetFieldName(field string) string

func (Setting) TableName

func (s Setting) TableName() string

func (Setting) UpdateValue

func (s Setting) UpdateValue(id, field string, value interface{}) (bool, error)

Jump to

Keyboard shortcuts

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