lib/jvertica.rb in jvertica-0.0.3 vs lib/jvertica.rb in jvertica-0.1.1

@@ -52,10 +52,14 @@
 
   def commit
     @connection.commit
   end
 
+  def rollback
+    @connection.rollback
+  end
+
   #def prepare query
   #  @pstmt = @connection.prepareStatement query
   #end
 
   #def prepared?
@@ -126,15 +130,16 @@
       raise e.class.new("[affected rows: #{r}] #{e.message}")
     end
 
     begin
       stream.execute
+      rejects = stream.getRejects
       results = stream.finish
     rescue => e
       raise e
     end
 
-    results
+    [results, rejects.to_ary]
   end
 
   private
   class ConnectionError < StandardError
   end