我正在尝试保存两条记录,然后获取第二条记录。问题是过滤器似乎不起作用。尽管我按姓名(“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)
}
最佳答案
(第一个)问题是这样的:
q := datastore.NewQuery("employee")
q.Filter("Name =", "Andrew W")
Query.Filter()
返回包含您指定的过滤器的派生查询。您必须存储返回值并持续使用它:
q := datastore.NewQuery("employee")
q = q.Filter("Name =", "Andrew W")
或者只有一行:
q := datastore.NewQuery("employee").Filter("Name =", "Andrew W")
注意:如果没有这个,您执行的查询将没有过滤器,因此将返回所有以前保存的 "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 .仅当您想要高度一致的结果时才需要祖先键。如果您可以延迟几秒钟让结果显示出来,那么您不必这样做。另请注意,祖先键不一定是现有实体的键,它只是语义。您可以创建任何虚构的 key 。对多个实体使用相同的(虚构的)键会将它们放入同一个实体组,并且对该组的祖先查询将是高度一致的。
祖先 key 通常是现有 key ,通常派生自当前用户或帐户,因为它可以很容易地创建/计算并且它保存/存储一些附加信息,但如上所述,它不一定是.
关于google-app-engine - 如何过滤 GAE 查询?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29228712/