postgresql 9.4.11 上的 pg-promise upsert

Question

我进行了广泛的搜索，但无法解决这个简单的问题。 我在 nodejs 中编程，并使用 pg-promise 将我的 JSON 文件动态存储到 postgres 9.4.11 数据库中（我不允许升级数据库）。 我的 JSON 每个包含大约一百列，并且我已将其正确解析为三个对象。 1.字段 2. 栏目 3. 表 当我这样做时，Pg-promise 完美地工作：

//-- connection details would be up here  const db = pgp (conn);--
//Insert statement is below


 for (var i=0; i<Object.keys(fields).length; i++){

    const data = [fields[i]];
    const cs = new pgp.helpers.ColumnSet(columns[i]);
    const table = new pgp.helpers.TableName(tables[i],"public");
    const insert = pgp.helpers.insert(data,cs,table);

       db.none(insert)
        .then(data => {
            console.log("Success! Record inserted for " + table);
        })
        .catch(error => {
            //error
            console.log("ALERT!!! Something went wrong with Record in table " + table);
        });
    }

当然，我在 postgresql 9.4.11 上，我不能使用简单的：

const insert = pgp.helpers.insert(data,cs,table) + " ON CONFLICT (id1, uid2, xid3) DO NOTHING";

仅执行插入新项目，因为 UPSERTS 仅从 9.5 开始可用。

我的查询每次运行执行大约 2,000 行插入，我对此感到满意。

我在这方面还很陌生，我希望也许在我的谷歌搜索中我忽略了直接的解决方案。

我见过的最接近的解决方案是存储过程，但我不确定如何实现它。

拜托，stackoverflow，你可能是我唯一的希望！

我只是想确保在 id1、uid2 和 xid3 上匹配的每一行都不会插入到我的 postgres 数据库中。

Answer 1

所以我学到了一些关于 postgres 的东西。但首先，这是最终对我有用的代码：

 for (var i=0; i<Object.keys(fields).length; i++){

    const data = [fields[i]];
    const cs = new pgp.helpers.ColumnSet(columns[i]);
    const table = new pgp.helpers.TableName(tables[i],"public");
    const insert = pgp.helpers.insert(data,cs,table);
         db.none( 'BEGIN WORK; LOCK TABLE public.'
        + tables[i] + ' IN SHARE ROW EXCLUSIVE MODE; ' 
        + 'INSERT INTO public.'+tables[i]+ ' ('+ columns[i]+')' 
        + 'SELECT 'google.com','another value', 'etc...' WHERE NOT EXISTS(SELECT 1 FROM public.'
        +tables[i] +' WHERE id1 ='+fields[i].id1 
        +' AND uid2 ='+fields[i].uid2 
        +' AND xid3 ='+fields[i].xid3 +');' 
        + 'COMMIT WORK;' ) 
    }

所以我了解到，postgres 不会将双引号内的项目视为值，而是将其视为列。 所以我不得不把我的值数组去掉双引号并用单引号替换，这允许 postgres 接受查询。

使用 pg-promise 将 postgres 查询拼接在一起可能看起来很老套，但这是我发现使用 for 循环加载数百行、数百列宽的数据的最佳方法。

请注意，我有一个值数组，但我将它们写为 'google.com'、'another value'、'etc...' 只是为了让您看到双引号与单引号。