Perlukan bantuan mendapatkan elemen daripada dokumen mongodb dan mengemas kini nilainya menggunakan pemacu go mongo

王林
Lepaskan: 2024-02-09 16:09:19
ke hadapan
914 orang telah melayarinya

需要帮助从 mongodb 文档获取元素并使用 go mongo 驱动程序更新其值

editor php Strawberry ada di sini untuk memperkenalkan anda kepada keperluan biasa: cara mendapatkan elemen daripada dokumen MongoDB dan mengemas kini nilainya menggunakan pemacu Go Mongo. MongoDB ialah pangkalan data NoSQL yang popular dan Go ialah bahasa pengaturcaraan yang berkuasa, dan gabungan kedua-duanya boleh membawa banyak faedah. Dalam artikel ini, kami akan meneroka cara menggunakan pemacu Go Mongo untuk mencapai keperluan ini dan membantu anda memahami dan menggunakan teknologi ini dengan lebih baik.

Kandungan soalan

Hei, saya menggunakan pakej go.mongodb.org/mongo-driver untuk menggunakan golang. Ini kod saya:

package src

import (
    "context"
    "fmt"
    "log"

    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

var (
    client      *mongo.client
    stickerscol *mongo.collection
)

func init() {
    log.println("setting up database...")
    var err error
    client, err = mongo.connect(context.background(), options.client().applyuri(envars.dburl))
    if err != nil {
        log.fatal(err)
    }
    log.println("connected to database")
    stickerscol = client.database("stickersbot").collection("stickers")
    chatcol = client.database("stickersbot").collection("chat")
}

func changedefaultpack(userid int64, stickername string, format string) error {
    fmt.println(userid, stickername, format)
    filter := bson.m{
        "_id":                      userid,
        "stickers.stickername":     stickername,
        "stickers.stickerpacktype": format,
    }
    updateother := bson.m{
        "$set": bson.m{
            "stickers.$[elem].isdefault": false,
        },
    }
    update := bson.m{
        "$set": bson.m{
            "stickers.$.isdefault": true,
        },
    }
    arrayfilters := options.arrayfilters{
        filters: []interface{}{bson.m{"elem.stickerpacktype": format}},
    }
    updateoptions := options.update().setarrayfilters(arrayfilters)
    _, err := stickerscol.updatemany(context.todo(), filter, updateother, updateoptions)
    if err != nil {
        return err
    }
    ok, err := stickerscol.updateone(context.background(), filter, update, options.update().setupsert(true))
    if err != nil {
        return err
    }
    if ok.modifiedcount == 0 {
        fmt.println("no document matched")
        return fmt.errorf("no document matched")
    }
    return err
}
Salin selepas log masuk

Ini adalah struktur pangkalan data:

...
{
  "_id": 1633375527,
  "stickers": [
    {
      "stickerpacktype": "static",
      "stickername": "gVtOy_1633375527_by_ChadManBot",
      "isdefault": true
    },
    {
      "stickerpacktype": "animated",
      "stickername": "zIjsa_1633375527_by_ChadManBot",
      "isdefault": true
    },
    {
      "stickerpacktype": "video",
      "stickername": "bJBle_1633375527_by_ChadManBot",
      "isdefault": true
    },
    {
      "stickerpacktype": "static",
      "stickername": "iujiw_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "video",
      "stickername": "CHnqb_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "XKJUP_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "animated",
      "stickername": "pCFlC_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "animated",
      "stickername": "jGGgt_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "animated",
      "stickername": "cTxyA_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "animated",
      "stickername": "ZfYXO_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "xJUkA_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "HIvsY_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "WIHFQ_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "OqjtE_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "QNysO_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "OrTsT_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "FzROg_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "QUBcT_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "NsZfM_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "AkxVM_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "Ddvus_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "LXfHV_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "sTaMv_1633375527_by_ChadManBot",
      "isdefault": false
    },
    {
      "stickerpacktype": "static",
      "stickername": "vppgK_1633375527_by_ChadManBot",
      "isdefault": false
    }
  ],
  "stickerpackcount": 2
}
...
Salin selepas log masuk

Apa yang saya perlukan kod saya ialah mencari senarai pek pelekat yang sepadan dengan id dan jenis pelekat yang diberikan dan tetapkan nilai lalainya kepada false 并将传递给 func 的包的默认值设置为 true.

Pada asasnya hanya tetapkan salah satu daripadanya sebagai lalai dan yang lain sebagai bukan lalai. Bolehkah seseorang menjelaskan mengapa fungsi ini mengembalikan dokumen tidak dijumpai?

Penyelesaian

Apabila terdapat berbilang medan yang sepadan, anda harus menggunakan operator $elemmatch 运算符。否则,$ tidak berfungsi. Lihat Mengemas kini dokumen terbenam menggunakan berbilang padanan medan.

Dan anda tidak perlu updatemany 来更新单个文档中的多个数组元素。请改用 updateone.

Berikut ialah demo berdasarkan kod dan data anda:

package main

import (
    "context"
    "fmt"
    "log"

    "go.mongodb.org/mongo-driver/bson"
    "go.mongodb.org/mongo-driver/mongo"
    "go.mongodb.org/mongo-driver/mongo/options"
)

var (
    client      *mongo.client
    stickerscol *mongo.collection
)

func init() {
    log.println("setting up database...")
    var err error
    client, err = mongo.connect(context.background(), options.client().applyuri("mongodb://localhost"))
    if err != nil {
        log.fatal(err)
    }
    log.println("connected to database")
    stickerscol = client.database("stickersbot").collection("stickers")
}

func changedefaultpack(userid int64, stickername string, format string) error {
    fmt.println(userid, stickername, format)
    filter := bson.m{
        "_id": userid,
        "stickers": bson.m{
            "$elemmatch": bson.m{
                "stickername":     stickername,
                "stickerpacktype": format,
            },
        },
    }
    updateother := bson.m{
        "$set": bson.m{
            "stickers.$[elem].isdefault": false,
        },
    }
    arrayfilters := options.arrayfilters{
        filters: []interface{}{bson.m{"elem.stickerpacktype": format}},
    }
    updateoptions := options.update().setarrayfilters(arrayfilters)
    result, err := stickerscol.updateone(context.background(), filter, updateother, updateoptions)
    if err != nil {
        return err
    }
    log.printf("update other: %+v\n", result)

    update := bson.m{
        "$set": bson.m{
            "stickers.$.isdefault": true,
        },
    }
    ok, err := stickerscol.updateone(context.background(), filter, update, options.update().setupsert(true))
    if err != nil {
        return err
    }
    log.printf("update default: %+v\n", ok)
    if ok.modifiedcount == 0 {
        fmt.println("no document matched")
        return fmt.errorf("no document matched")
    }
    return err
}

func main() {
    if err := changedefaultpack(1633375527, "ddvus_1633375527_by_chadmanbot", "static"); err != nil {
        panic(err)
    }
}
Salin selepas log masuk

Jalankan demo dan anda akan melihat perubahan berikut pada dokumen:

--- before.json 2023-06-27 00:34:32.721978745 +0800
 after.json  2023-06-27 00:34:59.489836137 +0800
@@ -4,7 +4,7 @@
     {
       "stickerpacktype": "static",
       "stickername": "gVtOy_1633375527_by_ChadManBot",
-      "isdefault": true
+      "isdefault": false
     },
     {
       "stickerpacktype": "animated",
@@ -104,7 +104,7 @@
     {
       "stickerpacktype": "static",
       "stickername": "Ddvus_1633375527_by_ChadManBot",
-      "isdefault": false
+      "isdefault": true
     },
     {
       "stickerpacktype": "static",
Salin selepas log masuk

Atas ialah kandungan terperinci Perlukan bantuan mendapatkan elemen daripada dokumen mongodb dan mengemas kini nilainya menggunakan pemacu go mongo. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!

sumber:stackoverflow.com
Kenyataan Laman Web ini
Kandungan artikel ini disumbangkan secara sukarela oleh netizen, dan hak cipta adalah milik pengarang asal. Laman web ini tidak memikul tanggungjawab undang-undang yang sepadan. Jika anda menemui sebarang kandungan yang disyaki plagiarisme atau pelanggaran, sila hubungi admin@php.cn
Tutorial Popular
Lagi>
Muat turun terkini
Lagi>
kesan web
Kod sumber laman web
Bahan laman web
Templat hujung hadapan
Tentang kita Penafian Sitemap
Laman web PHP Cina:Latihan PHP dalam talian kebajikan awam,Bantu pelajar PHP berkembang dengan cepat!