postgresql 触发器函数 - 重复或丢失数据

Question

postgresql 9.1 DB 写入从机器自动发送的数据。这很好用。

我有一个 AFTER INSERT ...FOR EACH ROW 触发器 - 这也有效。 触发器通过查看另一个表来工作，如果字段中有值，它就会触发。

我有两个问题 - 一种。一些机器发送超过 1 个结果。我使用 LIMIT 1 来防止重复，这意味着我错过了来自发送多个结果的机器的数据。有什么替代方法？ 湾。有些机器共享相同的测试代码，我找不到一种方法来限定它，以便在我使用 NEW 值时使其在 SELECT 中特定于机器。这是代码

CREATE FUNCTION testcode_matches()
    RETURNS TRIGGER as $$
DECLARE
    var INTEGER;
    name text;
    short text;
    id integer;
BEGIN
    SELECT count("TestID") from testcode WHERE "testcode"."Parameter" = NEW."Parameter" into var;
    IF var > 0 THEN
        SELECT "TestName", "ShortTestName", "TestID" 
        from testcode where "Parameter" = NEW."Parameter" Limit 1 into name, short, id;

        INSERT INTO finaldata /* various fields */
        SELECT /* various fields */ name, short, id
        from obx 
        WHERE "obx"."Parameter" = NEW."Parameter"
        LIMIT 1;
    END if;
    RETURN NEW;
END;
$$ language plpgsql;

Answer 1

纯 SQL 版本，没有所有变量的东西。 （未知细节省略或猜测）（未经测试）

CREATE FUNCTION testcode_matches()
    RETURNS TRIGGER as $meat$
BEGIN

    INSERT INTO finaldata ( name, short, id /* various fields */ )
    SELECT tc.name, tc.shorttestname, tc.id /* various fields */
    FROM testcode tc
    JOIN obx ON obx.parameter = tc.parameter
    WHERE tc.parameter = NEW.parameter
    AND tc.id = NEW.id -- is this the PK for testcode ??
                ;
    RETURN NEW;
END;
$meat$ language sql;

更新：

set search_path='tmp';

DROP TABLE obx CASCADE;
CREATE TABLE obx
        ( parameter INTEGER NOT NULL PRIMARY KEY
        );

DROP TABLE testcode CASCADE;
CREATE TABLE testcode
        ( ID INTEGER NOT NULL PRIMARY KEY
        , parameter INTEGER NOT NULL  REFERENCES obx(parameter)
        , zname VARCHAR
        , shorttestname VARCHAR
        );

DROP TABLE finaldata CASCADE;
CREATE TABLE finaldata
        ( ID INTEGER NOT NULL PRIMARY KEY
        , zname VARCHAR
        , shorttestname VARCHAR
        );


DROP FUNCTION testcode_matches();
CREATE FUNCTION testcode_matches()
    RETURNS TRIGGER
    AS $meat$
BEGIN

    INSERT INTO finaldata ( id, zname, shorttestname /* various fields */ )
    SELECT tc.id, tc.zname, tc.shorttestname /* various fields */
    FROM testcode tc
    JOIN obx ON obx.parameter = tc.parameter
    WHERE tc.parameter = NEW.parameter
    AND tc.id = NEW.id -- is this the PK for testcode ??
                ;
    RETURN NEW;
END;
$meat$ language plpgsql;

DROP TRIGGER testcode_ins;
CREATE TRIGGER testcode_ins
        AFTER INSERT ON testcode
        FOR EACH ROW
        EXECUTE PROCEDURE testcode_matches()
        ;