断言一组列可以在雪花中形成主要钥匙的最佳方法是什么？

Question

臭名昭著的主要关键约束是 不强制a>在雪花sql中：

-- Generating a table with 4 rows that contain duplicates and NULLs:
CREATE OR REPLACE TEMP TABLE PRIMARY_KEY_TEST AS
SELECT
*
FROM (
           SELECT 1    AS PK, 'TEST_TEXT' AS TEXT
UNION ALL  SELECT 1    AS PK, 'TEST_TEXT' AS TEXT
UNION ALL  SELECT NULL AS PK, NULL        AS TEXT
UNION ALL  SELECT NULL AS PK, NULL        AS TEXT
)
;

SELECT *
FROM PRIMARY_KEY_TEST
;

pk	文本
1	test_text
1	test_text
null	null null null null
null null null null null null null null null null null null null null null null null null null	null

-- These constraints will NOT throw any errors in Snowflake
ALTER TABLE PRIMARY_KEY_TEST ADD PRIMARY KEY (PK);
ALTER TABLE PRIMARY_KEY_TEST ADD UNIQUE (TEXT);

null null null null null null null null null nuln nuln nuln nuln nuln n n均值很大> 在更新一组数据时检查至关重要。

因此，我正在寻找易于编写和读取的（理想情况下是1-2行）的代码（易于基于某些雪花功能），如果一组列不再形成Snowflake SQL中的可行主键，则会引发错误。

有什么建议吗？

Answer 1

所以我正在寻找易于编写和读取的（理想情况下是1-2行）代码（大概是基于某些雪花功能），如果一组列不再形成可行的主键，则会引发错误雪花sql

错误测试查询很容易使用合格和窗口计数编写。该模式是将主密钥列列表按部分分配并搜索非唯一值，也可以添加对空的其他检查。如果列列表是主键的有效候选者，则不会返回任何行，如果有行违反规则将被返回：

-- checking if PK is applicable
SELECT *
FROM PRIMARY_KEY_TEST
QUALIFY COUNT(*) OVER(PARTITION BY PK) > 1
     OR PK IS NULL;
  
 -- chekcing if TEXT column is applicable 
SELECT *
FROM PRIMARY_KEY_TEST
QUALIFY COUNT(*) OVER(PARTITION BY TEXT) > 1
     OR TEXT IS NULL;
     
 -- chekcing if PK,TEXT columns are applicable 
SELECT *
FROM PRIMARY_KEY_TEST
QUALIFY COUNT(*) OVER(PARTITION BY PK,TEXT) > 1
    OR PK IS NULL
    OR TEXT IS NULL;

---

我仍然希望代码可能会引发错误，尽管

可以使用雪花脚本和提升例外：

BEGIN
   LET my_exception EXCEPTION (-20002, 'Columns cannot be used as PK.');

   IF (EXISTS(SELECT *
             FROM PRIMARY_KEY_TEST
              QUALIFY COUNT(*) OVER(PARTITION BY PK) > 1
               OR PK IS NULL
       )) THEN
     RAISE my_exception;
  END IF;
END;

-20002（p0001）：在位置5上的第8行中未知的“ my_exception”类型：列不能用作pk。

Answer 2

您可以通过在您希望不能够无效的列上添加非零件约束，从而在雪花上执行无效。

主要的关键限制仅是信息性；将数据插入表中时不会强制执行。对于主键，您必须删除 /删除数据或插入之前，您必须检查数据是否存在，然后仅更新。
根据您正在做的事情，您可以使用以下

1. 合并（插入和更新）
2. 使用以下方式检查行是否存在，然后更新或删除旧并插入新的。
3. 您可以使用ROW_NUMBER分析函数来识别重复项。