Where

create table process (fluid_id integer primary key, process varchar, contain varchar);

create table pipe ( fluid_id integer not null, contain varchar);

create or replace function base() returns trigger as $$

            begin

            insert into pipe (fluid_id) values (new.fluid_id);

            select * into pipe from process where contain = 'ip';

            return null;

            end;

            $$ language plpgsql;

            create trigger trig1 after insert on process

            for each row execute procedure base();

    insert into process (fluid_id, process, contain)