postgresql触发功能 - 重复或缺少数据

Question

postgresql 9.1数据库写入从机器自动发送的数据。这工作正常。

我有一个AFTER INSERT ... FOR EACH ROW触发器 - 这也适用。 触发器通过查看另一个表以及它触发的字段中是否有值。

我有两个问题 - a。有些机器发送的结果不止一个。我使用LIMIT 1来防止重复，这意味着我错过了发送多个结果的机器的数据。什么是替代这个？ b。有些机器共享相同的测试代码，我无法找到一种合格的方法，以便在使用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() 
     ;