Node与PostgreSQL中出现Cannot read property 'query' of undefined错误求助

这个问题我之前在做Node+PostgreSQL项目时也碰到过，咱们先拆解一下错误原因，再给出针对性的解决方案：

你看到的「Cannot read property 'query' of undefined」本质是client变量变成了undefined，通常有两个核心原因：

1. 连接池获取连接失败，但代码没处理错误：当pool.connect()因为连接池耗尽、数据库连接异常等原因失败时，回调里的client就是undefined，这时候直接调用client.query()自然会报错。
2. 连接未正确释放，导致连接池耗尽：你的代码里done()只在查询成功或失败时调用，但如果代码执行过程中抛出未捕获的异常，done()就不会执行，连接会一直被占用，最终连接池没有可用连接，后续请求获取client就会失败。
   另外还有个隐藏风险：直接用req.body.tablename拼接SQL语句，这会导致严重的SQL注入漏洞，这个必须先修复！

1. 先处理pool.connect()的连接错误 #

在使用client之前，一定要先判断pool.connect()是否返回错误，避免拿到undefined的client：

const pool = new pg.Pool(config); 
var tablename = req.body.tablename; 

pool.connect(function (err, client, done) { 
  // 第一步：先处理连接失败的情况
  if (err) {
    console.error('无法从连接池获取数据库连接:', err);
    // 给前端返回错误响应，不要让请求挂着
    return res.status(500).send('数据库连接失败');
  }

  var query_get_value = 'SELECT * FROM '+ tablename; 
  client.query(query_get_value, function (err, result) { 
    // ...后续逻辑
  });
});

2. 确保done()总是被调用，释放连接 #

不管查询成功还是失败，甚至抛出异常，都要调用done()把连接还给连接池。可以用try/catch包裹逻辑，或者在回调里确保done()一定会执行：

pool.connect(function (err, client, done) { 
  if (err) {
    console.error('无法从连接池获取数据库连接:', err);
    return res.status(500).send('数据库连接失败');
  }

  // 用try/catch包裹，确保异常时也能释放连接
  try {
    var query_get_value = 'SELECT * FROM '+ tablename; 
    client.query(query_get_value, function (err, result) { 
      // 不管查询成功还是失败，先释放连接
      done();
      
      if (err) { 
        console.error('查询失败:', err);
        return res.status(500).send('查询数据失败');
      } 
      var rows = result.rows; 
      // 处理查询结果，返回给前端
      res.send(rows);
    }); 
  } catch (unexpectedErr) {
    console.error('意外错误:', unexpectedErr);
    // 异常时也要释放连接
    done();
    res.status(500).send('服务器内部错误');
  }
});

3. 修复SQL注入漏洞（重中之重） #

直接拼接tablename到SQL语句里，攻击者可以通过构造恶意的tablename值来删除表、篡改数据。解决方法是维护一个允许访问的表名白名单，先验证输入的表名是否合法：

// 提前定义允许访问的表名列表
const allowedTables = ['user', 'product', 'order'];
var tablename = req.body.tablename; 

// 先验证表名是否在白名单内
if (!allowedTables.includes(tablename)) {
  return res.status(400).send('非法的表名请求');
}

// 验证通过后再执行查询
pool.connect(function (err, client, done) { 
  // ...后续逻辑
});

4. 优化setInterval的调用逻辑 #

如果setInterval的调用频率太高，会短时间内发起大量请求，耗尽连接池的可用连接。可以做两个优化：

• 调整连接池配置：在pg.Pool(config)里增加max参数（比如max: 20），根据服务器性能和数据库承载能力调整最大连接数。
• 改用setTimeout替代setInterval：确保上一次请求完全处理完成后，再发起下一次请求，避免并发请求过多：

function fetchData() {
  // 这里写你的数据库查询逻辑，完成后再发起下一次请求
  axios.post('/your-api-url').then(() => {
    // 请求完成后，1秒后再发起下一次
    setTimeout(fetchData, 1000);
  }).catch(err => {
    console.error('请求失败:', err);
    // 失败后也重试，避免中断
    setTimeout(fetchData, 1000);
  });
}

// 启动第一次请求
fetchData();

回调嵌套容易出错，改用async/await可以让代码更清晰，也更容易管理连接释放：

const pool = new pg.Pool(config); 
const allowedTables = ['user', 'product', 'order'];

// 把查询逻辑封装成async函数
async function fetchTableData(tablename) {
  let client;
  try {
    // 获取连接
    client = await pool.connect();
    const result = await client.query(`SELECT * FROM ${tablename}`);
    return result.rows;
  } catch (err) {
    console.error('查询出错:', err);
    throw err;
  } finally {
    // 不管成功失败，都释放连接
    if (client) client.release();
  }
}

// 接口处理逻辑
app.post('/your-api', async (req, res) => {
  const tablename = req.body.tablename;
  if (!allowedTables.includes(tablename)) {
    return res.status(400).send('非法的表名请求');
  }
  
  try {
    const rows = await fetchTableData(tablename);
    res.send(rows);
  } catch (err) {
    res.status(500).send('服务器错误');
  }
});

内容的提问来源于stack exchange，提问作者Eric Lee