0

这是我正在使用的查询：

app.get("/items/:data", async (req, res) => {

    const { data } = req.params;

    query = `
        SELECT items.discount
        FROM items
        WHERE items.discount @? '$[*] ? (@.discount[*].shift == $1)'
        `
    try {

        const obj = await pool.query(query, [data]);
        res.json(obj.rows[0])

    } catch(err) {

        console.error(err.message);

    }
});

我收到此错误：

error: bind message supplies 1 parameters, but prepared statement "" requires 0

我node-postgres在node.js.

我该如何解决这个问题？

4

2 回答 2

-1

使用括号表示法而不是点表示法。所以代替 obj.key 使用 obj[key]

于 2021-08-17T21:22:47.533 回答
-1

更新

他们所有的驱动连接器都有自己的方法来做你正在寻找的东西。node-postgres 也有自己的

水池


import { Pool } from 'pg';

const pool = new Pool({
  host: 'localhost',
  user: 'database-user',
  max: 20,
  idleTimeoutMillis: 30000,
  connectionTimeoutMillis: 2000,
});

/**
 * execs the given sql statement.
 * 
 * @param {string} sql - query to run.
 * @param {Array} params - an array with the parameter.
 * @example
 * runQuery("SELECT * FROM users WHERE id = $1", [1]).then(result=> console.log(result))
 */
export async function runQuery (sql, params) {
const connection = await pool.connect()
  try {
    await connection.query('BEGIN')
    const queryText = 'INSERT INTO users(name) VALUES($1) RETURNING id'
    const result = await connection.query(sql,params);
    
    // check what result has
    console.log(result);

    return connection.query('COMMIT').then(result)
  } catch (e) {
    await connection.query('ROLLBACK')
    throw e;
    throw e
  } finally {
    connection.release()
  }
}

池配置

config = {
  // all valid client config options are also valid here
  // in addition here are the pool specific configuration parameters:
  // number of milliseconds to wait before timing out when connecting a new client
  // by default this is 0 which means no timeout
  connectionTimeoutMillis?: int,
  // number of milliseconds a client must sit idle in the pool and not be checked out
  // before it is disconnected from the backend and discarded
  // default is 10000 (10 seconds) - set to 0 to disable auto-disconnection of idle clients
  idleTimeoutMillis?: int,
  // maximum number of clients the pool should contain
  // by default this is set to 10.
  max?: int,
}

结论

所以基本上查询的结构应该是这样或更少

const text = 'INSERT INTO users(name, email) VALUES($1, $2) RETURNING *'
const values = ['brianc', 'brian.m.carlson@gmail.com']

connection
  .query(text, values)
  .then(res => {
    console.log(res.rows[0])
    // { name: 'brianc', email: 'brian.m.carlson@gmail.com' }
  })
  .catch(e => console.error(e.stack))
于 2021-08-17T21:27:05.160 回答