Fix nested transaction callbacks handling

laravel · Sep 20, 2023 · cf8af67 · cf8af67
1 parent 1157523
commit cf8af67
Show file tree

Hide file tree

Showing 2 changed files with 39 additions and 21 deletions.
diff --git a/src/Illuminate/Database/Concerns/ManagesTransactions.php b/src/Illuminate/Database/Concerns/ManagesTransactions.php
@@ -48,10 +48,7 @@ public function transaction(Closure $callback, $attempts = 1)
                 }
 
                 $this->transactions = max(0, $this->transactions - 1);
-
-                if ($this->afterCommitCallbacksShouldBeExecuted()) {
-                    $this->transactionsManager?->commit($this->getName());
-                }
+                $this->transactionsManager?->commit($this->getName());
             } catch (Throwable $e) {
                 $this->handleCommitTransactionException(
                     $e, $currentAttempt, $attempts
@@ -203,18 +200,6 @@ public function commit()
         $this->fireConnectionEvent('committed');
     }
 
-    /**
-     * Determine if after commit callbacks should be executed.
-     *
-     * @return bool
-     */
-    protected function afterCommitCallbacksShouldBeExecuted()
-    {
-        return $this->transactions == 0 ||
-            ($this->transactionsManager &&
-             $this->transactionsManager->callbackApplicableTransactions()->count() === 1);
-    }
-
     /**
      * Handle an exception encountered when committing a transaction.
      *
@@ -254,8 +239,8 @@ public function rollBack($toLevel = null)
         // that this given transaction level is valid before attempting to rollback to
         // that level. If it's not we will just return out and not attempt anything.
         $toLevel = is_null($toLevel)
-                    ? $this->transactions - 1
-                    : $toLevel;
+            ? $this->transactions - 1
+            : $toLevel;
 
         if ($toLevel < 0 || $toLevel >= $this->transactions) {
             return;

diff --git a/src/Illuminate/Database/DatabaseTransactionsManager.php b/src/Illuminate/Database/DatabaseTransactionsManager.php
@@ -68,19 +68,52 @@ public function rollback($connection, $level)
      */
     public function commit($connection)
     {
-        [$forThisConnection, $forOtherConnections] = $this->transactions->partition(
+        if ($this->afterCommitCallbacksShouldBeExecuted()) {
+            [$forThisConnection, $forOtherConnections] = $this->transactions->partition(
+                fn ($transaction) => $transaction->connection == $connection
+            );
+
+            $this->transactions = $forOtherConnections->values();
+
+            $forThisConnection->map->executeCallbacks();
+
+            if ($this->transactions->isEmpty()) {
+                $this->callbacksShouldIgnore = null;
+            }
+
+            return;
+        }
+
+        $last = $this->transactions->last(
             fn ($transaction) => $transaction->connection == $connection
         );
+        $parent = $this->transactions->last(
+            fn ($transaction) => $transaction->connection == $connection && $last !== $transaction,
+        );
 
-        $this->transactions = $forOtherConnections->values();
+        $this->transactions = $this->transactions->reject(
+            fn ($transaction) => $transaction === $last,
+        );
 
-        $forThisConnection->map->executeCallbacks();
+        foreach ($last?->getCallbacks() ?? [] as $callback) {
+            $parent?->addCallback($callback);
+        }
 
         if ($this->transactions->isEmpty()) {
             $this->callbacksShouldIgnore = null;
         }
     }
 
+    /**
+     * Determine if after commit callbacks should be executed.
+     *
+     * @return bool
+     */
+    protected function afterCommitCallbacksShouldBeExecuted()
+    {
+        return $this->callbackApplicableTransactions()->count() === 1;
+    }
+
     /**
      * Register a transaction callback.
      *