summaryrefslogtreecommitdiff
path: root/qpid/java/perftests/src
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/java/perftests/src')
-rw-r--r--qpid/java/perftests/src/main/java/org/apache/qpid/disttest/db/ResultsDbWriter.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/db/ResultsDbWriter.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/db/ResultsDbWriter.java
index 549f37c2da..456c13a2b9 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/db/ResultsDbWriter.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/db/ResultsDbWriter.java
@@ -25,7 +25,6 @@ import static org.apache.qpid.disttest.message.ParticipantAttribute.TEST_NAME;
import static org.apache.qpid.disttest.message.ParticipantAttribute.THROUGHPUT;
import java.sql.Connection;
-import java.sql.Driver;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
@@ -203,8 +202,7 @@ public class ResultsDbWriter
+ " missing from context environment: " + environment);
}
- @SuppressWarnings("unchecked")
- Class<? extends Driver> driverClass = (Class<? extends Driver>) Class.forName(driverName);
+ Class.forName(driverName);
Object url = environment.get(URL);
if(url == null)
@@ -411,6 +409,10 @@ public class ResultsDbWriter
statement.execute();
connection.commit();
}
+ catch(SQLException e)
+ {
+ _logger.error("Couldn't write " + participantResult, e);
+ }
finally
{
if (statement != null)