如何过滤 GAE 查询？

Question

我正在尝试保存两条记录，然后获取第二条记录。问题是过滤器似乎不起作用。虽然我按名称 ("Andrew W") 过滤，但我总是得到 "Joe Citizen"。计数器还指示 2 条记录，而它应该只是一条记录。这让我发疯。请参阅下面的完整代码。结果打印 counter 2 e2 {"Joe Citizen" "Manager" "2015-03-24 09:08:58.363929 +0000 UTC" ""}

package main
import (
    "fmt"
    "time"
    "net/http"

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


type Employee struct {
    Name     string
    Role     string
    HireDate time.Time
    Account  string
}
func init(){

    http.HandleFunc("/", handle)
}
func handle(w http.ResponseWriter, r *http.Request) {
    c := appengine.NewContext(r)

    e1 := Employee{
        Name:     "Joe Citizen",
        Role:     "Manager",
        HireDate: time.Now(),
    }

    _, err := datastore.Put(c, datastore.NewKey(c, "employee", "", 0, nil), &e1)
    if err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
    panic(err)
        return
    }
    e1.Name = "Andrew W"

    _, err = datastore.Put(c, datastore.NewKey(c, "employee", "", 0, nil), &e1)
    if err != nil {
        http.Error(w, err.Error(), http.StatusInternalServerError)
    panic(err)
        return
    }

    var e2 Employee
    q :=  datastore.NewQuery("employee")
    q.Filter("Name =", "Andrew W")
    cnt, err  := q.Count(c)
    if err !=nil{
        http.Error(w, err.Error(), http.StatusInternalServerError)
        panic(err)
        return
    }
    for t := q.Run(c); ; {  
        if _, err := t.Next(&e2); err != nil {
             http.Error(w, err.Error(), http.StatusInternalServerError)
            panic(err)
            return
        }
        break
    }   
    fmt.Fprintf(w, "counter %v e2 %q", cnt, e2)
}

Answer 1

（第一个）问题是这样的：

q :=  datastore.NewQuery("employee")
q.Filter("Name =", "Andrew W")

Query.Filter() returns 包含您指定的过滤器的派生查询。您必须存储 return 值并持续使用它：

q := datastore.NewQuery("employee")
q = q.Filter("Name =", "Andrew W")

或者只有一行：

q := datastore.NewQuery("employee").Filter("Name =", "Andrew W")

注意：如果没有这个，您执行的查询将没有过滤器，因此 return 所有以前保存的 "employee" 类型的实体，其中 "Joe Citizen" 可能是第一个你看印出来了。

对于第一个运行，您很可能会看到 0 个结果。请注意，由于您不使用 Ancestor 查询，最终一致性适用。开发SDK模拟最终一致性的高复制数据存储，因此Put()操作后的查询将看不到结果。

如果您在继续查询之前放置一个小 time.Sleep()，您将看到您期望的结果：

time.Sleep(time.Second)

var e2 Employee
q := datastore.NewQuery("employee").Filter("Name=", "Andrew W")
// Rest of your code...

另请注意，运行在 SDK 中使用您的代码，您可以通过像这样创建上下文来模拟强一致性：

c, err := aetest.NewContext(&aetest.Options{StronglyConsistentDatastore: true})

但这当然只是为了测试目的，您不能在生产中这样做。

如果您想要高度一致的结果，请在创建密钥时指定一个祖先密钥，并使用ancestor queries。仅当您想要高度一致的结果时才需要祖先键。如果您可以延迟几秒钟让结果显示出来，那么您不必这样做。另请注意，祖先键不一定是现有实体的键，它只是语义。您可以创建任何虚构的密钥。对多个实体使用相同的（虚构的）键会将它们放入同一个实体组，并且对该组的祖先查询将是高度一致的。

祖先密钥通常是现有密钥，通常派生自当前用户或帐户，因为它可以 created/computed 很容易并且它 holds/stores 一些附加信息，但如上所述，它不一定。

如何过滤 GAE 查询？

How to filter a GAE query?

google-app-engine

go

google-cloud-datastore