pie 是基于官方mongo-go-driver 封装，所有操作都是通过链式调用，可以方便的对MongoDB进行操作
- Aggregate封装
- CRUD全功能 e.g FindOneAndDelete
- 测试
- 文档
go get github.com/NSObjects/pie
driver := pie.NewDriver(options.Client().ApplyURI("mongodb://127.0.0.1:27017"))
or
driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
var user User
err = driver.Filter("nickName", "淳朴的润土").FindOne(&user)
if err != nil {
panic(err)
}
fmt.Println(user)pie还处于开发阶段，如果有不能满足需求的功能可以调用DataBase()方法获取*mongo.Database进行操作
driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
base := driver.DataBase()
matchStage := bson.D{{"$match", bson.D{{"operationType", "insert"}}}}
opts := options.ChangeStream().SetMaxAwaitTime(2 * time.Second)
changeStream, err := base.Watch(context.TODO(), mongo.Pipeline{matchStage}, opts)
if err != nil {
panic(err)
}
for changeStream.Next(context.Background()) {
fmt.Println(changeStream.Current)
}type User struct {
ID string `bson:"_id"`
Username string `bson:"username"`
MobileNumber string `bson:"mobileNumber"`
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
var user User
user.Username = "小明"
user.MobileNumber = "138xxxx"
err := driver.Insert(&user)
if err != nil {
fmt.Println(err)
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
var users = []User{
{NickName: "aab"},
{NickName: "bbb"},
{NickName: "ccc"},
{NickName: "dd"},
{NickName: "eee"},
}
_, err = driver.InsertMany(context.Background(), users)
if err != nil {
panic(err)
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
var u User
_, err := driver.Filter("username", "小明").Get(&u)
if err != nil {
panic(err)
}
or
driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
type User struct {
ID string `bson:"_id" filter:"_id"`
Username string `bson:"user_name" filter:"user_name"`
MobileNumber string `bson:"mobile_number" filter:"-"` //ignore filter
}
var user User
user.Id, _ = primitive.ObjectIDFromHex("5f0ace734e2d4100013d8797")
user.Username = "Jack"
user.MobileNumber = "+86 10086"
err = driver.FilterBy(user).FindOne(context.Background(), &user)
if err != nil {
panic(err)
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
var user []User
driver.Gt("age",10).Skip(10).Limit(100).FindAll(&user)
if err != nil {
panic(err)
}
or
driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
type User struct {
ID string `bson:"_id" filter:"_id"`
Username string `bson:"user_name" filter:"user_name"`
MobileNumber string `bson:"mobile_number" filter:"-"` //ignore filter
}
var users []User
var user User
user.Age = 22
err = driver.FilterBy(user).FindAll(context.Background(), &users)
if err != nil {
panic(err)
}
fmt.Println(users)driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
u := new(User)
u.Username = "hahhahahah"
err := driver.Filter("mobileNumber", "138xxxxx").Id(u.Id).Update(u)
if err != nil {
fmt.Println(err)
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
u := new(User)
u.MobileNumber = "138xxxxx"
err := driver.Id(u.Id).Delete(u)
if err != nil {
fmt.Println(err)
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
u := new(User)
u.MobileNumber = "138xxxxx"
err := driver.DeleteMany(u)
if err != nil {
fmt.Println(err)
}driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
var user []User
err = driver.Aggregate().
Match(pie.DefaultCondition().
Eq("nick_name", "黄晶晶").
Eq("mobile_number", "c5b013cb2e102e0e743f117220b2acd1")).All(&user)
if err != nil {
panic(err)
}
fmt.Println(user)driver, err := pie.NewDriver()
driver.SetURI("mongodb://127.0.0.1:27017")
if err != nil {
panic(err)
}
if err = driver.Connect(context.Background()); err != nil {
panic(err)
}
driver.SetDatabase("xxxx")
indexes, err := driver.
AddIndex(bson.M{"nickName": 1}, options.Index().SetBackground(true)).
AddIndex(bson.M{"birthday": 1}).
AddIndex(bson.M{"createdAt": 1, "mobileNumber": 1},
options.Index().SetBackground(true).SetName("create_mobil_index")).
CreateIndexes(context.Background(), &User{})
if err != nil {
panic(err)
}
fmt.Println(indexes)