Added transactions

bakkdoor · Feb 28, 2012 · dbd41a0 · dbd41a0
1 parent 8ad11d7
commit dbd41a0
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 0 deletions.
diff --git a/examples/transactions.fy b/examples/transactions.fy
@@ -0,0 +1,11 @@
+require: "redis"
+
+r = Redis Client new
+
+r transaction: {
+  r[('set, 'hello, "world")]
+  r[('set, 'world, "hello")]
+}
+
+r[('get, 'hello)] println
+r[('get, 'world)] println
diff --git a/lib/redis/client.fy b/lib/redis/client.fy
@@ -52,6 +52,16 @@ class Redis {
       @thread_safe
     }
 
+    def transaction: block {
+      try {
+        call: ['multi]
+        block call: [self]
+      } catch {
+      } finally {
+        call: ['exec]
+      }
+    }
+
     def call: command {
       cmd_name = command first