* 延迟物理连接的关闭时机

bytejta-core/src/main/java/org/bytesoft/bytejta/supports/jdbc/LocalXAConnection.java

@@ -60,10 +60,6 @@ public LogicalConnection getConnection() throws SQLException {
 
 		LogicalConnection logicalConnection = new LogicalConnection(this, this.connection);
 
-		// if (this.physicalConnectionSharingCount == 0) {
-		// this.xaResource.setLocalTransaction(logicalConnection);
-		// }
-
 		this.physicalConnectionSharingCount++;
 		this.underlyingConCloseRequired = false;
 
@@ -105,10 +101,6 @@ public void commitLocalTransaction() throws SQLException {
 			throw ex;
 		} catch (RuntimeException ex) {
 			throw new SQLException(ex);
-		} finally {
-			if (this.underlyingConCloseRequired) {
-				this.releaseConnection();
-			}
 		}
 	}
 
@@ -119,10 +111,6 @@ public void rollbackLocalTransaction() throws SQLException {
 			throw ex;
 		} catch (RuntimeException ex) {
 			throw new SQLException(ex);
-		} finally {
-			if (this.underlyingConCloseRequired) {
-				this.releaseConnection();
-			}
 		}
 	}
 
@@ -135,7 +123,10 @@ public void closeQuietly() {
 	}
 
 	public void close() throws SQLException {
-		this.underlyingConCloseRequired = true;
+		if (this.underlyingConCloseRequired == false) {
+			logger.warn("Illegal state: there is at least one connection that is not closed!");
+		}
+
 		this.releaseConnection();
 	}
 

bytejta-core/src/main/java/org/bytesoft/bytejta/supports/jdbc/LocalXAResource.java

@@ -210,7 +210,7 @@ public synchronized void commit(Xid xid, boolean onePhase) throws XAException {
 			xae.initCause(ex);
 			throw xae;
 		} finally {
-			this.resetXAResource();
+			this.releasePhysicalConnection();
 		}
 	}
 
@@ -232,11 +232,11 @@ public synchronized void rollback(Xid xid) throws XAException {
 			xae.initCause(ex);
 			throw xae;
 		} finally {
-			this.resetXAResource();
+			this.releasePhysicalConnection();
 		}
 	}
 
-	private void resetXAResource() {
+	private void releasePhysicalConnection() {
 		Connection connection = this.managedConnection.getPhysicalConnection();
 		try {
 			connection.setAutoCommit(originalAutoCommit);