SMoveByTwoBuckets

将member从source集合移动到destination集合中。其中source集合和destination集合在两个不同的bucket中。

  1. bucket4 := "bucket4"
  2. bucket5 := "bucket5"
  3. if err := db.Update(
  4.     func(tx *nutsdb.Tx) error {
  5.         return tx.SAdd(bucket4, []byte("mySet1"), []byte("a"), []byte("b"), []byte("c"))
  6.     }); err != nil {
  7.     log.Fatal(err)
  8. }
  9. if err := db.Update(
  10.     func(tx *nutsdb.Tx) error {
  11.         return tx.SAdd(bucket5, []byte("mySet2"), []byte("c"), []byte("d"), []byte("e"))
  12.     }); err != nil {
  13.     log.Fatal(err)
  14. }
  16. if err := db.Update(
  17.     func(tx *nutsdb.Tx) error {
  18.         if ok, err := tx.SMoveByTwoBuckets(bucket4, []byte("mySet1"), bucket5, []byte("mySet2"), []byte("a")); err != nil {
  19.             return err
  20.         } else {
  21.             fmt.Println("SMoveByTwoBuckets", ok)
  22.         }
  23.         return nil
  24.     }); err != nil {
  25.     log.Fatal(err)
  26. }
  28. if err := db.View(
  29.     func(tx *nutsdb.Tx) error {
  30.         if items, err := tx.SMembers(bucket4, []byte("mySet1")); err != nil {
  31.             return err
  32.         } else {
  33.             fmt.Println("after SMoveByTwoBuckets bucket4 mySet1 SMembers", items)
  34.             for _, item := range items {
  35.                 fmt.Println("item", string(item))
  36.             }
  37.         }
  38.         return nil
  39.     }); err != nil {
  40.     log.Fatal(err)
  41. }
  43. if err := db.View(
  44.     func(tx *nutsdb.Tx) error {
  45.         if items, err := tx.SMembers(bucket5, []byte("mySet2")); err != nil {
  46.             return err
  47.         } else {
  48.             fmt.Println("after SMoveByTwoBuckets bucket5 mySet2 SMembers", items)
  49.             for _, item := range items {
  50.                 fmt.Println("item", string(item))
  51.             }
  52.         }
  53.         return nil
  54.     }); err != nil {
  55.     log.Fatal(err)
  56. }