You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by ti...@apache.org on 2016/02/29 20:01:35 UTC
svn commit: r1732936 -
/aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/SpringJdbcTemplateTransactionTest.java
Author: timothyjward
Date: Mon Feb 29 19:01:35 2016
New Revision: 1732936
URL: http://svn.apache.org/viewvc?rev=1732936&view=rev
Log:
[tx-control] Add a Spring rollback test
Modified:
aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/SpringJdbcTemplateTransactionTest.java
Modified: aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/SpringJdbcTemplateTransactionTest.java
URL: http://svn.apache.org/viewvc/aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/SpringJdbcTemplateTransactionTest.java?rev=1732936&r1=1732935&r2=1732936&view=diff
==============================================================================
--- aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/SpringJdbcTemplateTransactionTest.java (original)
+++ aries/trunk/tx-control/tx-control-itests/src/test/java/org/apache/aries/tx/control/itests/SpringJdbcTemplateTransactionTest.java Mon Feb 29 19:01:35 2016
@@ -22,6 +22,8 @@ import static org.junit.Assert.assertEqu
import static org.ops4j.pax.exam.CoreOptions.composite;
import static org.ops4j.pax.exam.CoreOptions.mavenBundle;
+import java.sql.ResultSet;
+
import org.junit.Before;
import org.junit.Test;
import org.junit.runner.RunWith;
@@ -58,6 +60,22 @@ public class SpringJdbcTemplateTransacti
jdbcTemplate.queryForObject("Select * from TEST_TABLE", String.class)));
}
+ @Test
+ public void testJdbcTemplateRollback() {
+
+ StatementCallback<Boolean> callback = s ->
+ s.execute("Insert into TEST_TABLE values ( 'Hello World!' )");
+
+ txControl.required(() -> {
+ jdbcTemplate.execute(callback);
+ txControl.setRollbackOnly();
+ return null;
+ });
+
+ assertEquals(Integer.valueOf(0), txControl.notSupported(() ->
+ jdbcTemplate.queryForInt("Select count(*) from TEST_TABLE")));
+ }
+
@Override
protected Option testSpecificOptions() {