Go Datastore灵活实体查询与ErrFieldMismatch处理指南

package main

import (
    "context"
    "encoding/json"
    "fmt"
    "log"
    "time"

    "google.golang.org/appengine/v2"
    "google.golang.org/appengine/v2/datastore"
)

// ItemA 和 ItemB 是两种不同的结构体，但都以 "Item" kind 存储
type ItemA struct {
    Name    string
    ValueA  int
    Created time.Time
}

type ItemB struct {
    Name    string
    ValueB  string
    Enabled bool
}

func main() {
    // 模拟App Engine上下文
    ctx := context.Background()
    // 在实际App Engine环境中，你需要使用 appengine.NewContext(r)
    // 这里为了示例，我们直接创建一个模拟上下文
    // 注意：在本地开发服务器上，你需要运行 dev_appserver.py
    // 或者使用 datastore/testutil 包进行测试
    // 对于生产环境，appengine.NewContext(r) 会自动提供一个有效的上下文

    // 假设我们已经有了一些数据
    // putExampleData(ctx) // 首次运行可以取消注释来填充数据

    // 1. 创建查询
    query := datastore.NewQuery("Item").Limit(10) // 可以添加Filter, Order等

    // 2. 声明目标切片为 []*datastore.Map
    var items []*datastore.Map // 注意这里是指针切片

    // 3. 执行 GetAll 查询
    keys, err := query.GetAll(ctx, &items)
    if err != nil {
        log.Fatalf("查询Datastore失败: %v", err)
    }

    fmt.Printf("成功查询到 %d 个实体。\n", len(items))

    // 4. 处理查询结果
    for i, itemMap := range items {
        fmt.Printf("\n--- 实体 %d (Key: %v) ---\n", i+1, keys[i])
        // itemMap 是一个 *datastore.Map，其内部是一个 map[string]interface{}
        // 可以直接访问其属性
        for k, v := range *itemMap {
            fmt.Printf("  %s: %v (类型: %T)\n", k, v, v)
        }

        // 示例：将单个实体编码为JSON
        jsonData, err := json.MarshalIndent(*itemMap, "", "  ")
        if err != nil {
            log.Printf("编码JSON失败: %v", err)
        } else {
            fmt.Printf("  JSON表示:\n%s\n", string(jsonData))
        }
    }

    // 示例：将所有查询结果编码为JSON数组
    allJSONData, err := json.MarshalIndent(items, "", "  ")
    if err != nil {
        log.Fatalf("编码所有JSON数据失败: %v", err)
    }
    fmt.Printf("\n--- 所有实体JSON数组 ---\n%s\n", string(allJSONData))
}

// putExampleData 用于向Datastore中填充一些示例数据
func putExampleData(ctx context.Context) {
    itemA1 := ItemA{Name: "Widget A", ValueA: 100, Created: time.Now()}
    itemB1 := ItemB{Name: "Gadget B", ValueB: "Alpha", Enabled: true}
    itemA2 := ItemA{Name: "Widget C", ValueA: 200, Created: time.Now().Add(-24 * time.Hour)}
    itemB2 := ItemB{Name: "Gadget D", ValueB: "Beta"} // Enabled 字段缺失

    itemsToPut := []interface{}{&itemA1, &itemB1, &itemA2, &itemB2}
    keys := make([]*datastore.Key, len(itemsToPut))

    for i, item := range itemsToPut {
        key := datastore.NewIncompleteKey(ctx, "Item", nil)
        k, err := datastore.Put(ctx, key, item)
        if err != nil {
            log.Fatalf("存储实体失败: %v", err)
        }
        keys[i] = k
        fmt.Printf("存储实体成功: Kind=%s, ID=%d\n", k.Kind(), k.ID())
    }
    fmt.Println("示例数据填充完成。")
}