主页 / dba / 问题 / 173825
Accepted
guettli
Asked: 2017-05-18 06:32:53 +0800 CST

在 UPDATE 时将数据添加到第二个表（仅限 PostgreSQL）

  • 772

我有包含这些（和其他）列的表票：

  • ID
  • ticket_type
  • 客户

如果ticket_type或client得到更新，那么表格transfere_table应该被归档。已更改机票的 ticket.id 应插入到转账表中。

这是工作代码：

CREATE FUNCTION add_ticket_to_transfere_table () RETURNS trigger 
       LANGUAGE plpythonu AS $$

plpy.execute(plpy.prepare(
'''INSERT INTO transfere_table (ticket_id) VALUES ($1)''',
     ['int']), [TD['new']['id']])
$$;

CREATE TRIGGER add_ticket_to_transfere_table_trigger 
    AFTER UPDATE OF ticket_type_id, client_id ON ticket
    FOR EACH ROW
    WHEN (OLD.ticket_type_id != NEW.ticket_type_id or 
         OLD.client_id != NEW.client_id)

    EXECUTE PROCEDURE add_ticket_to_transfere_table();

由于我到现在只用过plpythonu，所以就这样解决了。它有效，但我看到有两点需要改进：

  • 去掉 FOR EACH ROW: 如果 N 行被更新，如果只执行一个 INSERT 就好了
  • 不要使用 plpythonu

如何实现这些改进？

还有其他可以改进的地方吗？

我正在使用 PostgreSQL 9.3.13

postgresql trigger

1 个回答

  1. Best Answer

    1. 去掉 FOR EACH ROW: 如果 N 行被更新，如果只执行一个 INSERT 就好了

      那将如何工作，您将无法访问 OLD 或 NEW，因为它是一个语句触发器。

    2. 不要使用 plpythonu

      Python 本身不支持作为可信语言运行。您可以轻松使用plpgsql.

    plpgsql 函数的代码，

    CREATE OR REPLACE FUNCTION add_ticket_to_transfere_table()
RETURNS TRIGGER
AS $$
    BEGIN
      INSERT INTO transfere_table (ticket_id) VALUES (new.id);
      RETURN new;
    END;
$$
LANGUAGE plpgsql;

    这不是我个人运行它的方式。我会做的是

    1. triaged在代表的行或任何transfere_table代表的行上创建一个布尔值。
    2. 插入时，将该布尔值默认设置为 true。如果未提供数据，则实际上是一个列触发器。当您更新票证时，请在更新语句中设置该布尔值。

    如果你不想碰那个桌子本身，我会反向运行你的过程。

    1. 创建表transfere_done

      CREATE TABLE transfere_done (
  ticket_id int PRIMARY KEY REFERENCES ticket.ticket_id
)

    2. 将所有 ID 复制到它。

    3. 创建以下视图，

      CREATE VIEW transfere_queue
AS
  SELECT * FROM ticket
  WHERE NOT EXISTS (
    SELECT 1
    FROM transfere_done
    WHERE transfere_done.id = ticket.id
  );

    现在，当您插入时ticket，它会自动显示在下方，transfere_queue直到您插入到transfere_done。您可能想要也可能不想MATERIALIZE查看。无论哪种方式，我都非常讨厌在不需要时使用触发器，并且我尝试围绕它们进行设计。

    • 2

相关问题