我需要一个查询来更新表中的行,但如果id不存在,则插入默认值。它还必须避免线程竞争条件。
我在这里找到了答案,应该是很好的https://stackoverflow.com/a/7927957/8372336
使用此查询:
UPDATE tbl x
SET tbl_id = 24
, name = 'New Gal'
FROM (SELECT tbl_id, name FROM tbl WHERE tbl_id = 4 FOR UPDATE) y
WHERE x.tbl_id = y.tbl_id
RETURNING y.tbl_id AS old_id, y.name AS old_name, x.tbl_id, x.name;
所以我认为它应该在更新后返回旧的值,它应该防止线程竞争条件。
但是如果行不存在,我需要添加一个插入,并且这次也返回插入的值(旧值没有意义,因为它们不存在)。
所以基本上我需要做类似的事情
INSERT INTO tbl
(...) VALUES (...)
RETURNING ..., ...
ON CONFLICT DO
UPDATE tbl x
SET tbl_id = 24
, name = 'New Gal'
FROM (SELECT tbl_id, name FROM tbl WHERE tbl_id = 4 FOR UPDATE) y
WHERE x.tbl_id = y.tbl_id
RETURNING y.tbl_id AS old_id, y.name AS old_name, x.tbl_id, x.name;
但我不确定这样的事情是否有效。我怎样才能让它发挥作用并确保竞争条件?
不知何故,这似乎工作:
insert into t (x)
values ('a0'), ('b')
on conflict (x) do update
set x = excluded.x || '0'
returning i, x, (select x from t t2 where t2.i = t.i);
我很惊讶,因为t
在子查询的范围内,但excluded
不是。嗯。 。 。也许这是因为它不是on conflict
条款的一部分,而是整体insert
的一部分。这开始有意义了。
Here是这个版本的db <>小提琴。
我认为你的代码看起来像:
INSERT INTO tbl (...)
VALUES (...)
ON CONFLICT DO
UPDATE tbl x
SET tbl_id = 24,
name = 'New Gal'
RETURNING (SELECT t2.tbl_id FROM tbl t2 WHERE t2.tbl_id = tbl.tbl_id) AS old_id,
(SELECT t2.name FROM tbl t2 WHERE t2.tbl_id = tbl.tbl_id) AS old_name,
x.tbl_id, x.name;