变更

Connection.php

@@ -56,6 +56,9 @@ class Connection extends Component
 	
 	public array $pool = ['max' => 10, 'min' => 1];
 	
+	
+	private int $storey = 0;
+	
 	/**
 	 * @var bool
 	 * enable database cache
@@ -207,7 +210,10 @@ class Connection extends Component
 	public function beginTransaction(): static
 	{
 		$pdo = $this->getTransactionClient();
+		if ($this->storey == 0) {
 			$pdo->beginTransaction();
+		}
+		$this->storey++;
 		return $this;
 	}
 	
@@ -223,6 +229,7 @@ class Connection extends Component
 		}
 		$pdo = Context::get($this->cds);
 		if ($pdo === null) {
+			/** @var PDO $pdo */
 			$pdo = Context::set($this->cds, $this->getConnection());
 		}
 		return $pdo;
@@ -244,6 +251,8 @@ class Connection extends Component
 	 */
 	public function rollback()
 	{
+		$this->storey--;
+		if ($this->storey == 0) {
 			$pdo = $this->getTransactionClient();
 			if ($pdo->inTransaction()) {
 				$pdo->rollback();
@@ -251,6 +260,7 @@ class Connection extends Component
 			$this->connections->push($this->cds, $pdo);
 			Context::remove($this->cds);
 		}
+	}
 	
 	/**
 	 * @throws Exception
@@ -258,6 +268,8 @@ class Connection extends Component
 	 */
 	public function commit()
 	{
+		$this->storey--;
+		if ($this->storey == 0) {
 			$pdo = $this->getTransactionClient();
 			if ($pdo->inTransaction()) {
 				$pdo->commit();
@@ -265,6 +277,7 @@ class Connection extends Component
 			$this->connections->push($this->cds, $pdo);
 			Context::remove($this->cds);
 		}
+	}
 	
 	
 	/**