📄 datasourcetransactionmanagertests.java
字号:
Savepoint sp = (Savepoint) spControl.getMock();
con.getAutoCommit();
conControl.setReturnValue(false, 1);
md.supportsSavepoints();
mdControl.setReturnValue(true, 1);
con.getMetaData();
conControl.setReturnValue(md, 1);
con.setSavepoint();
conControl.setReturnValue(sp, 1);
con.releaseSavepoint(sp);
conControl.setVoidCallable(1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
ds.getConnection();
dsControl.setReturnValue(con, 1);
spControl.replay();
mdControl.replay();
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_NESTED);
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("Isn't nested transaction", !status.hasSavepoint());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertTrue("Isn't new transaction", !status.isNewTransaction());
assertTrue("Is nested transaction", status.hasSavepoint());
}
});
assertTrue("Is new transaction", status.isNewTransaction());
assertTrue("Isn't nested transaction", !status.hasSavepoint());
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
spControl.verify();
mdControl.verify();
conControl.verify();
dsControl.verify();
}
public void testExistingTransactionWithPropagationNestedAndRollback() throws Exception {
if (JdkVersion.getMajorJavaVersion() < JdkVersion.JAVA_14) {
return;
}
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
MockControl mdControl = MockControl.createControl(DatabaseMetaData.class);
DatabaseMetaData md = (DatabaseMetaData) mdControl.getMock();
MockControl spControl = MockControl.createControl(Savepoint.class);
Savepoint sp = (Savepoint) spControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
con.getAutoCommit();
conControl.setReturnValue(false, 1);
md.supportsSavepoints();
mdControl.setReturnValue(true, 1);
con.getMetaData();
conControl.setReturnValue(md, 1);
con.setSavepoint();
conControl.setReturnValue(sp, 1);
con.rollback(sp);
conControl.setVoidCallable(1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
spControl.replay();
mdControl.replay();
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_NESTED);
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("Isn't nested transaction", !status.hasSavepoint());
tt.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus status) throws RuntimeException {
assertTrue("Has thread connection", TransactionSynchronizationManager.hasResource(ds));
assertTrue("Synchronization active", TransactionSynchronizationManager.isSynchronizationActive());
assertTrue("Isn't new transaction", !status.isNewTransaction());
assertTrue("Is nested transaction", status.hasSavepoint());
status.setRollbackOnly();
}
});
assertTrue("Is new transaction", status.isNewTransaction());
assertTrue("Isn't nested transaction", !status.hasSavepoint());
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
spControl.verify();
mdControl.verify();
conControl.verify();
dsControl.verify();
}
public void testExistingTransactionWithManualSavepoint() throws Exception {
if (JdkVersion.getMajorJavaVersion() < JdkVersion.JAVA_14) {
return;
}
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
MockControl mdControl = MockControl.createControl(DatabaseMetaData.class);
DatabaseMetaData md = (DatabaseMetaData) mdControl.getMock();
MockControl spControl = MockControl.createControl(Savepoint.class);
Savepoint sp = (Savepoint) spControl.getMock();
con.getAutoCommit();
conControl.setReturnValue(false, 1);
md.supportsSavepoints();
mdControl.setReturnValue(true, 1);
con.getMetaData();
conControl.setReturnValue(md, 1);
con.setSavepoint();
conControl.setReturnValue(sp, 1);
con.releaseSavepoint(sp);
conControl.setVoidCallable(1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
ds.getConnection();
dsControl.setReturnValue(con, 1);
spControl.replay();
mdControl.replay();
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_NESTED);
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());
Object savepoint = status.createSavepoint();
status.releaseSavepoint(savepoint);
assertTrue("Is new transaction", status.isNewTransaction());
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
spControl.verify();
mdControl.verify();
conControl.verify();
dsControl.verify();
}
public void testExistingTransactionWithManualSavepointAndRollback() throws Exception {
if (JdkVersion.getMajorJavaVersion() < JdkVersion.JAVA_14) {
return;
}
MockControl dsControl = MockControl.createControl(DataSource.class);
final DataSource ds = (DataSource) dsControl.getMock();
MockControl conControl = MockControl.createControl(Connection.class);
Connection con = (Connection) conControl.getMock();
MockControl mdControl = MockControl.createControl(DatabaseMetaData.class);
DatabaseMetaData md = (DatabaseMetaData) mdControl.getMock();
MockControl spControl = MockControl.createControl(Savepoint.class);
Savepoint sp = (Savepoint) spControl.getMock();
ds.getConnection();
dsControl.setReturnValue(con, 1);
con.getAutoCommit();
conControl.setReturnValue(false, 1);
md.supportsSavepoints();
mdControl.setReturnValue(true, 1);
con.getMetaData();
conControl.setReturnValue(md, 1);
con.setSavepoint();
conControl.setReturnValue(sp, 1);
con.rollback(sp);
conControl.setVoidCallable(1);
con.commit();
conControl.setVoidCallable(1);
con.isReadOnly();
conControl.setReturnValue(false, 1);
con.close();
conControl.setVoidCallable(1);
spControl.replay();
mdControl.replay();
conControl.replay();
dsControl.replay();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
final TransactionTemplate tt = new TransactionTemplate(tm);
tt.setPropagationBehavior(TransactionDefinition.PROPAGATION_NESTED);
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());
Object savepoint = status.createSavepoint();
status.rollbackToSavepoint(savepoint);
assertTrue("Is new transaction", status.isNewTransaction());
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
spControl.verify();
mdControl.verify();
conControl.verify();
dsControl.verify();
}
public void testTransactionWithPropagationNested() 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_NESTED);
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("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
public void testTransactionWithPropagationNestedAndRollback() 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_NESTED);
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());
status.setRollbackOnly();
}
});
assertTrue("Hasn't thread connection", !TransactionSynchronizationManager.hasResource(ds));
conControl.verify();
dsControl.verify();
}
protected void tearDown() {
assertTrue(TransactionSynchronizationManager.getResourceMap().isEmpty());
assertFalse(TransactionSynchronizationManager.isSynchronizationActive());
assertFalse(TransactionSynchronizationManager.isCurrentTransactionReadOnly());
assertFalse(TransactionSynchronizationManager.isActualTransactionActive());
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -