X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=support%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Ftest%2FSpringTestCase.java;h=29334e003e78cea974ae913e64e919dfe6a841f6;hb=162af365e45e54e5e8d656be276914df2005eaec;hp=8b66e0e2419473e240b830108fb843c3efbed599;hpb=cf25a3646c663c5aadbd2de8c23840550b18125b;p=utils diff --git a/support/src/test/java/org/wamblee/test/SpringTestCase.java b/support/src/test/java/org/wamblee/test/SpringTestCase.java index 8b66e0e2..29334e00 100644 --- a/support/src/test/java/org/wamblee/test/SpringTestCase.java +++ b/support/src/test/java/org/wamblee/test/SpringTestCase.java @@ -21,6 +21,7 @@ import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; +import java.util.HashMap; import java.util.Iterator; import java.util.List; import java.util.Map; @@ -453,7 +454,7 @@ public class SpringTestCase extends MockObjectTestCase { } /** - * Executes an SQL query within a transaction. + * Executes an SQL query. * * @param aSql * Query to execute. @@ -479,7 +480,7 @@ public class SpringTestCase extends MockObjectTestCase { } /** - * Executes a query within a transaction. See + * Executes a query. See * {@link #setPreparedParam(int, PreparedStatement, Object)}for details on * supported argument types. * @@ -490,22 +491,16 @@ public class SpringTestCase extends MockObjectTestCase { * @return Result set. */ public ResultSet executeQuery(final String aSql, final Object[] aArgs) { - Map results = executeTransaction(new TestTransactionCallback() { - public Map execute() throws Exception { - Connection connection = getConnection(); - - PreparedStatement statement = connection.prepareStatement(aSql); - setPreparedParams(aArgs, statement); + try { + Connection connection = getConnection(); - ResultSet resultSet = statement.executeQuery(); - TreeMap results = new TreeMap(); - results.put("resultSet", resultSet); + PreparedStatement statement = connection.prepareStatement(aSql); + setPreparedParams(aArgs, statement); - return results; - } - }); - - return (ResultSet) results.get("resultSet"); + return statement.executeQuery(); + } catch (SQLException e) { + throw new RuntimeException(e); + } } /** @@ -576,14 +571,14 @@ public class SpringTestCase extends MockObjectTestCase { * @return * @throws SQLException */ - protected int getTableSize(String aTable) throws SQLException { + protected int getTableSize(final String aTable) throws SQLException { + ResultSet resultSet = executeQuery("select * from " + aTable); int count = 0; while (resultSet.next()) { count++; } - return count; }