我正在尝试在加载期间创建一个验证过程,以检查数据是否重复。然而,Vertica不支持此功能:Vertica仅在运行查询时检查约束违规,而不是在加载数据时检查。要在加载过程中检测约束违规,请使用带有NO COMMIT选项的COPY语句(第667页)。通过在不提交的情况下加载数据,您可以使用ANALYZE_CONSTRAINTS函数对数据进行后装载检查。如果该函数发现约束违规,则可以回滚加载,因为您还没有提交它。
问题在于我无法编写程序来实现此操作。我怀疑我需要一个存储过程,但我不熟悉Vertica的存储过程语法/限制。您能帮忙吗?以下是我的代码:
问题在于我无法编写程序来实现此操作。我怀疑我需要一个存储过程,但我不熟悉Vertica的存储过程语法/限制。您能帮忙吗?以下是我的代码:
-- Create a new table. "id" is auto-incremented and "name" must be unique
CREATE TABLE IF NOT EXISTS my_table (
id IDENTITY
, name varchar(50) UNIQUE NOT NULL
, type varchar(20)
, description varchar(200)
);
--Insert a record
begin;
copy my_table from stdin
abort on error
NO COMMIT; -- this begins the load
name1|type1|description1 --this is the load
\. -- this closes the load
commit;
-- insert the duplicate record
begin;
copy my_table from stdin
abort on error
NO COMMIT; -- this begins the load
name1|type1|description1 --this is the load
\. -- this closes the load
commit; -- Surprisingly, the load executes successfully! What's going on?!?!
-- Check constraints. We see that there is a failed constraints:
select analyze_constraints('my_table');
我想要进行一些条件逻辑操作。下面是伪代码。你能帮我准备一下Vertica吗?
Begin
load data
if (select count(*) from (select analyze_constraints('my_table')) sub) == 0:
commit
else rollback