📄 datasourcetransactionmanagertests.java
字号:
dsControl.setReturnValue(con, 1);
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization not active", !TransactionSynchronizationManager.isSynchronizationActive());
try {
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Is new transaction", status.isNewTransaction());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertTrue("Is existing transaction", !status.isNewTransaction());
status.setRollbackOnly();
}
});
assertTrue("Is new transaction", status.isNewTransaction());
}
});
fail("Should have thrown UnexpectedRollbackException");
}
catch (UnexpectedRollbackException ex) {
// expected
}
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testPropagationRequiresNewWithExistingTransaction() throws Exception {
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
con.getAutoCommit();
conControl.setReturnValue(false, 2);
con.rollback();
conControl.setVoidCallable(1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 2);
con.close();
conControl.setVoidCallable(2);
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 2);
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization not active", !TransactionSynchronizationManager.isSynchronizationActive());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Is new transaction", status.isNewTransaction());
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertTrue(TransactionSynchronizationManager.isActualTransactionActive());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertTrue("Is new transaction", status.isNewTransaction());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertTrue(TransactionSynchronizationManager.isActualTransactionActive());
status.setRollbackOnly();
}
});
assertTrue("Is new transaction", status.isNewTransaction());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertTrue(TransactionSynchronizationManager.isActualTransactionActive());
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testPropagationNotSupportedWithExistingTransaction() throws Exception {
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
con.getAutoCommit();
conControl.setReturnValue(false, 1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization not active", !TransactionSynchronizationManager.isSynchronizationActive());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Is new transaction", status.isNewTransaction());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertTrue(TransactionSynchronizationManager.isActualTransactionActive());
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertTrue("Isn't new transaction", !status.isNewTransaction());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertFalse(TransactionSynchronizationManager.isActualTransactionActive());
status.setRollbackOnly();
}
});
assertTrue("Is new transaction", status.isNewTransaction());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertTrue(TransactionSynchronizationManager.isActualTransactionActive());
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testPropagationNeverWithExistingTransaction() throws Exception {
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
con.getAutoCommit();
conControl.setReturnValue(false, 1);
con.rollback();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization not active", !TransactionSynchronizationManager.isSynchronizationActive());
try {
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Is new transaction", status.isNewTransaction());
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_NEVER);
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
fail("Should have thrown IllegalTransactionStateException");
}
});
fail("Should have thrown IllegalTransactionStateException");
}
});
}
catch (IllegalTransactionStateException ex) {
// expected
}
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testPropagationRequiresNewWithExistingConnection() throws Exception {
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
con.getAutoCommit();
conControl.setReturnValue(false, 1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_SUPPORTS);
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization not active", !TransactionSynchronizationManager.isSynchronizationActive());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
Connection con = DataSourceUtils.getConnection(ds);
DataSourceUtils.releaseConnection(con, ds);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertTrue("Is new transaction", status.isNewTransaction());
Connection con = DataSourceUtils.getConnection(ds);
DataSourceUtils.releaseConnection(con, ds);
}
});
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testTransactionWithIsolationAndReadOnly() throws Exception {
MockControl dsControl = MockControl.createControl(DataSource.class);
DataSource ds = (DataSource) dsControl.getMock();
MockControl conControl = MockControl.createControl(Connection.class);
final Connection con = (Connection) conControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
con.getTransactionIsolation();
conControl.setReturnValue(Connection.TRANSACTION_READ_COMMITTED, 1);
con.setTransactionIsolation(Connection.TRANSACTION_SERIALIZABLE);
conControl.setVoidCallable(1);
con.setReadOnly(true);
conControl.setVoidCallable(1);
con.getAutoCommit();
conControl.setReturnValue(true, 1);
con.setAutoCommit(false);
conControl.setVoidCallable(1);
con.commit();
conControl.setVoidCallable(1);
con.setAutoCommit(true);
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.setTransactionIsolation(Connection.TRANSACTION_READ_COMMITTED);
conControl.setVoidCallable(1);
con.close();
conControl.setVoidCallable(1);
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);
tt.setIsolationLevel(TransactionDefinition.ISOLATION_SERIALIZABLE);
tt.setReadOnly(true);
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) {
assertTrue(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertTrue(TransactionSynchronizationManager.isActualTransactionActive());
// something transactional
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testTransactionWithLongTimeout() throws Exception {
doTestTransactionWithTimeout(10);
}
public void testTransactionWithShortTimeout() throws Exception {
doTestTransactionWithTimeout(1);
}
private void doTestTransactionWithTimeout(int timeout) throws Exception {
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
MockControl conControl = MockControl.createControl(Connection.class);
final Connection con = (Connection) conControl.getMock();
MockControl psControl = MockControl.createControl(PreparedStatement.class);
PreparedStatement ps = (PreparedStatement) psControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
con.getAutoCommit();
conControl.setReturnValue(true, 1);
con.setAutoCommit(false);
conControl.setVoidCallable(1);
con.prepareStatement("some SQL statement");
conControl.setReturnValue(ps, 1);
if (timeout > 1) {
ps.setQueryTimeout(timeout - 1);
psControl.setVoidCallable(1);
con.commit();
}
else {
con.rollback();
}
conControl.setVoidCallable(1);
con.setAutoCommit(true);
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -