• SMoveByTwoBuckets
    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. }