0

我正在编写插入多行表的 API，我正在使用 UNNEST 使其工作。

我做了什么：

在 .js 文件中：

api.post(PREFIX + '/class/insert', function (request) {

    var db = pgp(dbconnect);

    //Params
    var data = request.body; //should be an array

    var classes = [];
    var starts = [];
    var ends = [];

    for (var i = 0; i < data.length; i++) {
        classes.push(data[i].class_id);
        starts.push(data[i].timestamp_start);
        ends.push(data[i].timestamp_end);
    }

    const PQ = require('pg-promise').ParameterizedQuery;

    var sql =
    "INSERT INTO sa1.class(class_id, timestamp_start, timestamp_end) " +
    "VALUES(  "+
        "UNNEST(ARRAY" + JSON.stringify(classes).replace(/"/g, "'") + "), " +
        "UNNEST(ARRAY" + JSON.stringify(starts).replace(/"/g, "'") + "), " +
        "UNNEST(ARRAY" + JSON.stringify(ends).replace(/"/g, "'") + ")" 

    const final_sql = new PQ(sql);

    return db.any(final_sql)
        .then(function (data) {
            pgp.end();

            return 'successful';
        })
        .catch(function (error) {
            console.log("Error: " + error);
            pgp.end();
        });
}

请求正文

[{
    "class_id":"1",
    "timestamp_start":"2017-11-14 14:01:23.634437+00",
    "timestamp_end":"2017-11-14 15:20:23.634437+00"
}, {
    "class_id":"2",
    "timestamp_start":"2017-11-14 15:01:23.634437+00",
    "timestamp_end": "2017-11-14 16:20:23.634437+00"
}]

当我在邮递员中运行 api 时，我得到的错误是：

列“timestamp_start”是带时区的时间戳类型，但表达式是文本类型

问题显然来自我在 sql 中使用的字符串数组，我的问题是如何为 UNNEST 创建时间戳数组，或者任何建议都值得赞赏。

谢谢

4

2 回答 2

0
  • 永远不要在处理程序中初始化数据库，请参阅：我应该在哪里初始化 pg-promise
  • 永远不要在 HTTP 处理程序内部调用pgp-end()，它会破坏所有连接池。
  • 使用静态ColumnSet类型生成多插入查询。
  • 不要从 回来db.any，在那种情况下没有意义
  • 您必须在 HTTP 处理程序中提供 HTTP 响应
  • 您正在为 column 提供令人困惑的语义class_id。为什么它被这样称呼，却被转换成一个timestamp？
  • 永远不要直接将对象与字符串连接起来。
  • 永远不要手动连接 SQL 字符串，它会破坏格式并将您的代码打开到 SQL 注入。
  • 根据预期结果使用数据库none方法，即在您的情况下，而不是any. 见：https ://github.com/vitaly-t/pg-promise#methods
只需初始化一次所需的一切： 
const db = pgp(/*connection*/);

const cs = new pgp.helpers.ColumnSet([
    'class_id',
    {
        name: 'timestamp_start',
        cast: 'timestamp'
    },
    {
        name: 'timestamp_end',
        cast: 'timestamp'
    }
], {table: {table: 'class', schema: 'sa1'}});
实现处理程序： 
api.post(PREFIX + '/class/insert', request => {

    const sql = pgp.helpers.insert(request.body, cs);

    db.none(sql)
        .then(data => {
            // provide an HTTP response here
        })
        .catch(error => {
            console.log('Error:', error);
            // provide an HTTP response here
        });   
}
于 2017-11-15T11:25:53.500 回答
-1

非常感谢@JustMe，

它在投射数组后工作

var sql =
    "INSERT INTO sa1.class(class_id, timestamp_start, timestamp_end) " +
    "VALUES(  "+
        "UNNEST(ARRAY" + JSON.stringify(classes).replace(/"/g, "'") + "), " +
        "UNNEST(ARRAY" + JSON.stringify(starts).replace(/"/g, "'") + "::timestamp[]), " +
        "UNNEST(ARRAY" + JSON.stringify(ends).replace(/"/g, "'") + "::timestamp[])"
于 2017-11-14T15:16:22.590 回答