[10.x] Introducing beforeStartingTransaction callback and use it in…

… `LazilyRefreshDatabase` (#49853)

* Introduced `beforeStartingTransaction` on `Connection`

* Use new `beforeStartingTransaction ` in `LazilyRefreshDatabase`

* Fix formatting

* formatting

---------

Co-authored-by: Taylor Otwell <taylor@laravel.com>

src/Illuminate/Database/Concerns/ManagesTransactions.php

@@ -119,6 +119,10 @@ protected function handleTransactionException(Throwable $e, $currentAttempt, $ma
      */
     public function beginTransaction()
     {
+        foreach ($this->beforeStartingTransaction as $callback) {
+            $callback($this);
+        }
+
         $this->createTransaction();
 
         $this->transactions++;

src/Illuminate/Database/Connection.php

@@ -182,6 +182,13 @@ class Connection implements ConnectionInterface
      */
     protected $pretending = false;
 
+    /**
+     * All of the callbacks that should be invoked before a transaction is started.
+     *
+     * @var \Closure[]
+     */
+    protected $beforeStartingTransaction = [];
+
     /**
      * All of the callbacks that should be invoked before a query is executed.
      *
@@ -1021,6 +1028,19 @@ public function disconnect()
         $this->doctrineConnection = null;
     }
 
+    /**
+     * Register a hook to be run just before a database transaction is started.
+     *
+     * @param  \Closure  $callback
+     * @return $this
+     */
+    public function beforeStartingTransaction(Closure $callback)
+    {
+        $this->beforeStartingTransaction[] = $callback;
+
+        return $this;
+    }
+
     /**
      * Register a hook to be run just before a database query is executed.
      *

src/Illuminate/Foundation/Testing/LazilyRefreshDatabase.php

@@ -17,15 +17,18 @@ public function refreshDatabase()
     {
         $database = $this->app->make('db');
 
-        $database->beforeExecuting(function () {
+        $callback = function () {
             if (RefreshDatabaseState::$lazilyRefreshed) {
                 return;
             }
 
             RefreshDatabaseState::$lazilyRefreshed = true;
 
             $this->baseRefreshDatabase();
-        });
+        };
+
+        $database->beforeStartingTransaction($callback);
+        $database->beforeExecuting($callback);
 
         $this->beforeApplicationDestroyed(function () {
             RefreshDatabaseState::$lazilyRefreshed = false;

tests/Database/DatabaseConnectionTest.php

@@ -484,6 +484,18 @@ public function testBeforeExecutingHooksCanBeRegistered()
         $connection->select('foo bar', ['baz']);
     }
 
+    public function testBeforeStartingTransactionHooksCanBeRegistered()
+    {
+        $this->expectException(Exception::class);
+        $this->expectExceptionMessage('The callback was fired');
+
+        $connection = $this->getMockConnection();
+        $connection->beforeStartingTransaction(function () {
+            throw new Exception('The callback was fired');
+        });
+        $connection->beginTransaction();
+    }
+
     public function testPretendOnlyLogsQueries()
     {
         $connection = $this->getMockConnection();