1

我的想法是实现一个基本的“矢量时钟”，其中时间戳是基于时钟的，始终向前并保证是唯一的。

例如，在一个简单的表中：

CREATE TABLE IF NOT EXISTS timestamps (
    last_modified TIMESTAMP UNIQUE
);

我使用触发器在插入之前设置时间戳值。当两个插入同时到达时，它基本上只是进入未来：

CREATE OR REPLACE FUNCTION bump_timestamp()
RETURNS trigger AS $$
DECLARE
    previous TIMESTAMP;
    current TIMESTAMP;
BEGIN
     previous := NULL;
     SELECT last_modified INTO previous
      FROM timestamps
     ORDER BY last_modified DESC LIMIT 1;

     current := clock_timestamp();
     IF previous IS NOT NULL AND previous >= current THEN
        current := previous + INTERVAL '1 milliseconds';
     END IF;
     NEW.last_modified := current;
     RETURN NEW;
END;
$$ LANGUAGE plpgsql;

DROP TRIGGER IF EXISTS tgr_timestamps_last_modified ON timestamps;

CREATE TRIGGER tgr_timestamps_last_modified
BEFORE INSERT OR UPDATE ON timestamps
FOR EACH ROW EXECUTE PROCEDURE bump_timestamp();

然后我在两个单独的客户端中运行大量插入：

DO
$$
BEGIN
    FOR i IN 1..100000 LOOP
       INSERT INTO timestamps DEFAULT VALUES;
    END LOOP;
END;
$$;

正如预期的那样，我遇到了碰撞：

ERROR: duplicate key value violates unique constraint "timestamps_last_modified_key"
État SQL :23505
Détail :Key (last_modified)=(2016-01-15 18:35:22.550367) already exists.
Contexte : SQL statement "INSERT INTO timestamps DEFAULT VALUES"
PL/pgSQL function inline_code_block line 4 at SQL statement

@rach 建议current_clock()与对象混合SEQUENCE，但这可能意味着摆脱TIMESTAMP类型。即使我真的无法弄清楚它如何解决隔离问题......

有没有共同的模式来避免这种情况？

谢谢你的见解:)

4

2 回答 2

1

我的两分钱（灵感来自http://tapoueh.org/blog/2013/03/15-batch-update）。

尝试在大量插入之前添加以下内容：

LOCK TABLE timestamps IN SHARE MODE;

官方文档在这里：http ://www.postgresql.org/docs/current/static/sql-lock.html

于 2016-01-15T19:29:51.817 回答
0

如果您只有一个 Postgres 服务器，我认为使用时间戳 + 序列可以解决问题，因为序列是非事务性的并且尊重插入顺序。如果你有 db 分片，那么它会复杂得多，但也许 BDR 中 2ndquadrant 的分布式序列可能会有所帮助，但我认为不会尊重序数。如果您已设置进行测试，我在下面添加了一些代码。

CREATE SEQUENCE "timestamps_seq";

-- Let's test first, how to generate id.
SELECT extract(epoch from now())::bigint::text || LPAD(nextval('timestamps_seq')::text, 20, '0') as unique_id ;

           unique_id
--------------------------------
 145288519200000000000000000010
(1 row)


CREATE TABLE IF NOT EXISTS timestamps (
    unique_id TEXT UNIQUE NOT NULL DEFAULT extract(epoch from now())::bigint::text || LPAD(nextval('timestamps_seq')::text, 20, '0')
);


INSERT INTO timestamps DEFAULT VALUES;
INSERT INTO timestamps DEFAULT VALUES;
INSERT INTO timestamps DEFAULT VALUES;

select * from timestamps;
           unique_id
--------------------------------
 145288556900000000000000000001
 145288557000000000000000000002
 145288557100000000000000000003
(3 rows)

让我知道这是否有效。我不是 DBA，所以最好在 dba.stackexchange.com 上询问潜在的副作用。

于 2016-01-15T19:23:02.667 回答