[10.x] Fix createOrFirst on transactions

src/Illuminate/Database/Eloquent/Builder.php

@@ -580,7 +580,9 @@ public function firstOrCreate(array $attributes = [], array $values = [])
     public function createOrFirst(array $attributes = [], array $values = [])
     {
         try {
-            return $this->create(array_merge($attributes, $values));
+            return $this->withSavepointIfNeeded(function () use ($attributes, $values) {
+                return $this->create(array_merge($attributes, $values));
+            });
         } catch (UniqueConstraintViolationException $exception) {
             return $this->where($attributes)->first();
         }
@@ -2029,4 +2031,19 @@ public function __clone()
     {
         $this->query = clone $this->query;
     }
+
+    /**
+     * Wraps the given Closure with a transaction savepoint if needed.
+     *
+     * @template TModelValue
+     *
+     * @param  \Closure(): TModelValue  $scope
+     * @return TModelValue
+     */
+    public function withSavepointIfNeeded(Closure $scope): mixed
+    {
+        return $this->getQuery()->getConnection()->transactionLevel() > 0
+            ? $this->getQuery()->getConnection()->transaction($scope)
+            : $scope();
+    }
 }

src/Illuminate/Database/Eloquent/Relations/BelongsToMany.php

@@ -643,14 +643,18 @@ public function firstOrCreate(array $attributes = [], array $values = [], array
     public function createOrFirst(array $attributes = [], array $values = [], array $joining = [], $touch = true)
     {
         try {
-            return $this->create(array_merge($attributes, $values), $joining, $touch);
+            return $this->getQuery()->withSavePointIfNeeded(function () use ($attributes, $values, $joining, $touch) {
+                return $this->create(array_merge($attributes, $values), $joining, $touch);
+            });
         } catch (UniqueConstraintViolationException $exception) {
             // ...
         }
 
         try {
             return tap($this->related->where($attributes)->first(), function ($instance) use ($joining, $touch) {
-                $this->attach($instance, $joining, $touch);
+                $this->getQuery()->withSavepointIfNeeded(function () use ($instance, $joining, $touch) {
+                    $this->attach($instance, $joining, $touch);
+                });
             });
         } catch (UniqueConstraintViolationException $exception) {
             return (clone $this)->where($attributes)->first();

src/Illuminate/Database/Eloquent/Relations/HasOneOrMany.php

@@ -252,7 +252,9 @@ public function firstOrCreate(array $attributes = [], array $values = [])
     public function createOrFirst(array $attributes = [], array $values = [])
     {
         try {
-            return $this->create(array_merge($attributes, $values));
+            return $this->getQuery()->withSavepointIfNeeded(function () use ($attributes, $values) {
+                return $this->create(array_merge($attributes, $values));
+            });
         } catch (UniqueConstraintViolationException $exception) {
             return $this->where($attributes)->first();
         }

tests/Database/DatabaseEloquentIntegrationTest.php

@@ -552,6 +552,22 @@ public function testCreateOrFirst()
         $this->assertSame('Nuno Maduro', $user4->name);
     }
 
+    public function testCreateOrFirstWithinTransaction()
+    {
+        $user1 = EloquentTestUniqueUser::create(['email' => 'taylorotwell@gmail.com']);
+
+        DB::transaction(function () use ($user1) {
+            $user2 = EloquentTestUniqueUser::createOrFirst(
+                ['email' => 'taylorotwell@gmail.com'],
+                ['name' => 'Taylor Otwell']
+            );
+
+            $this->assertEquals($user1->id, $user2->id);
+            $this->assertSame('taylorotwell@gmail.com', $user2->email);
+            $this->assertNull($user2->name);
+        });
+    }
+
     public function testUpdateOrCreate()
     {
         $user1 = EloquentTestUser::create(['email' => 'taylorotwell@gmail.com']);

tests/Integration/Database/EloquentBelongsToManyTest.php

@@ -629,6 +629,19 @@ public function testCreateOrFirstUnrelatedExisting()
         $this->assertTrue($tag->is($post->tagsUnique()->first()));
     }
 
+    public function testCreateOrFirstWithinTransaction()
+    {
+        $post = Post::create(['title' => Str::random()]);
+
+        $tag = UniqueTag::create(['name' => Str::random()]);
+
+        $post->tagsUnique()->attach(UniqueTag::all());
+
+        DB::transaction(function () use ($tag, $post) {
+            $this->assertEquals($tag->id, $post->tagsUnique()->createOrFirst(['name' => $tag->name])->id);
+        });
+    }
+
     public function testFirstOrNewMethodWithValues()
     {
         $post = Post::create(['title' => Str::random()]);

tests/Integration/Database/EloquentHasManyTest.php

@@ -5,6 +5,7 @@
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Eloquent\Relations\HasMany;
 use Illuminate\Database\Eloquent\Relations\HasOne;
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Schema;
 use Illuminate\Support\Str;
 
@@ -70,6 +71,21 @@ public function testCreateOrFirst()
         $this->assertTrue($post1->is($post2));
         $this->assertCount(1, $user->posts()->get());
     }
+
+    public function testCreateOrFirstWithinTransaction()
+    {
+        $user = EloquentHasManyTestUser::create();
+
+        $post1 = $user->posts()->create(['title' => Str::random()]);
+
+        DB::transaction(function () use ($user, $post1) {
+            $post2 = $user->posts()->createOrFirst(['title' => $post1->title]);
+
+            $this->assertTrue($post1->is($post2));
+        });
+
+        $this->assertCount(1, $user->posts()->get());
+    }
 }
 
 class EloquentHasManyTestUser extends Model

tests/Integration/Database/MySql/DatabaseEloquentMySqlIntegrationTest.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Schema;
 
 class DatabaseEloquentMySqlIntegrationTest extends MySqlTestCase
@@ -57,6 +58,22 @@ public function testCreateOrFirst()
 
         $this->assertSame('Nuno Maduro', $user4->name);
     }
+
+    public function testCreateOrFirstWithinTransaction()
+    {
+        $user1 = DatabaseEloquentMySqlIntegrationUser::createOrFirst(['email' => 'taylor@laravel.com']);
+
+        DB::transaction(function () use ($user1) {
+            $user2 = DatabaseEloquentMySqlIntegrationUser::createOrFirst(
+                ['email' => 'taylor@laravel.com'],
+                ['name' => 'Taylor Otwell']
+            );
+
+            $this->assertEquals($user1->id, $user2->id);
+            $this->assertSame('taylor@laravel.com', $user2->email);
+            $this->assertNull($user2->name);
+        });
+    }
 }
 
 class DatabaseEloquentMySqlIntegrationUser extends Model

tests/Integration/Database/Postgres/DatabaseEloquentPostgresIntegrationTest.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Schema;
 
 class DatabaseEloquentPostgresIntegrationTest extends PostgresTestCase
@@ -57,6 +58,22 @@ public function testCreateOrFirst()
 
         $this->assertSame('Nuno Maduro', $user4->name);
     }
+
+    public function testCreateOrFirstWithinTransaction()
+    {
+        $user1 = DatabaseEloquentPostgresIntegrationUser::create(['email' => 'taylor@laravel.com']);
+
+        DB::transaction(function () use ($user1) {
+            $user2 = DatabaseEloquentPostgresIntegrationUser::createOrFirst(
+                ['email' => 'taylor@laravel.com'],
+                ['name' => 'Taylor Otwell']
+            );
+
+            $this->assertEquals($user1->id, $user2->id);
+            $this->assertSame('taylor@laravel.com', $user2->email);
+            $this->assertNull($user2->name);
+        });
+    }
 }
 
 class DatabaseEloquentPostgresIntegrationUser extends Model

tests/Integration/Database/SqlServer/DatabaseEloquentSqlServerIntegrationTest.php

@@ -4,6 +4,7 @@
 
 use Illuminate\Database\Eloquent\Model;
 use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\DB;
 use Illuminate\Support\Facades\Schema;
 
 class DatabaseEloquentSqlServerIntegrationTest extends SqlServerTestCase
@@ -57,6 +58,22 @@ public function testCreateOrFirst()
 
         $this->assertSame('Nuno Maduro', $user4->name);
     }
+
+    public function testCreateOrFirstWithinTransaction()
+    {
+        $user1 = DatabaseEloquentSqlServerIntegrationUser::createOrFirst(['email' => 'taylor@laravel.com']);
+
+        DB::transaction(function () use ($user1) {
+            $user2 = DatabaseEloquentSqlServerIntegrationUser::createOrFirst(
+                ['email' => 'taylor@laravel.com'],
+                ['name' => 'Taylor Otwell']
+            );
+
+            $this->assertEquals($user1->id, $user2->id);
+            $this->assertSame('taylor@laravel.com', $user2->email);
+            $this->assertNull($user2->name);
+        });
+    }
 }
 
 class DatabaseEloquentSqlServerIntegrationUser extends Model