更新 Datastore 实体：如何在不改变实体键的情况下修改祖先-Golang-PHP中文网

更新 Datastore 实体：如何在不改变实体键的情况下修改祖先

DDD

发布： 2025-09-15 17:32:01

原创

911人浏览过

更新 datastore 实体：如何在不改变实体键的情况下修改祖先

在 Google Cloud Datastore 中，实体的键（Key）是其唯一标识符。键的组成部分包括种类（Kind）、名称或 ID，以及祖先路径（Ancestor Path）。祖先路径定义了实体在数据层级结构中的位置。因此，无法直接在不改变实体键的情况下修改实体的祖先，因为祖先是键的一部分。

如果尝试更改实体的祖先，实际上是在创建一个新的实体，而原始实体仍然存在。这可能会导致数据不一致或其他问题，特别是在现有代码中已经使用旧键引用的情况下。

替代方案：使用属性而非实体组

如果你的应用场景允许，可以考虑避免使用实体组，并采用以下替代方案：

在实体中添加属性来表示层级关系。 例如，对于 Company/Department/Employee 这种层级结构，可以在 Employee 实体中添加 Company 和 Department 属性。

type Employee struct {
    Company    string `datastore:"company"`
    Department string `datastore:"department"`
    Name       string `datastore:"name"`
}

登录后复制

使用属性进行查询。 即使没有实体组，你仍然可以通过这些属性进行查询。

q := datastore.NewQuery("Employee").
    Filter("company =", "MyCompany").
    Filter("department =", "MyDepartment")

var employees []*Employee
keys, err := client.GetAll(ctx, q, &employees)
if err != nil {
    // Handle error
}

登录后复制

示例代码

以下是一个完整的示例，展示了如何使用属性来模拟层级关系：

package main

import (
    "context"
    "fmt"
    "log"
    "os"

    "cloud.google.com/go/datastore"
)

type Employee struct {
    Company    string `datastore:"company"`
    Department string `datastore:"department"`
    Name       string `datastore:"name"`
}

func main() {
    ctx := context.Background()

    // Replace "your-project-id" with your actual Google Cloud project ID.
    projectID := os.Getenv("GOOGLE_CLOUD_PROJECT")
    if projectID == "" {
        log.Fatalf("GOOGLE_CLOUD_PROJECT environment variable must be set.")
    }

    client, err := datastore.NewClient(ctx, projectID)
    if err != nil {
        log.Fatalf("Failed to create client: %v", err)
    }
    defer client.Close()

    // Create a new Employee entity.
    employee := &Employee{
        Company:    "MyCompany",
        Department: "MyDepartment",
        Name:       "John Doe",
    }

    // Create a key for the entity.
    key := datastore.NameKey("Employee", "john.doe", nil)

    // Save the entity to Datastore.
    _, err = client.Put(ctx, key, employee)
    if err != nil {
        log.Fatalf("Failed to save employee: %v", err)
    }

    fmt.Println("Employee saved successfully.")

    // Query for the employee.
    q := datastore.NewQuery("Employee").
        Filter("company =", "MyCompany").
        Filter("department =", "MyDepartment").
        Filter("name =", "John Doe")

    var employees []*Employee
    keys, err := client.GetAll(ctx, q, &employees)
    if err != nil {
        log.Fatalf("Failed to query employees: %v", err)
    }

    if len(employees) > 0 {
        fmt.Printf("Found employee: %+v, key: %+v\n", employees[0], keys[0])
    } else {
        fmt.Println("Employee not found.")
    }
}

登录后复制

注意事项：

AssemblyAI

转录和理解语音的AI模型

查看详情

确保已设置 GOOGLE_CLOUD_PROJECT 环境变量。
将 datastore:"company" 等标签添加到结构体字段，以便 Datastore 知道如何将数据映射到实体。
使用 datastore.NameKey 创建具有名称的键，或使用 datastore.IDKey 创建具有 ID 的键。

强一致性与最终一致性

使用属性进行查询时，需要注意数据一致性。Datastore 查询通常是最终一致的，这意味着在属性更新后，可能需要几秒钟的时间才能反映在查询结果中。

如果需要强一致性，可以通过键直接查找实体。按键查找始终返回最新的版本。

// Get the employee by key.
var employee Employee
err = client.Get(ctx, key, &employee)
if err != nil {
    log.Fatalf("Failed to get employee by key: %v", err)
}

fmt.Printf("Employee retrieved by key: %+v\n", employee)

登录后复制