GaussDB(DWS)运维 -- 常见问题分析 -- 更新/删除报错

【报错信息】

并发更新(UPDATE/DELETE/MERGE)同一个表的时候，有时候会触发以下两种报错

ERROR:  concurrent update under Stream mode is not yet supported

-- 这种报错信息主要出现在更新目标表是行存表的场景。这种场景可以通过下面章节的描述进行规避

ERROR：These rows have been deleted or updated

-- 这种报错信息主要出现在更新目标表是列存表的场景。这种报错尽量从业务层面规避，如果业务层面不能规避，那么只能把目标修改为行存表，然后按照第一种报错信息同样的方法进行规避

【触发原因】

1) 数据更新(update/delete)时，发现满足更新条件的记录已经被别的事物T1更新，但是事物T1尚未提交

2) 执行数据更新(update/delete)的语句走了stream计划，且数据更新算子下层含有stream算子[见附1]

【解决方法】

消除数据更新(update/delete)算子下面的stream算子，可以通过以下两个步骤解决

1. 把要关联的结果集写到临时表中

实际业务场景中更新的关联结果集可能比较复杂，为了可以完美的消除stream算子，可以将关联结果集转储到一个临时表中，比如本文示例中的“SELECT * FROM t2 WHERE b = 1”这个查询就是要更新的关联结果集

1.1) 如果更新(update/delete)的目标表的分布列出现在更新关联列上，临时表的分布列设置为关联条件列，且分布列的数据类型跟对端一致

1.2) 如果更新(update/delete)的目标表的分布列没有出现在更新关联列上，临时表定义为复制表

比如当前示例中的两个SQL，数据更新(update/delete)的关联条件是 t.b = t1.a， 因此可以把关联结果集转储的中间表的分布列定义为b;

CREATE TEMP TABLE t DISTRIBUTE BY HASH(b) AS SELECT * FROM t2 WHERE b = 1;

 临时表t尽量使用hash表，因为复制表实际写数据量比较大，可能会引入性能问题

2. 使用临时表跟更新(update/delete)的目标表做联动更新

   如本文示例，关联结果集转储之后，更新语句可以改写为如下SQL

UPDATE t1 SET b = 2 FROM t WHERE t.b = t1.a;
DELETE FROM t1 USING t WHERE t.b = t1.a;

附1） 

示例中的UPDATE计划，可以看到UPDATE下层存在算子Streaming(type: REDISTRIBUTE)

示例中的DELETE计划，可以看到DELETE下层存在算子Streaming(type: REDISTRIBUTE)