如何过滤GAE查询？

Question

我正在尝试保存两条记录,然后获得第二条记录.问题是过滤器似乎不起作用.虽然我按名称("安德鲁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()返回包含您指定的过滤器的衍生查询.您必须存储返回值并持续使用它:

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})

但当然这只是为了测试目的,你不能在生产中这样做.

如果要获得强一致的结果,请在创建密钥时指定祖先密钥,并使用祖先查询.只有在需要强烈一致的结果时才需要祖先密钥.如果您只有几秒钟的延迟才能显示结果,那么您不必这样做.还要注意,祖先密钥不必是现有实体的密钥,它只是语义.您可以创建任何虚构的密钥.对多个实体使用相同(虚构)密钥将它们放入同一个实体组,并且该组上的祖先查询将非常一致.

祖先密钥通常是现有密钥,通常是从当前用户或帐户派生的,因为它可以轻松创建/计算并保存/存储一些附加信息,但如上所述,它不一定是.