bug: transactions must correctly rollback in case of exception

martinpoljak · Jul 14, 2011 · 23e6a55 · 23e6a55
1 parent e6ba704
commit 23e6a55
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/lib/fluent-query/connection.rb b/lib/fluent-query/connection.rb
@@ -256,7 +256,12 @@ def do(query)
         public
         def transaction(&block)
             self.begin
-            block.call
+            begin
+                block.call
+            rescue ::Exception => e
+                self.rollback
+                raise e
+            end
             self.commit
         end