Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
5 changed files
with
180 additions
and
111 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,23 @@ | ||
| package mgodb | ||
|
|
||
| import ( | ||
| "labix.org/v2/mgo" | ||
| ) | ||
|
|
||
| var DefaultDatabase *Database | ||
|
|
||
| func Setup(ds string, db string) { | ||
| DefaultDatabase = NewDatabase(ds, db) | ||
| } | ||
|
|
||
| func CollectionDo(name string, f func(c *mgo.Collection)) { | ||
| DefaultDatabase.CollectionDo(name, f) | ||
| } | ||
|
|
||
| func DatabaseDo(f func(db *mgo.Database)) { | ||
| DefaultDatabase.DatabaseDo(f) | ||
| } | ||
|
|
||
| func CollectionsDo(f func(c ...*mgo.Collection), names ...string) { | ||
| DefaultDatabase.CollectionsDo(f, names...) | ||
| } |
File renamed without changes.
This file was deleted.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,94 +1,45 @@ | ||
| package mgodb | ||
|
|
||
| import ( | ||
| "labix.org/v2/mgo" | ||
| "labix.org/v2/mgo/bson" | ||
| "reflect" | ||
| ) | ||
|
|
||
| type Id interface { | ||
| MakeId() interface{} | ||
| } | ||
|
|
||
| func Save(collectionName string, obj Id) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| _, err = rc.Upsert(bson.M{"_id": obj.MakeId()}, obj) | ||
| }) | ||
| err = DefaultDatabase.Save(collectionName, obj) | ||
| return | ||
| } | ||
|
|
||
| func DropCollection(collectionName string) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| err = rc.DropCollection() | ||
| }) | ||
| err = DefaultDatabase.DropCollection(collectionName) | ||
| return | ||
| } | ||
|
|
||
| func DropCollections(collectionNames ...string) (err error) { | ||
| CollectionsDo(func(rcs ...*mgo.Collection) { | ||
| for _, rc := range rcs { | ||
| err1 := rc.DropCollection() | ||
| if err == nil && err1 != nil { | ||
| err = err1 | ||
| } | ||
| } | ||
| }, collectionNames...) | ||
| err = DefaultDatabase.DropCollections(collectionNames...) | ||
| return | ||
| } | ||
|
|
||
| func Delete(collectionName string, id interface{}) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| _, err = rc.RemoveAll(bson.M{"_id": id}) | ||
| }) | ||
| err = DefaultDatabase.Delete(collectionName, id) | ||
| return | ||
| } | ||
|
|
||
| func Update(collectionName string, obj Id) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| v := reflect.ValueOf(obj) | ||
| if v.Kind() == reflect.Ptr { | ||
| v = v.Elem() | ||
| } | ||
|
|
||
| found := reflect.New(v.Type()).Interface() | ||
| rc.Find(bson.M{"_id": obj.MakeId()}).One(found) | ||
|
|
||
| originalValue := reflect.ValueOf(found) | ||
| if originalValue.Kind() == reflect.Ptr { | ||
| originalValue = originalValue.Elem() | ||
| } | ||
|
|
||
| for i := 0; i < v.NumField(); i++ { | ||
| fieldValue := v.Field(i) | ||
| if !reflect.DeepEqual(fieldValue.Interface(), reflect.Zero(fieldValue.Type()).Interface()) { | ||
| continue | ||
| } | ||
|
|
||
| fieldValue.Set(originalValue.Field(i)) | ||
| } | ||
|
|
||
| rc.Upsert(bson.M{"_id": obj.MakeId()}, v.Interface()) | ||
| }) | ||
| err = DefaultDatabase.Update(collectionName, obj) | ||
| return | ||
| } | ||
|
|
||
| func FindAll(collectionName string, query interface{}, result interface{}) (err error) { | ||
| CollectionDo(collectionName, func(c *mgo.Collection) { | ||
| err = c.Find(query).All(result) | ||
| }) | ||
| err = DefaultDatabase.FindAll(collectionName, query, result) | ||
| return | ||
| } | ||
|
|
||
| func FindOne(collectionName string, query interface{}, result interface{}) (err error) { | ||
| CollectionDo(collectionName, func(c *mgo.Collection) { | ||
| err = c.Find(query).One(result) | ||
| }) | ||
| err = DefaultDatabase.FindOne(collectionName, query, result) | ||
| return | ||
| } | ||
|
|
||
| func FindById(collectionName string, id interface{}, result interface{}) (err error) { | ||
| CollectionDo(collectionName, func(c *mgo.Collection) { | ||
| err = c.Find(bson.M{"_id": id}).One(result) | ||
| }) | ||
| err = DefaultDatabase.FindById(collectionName, id, result) | ||
| return | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,149 @@ | ||
| package mgodb | ||
|
|
||
| import ( | ||
| "labix.org/v2/mgo" | ||
| "labix.org/v2/mgo/bson" | ||
| "reflect" | ||
| ) | ||
|
|
||
| type Database struct { | ||
| Dialstring string | ||
| DatabaseName string | ||
| } | ||
|
|
||
| func NewDatabase(dialstring string, db string) (r *Database) { | ||
|
|
||
| r = &Database{ | ||
| Dialstring: dialstring, | ||
| DatabaseName: db, | ||
| } | ||
| return | ||
| } | ||
|
|
||
| var ConnectedSessions map[string]*mgo.Session | ||
|
|
||
| func (db *Database) GetOrDialSession() (r *mgo.Session) { | ||
| if db.DatabaseName == "" || db.Dialstring == "" { | ||
| panic("mgo: must provide valid dialstring and database name") | ||
| } | ||
| if ConnectedSessions == nil { | ||
| ConnectedSessions = make(map[string]*mgo.Session) | ||
| } | ||
|
|
||
| key := db.Dialstring | ||
| r = ConnectedSessions[key] | ||
| if r == nil { | ||
| var err error | ||
| r, err = mgo.Dial(db.Dialstring) | ||
| if err != nil { | ||
| panic(err) | ||
| } | ||
| ConnectedSessions[key] = r | ||
| } | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) CollectionDo(name string, f func(c *mgo.Collection)) { | ||
| s := db.GetOrDialSession().Copy() | ||
| defer s.Close() | ||
| f(s.DB(db.DatabaseName).C(name)) | ||
| } | ||
|
|
||
| func (db *Database) DatabaseDo(f func(db *mgo.Database)) { | ||
| s := db.GetOrDialSession().Copy() | ||
| defer s.Close() | ||
| f(s.DB(db.DatabaseName)) | ||
| } | ||
|
|
||
| func (db *Database) CollectionsDo(f func(c ...*mgo.Collection), names ...string) { | ||
| s := db.GetOrDialSession().Copy() | ||
| defer s.Close() | ||
| cs := []*mgo.Collection{} | ||
| for _, name := range names { | ||
| cs = append(cs, s.DB(db.DatabaseName).C(name)) | ||
| } | ||
| f(cs...) | ||
| } | ||
|
|
||
| func (db *Database) Save(collectionName string, obj Id) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| _, err = rc.Upsert(bson.M{"_id": obj.MakeId()}, obj) | ||
| }) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) DropCollection(collectionName string) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| err = rc.DropCollection() | ||
| }) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) DropCollections(collectionNames ...string) (err error) { | ||
| CollectionsDo(func(rcs ...*mgo.Collection) { | ||
| for _, rc := range rcs { | ||
| err1 := rc.DropCollection() | ||
| if err == nil && err1 != nil { | ||
| err = err1 | ||
| } | ||
| } | ||
| }, collectionNames...) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) Delete(collectionName string, id interface{}) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| _, err = rc.RemoveAll(bson.M{"_id": id}) | ||
| }) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) Update(collectionName string, obj Id) (err error) { | ||
| CollectionDo(collectionName, func(rc *mgo.Collection) { | ||
| v := reflect.ValueOf(obj) | ||
| if v.Kind() == reflect.Ptr { | ||
| v = v.Elem() | ||
| } | ||
|
|
||
| found := reflect.New(v.Type()).Interface() | ||
| rc.Find(bson.M{"_id": obj.MakeId()}).One(found) | ||
|
|
||
| originalValue := reflect.ValueOf(found) | ||
| if originalValue.Kind() == reflect.Ptr { | ||
| originalValue = originalValue.Elem() | ||
| } | ||
|
|
||
| for i := 0; i < v.NumField(); i++ { | ||
| fieldValue := v.Field(i) | ||
| if !reflect.DeepEqual(fieldValue.Interface(), reflect.Zero(fieldValue.Type()).Interface()) { | ||
| continue | ||
| } | ||
|
|
||
| fieldValue.Set(originalValue.Field(i)) | ||
| } | ||
|
|
||
| rc.Upsert(bson.M{"_id": obj.MakeId()}, v.Interface()) | ||
| }) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) FindAll(collectionName string, query interface{}, result interface{}) (err error) { | ||
| CollectionDo(collectionName, func(c *mgo.Collection) { | ||
| err = c.Find(query).All(result) | ||
| }) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) FindOne(collectionName string, query interface{}, result interface{}) (err error) { | ||
| CollectionDo(collectionName, func(c *mgo.Collection) { | ||
| err = c.Find(query).One(result) | ||
| }) | ||
| return | ||
| } | ||
|
|
||
| func (db *Database) FindById(collectionName string, id interface{}, result interface{}) (err error) { | ||
| CollectionDo(collectionName, func(c *mgo.Collection) { | ||
| err = c.Find(bson.M{"_id": id}).One(result) | ||
| }) | ||
| return | ||
| } |