Author: rmannibucau
Date: Thu Jan 10 15:43:09 2013
New Revision: 1431442
URL: http://svn.apache.org/viewvc?rev=1431442&view=rev
Log:
how was working this test before - fixing it
Modified:
openejb/trunk/openejb/container/openejb-core/src/test/java/org/apache/openejb/resource/jdbc/MultiThreadedManagedDataSourceTest.java
Modified:
openejb/trunk/openejb/container/openejb-core/src/test/java/org/apache/openejb/resource/jdbc/MultiThreadedManagedDataSourceTest.java
URL:
http://svn.apache.org/viewvc/openejb/trunk/openejb/container/openejb-core/src/test/java/org/apache/openejb/resource/jdbc/MultiThreadedManagedDataSourceTest.java?rev=1431442&r1=1431441&r2=1431442&view=diff
==============================================================================
---
openejb/trunk/openejb/container/openejb-core/src/test/java/org/apache/openejb/resource/jdbc/MultiThreadedManagedDataSourceTest.java
(original)
+++
openejb/trunk/openejb/container/openejb-core/src/test/java/org/apache/openejb/resource/jdbc/MultiThreadedManagedDataSourceTest.java
Thu Jan 10 15:43:09 2013
@@ -40,8 +40,10 @@ import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
+import java.util.List;
import java.util.Map;
import java.util.Properties;
+import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
@@ -150,9 +152,11 @@ public class MultiThreadedManagedDataSou
@Test
public void insertsWithRollback() throws SQLException {
+ final int count = count("");
final AtomicInteger errors = new AtomicInteger(0);
final AtomicInteger fail = new AtomicInteger(0);
final AtomicInteger ok = new AtomicInteger(0);
+ final List<Exception> ex = new CopyOnWriteArrayList<Exception>();
run(new Runnable() {
@Override
public void run() {
@@ -165,6 +169,7 @@ public class MultiThreadedManagedDataSou
id = persistManager.saveRollback(!rollback);
} catch (SQLException e) {
errors.incrementAndGet();
+ ex.add(e);
}
if (!rollback) {
try {
@@ -173,13 +178,17 @@ public class MultiThreadedManagedDataSou
}
} catch (SQLException e) {
errors.incrementAndGet();
+ ex.add(e);
}
}
}
});
+ for (Exception e : ex) {
+ e.printStackTrace(System.err);
+ }
assertEquals(0, errors.get());
assertEquals(0, fail.get());
- assertEquals(ok.get(), count(""));
+ assertEquals(ok.get(), count("") - count);
}
@After
