java/sql-dk/src/info/globalcode/sql/dk/DatabaseConnection.java
branchv_0
changeset 86 6b0eb3b22eb8
parent 65 f05be87239ad
child 91 43e8d52091d5
--- a/java/sql-dk/src/info/globalcode/sql/dk/DatabaseConnection.java	Fri Dec 27 18:30:37 2013 +0100
+++ b/java/sql-dk/src/info/globalcode/sql/dk/DatabaseConnection.java	Fri Dec 27 19:33:46 2013 +0100
@@ -26,6 +26,7 @@
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
+import java.sql.SQLWarning;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -73,6 +74,7 @@
 			} else {
 				processUpdateResult(sqlCommand, ps, formatter);
 			}
+			logWarnings(ps);
 
 			while (ps.getMoreResults() || ps.getUpdateCount() > -1) {
 				ResultSet rs = ps.getResultSet();
@@ -82,6 +84,7 @@
 					processResultSet(sqlCommand, rs, formatter);
 					rs.close();
 				}
+				logWarnings(ps);
 			}
 		}
 	}
@@ -120,6 +123,15 @@
 
 	}
 
+	private void logWarnings(PreparedStatement ps) throws SQLException {
+		SQLWarning w = ps.getWarnings();
+		while (w != null) {
+			log.log(Level.WARNING, "SQL: {0}", w.getLocalizedMessage());
+			w = w.getNextWarning();
+		}
+		ps.clearWarnings();
+	}
+
 	/**
 	 * Tests if this connection is live.
 	 *