mongodb - Golang 和 MongoDB : DeleteMany with filter

Question

我尝试使用 go 的官方 mongodb 驱动程序 (go.mongodb.org/mongo-driver) 从 Go 应用程序读取、写入和删除数据。

这是我要使用的结构:

Contact struct {
    ID               xid.ID `json:"contact_id" bson:"contact_id"`
    SurName          string `json:"surname" bson:"surname"`
    PreName          string `json:"prename" bson:"prename"`
}
// xid is https://github.com/rs/xid

我省略了添加到集合中的代码，因为这是有效的查找。

我可以使用以下代码(缩写)获取具有特定 contact_id 的联系人列表:

filter := bson.D{}
cursor, err := contactCollection.Find(nil, filter)
for cur.Next(context.TODO()) {
  ...
}

这有效并返回文档。我考虑过对删除或匹配的获取做同样的事情:

// delete - abbreviated
filter := bson.M{"contact_id": id}
result, _ := contactCollection.DeleteMany(nil, filter)
// result.DeletedCount is always 0, err is nil
if err != nil {
    sendError(c, err) // helper function
    return
}

c.JSON(200, gin.H{
    "ok":      true,
    "message": fmt.Sprintf("deleted %d patients", result.DeletedCount),
}) // will be called, it is part of a webservice done with gin

// get complete
func Get(c *gin.Context) {
    defer c.Done()

    id := c.Param("id")
    filter := bson.M{"contact_id": id}

    cur, err := contactCollection.Find(nil, filter)
    if err != nil {
        sendError(c, err) // helper function
        return
    } // no error

    contacts := make([]types.Contact, 0)
    for cur.Next(context.TODO()) { // nothing returned
        // create a value into which the single document can be decoded
        var elem types.Contact
        err := cur.Decode(&elem)
        if err != nil {
            sendError(c, err) // helper function
            return
        }
        contacts = append(contacts, elem)
    }

    c.JSON(200, contacts)
}

为什么同样的过滤器对删除不起作用？

编辑:插入代码如下所示:

_, _ = contactCollection.InsertOne(context.TODO(), Contact{
    ID: "abcdefg",
    SurName: "Demo",
    PreName: "on stackoverflow",
})

Answer 1

Contact.ID 的类型为 xid.ID ，这是一个字节数组:

type ID [rawLen]byte

因此，您在使用 string 文字指定 ID 字段的值时提供的插入代码将是一个编译时错误:

_, _ = contactCollection.InsertOne(context.TODO(), Contact{
    ID: "abcdefg",
    SurName: "Demo",
    PreName: "on stackoverflow",
})

稍后在您的评论中您澄清了上面的插入代码只是一个示例，而不是您实际执行的方式。在您的真实代码中，您从请求中解码联系人(或其 ID 字段)。

xid.ID有自己的解码逻辑，这可能会以不同的方式解释输入数据，并可能导致 ID 表示与您的输入不同的 string 值。 ID.UnmarshalJSON()定义如何将 string ID 转换为 xid.ID:

func (id *ID) UnmarshalJSON(b []byte) error {
    s := string(b)
    if s == "null" {
        *id = nilID
        return nil
    }
    return id.UnmarshalText(b[1 : len(b)-1])
}

如你所见，第一个字节被截断，ID.UnmarshalText()在它上面做更多的“魔法”(如果您有兴趣，请检查来源)。

总而言之，为避免在您不知情的情况下在后台发生此类“转换”，请为您的 ID 使用简单的 string 类型，并在需要存储的地方自行进行必要的转换/传输您的 ID。