SUnionByOneBucket

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

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