mongo

package
v0.0.0-...-06d4dd4 Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2013 License: MIT Imports: 14 Imported by: 0

Documentation

Overview

Wraps MongoDB to make it compatible with the model package.

Built on top of Gustavo Niemeyer's great mgo package: http://labix.org/mgo

Index

Constants

This section is empty.

Variables

View Source 
var Collections = map[string]*Collection{}
View Source 
var Config = Configuration{
	Safe: mgo.Safe{
		W:     1,
		FSync: true,
		J:     true,
	},
	CheckQuerySelectors: true,
}
View Source 
var Database *mgo.Database

Functions

func CheckRefs 

func CheckRefs(refs []Ref) (validRefs []Ref, invalidRefs []Ref, err error)

nil refs will be ignored

func FindRefWithID 

func FindRefWithID(refs []Ref, id bson.ObjectId) (index int, found bool)

func InitLocalhost 

func InitLocalhost(database, user, password string) (err error)

func InitRefs 

func InitRefs(document interface{})

func MatchBsonField 

func MatchBsonField(bsonName string) reflection.MatchStructFieldFunc

func NewMongoIterator 

func NewMongoIterator(query Query) model.Iterator

func RemoveInvalidRefsInAllCollections 

func RemoveInvalidRefsInAllCollections() (invalidCollectionRefs map[string][]InvalidRefData, err error)

func ReverseBsonD 

func ReverseBsonD(d bson.D)

func SortRefs 

func SortRefs(refs []Ref, lessFunc func(a, b *Ref) bool)

Types

type Collection 

type Collection struct {
	Name              string
	DocLabelSelectors []string
	DocLabelSeparator string
	// contains filtered or unexported fields
}

Collection represents a MongoDB collection and implements mongo.Query for all documents in the collection.

Example for creating, modifying and saving a document: 

user := models.Users.NewDocument().(*models.User)

user.Name.First.Set("Erik")
user.Name.Last.Set("Unger")

err := user.Save()

func CollectionByName 

func CollectionByName(name string) (collection *Collection, ok bool)

func NewCollection 

func NewCollection(name string, documentLabelSelectors ...string) *Collection

func (*Collection) Collection 

func (self *Collection) Collection() *Collection

func (*Collection) Count 

func (self *Collection) Count() (n int, err error)

func (*Collection) DeleteAllNotWithIDs 

func (self *Collection) DeleteAllNotWithIDs(ids ...bson.ObjectId) (numDeleted int, err error)

func (*Collection) DeleteAllWithIDs 

func (self *Collection) DeleteAllWithIDs(ids ...bson.ObjectId) (numDeleted int, err error)

func (*Collection) DeleteWithID 

func (self *Collection) DeleteWithID(id bson.ObjectId) error

func (*Collection) DocumentIDs 

func (self *Collection) DocumentIDs() (ids []bson.ObjectId, err error)

func (*Collection) DocumentLabel 

func (self *Collection) DocumentLabel(docId bson.ObjectId, labelSelectors ...string) (string, error)

func (*Collection) DocumentWithID 

func (self *Collection) DocumentWithID(id bson.ObjectId, resultRef interface{}) error

func (*Collection) DocumentWithIDIterator 

func (self *Collection) DocumentWithIDIterator(id bson.ObjectId) model.Iterator

func (*Collection) Explain 

func (self *Collection) Explain() string

func (*Collection) Filter 

func (self *Collection) Filter(selector string, value interface{}) Query

func (*Collection) FilterAllIn 

func (self *Collection) FilterAllIn(selector string, values ...interface{}) Query

func (*Collection) FilterArraySize 

func (self *Collection) FilterArraySize(selector string, size int) Query

func (*Collection) FilterContains 

func (self *Collection) FilterContains(selector string, str string) Query

func (*Collection) FilterContainsCaseInsensitive 

func (self *Collection) FilterContainsCaseInsensitive(selector string, str string) Query

func (*Collection) FilterEndsWith 

func (self *Collection) FilterEndsWith(selector string, str string) Query

func (*Collection) FilterEndsWithCaseInsensitive 

func (self *Collection) FilterEndsWithCaseInsensitive(selector string, str string) Query

func (*Collection) FilterEqualCaseInsensitive 

func (self *Collection) FilterEqualCaseInsensitive(selector string, str string) Query

func (*Collection) FilterExists 

func (self *Collection) FilterExists(selector string, exists bool) Query

func (*Collection) FilterFunc 

func (self *Collection) FilterFunc(passFilter model.FilterFunc) model.Iterator

func (*Collection) FilterGreater 

func (self *Collection) FilterGreater(selector string, value interface{}) Query

func (*Collection) FilterGreaterEqual 

func (self *Collection) FilterGreaterEqual(selector string, value interface{}) Query

func (*Collection) FilterID 

func (self *Collection) FilterID(ids ...bson.ObjectId) Query

func (*Collection) FilterIn 

func (self *Collection) FilterIn(selector string, values ...interface{}) Query

func (*Collection) FilterLess 

func (self *Collection) FilterLess(selector string, value interface{}) Query

func (*Collection) FilterLessEqual 

func (self *Collection) FilterLessEqual(selector string, value interface{}) Query

func (*Collection) FilterModulo 

func (self *Collection) FilterModulo(selector string, divisor, result interface{}) Query

func (*Collection) FilterNotEqual 

func (self *Collection) FilterNotEqual(selector string, value interface{}) Query

func (*Collection) FilterNotIn 

func (self *Collection) FilterNotIn(selector string, values ...interface{}) Query

func (*Collection) FilterRef 

func (self *Collection) FilterRef(selector string, refs ...Ref) Query

func (*Collection) FilterReferenced 

func (self *Collection) FilterReferenced(refs ...Ref) Query

FilterReferenced filters the collection for documents, that are referenced by refs.

func (*Collection) FilterStartsWith 

func (self *Collection) FilterStartsWith(selector string, str string) Query

func (*Collection) FilterStartsWithCaseInsensitive 

func (self *Collection) FilterStartsWithCaseInsensitive(selector string, str string) Query

func (*Collection) FilterWhere 

func (self *Collection) FilterWhere(javascript string) Query

func (*Collection) Init 

func (self *Collection) Init()

func (*Collection) InitAndSaveDocument 

func (self *Collection) InitAndSaveDocument(doc Document) error

func (*Collection) InitDocument 

func (self *Collection) InitDocument(doc Document)

func (*Collection) InitSubDocument 

func (self *Collection) InitSubDocument(subDoc interface{})

func (*Collection) IsFilter 

func (self *Collection) IsFilter() bool

func (*Collection) Iterator 

func (self *Collection) Iterator() model.Iterator

func (*Collection) Limit 

func (self *Collection) Limit(limit int) Query

func (*Collection) OneDocument 

func (self *Collection) OneDocument(resultRef interface{}) error

func (*Collection) OneDocumentID 

func (self *Collection) OneDocumentID() (id bson.ObjectId, err error)

func (*Collection) OneSubDocument 

func (self *Collection) OneSubDocument(selector string, resultRef interface{}) error

func (*Collection) Or 

func (self *Collection) Or() Query

func (*Collection) ParentQuery 

func (self *Collection) ParentQuery() Query

func (*Collection) RefForID 

func (self *Collection) RefForID(id bson.ObjectId) Ref

func (*Collection) Refs 

func (self *Collection) Refs() (refs []Ref, err error)

func (*Collection) RemoveAll 

func (self *Collection) RemoveAll() (numRemoved int, err error)

func (*Collection) RemoveInvalidRefs 

func (self *Collection) RemoveInvalidRefs() (invalidRefs []InvalidRefData, err error)

RemoveInvalidRefs removes invalid refs from all documents and saves the changes.

func (*Collection) Selector 

func (self *Collection) Selector() string

func (*Collection) Skip 

func (self *Collection) Skip(skip int) Query

func (*Collection) Sort 

func (self *Collection) Sort(selectors ...string) Query

func (*Collection) SortFunc 

func (self *Collection) SortFunc(compareFunc interface{}) model.Iterator

func (*Collection) String 

func (self *Collection) String() string

func (*Collection) SubDocument 

func (self *Collection) SubDocument(selector string) Query

func (*Collection) SubDocumentWithID 

func (self *Collection) SubDocumentWithID(id bson.ObjectId, selector string, resultRef interface{}) error

func (*Collection) TryDocumentWithID 

func (self *Collection) TryDocumentWithID(id bson.ObjectId, resultRef interface{}) (found bool, err error)

func (*Collection) TryDocumentWithIDIterator 

func (self *Collection) TryDocumentWithIDIterator(id bson.ObjectId) model.Iterator

func (*Collection) TryOneDocument 

func (self *Collection) TryOneDocument(resultRef interface{}) (found bool, err error)

func (*Collection) TryOneDocumentID 

func (self *Collection) TryOneDocumentID() (id bson.ObjectId, found bool, err error)

func (*Collection) TryOneSubDocument 

func (self *Collection) TryOneSubDocument(selector string, resultRef interface{}) (found bool, err error)

func (*Collection) TrySubDocumentWithID 

func (self *Collection) TrySubDocumentWithID(id bson.ObjectId, selector string, resultRef interface{}) (found bool, err error)

func (*Collection) UpdateAll 

func (self *Collection) UpdateAll(selector string, value interface{}) (numUpdated int, err error)

func (*Collection) UpdateOne 

func (self *Collection) UpdateOne(selector string, value interface{}) error

func (*Collection) UpdateSubDocument 

func (self *Collection) UpdateSubDocument(selector string, subDocument interface{}) error

func (*Collection) UpdateSubDocumentWithID 

func (self *Collection) UpdateSubDocumentWithID(id bson.ObjectId, selector string, subDocument interface{}) error

func (*Collection) ValidateSelectors 

func (self *Collection) ValidateSelectors(selectors ...string) (err error)

todo

type Configuration 

type Configuration struct {
	Host                string
	Database            string
	User                string
	Password            string
	Safe                mgo.Safe
	CheckQuerySelectors bool
}

func (*Configuration) Close 

func (self *Configuration) Close() error

func (*Configuration) Init 

func (self *Configuration) Init() error

func (*Configuration) Name 

func (self *Configuration) Name() string

type DereferenceIterator 

type DereferenceIterator struct {
	Refs []Ref
	// contains filtered or unexported fields
}

func NewDereferenceIterator 

func NewDereferenceIterator(refs ...Ref) *DereferenceIterator

Returns an iterator of dereferenced refs, or an error iterator if there was an error

func (*DereferenceIterator) Err 

func (self *DereferenceIterator) Err() error

func (*DereferenceIterator) Next 

func (self *DereferenceIterator) Next(resultRef interface{}) bool

type Document 

type Document interface {
	Init(collection *Collection, embeddingStruct interface{})
	Collection() *Collection
	ObjectId() bson.ObjectId
	SetObjectId(id bson.ObjectId)
	// Iterator returns an iterator that iterates only this document.
	Iterator() model.Iterator
	CreationTime() time.Time
	Ref() Ref
	Save() error
	Delete() error

	// RemoveInvalidRefs sets all invalid mongo.Ref instances to empty,
	// but does not save the document.
	RemoveInvalidRefs() (invalidRefs []InvalidRefData, err error)
}

type DocumentBase 

type DocumentBase struct {
	ID bson.ObjectId `bson:"_id,omitempty" gostart:"-"`
	// contains filtered or unexported fields
}

func (*DocumentBase) Collection 

func (self *DocumentBase) Collection() *Collection

func (*DocumentBase) CreationTime 

func (self *DocumentBase) CreationTime() (t time.Time)

func (*DocumentBase) Delete 

func (self *DocumentBase) Delete() error

func (*DocumentBase) Init 

func (self *DocumentBase) Init(collection *Collection, embeddingStructPtr interface{})

func (*DocumentBase) Iterator 

func (self *DocumentBase) Iterator() model.Iterator

func (*DocumentBase) ObjectId 

func (self *DocumentBase) ObjectId() bson.ObjectId

func (*DocumentBase) Ref 

func (self *DocumentBase) Ref() Ref

func (*DocumentBase) RemoveInvalidRefs 

func (self *DocumentBase) RemoveInvalidRefs() (invalidRefs []InvalidRefData, err error)

func (*DocumentBase) Save 

func (self *DocumentBase) Save() (err error)

func (*DocumentBase) SetObjectId 

func (self *DocumentBase) SetObjectId(id bson.ObjectId)

type ForeignRef 

type ForeignRef struct {
	Collection *Collection
	Selector   string
}

type InvalidRefData 

type InvalidRefData struct {
	Ref      *Ref
	MetaData *model.MetaData
}

func RemoveInvalidRefs 

func RemoveInvalidRefs(document interface{}) (invalidRefs []InvalidRefData, err error)

type MongoIterator 

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

func (*MongoIterator) Err 

func (self *MongoIterator) Err() error

func (*MongoIterator) Next 

func (self *MongoIterator) Next(resultRef interface{}) bool

type Query 

type Query interface {
	Selector() string

	ParentQuery() Query
	Collection() *Collection

	SubDocument(selector string) Query
	Skip(int) Query
	Limit(int) Query
	Sort(selectors ...string) Query // sort reverse by prefixing the selector with a minus -

	// SortFunc will sort the query according to compareFunc.
	// compareFunc must have two arguments that are assignable from
	// the iterated document type or pointers to such a type.
	// The result of compareFunc must be a bool indicating
	// if the first argument is less than the second.
	SortFunc(compareFunc interface{}) model.Iterator

	// FilterX must be the first query on a Collection
	IsFilter() bool
	Filter(selector string, value interface{}) Query
	FilterWhere(javascript string) Query

	// Filter via a Go function. Note that all documents have to be loaded
	// in memory in order for Go code to be able to filter it.
	FilterFunc(passFilter model.FilterFunc) model.Iterator
	FilterRef(selector string, refs ...Ref) Query
	FilterID(ids ...bson.ObjectId) Query
	FilterEqualCaseInsensitive(selector string, str string) Query
	FilterNotEqual(selector string, value interface{}) Query
	FilterLess(selector string, value interface{}) Query
	FilterGreater(selector string, value interface{}) Query
	FilterLessEqual(selector string, value interface{}) Query
	FilterGreaterEqual(selector string, value interface{}) Query
	FilterModulo(selector string, divisor, result interface{}) Query
	FilterIn(selector string, values ...interface{}) Query
	FilterNotIn(selector string, values ...interface{}) Query
	FilterAllIn(selector string, values ...interface{}) Query
	FilterArraySize(selector string, size int) Query
	FilterStartsWith(selector string, str string) Query
	FilterStartsWithCaseInsensitive(selector string, str string) Query
	FilterEndsWith(selector string, str string) Query
	FilterEndsWithCaseInsensitive(selector string, str string) Query
	FilterContains(selector string, str string) Query
	FilterContainsCaseInsensitive(selector string, str string) Query
	FilterExists(selector string, exists bool) Query

	Or() Query

	// Statistics
	Count() (n int, err error)
	// Distinct() int
	Explain() string

	// Read
	OneDocument(resultRef interface{}) error
	TryOneDocument(resultRef interface{}) (found bool, err error)

	OneSubDocument(selector string, resultRef interface{}) error
	TryOneSubDocument(selector string, resultRef interface{}) (found bool, err error)

	Iterator() model.Iterator

	OneDocumentID() (id bson.ObjectId, err error)
	TryOneDocumentID() (id bson.ObjectId, found bool, err error)
	DocumentIDs() (ids []bson.ObjectId, err error)
	Refs() (refs []Ref, err error)

	// Write
	UpdateOne(selector string, value interface{}) error
	UpdateAll(selector string, value interface{}) (numUpdated int, err error)
	// UpdateSubDocument updates a sub-part of queried documents.
	// selector can be an empty string if subDocument is on
	// the root level of the queried documents.
	UpdateSubDocument(selector string, subDocument interface{}) error

	// RemoveAll ignores Skip() and Limit()
	RemoveAll() (numRemoved int, err error)
	// contains filtered or unexported methods
}

Query is the interface with all query methods for mongo.

type QueryError 

type QueryError struct {
	Err error
	// contains filtered or unexported fields
}

QueryError implements Query, but all it does is hold and return an error generated by another query.

func (*QueryError) Collection 

func (self *QueryError) Collection() *Collection

func (*QueryError) Count 

func (self *QueryError) Count() (n int, err error)

func (*QueryError) DocumentIDs 

func (self *QueryError) DocumentIDs() (ids []bson.ObjectId, err error)

func (*QueryError) Explain 

func (self *QueryError) Explain() string

func (*QueryError) Filter 

func (self *QueryError) Filter(selector string, value interface{}) Query

func (*QueryError) FilterAllIn 

func (self *QueryError) FilterAllIn(selector string, values ...interface{}) Query

func (*QueryError) FilterArraySize 

func (self *QueryError) FilterArraySize(selector string, size int) Query

func (*QueryError) FilterContains 

func (self *QueryError) FilterContains(selector string, str string) Query

func (*QueryError) FilterContainsCaseInsensitive 

func (self *QueryError) FilterContainsCaseInsensitive(selector string, str string) Query

func (*QueryError) FilterEndsWith 

func (self *QueryError) FilterEndsWith(selector string, str string) Query

func (*QueryError) FilterEndsWithCaseInsensitive 

func (self *QueryError) FilterEndsWithCaseInsensitive(selector string, str string) Query

func (*QueryError) FilterEqualCaseInsensitive 

func (self *QueryError) FilterEqualCaseInsensitive(selector string, str string) Query

func (*QueryError) FilterExists 

func (self *QueryError) FilterExists(selector string, exists bool) Query

func (*QueryError) FilterFunc 

func (self *QueryError) FilterFunc(passFilter model.FilterFunc) model.Iterator

func (*QueryError) FilterGreater 

func (self *QueryError) FilterGreater(selector string, value interface{}) Query

func (*QueryError) FilterGreaterEqual 

func (self *QueryError) FilterGreaterEqual(selector string, value interface{}) Query

func (*QueryError) FilterID 

func (self *QueryError) FilterID(id ...bson.ObjectId) Query

func (*QueryError) FilterIn 

func (self *QueryError) FilterIn(selector string, values ...interface{}) Query

func (*QueryError) FilterLess 

func (self *QueryError) FilterLess(selector string, value interface{}) Query

func (*QueryError) FilterLessEqual 

func (self *QueryError) FilterLessEqual(selector string, value interface{}) Query

func (*QueryError) FilterModulo 

func (self *QueryError) FilterModulo(selector string, divisor, result interface{}) Query

func (*QueryError) FilterNotEqual 

func (self *QueryError) FilterNotEqual(selector string, value interface{}) Query

func (*QueryError) FilterNotIn 

func (self *QueryError) FilterNotIn(selector string, values ...interface{}) Query

func (*QueryError) FilterRef 

func (self *QueryError) FilterRef(selector string, ref ...Ref) Query

func (*QueryError) FilterStartsWith 

func (self *QueryError) FilterStartsWith(selector string, str string) Query

func (*QueryError) FilterStartsWithCaseInsensitive 

func (self *QueryError) FilterStartsWithCaseInsensitive(selector string, str string) Query

func (*QueryError) FilterWhere 

func (self *QueryError) FilterWhere(javascript string) Query

func (*QueryError) HasDocumentWithID 

func (self *QueryError) HasDocumentWithID(id bson.ObjectId) (bool, error)

func (*QueryError) IsFilter 

func (self *QueryError) IsFilter() bool

func (*QueryError) Iterator 

func (self *QueryError) Iterator() model.Iterator

func (*QueryError) Limit 

func (self *QueryError) Limit(int) Query

func (*QueryError) OneDocument 

func (self *QueryError) OneDocument(resultRef interface{}) error

func (*QueryError) OneDocumentID 

func (self *QueryError) OneDocumentID() (id bson.ObjectId, err error)

func (*QueryError) OneSubDocument 

func (self *QueryError) OneSubDocument(selector string, resultRef interface{}) error

func (*QueryError) Or 

func (self *QueryError) Or() Query

func (*QueryError) ParentQuery 

func (self *QueryError) ParentQuery() Query

func (*QueryError) Refs 

func (self *QueryError) Refs() (refs []Ref, err error)

func (*QueryError) RemoveAll 

func (self *QueryError) RemoveAll() (numRemoved int, err error)

func (*QueryError) Selector 

func (self *QueryError) Selector() string

func (*QueryError) Skip 

func (self *QueryError) Skip(int) Query

func (*QueryError) Sort 

func (self *QueryError) Sort(selectors ...string) Query

func (*QueryError) SortFunc 

func (self *QueryError) SortFunc(compareFunc interface{}) model.Iterator

func (*QueryError) SubDocument 

func (self *QueryError) SubDocument(selector string) Query

func (*QueryError) TryOneDocument 

func (self *QueryError) TryOneDocument(resultRef interface{}) (found bool, err error)

func (*QueryError) TryOneDocumentID 

func (self *QueryError) TryOneDocumentID() (id bson.ObjectId, found bool, err error)

func (*QueryError) TryOneSubDocument 

func (self *QueryError) TryOneSubDocument(selector string, resultRef interface{}) (found bool, err error)

func (*QueryError) UpdateAll 

func (self *QueryError) UpdateAll(selector string, value interface{}) (numUpdated int, err error)

func (*QueryError) UpdateOne 

func (self *QueryError) UpdateOne(selector string, value interface{}) error

func (*QueryError) UpdateSubDocument 

func (self *QueryError) UpdateSubDocument(selector string, subDocument interface{}) error

type Ref 

type Ref struct {
	ID             bson.ObjectId `gostart:"-"`
	CollectionName string        `gostart:"-"`
}

Ref holds a mongo.ID and the name of the collection of the referenced document. Only the ID will be saved in MongoDB, the collection name is for validation and convenience functions only.

func RemoveRefWithIDFromSlice 

func RemoveRefWithIDFromSlice(refs []Ref, id bson.ObjectId) ([]Ref, bool)

func (*Ref) CheckID 

func (self *Ref) CheckID() (bool, error)

func (*Ref) Collection 

func (self *Ref) Collection() *Collection

func (*Ref) DocumentLabel 

func (self *Ref) DocumentLabel() (string, error)

func (*Ref) Get 

func (self *Ref) Get(resultRef interface{}) error

Returns nil and no error if the reference is empty

func (Ref) GetBSON 

func (self Ref) GetBSON() (interface{}, error)

Implements bson.Getter

func (*Ref) IsEmpty 

func (self *Ref) IsEmpty() bool

func (*Ref) References 

func (self *Ref) References(doc Document) (ok bool, err error)

func (*Ref) Required 

func (self *Ref) Required(metaData *model.MetaData) bool

func (*Ref) Set 

func (self *Ref) Set(document Document)

nil is valid and sets the reference to empty

func (*Ref) SetBSON 

func (self *Ref) SetBSON(raw bson.Raw) error

Implements bson.Setter

func (*Ref) SetStringID 

func (self *Ref) SetStringID(str string) error

func (*Ref) String 

func (self *Ref) String() string

func (*Ref) StringID 

func (self *Ref) StringID() string

func (*Ref) TryGet 

func (self *Ref) TryGet(resultRef interface{}) (found bool, err error)

Returns an error if the reference is empty

func (*Ref) Validate 

func (self *Ref) Validate(metaData *model.MetaData) error

type SortableRefs 

type SortableRefs struct {
	Refs     []Ref
	LessFunc func(a, b *Ref) bool
}

func (*SortableRefs) Len 

func (self *SortableRefs) Len() int

func (*SortableRefs) Less 

func (self *SortableRefs) Less(i, j int) bool

func (*SortableRefs) Swap 

func (self *SortableRefs) Swap(i, j int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.