add query to exception message

cwensel · May 5, 2009 · eaa6786 · eaa6786
1 parent ece90a7
commit eaa6786
Showing 1 changed file with 10 additions and 2 deletions.
diff --git a/src/java/cascading/jdbc/db/DBInputFormat.java b/src/java/cascading/jdbc/db/DBInputFormat.java
@@ -77,7 +77,7 @@ protected class DBRecordReader implements RecordReader<LongWritable, T>
      * @param split The InputSplit to read data for
      * @throws SQLException
      */
-    protected DBRecordReader( DBInputSplit split, Class<T> inputClass, JobConf job ) throws SQLException
+    protected DBRecordReader( DBInputSplit split, Class<T> inputClass, JobConf job ) throws SQLException, IOException
       {
       this.inputClass = inputClass;
       this.split = split;
@@ -86,7 +86,15 @@ protected DBRecordReader( DBInputSplit split, Class<T> inputClass, JobConf job )
       statement = connection.createStatement( ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY );
 
       //statement.setFetchSize(Integer.MIN_VALUE);
-      results = statement.executeQuery( getSelectQuery() );
+      String query = getSelectQuery();
+      try
+        {
+        results = statement.executeQuery( query );
+        }
+      catch( SQLException exception )
+        {
+        throw new IOException( "unable to execute select query: " + query, exception );
+        }
       }
 
     /**