lib/adhoq/executor.rb in adhoq-0.0.2 vs lib/adhoq/executor.rb in adhoq-0.0.3

@@ -1,13 +1,24 @@
 module Adhoq
   class Executor
     class << self
       def select(query)
-        current_connection.send(:select, query)
+        with_sandbox do
+          current_connection.exec_query(query)
+        end
       end
 
       def current_connection
         ActiveRecord::Base.connection
+      end
+
+      def with_sandbox
+        result = nil
+        ActiveRecord::Base.transaction do
+          result = yield
+          raise ActiveRecord::Rollback
+        end
+        result
       end
     end
 
     def initialize(query)
       @query = query