#37 log errors

lib/pgtk/pool.rb

@@ -137,14 +137,19 @@ def initialize(conn, log)
     def exec(query, args = [], result = 0)
       start = Time.now
       sql = query.is_a?(Array) ? query.join(' ') : query
-      out = @conn.exec_params(sql, args, result) do |res|
-        if block_given?
-          yield res
-        else
-          rows = []
-          res.each { |r| rows << r }
-          rows
+      begin
+        out = @conn.exec_params(sql, args, result) do |res|
+          if block_given?
+            yield res
+          else
+            rows = []
+            res.each { |r| rows << r }
+            rows
+          end
         end
+      rescue StandardError => e
+        @log.error("#{sql}: #{e.message}")
+        raise e
       end
       lag = Time.now - start
       if lag < 1

test/test_pool.rb

@@ -64,6 +64,16 @@ def test_logs_sql
     end
   end
 
+  def test_logs_errors
+    log = Loog::Buffer.new
+    bootstrap(log: log) do |pool|
+      assert_raises PG::UndefinedTable do
+        pool.exec('INSERT INTO tableDoesNotExist (a) VALUES (42)')
+      end
+      assert(log.to_s.include?('INSERT INTO tableDoesNotExist'))
+    end
+  end
+
   def test_transaction
     bootstrap do |pool|
       id = pool.transaction do |t|