MySQL中的多次更新

UPDATE table1, table2 SET table1.col1='value', table2.col1='value' WHERE table1.col3='567' AND table2.col6='567'

这应该对你有用。

在MySQL手册中有一个用于多个表的引用。

下面的操作将更新一个表中的所有行

Update Table Set
Column1 = 'New Value'

下一个将更新Column2值大于5的所有行

Update Table Set
Column1 = 'New Value'
Where
Column2 > 5

Unkwntech有一个更新多个表的例子

UPDATE table1, table2 SET
table1.col1 = 'value',
table2.col1 = 'value'
WHERE
table1.col3 = '567'
AND table2.col6='567'

您可能还对在更新上使用连接感兴趣，这也是可能的。

Update someTable Set someValue = 4 From someTable s Inner Join anotherTable a on s.id = a.id Where a.id = 4
-- Only updates someValue in someTable who has a foreign key on anotherTable with a value of 4.

编辑:如果要更新的值不是来自数据库中的其他地方，则需要发出多个更新查询。

UPDATE tableName SET col1='000' WHERE id='3' OR id='5'

这应该能达到你想要的效果。只需要添加更多的id。我已经测试过了。

是的，这是可能的-你可以使用INSERT…重复密钥更新。

举个例子:

INSERT INTO table (id,Col1,Col2) VALUES (1,1,1),(2,2,3),(3,9,3),(4,10,12)
ON DUPLICATE KEY UPDATE Col1=VALUES(Col1),Col2=VALUES(Col2);

由于您有动态值，因此需要为要更新的列使用IF或CASE。虽然有点难看，但应该能行。

用你的例子，你可以这样做:

UPDATE table SET Col1 = CASE id
WHEN 1 THEN 1
WHEN 2 THEN 2
WHEN 4 THEN 10
ELSE Col1
END,
Col2 = CASE id
WHEN 3 THEN 3
WHEN 4 THEN 12
ELSE Col2
END
WHERE id IN (1, 2, 3, 4);

你可以修改一个名为“多语句”的设置，它会禁用MySQL为防止(多个)注入命令而实现的“安全机制”。典型的MySQL的“辉煌”实现，它也阻止用户进行有效的查询。

这里(http://dev.mysql.com/doc/refman/5.1/en/mysql-set-server-option.html)是关于设置的C实现的一些信息。

如果你正在使用PHP，你可以使用mysqli来做多个语句(我认为PHP已经发布了mysqli一段时间了)

$con = new mysqli('localhost','user1','password','my_database');
$query = "Update MyTable SET col1='some value' WHERE id=1 LIMIT 1;";
$query .= "UPDATE MyTable SET col1='other value' WHERE id=2 LIMIT 1;";
//etc
$con->multi_query($query);
$con->close();

希望这能有所帮助。

使用临时表

// Reorder items
function update_items_tempdb(&$items)
{
shuffle($items);
$table_name = uniqid('tmp_test_');
$sql = "CREATE TEMPORARY TABLE `$table_name` ("
."  `id` int(10) unsigned NOT NULL AUTO_INCREMENT"
.", `position` int(10) unsigned NOT NULL"
.", PRIMARY KEY (`id`)"
.") ENGINE = MEMORY";
query($sql);
$i = 0;
$sql = '';
foreach ($items as &$item)
{
$item->position = $i++;
$sql .= ($sql ? ', ' : '')."({$item->id}, {$item->position})";
}
if ($sql)
{
query("INSERT INTO `$table_name` (id, position) VALUES $sql");
$sql = "UPDATE `test`, `$table_name` SET `test`.position = `$table_name`.position"
." WHERE `$table_name`.id = `test`.id";
query($sql);
}
query("DROP TABLE `$table_name`");
}

你可以给同一个表添加别名来给你想要插入的id(如果你正在逐行更新:

UPDATE table1 tab1, table1 tab2 -- alias references the same table
SET
col1 = 1
,col2 = 2
. . .
WHERE
tab1.id = tab2.id;

此外，显然还可以从其他表进行更新。在本例中，更新将兼任“SELECT”语句，从指定的表中提供数据。您在查询中显式地声明了更新值，因此第二个表不受影响。

这个问题很老了，但我想用另一个答案来扩展这个话题。

我的观点是，实现它的最简单的方法是用一个事务包装多个查询。公认的答案INSERT ... ON DUPLICATE KEY UPDATE是一个很好的hack，但应该意识到它的缺点和限制:

• 如前所述，如果启动查询时，行主键不存在于表中，查询将插入新的“半生不熟”记录。也许这不是你想要的
• 如果你有一个没有默认值的非空字段的表，并且不想在查询中触及这个字段，即使你根本没有插入一行，你也会得到"Field 'fieldname' doesn't have a default value" MySQL警告。如果你决定严格地把mysql警告变成应用中的运行时异常，这会给你带来麻烦。

我为三个建议的变体做了一些性能测试，包括INSERT ... ON DUPLICATE KEY UPDATE变体，一个带有“case / when / then”子句的变体和一个带有事务的简单方法。你可以得到python代码和结果在这里。总的结论是，带有case语句的变体的速度是其他两个变体的两倍，但是很难为它编写正确和注入安全的代码，所以我个人坚持使用最简单的方法:使用事务。

编辑: Dakusan的发现证明我的性能估计不太有效。另一个更详细的研究请参见这个答案。

UPDATE `your_table` SET


`something` = IF(`id`="1","new_value1",`something`), `smth2` = IF(`id`="1", "nv1",`smth2`),
`something` = IF(`id`="2","new_value2",`something`), `smth2` = IF(`id`="2", "nv2",`smth2`),
`something` = IF(`id`="4","new_value3",`something`), `smth2` = IF(`id`="4", "nv3",`smth2`),
`something` = IF(`id`="6","new_value4",`something`), `smth2` = IF(`id`="6", "nv4",`smth2`),
`something` = IF(`id`="3","new_value5",`something`), `smth2` = IF(`id`="3", "nv5",`smth2`),
`something` = IF(`id`="5","new_value6",`something`), `smth2` = IF(`id`="5", "nv6",`smth2`)

//你只是在php中构建它

$q = 'UPDATE `your_table` SET ';


foreach($data as $dat){


$q .= '


`something` = IF(`id`="'.$dat->id.'","'.$dat->value.'",`something`),
`smth2` = IF(`id`="'.$dat->id.'", "'.$dat->value2.'",`smth2`),';


}


$q = substr($q,0,-1);

所以你可以用一个查询更新孔表

不知道为什么没有提到另一个有用的选项:

UPDATE my_table m
JOIN (
SELECT 1 as id, 10 as _col1, 20 as _col2
UNION ALL
SELECT 2, 5, 10
UNION ALL
SELECT 3, 15, 30
) vals ON m.id = vals.id
SET col1 = _col1, col2 = _col2;

使用

REPLACE INTO`table` VALUES (`id`,`col1`,`col2`) VALUES
(1,6,1),(2,2,3),(3,9,5),(4,16,8);

请注意:

• Id必须是一个主唯一键
• 如果你使用外键到 引用表，REPLACE删除然后插入，所以这可能 导致错误

这些都适用于InnoDB。

我觉得了解这3种不同方法的速度很重要。

有3种方法:

1. 插入:插入时没有重复的密钥更新
2. TRANSACTION:对事务中的每个记录进行更新
3. CASE:在这种情况下，您可以在UPDATE中为每个不同的记录设置CASE /时间

我刚刚测试了这个，INSERT方法比TRANSACTION方法快6.7倍。我同时尝试了3000行和30000行。

TRANSACTION方法仍然必须单独运行每个查询，这需要时间，尽管它在执行时将结果批处理在内存或其他地方。TRANSACTION方法在复制和查询日志中也非常昂贵。

更糟糕的是，CASE方法比有30000条记录的INSERT方法慢41.1倍(比TRANSACTION慢6.1倍)。并且在MyISAM中75 x较慢。INSERT和CASE方法在大约1000条记录中保持平衡。即使是在100条记录中，CASE方法也仅仅快一点。

所以一般来说，我觉得INSERT方法是最好的，也是最容易使用的。查询更小，更容易阅读，并且只占用1个查询操作。InnoDB和MyISAM都适用。

附加材料:

INSERT非默认字段问题的解决方案是临时关闭相关的SQL模式:SET SESSION sql_mode=REPLACE(REPLACE(@@SESSION.sql_mode,"STRICT_TRANS_TABLES",""),"STRICT_ALL_TABLES","")。如果计划恢复sql_mode，请确保首先保存它。

至于我看到的其他评论说auto_increment是使用INSERT方法增加的，这似乎在InnoDB中是这样的，但在MyISAM中不是。

运行测试的代码如下所示。它还输出.SQL文件以消除php解释器开销

<?php
//Variables
$NumRows=30000;


//These 2 functions need to be filled in
function InitSQL()
{


}
function RunSQLQuery($Q)
{


}


//Run the 3 tests
InitSQL();
for($i=0;$i<3;$i++)
RunTest($i, $NumRows);


function RunTest($TestNum, $NumRows)
{
$TheQueries=Array();
$DoQuery=function($Query) use (&$TheQueries)
{
RunSQLQuery($Query);
$TheQueries[]=$Query;
};


$TableName='Test';
$DoQuery('DROP TABLE IF EXISTS '.$TableName);
$DoQuery('CREATE TABLE '.$TableName.' (i1 int NOT NULL AUTO_INCREMENT, i2 int NOT NULL, primary key (i1)) ENGINE=InnoDB');
$DoQuery('INSERT INTO '.$TableName.' (i2) VALUES ('.implode('), (', range(2, $NumRows+1)).')');


if($TestNum==0)
{
$TestName='Transaction';
$Start=microtime(true);
$DoQuery('START TRANSACTION');
for($i=1;$i<=$NumRows;$i++)
$DoQuery('UPDATE '.$TableName.' SET i2='.(($i+5)*1000).' WHERE i1='.$i);
$DoQuery('COMMIT');
}
    

if($TestNum==1)
{
$TestName='Insert';
$Query=Array();
for($i=1;$i<=$NumRows;$i++)
$Query[]=sprintf("(%d,%d)", $i, (($i+5)*1000));
$Start=microtime(true);
$DoQuery('INSERT INTO '.$TableName.' VALUES '.implode(', ', $Query).' ON DUPLICATE KEY UPDATE i2=VALUES(i2)');
}
    

if($TestNum==2)
{
$TestName='Case';
$Query=Array();
for($i=1;$i<=$NumRows;$i++)
$Query[]=sprintf('WHEN %d THEN %d', $i, (($i+5)*1000));
$Start=microtime(true);
$DoQuery("UPDATE $TableName SET i2=CASE i1\n".implode("\n", $Query)."\nEND\nWHERE i1 IN (".implode(',', range(1, $NumRows)).')');
}
    

print "$TestName: ".(microtime(true)-$Start)."<br>\n";


file_put_contents("./$TestName.sql", implode(";\n", $TheQueries).';');
}

为什么没有人提到一个查询中的多条语句?

在php中，使用mysqli实例的multi_query方法。

从php手册

MySQL允许在一个语句字符串中包含多条语句。一次发送多个语句可以减少客户端-服务器之间的往返，但需要特殊处理。

下面是更新30,000 raw中与其他3种方法的比较结果。代码可以找到在这里，这是基于@Dakusan的回答

如您所见，多语句查询比最高答案更有效。

如果你得到这样的错误信息:

PHP Warning:  Error while sending SET_OPTION packet

你可能需要增加mysql配置文件中的max_allowed_packet，在我的机器中是/etc/mysql/my.cnf，然后重新启动mysqld。

下面是简单的方法

update my_table m, -- let create a temp table with populated values
(select 1 as id, 20 as value union -- this part will be generated
select 2 as id, 30 as value union -- using a backend code
-- for loop
select N as id, X as value
) t
set m.value = t.value where t.id=m.id -- now update by join - quick

我从@newtover中得到答案，并使用MySql 8中的新json_table函数扩展它。这允许你创建一个存储过程来处理工作负载，而不是在代码中构建自己的SQL文本:

drop table if exists `test`;
create table `test` (
`Id` int,
`Number` int,
PRIMARY KEY (`Id`)
);
insert into test (Id, Number) values (1, 1), (2, 2);


DROP procedure IF EXISTS `Test`;
DELIMITER $$
CREATE PROCEDURE `Test`(
p_json json
)
BEGIN
update test s
join json_table(p_json, '$[*]' columns(`id` int path '$.id', `number` int path '$.number')) v
on s.Id=v.id set s.Number=v.number;
END$$
DELIMITER ;


call `Test`('[{"id": 1, "number": 10}, {"id": 2, "number": 20}]');
select * from test;


drop table if exists `test`;

它比纯SQL慢了几毫秒，但我很高兴接受打击，而不是在代码中生成SQL文本。不确定它对巨大记录集的性能如何(JSON对象的最大大小为1Gb)，但我在一次更新10k行时一直使用它。