Я пытаюсь познакомиться с официальным монго-гонщик и правильным синтаксисом для UpdateOne
.
Мой самый простой полный пример выглядит следующим образом:
(ПРИМЕЧАНИЕ: чтобы использовать этот код, вам нужно будет заменить свои собственные имена пользователя и сервера, а также экспортировать пароль для входа в среду как MONGO_PW):
package main
import (
"context"
"fmt"
"os"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo"
"go.mongodb.org/mongo-driver/mongo/options"
)
type DB struct {
User string
Server string
Database string
Collection string
Client *mongo.Client
Ctx context.Context
}
var db = DB{
User: <username>,
Server: <server_IP>,
Database: "test",
Collection: "movies",
Ctx: context.TODO(),
}
type Movie struct {
ID primitive.ObjectID `bson:"_id" json:"id"`
Name string `bson:"name" json:"name"`
Description string `bson:"description" json:"description"`
}
func main() {
if err := db.Connect(); err != nil {
fmt.Println("error: unable to connect")
os.Exit(1)
}
fmt.Println("connected")
// The code assumes the original entry for dunkirk is the following
// {"Name":"dunkirk", "Description":"a world war 2 movie"}
updatedMovie := Movie{
Name: "dunkirk",
Description: "movie about the british evacuation in WWII",
}
res, err := db.UpdateByName(updatedMovie)
if err != nil {
fmt.Println("error updating movie:", err)
os.Exit(1)
}
if res.MatchedCount < 1 {
fmt.Println("error: update did not match any documents")
os.Exit(1)
}
}
// UpdateByName changes the description for a movie identified by its name
func (db *DB) UpdateByName(movie Movie) (*mongo.UpdateResult, error) {
filter := bson.D{{"name", movie.Name}}
res, err := db.Client.Database(db.Database).Collection(db.Collection).UpdateOne(
db.Ctx,
filter,
movie,
)
if err != nil {
return nil, err
}
return res, nil
}
// Connect assumes that the database password is stored in the
// environment variable MONGO_PW
func (db *DB) Connect() error {
pw, ok := os.LookupEnv("MONGO_PW")
if !ok {
fmt.Println("error: unable to find MONGO_PW in the environment")
os.Exit(1)
}
mongoURI := fmt.Sprintf("mongodb+srv://%s:%s@%s", db.User, pw, db.Server)
// Set client options and verify connection
clientOptions := options.Client().ApplyURI(mongoURI)
client, err := mongo.Connect(db.Ctx, clientOptions)
if err != nil {
return err
}
err = client.Ping(db.Ctx, nil)
if err != nil {
return err
}
db.Client = client
return nil
}
Подпись функции для UpdateOne
из документации по пакету:
func (coll *Collection) UpdateOne(ctx context.Context, filter interface{},
update interface{}, opts ...*options.UpdateOptions) (*UpdateResult, error)
Итак, я явно делаю какую-то ошибку при создании аргумента update interface{}
для функции, потому что мне представлена эта ошибка
error updating movie: update document must contain key beginning with '$'
Самый популярный ответ здесь показывает, что мне нужно использовать документ вроде этого
{ $set: {"Name" : "The Matrix", "Decription" "Neo and Trinity kick butt" } }
но дословно это не скомпилируется в mongo-go-driver.
Я думаю, мне нужна какая-то форма документа bson, чтобы соответствовать синтаксису Go. Каков наилучший и/или наиболее эффективный синтаксис для создания этого документа bson для update
?
Поиграв с этим немного дольше, я смог решить проблему после МНОГО ПРОБ И ОШИБОК, используя пакет mongodb bson, изменив функцию UpdateByName
в моем коде выше следующим образом:
// UpdateByName changes the description for a movie identified by its name
func (db *DB) UpdateByName(movie Movie) (*mongo.UpdateResult, error) {
filter := bson.D{{"name", movie.Name}}
update := bson.D{{"$set",
bson.D{
{"description", movie.Description},
},
}}
res, err := db.Client.Database(db.Database).Collection(db.Collection).UpdateOne(
db.Ctx,
filter,
update,
)
if err != nil {
return nil, err
}
return res, nil
}
Обратите внимание на использование bson.D{{$"set", ...
. К сожалению, MongoDB реализовал пакет bson
, этот синтаксис все еще не проходит проверку. Если у кого-то есть комментарий, чтобы исправить конфликт ворса ниже, он был бы признателен.
go.mongodb.org/mongo-driver/bson/primitive.E composite literal uses unkeyed fields
Вот как я реализовал свой фильтр обновлений -- update := bson.D{primitive.E{Key: "$set", Value: bson.D{primitive.E{Key: "name", Value: supplier.Name} , примитив.E{Ключ: "documentType", Значение: поставщик.DocumentType} }, }}
@sumedhe, если вы хотите заменить весь документ, а не только определенные поля, вы можете рассмотреть возможность использования ReplaceOne (), а не UpdateOne ()
@shontauro, пожалуйста, напишите ответ и предоставьте некоторые подробности. Это будет полезно для читателей. Очень сложно понять код в комментарии.
Во многих случаях вы можете заменить конструкцию
filter := bson.D{{"name", movie.Name}}
с участием
filter := bson.M{"name": movie.Name}
если порядок аргументов не имеет значения
Как мы можем обновить все поле
movie
, не упоминая каждое поле в документе обновления?