Laravel中如何为用户关联产品添加用户维度自增列？

问题背景 #

现有users表和products表，用户与产品为一对多关联，products表的id字段正常使用。需要为products表新增another_incremental列，实现每个用户的产品该列从1开始依次递增：

• 当前不符合需求的情况：
  • user[1]的产品id为[1,5,7] ❌
  • user[2]的产品id为[2,3,4] ❌
• 期望效果：
  • user[1]的产品another_incremental列值为[1,2,3,4,5,...] ✅
  • user[2]的产品another_incremental列值为[1,2,3,4,5,...] ✅

关联模型代码：

// User 模型
public function products()
{
    return $this->hasMany(Product::class);
}

// Product 模型
public function user()
{
    return $this->belongsTo(User::class);
}

解决方案 #

Laravel没有直接内置的方法实现这个需求，但可以通过以下几种方式完成：

1. 模型事件自动生成值 #

在Product模型的boot方法中监听creating事件，插入新产品时自动计算当前用户的产品数量，加1赋值给another_incremental：

// Product 模型
protected static function boot()
{
    parent::boot();

    static::creating(function ($product) {
        // 统计当前用户已有的产品数量，加1作为新值
        $count = $product->user->products()->lockForUpdate()->count();
        $product->another_incremental = $count + 1;
    });
}

• 注意：加上lockForUpdate()是为了避免并发创建产品时出现重复值，确保数据一致性。

2. 数据库触发器实现 #

通过数据库触发器在插入数据时自动计算自增值，无需在Laravel代码中处理：

以MySQL为例，创建触发器的SQL：

DELIMITER //
CREATE TRIGGER set_another_incremental BEFORE INSERT ON products
FOR EACH ROW
BEGIN
    SELECT COUNT(*) + 1 INTO NEW.another_incremental
    FROM products
    WHERE user_id = NEW.user_id;
END //
DELIMITER ;

可以在Laravel迁移文件中执行这段SQL：

// 迁移文件
public function up()
{
    Schema::table('products', function (Blueprint $table) {
        $table->unsignedInteger('another_incremental')->nullable();
    });

    DB::statement('
        DELIMITER //
        CREATE TRIGGER set_another_incremental BEFORE INSERT ON products
        FOR EACH ROW
        BEGIN
            SELECT COUNT(*) + 1 INTO NEW.another_incremental
            FROM products
            WHERE user_id = NEW.user_id;
        END //
        DELIMITER ;
    ');
}

public function down()
{
    DB::statement('DROP TRIGGER IF EXISTS set_another_incremental');
    Schema::table('products', function (Blueprint $table) {
        $table->dropColumn('another_incremental');
    });
}

3. 批量更新已有数据 #

如果需要给已存在的产品数据补全another_incremental值，可以用窗口函数批量更新：

DB::statement('
    UPDATE products p
    JOIN (
        SELECT id, user_id, 
               ROW_NUMBER() OVER (PARTITION BY user_id ORDER BY id) AS rn
        FROM products
    ) AS sub ON p.id = sub.id
    SET p.another_incremental = sub.rn
');

这段SQL会按user_id分组，按id排序生成自增序号，批量更新到目标字段。

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