Golang：mongodb增删改 - Go

	func main() {
	var (
	client = mongodb.MgoCli()
	err error
	collection *mongo.Collection
	iResult *mongo.InsertOneResult
	id primitive.ObjectID
	)
	// 选择数据库 my_db 里的某个表
	collection = client.Database("my_db").Collection("my_collection")

	// 插入某一条数据
	logRecord := model.LogRecord{
	JobName: "job1",
	Command: "echo 1",
	Err: "",
	Content: "1",
	Tp: model.ExecTime{
	StartTime: time.Now().Unix(),
	EndTime: time.Now().Unix() + 10,
	},
	}
	if iResult, err = collection.InsertOne(context.TODO(), logRecord); err != nil {
	fmt.Print(err)
	return
	}
	//_id: 默认生成一个全局唯一 ID
	id = iResult.InsertedID.(primitive.ObjectID)
	fmt.Println("自增ID", id.Hex())
	}

	func main() {
	var (
	client = mongodb.MgoCli()
	err error
	collection *mongo.Collection
	result *mongo.InsertManyResult
	id primitive.ObjectID
	)
	collection = client.Database("my_db").Collection("table1")

	// 批量插入
	result, err = collection.InsertMany(context.TODO(), []interface{}{
	model.LogRecord{
	JobName: "job multi1",
	Command: "echo multi1",
	Err: "",
	Content: "1",
	Tp: model.ExecTime{
	StartTime: time.Now().Unix(),
	EndTime: time.Now().Unix() + 10,
	},
	},
	model.LogRecord{
	JobName: "job multi2",
	Command: "echo multi2",
	Err: "",
	Content: "2",
	Tp: model.ExecTime{
	StartTime: time.Now().Unix(),
	EndTime: time.Now().Unix() + 10,
	},
	},
	})
	if err != nil{
	log.Fatal(err)
	}
	if result == nil {
	log.Fatal("result nil")
	}
	for _, v := range result.InsertedIDs {
	id = v.(primitive.ObjectID)
	fmt.Println("自增ID", id.Hex())
	}
	}

执行 Insert 命令后，还要再执行

	for _, v := range result.InsertedIDs {
	id = v.(primitive.ObjectID)
	fmt.Println("自增ID", id.Hex())
	}

使用 bson 设置 ObjectID

	func main() {
	var (
	client = mongodb.MgoCli()
	collection *mongo.Collection
	err error
	cursor *mongo.Cursor
	)
	collection = client.Database("my_db").Collection("table1")
	filter := bson.M{"jobName":"job multi1"}
	if cursor, err = collection.Find(context.TODO(), filter,options.Find().SetSkip(0), options.Find().SetLimit(2) ); err != nil {
	log.Fatal(err)
	}
	defer func() {
	if err = cursor.Close(context.TODO()); err != nil {
	log.Fatal(err)
	}
	}()

	var results []model.LogRecord
	if err = cursor.All(context.TODO(), &results); err != nil {
	log.Fatal(err)
	}
	for _, result := range results {
	fmt.Println(result)
	}
	}

	func main() {
	var (
	client = mongodb.MgoCli()
	collection *mongo.Collection
	err error
	uResult *mongo.UpdateResult
	)
	collection = client.Database("my_db").Collection("table1")
	filter := bson.M{"jobName": "job multi1"}
	update := bson.M{"$set": model.
	UpdateByJobName{Command: "byModel",Content:"model"}}
	if uResult, err = collection.
	UpdateMany(context.TODO(), filter, update); err != nil {
	log.Fatal(err)
	}
	//uResult.MatchedCount 表示符合过滤条件的记录数，即更新了多少条数据。
	log.Println(uResult.MatchedCount)
	}

	sql := `{"name":"jack"}`
	var bs interface{}
	bson.UnmarshalExtJSON([]byte(sql), true,&bs)
	collection.DeleteMany(context.TODO(), bs)

同样的，先 sqlstr 转 interface ，然而直接传入参数。