批量更新 - Laravel

Question

我正在尝试寻找一种方法来一次更新多条记录，就像我们使用 insert 一次创建多条记录一样。

假设我有一个关联数组，其中包含要在员工表的每一行中更新的数据：

$data = [
  ['id'=>1,'name'=>'xxx'],
  ['id'=>2,'name'=>'xxx'],
  ['id'=>3,'name'=>'xxx'],
  ['id'=>4,'name'=>'xxx']
];

更新所有这些记录的一种方法是：

foreach($data as $d){
   Employee::where('id'=>$d['id'])->update(['name'=>$d['name']]);
}

其中 Employee 是员工表的模型。

我想知道我是否可以通过一行语句更新所有记录？

例如，如果我从 $data 创建新记录，我会使用：

Employee::insert($data);

而不是遍历 $data 并为每条记录使用 create()。

还有什么类似的东西可以更新吗？

Answer 1

这是不可能的，因为只能通过union 进行批量更新，这是您可以在 sql 中使用的最慢的运算符。 否则，即使在原始 sql 中，也无法使用不同行中的不同值批量更新，因此在 laravel 中也没有办法。

Answer 2

不，这是不可能的，你应该遍历数组并分别更新每一行。

Answer 3

你试过Employee::update($data);吗？当然数据应该是数组 喜欢： $data = (['name'=>'test'],['surname'=>'test2'])); - 它将更新表中的所有行 - 但您可以添加 where 条件。

Answer 4

Doctrine 允许您进行批量插入/更新。你可以在这里找到它：http://www.laraveldoctrine.org/

Answer 5

使用集合来做这样的事情怎么样？

$data = [
  ['id'=>3,'name'=>'xxx'],
  ['id'=>4,'name'=>'xxx'],
  ['id'=>5,'name'=>'xxx']
];

Employee::find(collect($data)->pluck('id')->toArray())->map(function($item, $key) use ($data){
  $item['name'] = $data[$key]['name'];
  return $item->save();
});

Answer 6

我写了一个批量更新函数用于我的 Laravel 项目。对于想要在 laravel 中使用批量更新查询的人来说，它可能很有用。它的第一个参数 是表名字符串，第二个是要更新行的键名字符串，主要是“id”，第三个参数是数据数组，格式如下：

array(
    array(
        'id' => 1,
        'col_1_name' => 'col_1_value',
        'col_2_name' => 'col_2_value',
        //....
    ),
    array(
        'id' => 2,
        'col_1_name' => 'col_1_value',
        'col_2_name' => 'col_2_value',
        //....
    ),
    //....
);

函数定义：

private function custom_batch_update(string $table_name = '', string $key = '', Array $update_arr = array()) {

    if(!$table_name || !$key || !$update_arr){
        return false;
    }

    $update_keys = array_keys($update_arr[0]);
    $update_keys_count = count($update_keys);

    for ($i = 0; $i < $update_keys_count; $i++) {
        $key_name = $update_keys[$i];
        if($key === $key_name){
            continue;
        }
        $when_{$key_name} = $key_name . ' = CASE';
    }

    $length = count($update_arr);
    $index = 0;
    $query_str = 'UPDATE ' . $table_name . ' SET ';
    $when_str = '';
    $where_str = ' WHERE ' . $key . ' IN(';

    while ($index < $length) {
        $when_str = " WHEN $key = '{$update_arr[$index][$key]}' THEN";
        $where_str .= "'{$update_arr[$index][$key]}',";
        for ($i = 0; $i < $update_keys_count; $i++) {
            $key_name = $update_keys[$i];
            if($key === $key_name){
                continue;
            }
            $when_{$key_name} .= $when_str . " '{$update_arr[$index][$key_name]}'";
        }
        $index++;
    }

    for ($i = 0; $i < $update_keys_count; $i++) {
        $key_name = $update_keys[$i];
        if($key === $key_name){
            continue;
        }
        $when_{$key_name} .= ' ELSE ' . $key_name . ' END, ';
        $query_str .= $when_{$key_name};
    }
    $query_str = rtrim($query_str, ', ');
    $where_str = rtrim($where_str, ',') . ')';
    $query_str .= $where_str;
    $affected = DB::update($query_str);

    return $affected;
}

它将像这样生成并执行查询字符串：

UPDATE table_name SET col_1_name = CASE 
WHEN id = '1' THEN 'col_1_value' 
WHEN id = '2' THEN 'col_1_value' 
ELSE col_1_name END, 
col_2_name = CASE 
WHEN id = '1' THEN 'col_2_value' 
WHEN id = '2' THEN 'col_2_value' 
ELSE col_2_name END 
WHERE id IN('1','2')

Answer 7

它将在 laravel 中工作以更新现有或新插入到表中。

$data=array(  
    array('id'=>1,'name'=>'kaleemullah@example.com'),
    array('id'=>2,'name'=>'kaleemullah@example.com2'),
    array('id'=>4,'name'=>'kaleemullah@example.com4')
);
$imported =  implode(', ', array_map(function ($string) {
return "(".$string['id'].','."'".$string['name']."'"."),";
}, $data));
$OneStepAway =  str_replace(',,', ',', $imported);
$kale = rtrim($OneStepAway,',');
$s = DB::statement("INSERT INTO  tests (id,name) VALUES $kale
ON DUPLICATE KEY UPDATE name=VALUES(name)") ;
echo "Successfully Updated and Insert New records into the database ";

Answer 8

对于一小块数据，循环就可以了。

但是，如果您有大量数据 - 绝对不要使用循环，因为 “数据库事务”是一项昂贵的操作，并且使用 for 循环，您将结束为每次迭代做一个事务。

在这里您可以看到如何在没有 for 循环的情况下进行更新：

$data = [
  ['id'=>1,'name'=>'xxx'],
  ['id'=>2,'name'=>'xxx'],
  ['id'=>3,'name'=>'xxx'],
  ['id'=>4,'name'=>'xxx']
];

$cases = [];
$ids = [];
$params = [];

foreach ($data as $datum) {
   $id = $datum['id'];

   $cases[] = "WHEN {$id} then ?";
   $params[] = $datum['name'];
   $ids[] = $id;
}

$ids = implode(',', $ids);
$cases = implode(' ', $cases);

if (!empty($ids)) {
    \DB::update("UPDATE employees SET `name` = CASE `id` {$cases} END WHERE `id` in ({$ids})", $params);
}

如果您想了解它，请查看https://medium.com/@sentiasa/bulk-update-multiple-records-with-separate-data-laravel-3da9131c279a

Answer 9

public function transaction($callback) {
    DB::connection(**<TABLE_NAME>**)->transaction($callback);
}

public function updateBatch($batchData)
{
    $count = 0;
    try {
        $batchData = array_values($batchData);
        $total = count($batchData);
        $j = 0;
        $i = 0;
        do {
            $j = min($total -1, $j + self::$configBatch);
            DB::connection(**<TABLE_NAME>**)->transaction(function() use ($batchData, &$count, $total, $j, &$i) {
                for (; $i <= $j; $i++) {
                    $batchData[$i]->save();
                    $count++;
                }
            });
        } while ($i < $total);
    } catch (\Exception $exception) {
        print_r($exception->getMessage());
        $count = 0;
    }
    return $count;
}

希望能帮到你