MCPcopy Create free account
hub / github.com/couchbase/cbft / TestDeleteByQuery

Function TestDeleteByQuery

pindex_bleve_delete_test.go:18–169  ·  view source on GitHub ↗
(t *testing.T)

Source from the content-addressed store, hash-verified

16)
17
18func TestDeleteByQuery(t *testing.T) {
19 bleve.Config.DefaultIndexType = "scorch"
20 defer func() {
21 err := os.RemoveAll("testidx")
22 if err != nil {
23 t.Fatal(err)
24 }
25 }()
26
27 index, err := bleve.New("testidx", bleve.NewIndexMapping())
28 if err != nil {
29 t.Fatal(err)
30 }
31
32 batch := index.NewBatch()
33 doca := map[string]interface{}{
34 "name": "couchbase fts",
35 "desc": "awesome search functionality",
36 }
37 err = batch.Index("a", doca)
38 if err != nil {
39 t.Error(err)
40 }
41
42 docy := map[string]interface{}{
43 "name": "couchbase fts dev",
44 "desc": "steve abhi sreekanth",
45 }
46 err = batch.Index("y", docy)
47 if err != nil {
48 t.Error(err)
49 }
50
51 docx := map[string]interface{}{
52 "name": "couchbase fts dead",
53 "desc": "keshav",
54 }
55 err = batch.Index("x", docx)
56 if err != nil {
57 t.Error(err)
58 }
59
60 docb := map[string]interface{}{
61 "name": "couchbase fts test",
62 "desc": "girish master",
63 }
64 err = batch.Index("b", docb)
65 if err != nil {
66 t.Error(err)
67 }
68
69 err = index.Batch(batch)
70 if err != nil {
71 t.Error(err)
72 }
73
74 // close the index, open it again
75 err = index.Close()

Callers

nothing calls this directly

Calls 8

newDelByQueryHandlerFunction · 0.85
deleteByQueryMethod · 0.80
DocCountMethod · 0.65
NewBatchMethod · 0.45
IndexMethod · 0.45
BatchMethod · 0.45
CloseMethod · 0.45
ResetMethod · 0.45

Tested by

no test coverage detected