Go语言mgo库MongoDB _id字段解析异常排查与解决方案

type Article struct {
    // 注意：这里的json和bson标签之间可能存在问题
    Id      bson.ObjectId `json:"id"        bson:"_id,omitempty"`
    Title   string        `json:"title"`
    Author  string        `json:"author"`
    Date    string        `json:"date"`
    Tags    string        `json:"tags"`
    Content string        `json:"content"`
    Status  string        `json:"status"`
}

import (
    "gopkg.in/mgo.v2"
    "gopkg.in/mgo.v2/bson"
    // ... 其他导入
)

var c_articles *mgo.Collection // 假设c_articles已正确初始化

func AllArticles() []Article {
    articles := []Article{}
    err := c_articles.Find(bson.M{}).All(&articles)
    if err != nil {
        panic(err) // 在实际应用中应进行更优雅的错误处理
    }
    return articles
}

{ 
  "_id" : ObjectId( "5281b83afbb7f35cb62d0834" ),
  "title" : "Hello1",
  "author" : "DYZ",
  "date" : "2013-11-10",
  "tags" : "abc",
  "content" : "This is another content.",
  "status" : "published" 
}

[{ObjectIdHex("") Hello1 DYZ 2013-11-10 abc This is another content. published} {ObjectIdHex("") Hello2 DYZ 2013-11-14 abc This is the content. published}]

Id      bson.ObjectId `json:"id"        bson:"_id,omitempty"` // 注意json和bson之间使用了制表符或多个空格

Id      bson.ObjectId `json:"id" bson:"_id,omitempty"` // json和bson之间仅使用一个空格

package main

import (
    "fmt"
    "log"

    "gopkg.in/mgo.v2"
    "gopkg.in/mgo.v2/bson"
)

// Article 结构体定义，确保标签间使用单个空格
type Article struct {
    Id      bson.ObjectId `json:"id" bson:"_id,omitempty"` // 关键修正点
    Title   string        `json:"title"`
    Author  string        `json:"author"`
    Date    string        `json:"date"`
    Tags    string        `json:"tags"`
    Content string        `json:"content"`
    Status  string        `json:"status"`
}

var session *mgo.Session
var c_articles *mgo.Collection

func init() {
    // 假设MongoDB运行在本地，并有一个名为"testdb"的数据库
    // 在实际应用中，连接字符串和错误处理应更健壮
    var err error
    session, err = mgo.Dial("mongodb://localhost:27017")
    if err != nil {
        log.Fatalf("Failed to connect to MongoDB: %v", err)
    }
    session.SetMode(mgo.Monotonic, true) // 设置连接模式

    c_articles = session.DB("testdb").C("articles") // 连接到testdb数据库的articles集合
}

// AllArticles 从数据库中获取所有文章
func AllArticles() ([]Article, error) {
    articles := []Article{}
    err := c_articles.Find(bson.M{}).All(&articles)
    if err != nil {
        return nil, fmt.Errorf("failed to retrieve articles: %w", err)
    }
    return articles, nil
}

func main() {
    defer session.Close() // 确保在程序退出时关闭MongoDB会话

    // 假设数据库中已有数据，如果没有，可以插入一些测试数据
    // err := c_articles.Insert(Article{
    //     Id:      bson.NewObjectId(),
    //     Title:   "Test Article 1",
    //     Author:  "Go User",
    //     Date:    "2023-01-01",
    //     Tags:    "go,mongodb",
    //     Content: "This is a test article content.",
    //     Status:  "published",
    // })
    // if err != nil {
    //     log.Printf("Error inserting test data: %v", err)
    // }

    articles, err := AllArticles()
    if err != nil {
        log.Fatalf("Error getting articles: %v", err)
    }

    fmt.Println("Retrieved articles:")
    for _, article := range articles {
        fmt.Printf("ID: %s, Title: %s, Author: %s\n", article.Id.Hex(), article.Title, article.Author)
    }
}