SUnionByTwoBuckets

返回指定两个bucket里面的给定的两个集合的并集中的所有成员。

  1. bucket8 := "bucket1"
  2. key1 := []byte("mySet1")
  4. bucket9 := "bucket2"
  5. key2 := []byte("mySet2")
  7. if err := db.Update(
  8.     func(tx *nutsdb.Tx) error {
  9.         return tx.SAdd(bucket8, key1, []byte("a"), []byte("b"), []byte("c"))
  10.     }); err != nil {
  11.     log.Fatal(err)
  12. }
  14. if err := db.Update(
  15.     func(tx *nutsdb.Tx) error {
  16.         return tx.SAdd(bucket9, key2, []byte("c"), []byte("d"))
  17.     }); err != nil {
  18.     log.Fatal(err)
  19. }
  21. if err := db.View(
  22.     func(tx *nutsdb.Tx) error {
  23.         if items, err := tx.SUnionByTwoBuckets(bucket8, key1, bucket9, key2); err != nil {
  24.             return err
  25.         } else {
  26.             fmt.Println("SUnionByTwoBucket:", items)
  27.             for _, item := range items {
  28.                 fmt.Println("item", string(item))
  29.             }
  30.         }
  31.         return nil
  32.     }); err != nil {
  33.     log.Fatal(err)
  34. }