add multi.tcl

tests/unit/type/multi.tcl

@@ -0,0 +1,321 @@
+start_server {tags {"multi"}} {
+    test {MUTLI / EXEC basics} {
+        r del mylist
+        r rpush mylist a
+        r rpush mylist b
+        r rpush mylist c
+        r multi
+        set v1 [r lrange mylist 0 -1]
+        set v2 [r ping]
+        set v3 [r exec]
+        list $v1 $v2 $v3
+    } {QUEUED QUEUED {{a b c} PONG}}
+
+    test {DISCARD} {
+        r del mylist
+        r rpush mylist a
+        r rpush mylist b
+        r rpush mylist c
+        r multi
+        set v1 [r del mylist]
+        set v2 [r discard]
+        set v3 [r lrange mylist 0 -1]
+        list $v1 $v2 $v3
+    } {QUEUED OK {a b c}}
+
+    test {Nested MULTI are not allowed} {
+        set err {}
+        r multi
+        catch {[r multi]} err
+        r exec
+        set _ $err
+    } {*ERR MULTI*}
+
+    test {MULTI where commands alter argc/argv} {
+        r sadd myset a
+        r multi
+        r spop myset
+        list [r exec] [r exists myset]
+    } {a 0}
+
+    test {WATCH inside MULTI is not allowed} {
+        set err {}
+        r multi
+        catch {[r watch x]} err
+        r exec
+        set _ $err
+    } {*ERR WATCH*}
+
+    test {EXEC fails if there are errors while queueing commands #1} {
+        r del foo1 foo2
+        r multi
+        r set foo1 bar1
+        catch {r non-existing-command}
+        r set foo2 bar2
+        catch {r exec} e
+        assert_match {EXECABORT*} $e
+        list [r exists foo1] [r exists foo2]
+    } {0 0}
+
+# This parameter is not available in Pika
+#    test {EXEC fails if there are errors while queueing commands #2} {
+#        set rd [redis_deferring_client]
+#        r del foo1 foo2
+#        r multi
+#        r set foo1 bar1
+#        $rd config set maxmemory 1
+#        assert  {[$rd read] eq {OK}}
+#        catch {r lpush mylist myvalue}
+#        $rd config set maxmemory 0
+#        assert  {[$rd read] eq {OK}}
+#        r set foo2 bar2
+#        catch {r exec} e
+#        assert_match {EXECABORT*} $e
+#        $rd close
+#        list [r exists foo1] [r exists foo2]
+#    } {0 0}
+
+    test {If EXEC aborts, the client MULTI state is cleared} {
+        r del foo1 foo2
+        r multi
+        r set foo1 bar1
+        catch {r non-existing-command}
+        r set foo2 bar2
+        catch {r exec} e
+        assert_match {EXECABORT*} $e
+        r ping
+    } {PONG}
+
+    test {EXEC works on WATCHed key not modified} {
+        r watch x y z
+        r watch k
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+# The return value of Pika is inconsistent with Redis
+#    test {EXEC fail on WATCHed key modified (1 key of 1 watched)} {
+#        r set x 30
+#        r watch x
+#        r set x 40
+#        r multi
+#        r ping
+#        r exec
+#    } {}
+
+# The return value of Pika is inconsistent with Redis
+#    test {EXEC fail on WATCHed key modified (1 key of 5 watched)} {
+#        r set x 30
+#        r watch a b x k z
+#        r set x 40
+#        r multi
+#        r ping
+#        r exec
+#    } {}
+
+# The return value of Pika is inconsistent with Redis
+#    test {EXEC fail on WATCHed key modified by SORT with STORE even if the result is empty} {
+#        r flushdb
+#        r lpush foo barsync"
+#        r watch foo
+#        r sort emptylist store foo
+#        r multi
+#        r ping
+#        r exec
+#    } {}
+
+    test {After successful EXEC key is no longer watched} {
+        r set x 30
+        r watch x
+        r multi
+        r ping
+        r exec
+        r set x 40
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+    test {After failed EXEC key is no longer watched} {
+        r set x 30
+        r watch x
+        r set x 40
+        r multi
+        r ping
+        r exec
+        r set x 40
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+    test {It is possible to UNWATCH} {
+        r set x 30
+        r watch x
+        r set x 40
+        r unwatch
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+    test {UNWATCH when there is nothing watched works as expected} {
+        r unwatch
+    } {OK}
+
+# The return value of Pika is inconsistent with Redis
+#    test {FLUSHALL is able to touch the watched keys} {
+#        r set x 30
+#        r watch x
+#        r flushall
+#        r multi
+#        r ping
+#        r exec
+#    } {}
+
+    test {FLUSHALL does not touch non affected keys} {
+        r del x
+        r watch x
+        r flushall
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+# The return value of Pika is inconsistent with Redis
+#    test {FLUSHDB is able to touch the watched keys} {
+#        r set x 30
+#        r watch x
+#        r flushdb
+#        r multi
+#        r ping
+#        r exec
+#    } {}
+
+    test {FLUSHDB does not touch non affected keys} {
+        r del x
+        r watch x
+        r flushdb
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+# The return value of Pika is inconsistent with Redis
+#    test {WATCH is able to remember the DB a key belongs to} {
+#        r select 5
+#        r set x 30
+#        r watch x
+#        r select 1
+#        r set x 10
+#        r select 5
+#        r multi
+#        r ping
+#        set res [r exec]
+#        # Restore original DB
+#        r select 9
+#        set res
+#    } {PONG}
+
+# The return value of Pika is inconsistent with Redis
+#    test {WATCH will consider touched keys target of EXPIRE} {
+#        r del x
+#        r set x foo
+#        r watch x
+#        r expire x 10
+#        r multi
+#        r ping
+#        r exec
+#    } {}
+
+    test {WATCH will not consider touched expired keys} {
+        r del x
+        r set x foo
+        r expire x 1
+        r watch x
+        after 1100
+        r multi
+        r ping
+        r exec
+    } {PONG}
+
+    test {DISCARD should clear the WATCH dirty flag on the client} {
+        r watch x
+        r set x 10
+        r multi
+        r discard
+        r multi
+        r incr x
+        r exec
+    } {11}
+
+    test {DISCARD should UNWATCH all the keys} {
+        r watch x
+        r set x 10
+        r multi
+        r discard
+        r set x 10
+        r multi
+        r incr x
+        r exec
+    } {11}
+
+# Pika does not support the sync command
+#    test {MULTI / EXEC is propagated correctly (single write command)} {
+#        set repl [attach_to_replication_stream]
+#        r multi
+#        r set foo bar
+#        r exec
+#        assert_replication_stream $repl {
+#            {select *}
+#            {multi}
+#            {set foo bar}
+#            {exec}
+#        }
+#        close_replication_stream $repl
+#   }
+
+# Pika does not support the sync command
+#    test {MULTI / EXEC is propagated correctly (empty transaction)} {
+#        set repl [attach_to_replication_stream]
+#        r multi
+#        r exec
+#        r set foo bar
+#        assert_replication_stream $repl {
+#            {select *}
+#            {set foo bar}
+#        }
+#        close_replication_stream $repl
+#    }
+
+# Pika does not support the sync command
+#    test {MULTI / EXEC is propagated correctly (read-only commands)} {
+#        r set foo value1
+#        set repl [attach_to_replication_stream]
+#        r multi
+#        r get foo
+#        r exec
+#        r set foo value2
+#        assert_replication_stream $repl {
+#            {select *}
+#            {set foo value2}
+#        }
+#        close_replication_stream $repl
+#    }
+
+# Pika does not support the sync command
+#    test {MULTI / EXEC is propagated correctly (write command, no effect)} {
+#       r del bar foo bar
+#        set repl [attach_to_replication_stream]
+#        r multi
+#        r del foo
+#        r exec
+#        assert_replication_stream $repl {
+#            {select *}
+#            {multi}
+#            {exec}
+#        }
+#        close_replication_stream $repl
+#    }
+}