0

这是这个问题的后续问题，所以我知道我可以使用（阻塞）锁，但我想使用谓词锁和可序列化事务隔离。

我想要的是一个序列化失败的通用处理程序，它将重试函数/查询 X 次。

例如，我有这个：

CREATE SEQUENCE account_id_seq;

CREATE TABLE account
(
  id integer NOT NULL DEFAULT nextval('account_id_seq'),
  title character varying(40) NOT NULL,
  balance integer NOT NULL DEFAULT 0,
  CONSTRAINT account_pkey PRIMARY KEY (id)
);

INSERT INTO account (title) VALUES ('Test Account');

CREATE OR REPLACE FUNCTION mytest() RETURNS integer AS $$
DECLARE
    cc integer;
BEGIN
    cc := balance from account where id=1;

    RAISE NOTICE 'Balance: %', cc;
    perform pg_sleep(3);

    update account set balance = cc+10 where id=1 RETURNING balance INTO cc;

    return cc;
END
$$
LANGUAGE plpgsql;

CREATE OR REPLACE FUNCTION myretest() RETURNS integer AS $$
DECLARE
    tries integer := 5;
BEGIN
    WHILE TRUE LOOP
        BEGIN -- nested block for exception
            RETURN mytest();
        EXCEPTION
            WHEN SQLSTATE '40001' THEN
                IF tries > 0 THEN
                    tries := tries - 1;
                    RAISE NOTICE 'Restart! % left', tries;
                ELSE
                    RAISE EXCEPTION 'NO RESTARTS LEFT';
                END IF;
        END;
    END LOOP;
END
$$
LANGUAGE plpgsql;

因此，如果mytest()同时直接调用，我在最后一次提交时会出现序列化失败：

4SO$ psql -c "select mytest()" & PIDA=$! && psql -c "select mytest()" && wait $PIDA
[1] 4909
NOTICE:  Balance: 0
NOTICE:  Balance: 0
 mytest 
--------
     10
(1 row)

ERROR:  could not serialize access due to concurrent update
CONTEXT:  SQL statement "update account set balance = cc+10 where id=1 RETURNING balance"
PL/pgSQL function mytest() line 10 at SQL statement

如果我调用myretest()它，它应该尝试执行mytest()到第 5 次尝试，它会引发异常。

所以我在这里有两点（也许第 2 点也使第 1 点无效）：

  • myretest()没有按预期工作，即使在并发线程完成后，每次迭代都会导致 serialiation_failure 异常：我应该添加一些东西来“重置”事务吗？

  • 我怎样才能使这个（myretest()逻辑）通用，以便它适用于系统中的每个调用函数，而不需要“包装器”函数本身？

4

1 回答 1

1

只要您使用一些框架，当它收到带有SQLSTATEof40001或的错误时，可序列化事务就可以提供您正在寻找的东西40P01。

在 PostgreSQL 中，函数总是在事务的上下文中运行。您不能在“包装器”函数的上下文中启动新事务。这将需要一个稍微不同的功能，通常称为“存储过程”——PostgreSQL 中不存在的东西。因此，您需要将管理重启的逻辑放入将事务提交到数据库的代码中。幸运的是，有很多连接器——Java、perl、python、tcl、ODBC 等。甚至还有一个连接器用于在 PostgreSQL 过程语言中与 PostgreSQL 数据库建立单独的连接，这可能允许您执行类似的操作你想要什么：

http://www.postgresql.org/docs/current/static/dblink.html

我已经在各种“客户端”框架中看到了这一点。显然，将其传播到应用程序在逻辑上处理数据库的所有位置是一个坏主意，但是有很多充分的理由通过一个“访问器”方法（或至少其中的一小部分）路由所有数据库请求)，并且大多数框架都提供了一种在该层处理此问题的方法。（例如，在 Spring 中，您可能希望使用依赖注入创建事务管理器。）这可能属于您用于应用程序逻辑的某种语言，但如果您真的想要，您可能会使用 plpgsql 和 dblink；不过，这可能不是您最简单的方法。

于 2015-04-06T21:23:32.007 回答