马蒂·肖克does not recommend that solution anymore.
他的建议是:
doc := document.Document{
ID: post.URI,
}
if err := bleve.NewIndexMapping().MapDocument(&doc, post); err != nil {
return errors.Errorf("failed to map document: %v", err)
}
var b bytes.Buffer
enc := gob.NewEncoder(&b)
if err := enc.Encode(post); err != nil {
return errors.Errorf("failed to encode post: %v", err)
}
field := document.NewTextFieldWithIndexingOptions("_source", nil, b.Bytes(), document.StoreField)
if err := batch.IndexAdvanced(doc.AddField(field)); err != nil {
return errors.Errorf("failed to add index to the batch: %v", err)
}
query := bleve.NewMatchQuery(value)
request := bleve.NewSearchRequest(query)
request.Fields = []string{"_source"}
searchResults, err := ps.index.Search(request)
if err != nil {
return nil, errors.Errorf("failed to execute a search request: %v", err)
}
var searchPosts []*blog.Post
for _, result := range searchResults.Hits {
var post *blog.Post
b := bytes.NewBuffer([]byte(fmt.Sprintf("%v", result.Fields["_source"])))
dec := gob.NewDecoder(b)
if err = dec.Decode(&post); err != nil {
return nil, errors.Errorf("failed to decode post: %v", err)
}
searchPosts = append(searchPosts, post)
}
来源:https://gist.github.com/michaeljs1990/25f9949c10ab64d971422dda44feea0e