使用INSERT INTO...SELECT语句可高效插入数据，通过NOT EXISTS、LEFT JOIN、MERGE语句或唯一约束避免重复；表结构不一致时可通过别名、类型转换、默认值或计算字段处理；结合存储过程可提升可维护性，支持参数化与动态SQL。
将查询结果数据插入到另一个表中，可以使用
INSERT INTO ... SELECT语句，这是一种高效且常用的方法。
INSERT INTO ... SELECT 语句
假设你有一个名为
source_table的表，其中包含你需要插入到
target_table的数据。
如何避免重复插入数据？
如何避免重复插入数据是一个非常重要的问题，特别是当你的
source_table数据会定期更新时。以下是一些常见的方法：
1. 使用 NOT EXISTS
子句：
这种方法通过检查
target_table中是否已经存在与
source_table中匹配的记录来避免重复插入。
INSERT INTO target_table (column1, column2, column3)
SELECT s.column1, s.column2, s.column3
FROM source_table s
WHERE NOT EXISTS (
SELECT 1
FROM target_table t
WHERE t.column1 = s.column1 AND t.column2 = s.column2 -- 根据实际情况调整匹配条件
);这个查询会从
source_table中选择所有记录，然后检查
target_table中是否已经存在具有相同
column1和
column2值的记录。如果不存在，则将该记录插入到
target_table中。
2. 使用 LEFT JOIN
和 WHERE
子句：
这种方法使用
LEFT JOIN将
source_table和
target_table连接起来，然后使用
WHERE子句过滤掉
target_table中已经存在的记录。
INSERT INTO target_table (column1, column2, column3) SELECT s.column1, s.column2, s.column3 FROM source_table s LEFT JOIN target_table t ON s.column1 = t.column1 AND s.column2 = t.column2 -- 根据实际情况调整匹配条件 WHERE t.column1 IS NULL;
这个查询会返回
source_table中的所有记录，以及
target_table中与
source_table记录匹配的记录。由于是
LEFT JOIN，如果
target_table中没有匹配的记录，则
target_table的列将返回
NULL。
WHERE t.column1 IS NULL子句会过滤掉
target_table中已经存在的记录，只留下需要插入的记录。
3. 使用 MERGE
语句 (SQL Server)：
MERGE语句是 SQL Server 中用于同时执行
INSERT、
UPDATE和
DELETE操作的强大工具。它可以用来避免重复插入数据，并根据需要更新现有数据。
MERGE INTO target_table AS target
USING source_table AS source
ON target.column1 = source.column1 AND target.column2 = source.column2 -- 根据实际情况调整匹配条件
WHEN NOT MATCHED THEN
INSERT (column1, column2, column3)
VALUES (source.column1, source.column2, source.column3);这个语句首先将
target_table和
source_table连接起来，然后检查
target_table中是否已经存在与
source_table中匹配的记录。如果不存在，则使用
WHEN NOT MATCHED THEN子句将该记录插入到
target_table中。
4. 使用唯一索引或约束：
在
target_table上创建唯一索引或约束可以防止插入重复数据。如果尝试插入重复数据，数据库会抛出一个错误。
-- 创建唯一索引 CREATE UNIQUE INDEX idx_target_table_column1_column2 ON target_table (column1, column2); -- 创建唯一约束 ALTER TABLE target_table ADD CONSTRAINT uc_target_table_column1_column2 UNIQUE (column1, column2);
这种方法需要在
target_table上创建索引或约束，因此可能会影响插入性能。但是，它可以确保
target_table中永远不会存在重复数据。
选择哪种方法取决于你的具体需求和数据库系统。如果你的数据量不大，并且不需要高性能，那么
NOT EXISTS或
LEFT JOIN方法可能就足够了。如果你的数据量很大，并且需要高性能，那么可以考虑使用
MERGE语句或唯一索引/约束。
如何处理目标表和源表结构不一致的情况？
目标表和源表结构不一致是很常见的情况，例如列名不同、数据类型不匹配、列的数量不同等。以下是处理这些情况的一些常见方法：
1. 列名不同：
如果列名不同，可以使用
AS关键字来为源表中的列指定别名，使其与目标表中的列名匹配。
INSERT INTO target_table (target_column1, target_column2) SELECT source_column1 AS target_column1, source_column2 AS target_column2 FROM source_table;
2. 数据类型不匹配：
如果数据类型不匹配，可以使用
CAST或
CONVERT函数将源表中的数据转换为目标表中的数据类型。
INSERT INTO target_table (target_column1) SELECT CAST(source_column1 AS INT) FROM source_table; INSERT INTO target_table (target_column2) SELECT CONVERT(VARCHAR(20), source_column2) FROM source_table;
需要注意的是，数据类型转换可能会导致数据丢失或精度损失。例如，将
VARCHAR类型转换为
INT类型时，如果
VARCHAR类型的值不是有效的整数，则转换会失败。
3. 列的数量不同：
如果源表中的列的数量少于目标表中的列的数量，可以在
INSERT INTO语句中为目标表中缺失的列指定默认值。
INSERT INTO target_table (target_column1, target_column2, target_column3) SELECT source_column1, source_column2, 'default_value' FROM source_table;
如果源表中的列的数量多于目标表中的列的数量，可以在
SELECT语句中只选择目标表中存在的列。
INSERT INTO target_table (target_column1, target_column2) SELECT source_column1, source_column2 FROM source_table;
4. 需要进行数据转换或计算：
有时候，你需要对源表中的数据进行转换或计算才能将其插入到目标表中。例如，你需要将两个列的值合并为一个列的值，或者你需要根据某个条件计算出一个新的值。
INSERT INTO target_table (target_column1)
SELECT source_column1 + source_column2
FROM source_table;
INSERT INTO target_table (target_column2)
SELECT CASE
WHEN source_column3 > 10 THEN 'A'
ELSE 'B'
END
FROM source_table;示例：
假设
source_table的结构如下：
id
(INT)name
(VARCHAR(50))amount
(DECIMAL(10, 2))
target_table的结构如下：
product_id
(INT)product_name
(VARCHAR(100))price
(FLOAT)status
(VARCHAR(10))
要将
source_table中的数据插入到
target_table中，可以使用以下 SQL 语句：
INSERT INTO target_table (product_id, product_name, price, status) SELECT id, name, CAST(amount AS FLOAT), 'active' FROM source_table;
在这个例子中，我们使用了
AS关键字来为
source_table中的
id和
name列指定了别名，使其与
target_table中的
product_id和
product_name列匹配。我们还使用了
CAST函数将
source_table中的
amount列转换为
target_table中的
price列的数据类型。最后，我们为
target_table中的
status列指定了一个默认值
'active'。
如何使用存储过程来简化插入操作？
使用存储过程可以封装复杂的插入逻辑，提高代码的可重用性和可维护性。
-- 创建存储过程
CREATE PROCEDURE InsertDataFromSourceToTarget
AS
BEGIN
INSERT INTO target_table (column1, column2, column3)
SELECT s.column1, s.column2, s.column3
FROM source_table s
WHERE NOT EXISTS (
SELECT 1
FROM target_table t
WHERE t.column1 = s.column1 AND t.column2 = s.column2
);
END;
-- 执行存储过程
EXEC InsertDataFromSourceToTarget;存储过程可以接受参数，例如源表名、目标表名、匹配条件等，从而使其更加灵活。
CREATE PROCEDURE InsertDataFromSourceToTarget
@sourceTableName VARCHAR(100),
@targetTableName VARCHAR(100),
@matchColumn1 VARCHAR(100),
@matchColumn2 VARCHAR(100)
AS
BEGIN
DECLARE @sql VARCHAR(MAX);
SET @sql = '
INSERT INTO ' + @targetTableName + ' (column1, column2, column3)
SELECT s.column1, s.column2, s.column3
FROM ' + @sourceTableName + ' s
WHERE NOT EXISTS (
SELECT 1
FROM ' + @targetTableName + ' t
WHERE t.' + @matchColumn1 + ' = s.' + @matchColumn1 + ' AND t.' + @matchColumn2 + ' = s.' + @matchColumn2 + '
);
';
EXEC(@sql);
END;
-- 执行存储过程
EXEC InsertDataFromSourceToTarget 'source_table', 'target_table', 'column1', 'column2';需要注意的是，使用动态 SQL 语句可能会导致 SQL 注入攻击。因此，在使用动态 SQL 语句时，一定要对参数进行验证和转义。
