You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
70 lines
1.7 KiB
70 lines
1.7 KiB
2 years ago
|
package main
|
||
|
|
|
||
|
|
import (
|
||
|
|
"Open_IM/pkg/utils"
|
||
|
|
"context"
|
||
|
|
"fmt"
|
||
|
|
"go.mongodb.org/mongo-driver/bson"
|
||
|
|
"go.mongodb.org/mongo-driver/mongo"
|
||
|
|
"go.mongodb.org/mongo-driver/mongo/options"
|
||
|
|
"time"
|
||
|
|
)
|
||
|
|
|
||
|
|
type MongoMsg struct {
|
||
|
|
UID string
|
||
|
|
Msg []string
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
func main() {
|
||
|
|
//"mongodb://%s:%s@%s/%s/?maxPoolSize=%d"
|
||
|
|
uri := "mongodb://user:pass@sample.host:27017/?maxPoolSize=20&w=majority"
|
||
|
|
DBAddress := "127.0.0.1:37017"
|
||
|
|
DBDatabase := "new-test-db"
|
||
|
|
Collection := "new-test-collection"
|
||
|
|
DBMaxPoolSize := 100
|
||
|
|
uri = fmt.Sprintf("mongodb://%s/%s/?maxPoolSize=%d",
|
||
|
|
DBAddress,DBDatabase,
|
||
|
|
DBMaxPoolSize)
|
||
|
|
|
||
|
|
mongoClient, err := mongo.Connect(context.TODO(), options.Client().ApplyURI(uri))
|
||
|
|
if err != nil {
|
||
|
|
panic(err)
|
||
|
|
}
|
||
|
|
filter := bson.M{"uid":"my_uid"}
|
||
|
|
ctx, _ := context.WithTimeout(context.Background(), 30*time.Second)
|
||
|
|
for i:=0; i < 2; i++{
|
||
|
|
|
||
|
|
if err = mongoClient.Database(DBDatabase).Collection(Collection).FindOneAndUpdate(ctx, filter,
|
||
|
|
bson.M{"$push": bson.M{"msg": utils.Int32ToString(int32(i))}}).Err(); err != nil{
|
||
|
|
fmt.Println("FindOneAndUpdate failed ", i, )
|
||
|
|
var mmsg MongoMsg
|
||
|
|
mmsg.UID = "my_uid"
|
||
|
|
mmsg.Msg = append(mmsg.Msg, utils.Int32ToString(int32(i)))
|
||
|
|
_, err := mongoClient.Database(DBDatabase).Collection(Collection).InsertOne(ctx, &mmsg)
|
||
|
|
if err != nil {
|
||
|
|
fmt.Println("insertone failed ", err.Error(), i)
|
||
|
|
} else{
|
||
|
|
fmt.Println("insertone ok ", i)
|
||
|
|
}
|
||
|
|
|
||
|
|
}else {
|
||
|
|
fmt.Println("FindOneAndUpdate ok ", i)
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|
||
|
|
|
||
|
|
var mmsg MongoMsg
|
||
|
|
|
||
|
|
if err = mongoClient.Database(DBDatabase).Collection(Collection).FindOne(ctx, filter).Decode(&mmsg); err != nil {
|
||
|
|
fmt.Println("findone failed ", err.Error())
|
||
|
|
}else{
|
||
|
|
fmt.Println("findone ok ", mmsg.UID)
|
||
|
|
for i, v:=range mmsg.Msg{
|
||
|
|
fmt.Println("find value: ", i, v)
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
}
|