Laravel 10中如何便捷完成一对多关联Specification的增删改操作

问题场景 #

我有一个Product模型和Specification模型的一对多关联：

class Product extends Model {
    //...
    public function specifications() {
        return $this->hasMany(Specification::class);
    }
}

class Specification extends Model {
    //...
}

现有specifications表数据：

id | product_id | title       | value
10 | 42         | old title   | old val
20 | 42         | del title   | del val

给定新的规格数据：

$newSpecifications = [
  [
    'id' => 10,
    'title' => 'Updated title',
    'value' => 'Updated value'
  ],
  [
    'id' => null,
    'title' => 'New title',
    'value' => 'New value'
  ]
];

$product = Product::find(42);

需要实现：更新ID为10的记录、删除ID为20的记录、新增一条新记录。

类似Hibernate中只需给实体集合赋值并保存，就能自动处理增删改：

@Entity
public class Product {
    //...     
    @OneToMany(mappedBy="product")
    private Set<Specification> specifications;
    //...
}

@Entity
public class Specification {
    //...     
    @ManyToOne
    @JoinColumn(name="product_id")
    private Product product;
    //...
}

Product product = ...
product.setSpecifications(List.of(
  // specifications details
));

session.save(product);

但Laravel的upsert方法仅支持新增和更新，不处理删除操作，因此需要自定义逻辑完成完整的同步。

解决方案 #

可以在Product模型中封装一个同步方法，整合删除、更新、新增操作：

1. 封装同步方法 #

在Product模型中添加syncSpecifications方法：

class Product extends Model {
    //...
    public function specifications() {
        return $this->hasMany(Specification::class);
    }

    public function syncSpecifications(array $specifications) {
        // 提取新数据中存在的有效ID（排除null）
        $newSpecIds = collect($specifications)
            ->pluck('id')
            ->filter(fn($id) => $id !== null)
            ->toArray();

        // 删除不在新数据列表中的关联规格
        $this->specifications()->whereNotIn('id', $newSpecIds)->delete();

        // 遍历处理每条新数据：更新已有记录，新增无ID的记录
        foreach ($specifications as $specData) {
            if (isset($specData['id']) && !is_null($specData['id'])) {
                // 更新已有规格
                $this->specifications()->where('id', $specData['id'])->update($specData);
            } else {
                // 移除ID字段后新增规格
                unset($specData['id']);
                $this->specifications()->create($specData);
            }
        }
    }
}

2. 使用同步方法 #

调用封装好的方法即可完成所有操作：

$product = Product::find(42);
$product->syncSpecifications($newSpecifications);

补充说明 #

• 若需要保证操作的原子性，可以在方法内包裹事务，避免中途出错导致数据不一致：

public function syncSpecifications(array $specifications) {
    \Illuminate\Support\Facades\DB::transaction(function () use ($specifications) {
        // 原有的删除、更新、新增逻辑
    });
}

内容的提问来源于stack exchange，提问作者Inxty