在数据库操作中，我们经常会遇到需要根据其他表的数据来更新目标表部分记录的需求，这类操作通常需要结合子查询和关联条件来实现。同时MERGE语句作为能够处理插入、更新、删除的复合语法，在复杂条件场景下有着更灵活的应用空间。
带条件的子查询关联更新实现
基础关联更新语法
大多数关系型数据库都支持通过JOIN或者子查询的方式实现关联更新，当更新需要满足特定条件时，可以在WHERE子句中追加过滤逻辑。以MySQL为例，更新员工表中部门为技术部且工资低于平均值的员工工资，参考代码如下：
-- 更新技术部工资低于部门平均工资的员工工资，提升10%
UPDATE employee e
JOIN (
-- 子查询计算技术部平均工资
SELECT dept_id, AVG(salary) AS avg_salary
FROM employee
WHERE dept_name = '技术部'
GROUP BY dept_id
) AS dept_avg ON e.dept_id = dept_avg.dept_id
SET e.salary = e.salary * 1.1
WHERE e.dept_name = '技术部'
AND e.salary < dept_avg.avg_salary;
不同数据库的语法差异
不同数据库对关联更新的语法支持有所不同，SQL Server中可以使用UPDATE结合FROM子句实现：
-- SQL Server关联更新示例
UPDATE e
SET e.salary = e.salary * 1.1
FROM employee e
INNER JOIN (
SELECT dept_id, AVG(salary) AS avg_salary
FROM employee
WHERE dept_name = '技术部'
GROUP BY dept_id
) AS dept_avg ON e.dept_id = dept_avg.dept_id
WHERE e.dept_name = '技术部'
AND e.salary < dept_avg.avg_salary;
Oracle则通常使用MERGE语句或者子查询嵌套UPDATE的方式实现，基础关联更新示例如下：
-- Oracle子查询关联更新示例
UPDATE employee e
SET e.salary = (
SELECT e.salary * 1.1
FROM employee e2
JOIN (
SELECT dept_id, AVG(salary) AS avg_salary
FROM employee
WHERE dept_name = '技术部'
GROUP BY dept_id
) dept_avg ON e2.dept_id = dept_avg.dept_id
WHERE e2.emp_id = e.emp_id
AND e2.dept_name = '技术部'
AND e2.salary < dept_avg.avg_salary
)
WHERE EXISTS (
SELECT 1
FROM employee e3
JOIN (
SELECT dept_id, AVG(salary) AS avg_salary
FROM employee
WHERE dept_name = '技术部'
GROUP BY dept_id
) dept_avg ON e3.dept_id = dept_avg.dept_id
WHERE e3.emp_id = e.emp_id
AND e3.dept_name = '技术部'
AND e3.salary < dept_avg.avg_salary
);
MERGE语句基础用法
MERGE语句是SQL标准提供的语法，能够根据源表和目标表的匹配结果，执行更新、插入、删除等操作，基本语法结构如下：
MERGE INTO 目标表 别名
USING 源表 别名
ON (匹配条件)
WHEN MATCHED THEN
UPDATE SET 字段1 = 值1, 字段2 = 值2
WHEN NOT MATCHED THEN
INSERT (字段列表) VALUES (值列表);
以Oracle为例，将员工表的新数据同步到历史表，匹配到则更新，未匹配到则插入：
MERGE INTO employee_history eh
USING new_employee ne
ON (eh.emp_id = ne.emp_id)
WHEN MATCHED THEN
UPDATE SET eh.salary = ne.salary, eh.dept_name = ne.dept_name, eh.update_time = SYSDATE
WHEN NOT MATCHED THEN
INSERT (emp_id, emp_name, salary, dept_name, create_time)
VALUES (ne.emp_id, ne.emp_name, ne.salary, ne.dept_name, SYSDATE);
MERGE语句嵌套应用
嵌套子查询作为源表
当更新条件需要基于复杂的子查询结果时，可以将子查询嵌套在USING子句中作为源表，实现带条件的更新。例如更新技术部中工资低于部门平均工资的员工工资，参考代码如下：
MERGE INTO employee e
USING (
-- 嵌套子查询作为源表，计算技术部员工和对应部门平均工资
SELECT
emp.emp_id,
emp.salary * 1.1 AS new_salary,
dept_avg.avg_salary
FROM employee emp
JOIN (
SELECT dept_id, AVG(salary) AS avg_salary
FROM employee
WHERE dept_name = '技术部'
GROUP BY dept_id
) dept_avg ON emp.dept_id = dept_avg.dept_id
WHERE emp.dept_name = '技术部'
AND emp.salary < dept_avg.avg_salary
) src ON (e.emp_id = src.emp_id)
WHEN MATCHED THEN
UPDATE SET e.salary = src.new_salary, e.update_time = SYSDATE;
嵌套MERGE实现多条件批量操作
在复杂业务场景中，可能需要先处理源数据再执行合并操作，此时可以嵌套MERGE语句。例如先过滤出有效的新员工数据，再将有效数据同步到主表，匹配则更新工资，未匹配则插入新员工：
MERGE INTO employee e
USING (
-- 内层MERGE处理源数据，过滤出工资大于5000的有效新员工
SELECT
ne.emp_id,
ne.emp_name,
ne.salary,
ne.dept_name
FROM new_employee ne
WHERE ne.salary > 5000
) valid_emp ON (e.emp_id = valid_emp.emp_id)
WHEN MATCHED THEN
UPDATE SET e.salary = valid_emp.salary, e.dept_name = valid_emp.dept_name
WHEN NOT MATCHED THEN
INSERT (emp_id, emp_name, salary, dept_name, create_time)
VALUES (valid_emp.emp_id, valid_emp.emp_name, valid_emp.salary, valid_emp.dept_name, SYSDATE);
注意事项
- 使用关联更新或者MERGE语句前，建议先通过SELECT语句验证匹配条件和更新数据是否符合预期，避免误操作。
- 嵌套子查询时需要注意性能问题，尽量给关联字段和过滤字段添加索引，减少全表扫描的开销。
- 不同数据库对MERGE语句的支持程度不同，MySQL目前不支持标准MERGE语法，需要使用其他方式实现类似功能。
- 在MERGE语句中，匹配条件需要保证唯一性，避免出现一行源数据匹配多行目标数据的情况，否则会抛出错误。