Snowflake 中的 INSERT INTO：完整新手指南

在使用 Snowflake 时，您最常执行的基础操作之一就是向表中插入数据。INSERT INTO 语句可让您将新记录添加到表中，无论是手动输入数值、一次性插入多行，还是从其他表中提取数据。

在本指南中，我将带您了解在 Snowflake 中高效使用 INSERT INTO 的语法、各种用例、最佳实践以及常见故障排除步骤。

什么是 Snowflake 中的 INSERT INTO 命令？

在讨论语法之前，我们需要先理解 Snowflake 中 INSERT INTO 的用途及其不同用例。

向数据库添加数据是数据库管理的重要组成部分。Snowflake 中的 INSERT INTO 语句用于向表中添加新的数据行。它既可以插入单行、多行，也可以从另一张表批量插入数据。您可以为某一行或一组行手动输入每个值，或使用 SQL 语句从其他数据源批量加载数据。

> 尽管 INSERT INTO 是一条基础命令，但先理解 Snowflake 及其架构会更有帮助。请查看这篇 Snowflake 教程，快速回顾基础知识！

INSERT INTO 的使用场景

以下是 INSERT INTO 子句的一些常见用例。

• 向表中手动添加新记录。
• 在一个查询中批量插入多行。
• 在表与表之间迁移数据。
• 向现有数据集追加新数据。
• 将 SELECT 查询结果写入表中。

> 掌握该子句对Snowflake 面试也很有帮助！

Snowflake 中 INSERT INTO 的语法

现在进入实际语法。我们先来看最直接的用法：通过手动输入值为某一行添加数据。

INSERT INTO 的基本语法如下：

INSERT INTO table_name (column1, column2, column3)
VALUES (value1, value2, value3);技术支持

先写出 INSERT INTO 子句并跟上 table_name，即我们要插入数据的表名。为明确数据的顺序，我们可以在括号中指定列名，如 (column1, column2, column3)。最后部分是写出 VALUES (value1, value2, value3)，这些值将被插入到相应列中。

不指定列名进行插入

如果省略列名，Snowflake 会假定提供的值与表架构中的列顺序一致。也就是说，第一个值对应表中的第一列，依此类推。

INSERT INTO table_name
VALUES (value1, value2, value3);技术支持

采用这种方式，您必须确保数值顺序与列顺序一致，否则可能会出现数据类型或数据一致性问题。

Snowflake 中 INSERT INTO 的高级用法

更加高级的用法包括：从其他表插入单行、一次插入多行，或按条件插入数据。这是向表中添加数据或将数据归档到独立表的实用方式。

使用 INSERT INTO 插入多行

您可以在一条语句中插入多行，而不是一行一行地插入：

INSERT INTO employees (id, name, department)
VALUES
    (1, 'Alice', 'HR'),
    (2, 'Bob', 'Finance'),
    (3, 'Charlie', 'IT');技术支持

这种做法可降低查询执行开销并提升性能。请注意，每一行都必须用一对括号完整包裹并以逗号分隔，否则会导致错误。

从另一张表插入数据

要将数据从一张表复制到另一张表，可将 INSERT INTO 与 SELECT 语句结合使用：

INSERT INTO target_table (column1, column2)

SELECT
column1, 
column2 
FROM source_table ;技术支持

这对于归档数据、在插入前进行数据转换或仅追加经过筛选的记录很有用。如果源数据的列顺序与目标一致，您可以省略 target_table 后的列名。

条件插入

您可以基于 SELECT 语句中的条件插入数据，从而避免复制整张表。

INSERT INTO high_salary_employees (id, name, salary)

SELECT 
id, 
name, 
salary
FROM employees 
WHERE salary > 100000;技术支持

这可确保只有满足条件的员工被插入新表。这样做有助于保持数据完整性，并降低存储与计算开销。

在 Snowflake 中使用 INSERT INTO 的最佳实践

以下是使用 INSERT INTO 时的一些最佳实践，包括使用更高效的语句（如 MERGE）以及在插入前进行数据验证。

用 MERGE 代替 INSERT INTO 实现 upsert

如果既需要插入新记录，又要更新已有记录，MERGE 是更佳选择，因为它可以匹配并处理现有数据。

它会查找当前行是否满足某些条件（例如，是否存在员工 ID），并可使用源表在目标表中更新特定值；若没有匹配，则插入新数据。这就是所谓的“upsert”（更新并插入）。

如下是使用 MERGE 的示例：

MERGE INTO target_table AS t
USING source_table AS s
ON t.id = s.id
WHEN MATCHED THEN
    UPDATE SET t.salary = s.salary
WHEN NOT MATCHED THEN
    INSERT (id, name, salary) VALUES (s.id, s.name, s.salary);技术支持

> MERGE 语句正迅速成为标准做法，也是Snowflake 认证的关键内容。

批量插入与性能

在插入大型数据集时，为提升性能应尽量进行批量插入。这样可避免每次加载都新建连接所带来的开销，并提升整体性能。以下是一些批量插入提示：

• 优先选择批量插入，而非逐行插入。
• 从外部源加载海量数据时使用 COPY INTO。例如连接到 S3 场景时非常有用。
• 避免在脚本循环中插入数据；批处理更高效。先完成循环，将数据存为单一数据源，再一次性加载整个数据源。

插入前进行数据验证

在插入数据之前，请先进行验证。若数据未验证，可能会引发诸多问题，甚至完全失败。请考虑下游如何使用这些数据，以及插入数据应呈现的形态。以下是需要重点关注的方面：

• 数据类型与列定义一致。
• 必填字段不为 NULL。
• 不存在重复主键或唯一性约束冲突。

在 Snowflake 中使用 INSERT INTO 的错误处理

如前所述，插入数据时偶尔会遇到错误。以下是处理常见错误的一些建议。

处理重复键

Snowflake 本身并不一定强制唯一性约束，这意味着可能插入重复数据。

如果您担心重复键，最好考虑使用 MERGE 或 ON CONFLICT（若受支持）进行处理。最终，您也可以在插入时使用 WHERE 条件，排除目标表中已存在的记录。

INSERT INTO employees (id, name)
SELECT id, name FROM new_employees
WHERE id NOT IN (SELECT id FROM employees);技术支持

处理 NULL 值

确保可为空的列允许 NULL 值，或提供默认值。Snowflake 会强制执行 NOT NULL 列约束，因此如果在具有该约束的列中出现 NULL 数据，插入将失败。关键在于理解您的数据，明确哪些位置允许出现 NULL，哪些不允许。

INSERT INTO 的常见问题排查

其他一些问题可能与数据类型或权限相关。我们将简要讨论如何处理这些问题。

数据类型不匹配

当插入的值数据类型不正确时会发生错误。有时您可以通过类型转换来处理，但这可能导致出现 NULL。为确保插入数据与目标一致，您可以在有权限的情况下查看 information_schema，以此评估架构：

SELECT column_name, 
data_type
 FROM information_schema.columns 
WHERE table_name = 'employees';技术支持

权限问题

如果收到权限错误，请检查用户角色和权限：

SHOW GRANTS TO USER current_user;技术支持

如果您没有使用 INSERT 的权限，请联系您的经理、IT 部门或数据集所有者。若您能够自行授予权限，请使用以下代码：

GRANT INSERT ON TABLE employees TO user_name;技术支持

结语

Snowflake 中的 INSERT INTO 命令是一种高效向表中添加数据的强大工具。无论是插入单行、批量数据，还是从另一张表复制，只要理解其语法和最佳实践，就能确保数据完整性与性能。通过妥善处理错误、验证数据并优化插入，您即可维护一个稳健高效的 Snowflake 数据库。

若想进一步学习 Snowflake，我建议查看以下课程：

• Introduction to Snowflake
• Introduction to Data Modeling in Snowflake