我得到一个
org.hibernate.TransactionException: nested transactions not supported
at org.hibernate.engine.transaction.spi.AbstractTransactionImpl.begin(AbstractTransactionImpl.java:152)
at org.hibernate.internal.SessionImpl.beginTransaction(SessionImpl.java:1395)
at com.mcruiseon.server.hibernate.ReadOnlyOperations.flush(ReadOnlyOperations.java:118)
引发该异常的代码。我从一个无限运行的线程调用刷新,直到有数据要刷新。
public void flush(Object dataStore) throws DidNotSaveRequestSomeRandomError {
Transaction txD;
Session session;
session = currentSession();
// Below Line 118
txD = session.beginTransaction();
txD.begin() ;
session.saveOrUpdate(dataStore);
try {
txD.commit();
while(!txD.wasCommitted()) ;
} catch (ConstraintViolationException e) {
txD.rollback() ;
throw new DidNotSaveRequestSomeRandomError(dataStore, feedbackManager);
} catch (TransactionException e) {
txD.rollback() ;
} finally {
// session.flush();
txD = null;
session.close();
}
// mySession.clear();
}
编辑:我在独立线程中调用刷新,因为数据存储列表包含数据。从我所看到的情况来看,它是对刷新的同步操作调用,因此理想情况下,刷新不应该在事务完成之前返回。我希望这样是我最不希望的。由于它是一个独立的线程来完成它的工作,我只关心它刷新是一个同步操作。现在我的问题是, txD.commit 是异步操作吗?它是否在该事务有机会完成之前返回。如果是,有没有办法在事务完成之前提交“等待”?
public void run() {
Object dataStore = null;
while (true) {
try {
synchronized (flushQ) {
if (flushQ.isEmpty())
flushQ.wait();
if (flushQ.isEmpty()) {
continue;
}
dataStore = flushQ.removeFirst();
if (dataStore == null) {
continue;
}
}
try {
flush(dataStore);
} catch (DidNotSaveRequestSomeRandomError e) {
e.printStackTrace();
log.fatal(e);
}
} catch (HibernateException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
编辑 2:添加while(!txD.wasCommitted()) ;
(在上面的代码中),我仍然觉得这该死nested transactions not supported
。事实上,由于这个异常,表也没有写入记录。与表的类型有关吗?我所有的表都有 INNODB 吗?