node-postgres中client.query()未执行问题排查与解决方案求助

你遇到的问题其实有两个核心点：异步回调的返回值问题，以及数据库连接未就绪就执行查询的问题，咱们一步步来解决：

1. 异步回调导致getUser无法正确返回结果 #

pgclient.query是异步操作，它的回调函数会在查询完成后才执行，但你的getUser函数在回调执行前就已经结束了——也就是说，你在回调里写的return根本不会作为getUser的返回值，所以调用db.getUser()时拿到的永远是undefined，自然会进入userObj==null的分支。

修复方案：改用Promise封装异步操作 #

把getUser改成返回一个Promise，这样调用方可以通过async/await或者.then()来获取异步结果：

const { Client } = require('pg');
const pgclient = new Client({ 
  connectionString: process.env.DATABASE_URL, 
  ssl: true 
});

module.exports = {
  getUser: function(phonenumber) {
    // 返回一个Promise
    return new Promise((resolve, reject) => {
      // 注意：这里要避免SQL注入！用参数化查询，不要直接拼接字符串
      const queryStr = 'SELECT * FROM users where phonenumber = $1';
      pgclient.query(queryStr, [phonenumber], (err, res) => {
        if (err) {
          console.error('查询出错:', err);
          return reject(err); // 把错误抛出去
        }
        console.log("rows length " + res.rows.length);
        if (res.rows.length === 0) {
          resolve(null); // 成功返回null
        } else {
          resolve(res.rows[0]); // 成功返回用户对象
        }
      });
    });
  }
}

调用的时候也要改成异步方式：

var db = require('./database');

// 用async/await的方式（需要在async函数里执行）
async function checkUser() {
  try {
    const userObj = await db.getUser('+19991112222');
    if (userObj == null) {
      console.log("user not found");
    } else {
      console.log(userObj["phonenumber"]);
    }
  } catch (err) {
    console.error('获取用户失败:', err);
  }
}

checkUser();

// 或者用.then()的方式
db.getUser('+19991112222')
  .then(userObj => {
    if (userObj == null) {
      console.log("user not found");
    } else {
      console.log(userObj["phonenumber"]);
    }
  })
  .catch(err => console.error('获取用户失败:', err));

额外提醒：你原来的代码直接拼接phonenumber到SQL里，存在SQL注入风险，一定要用参数化查询（上面代码里的$1和数组参数）来避免这个问题！

2. 确保数据库连接就绪后再执行查询 #

你猜的没错，模块加载时pgclient.connect()是异步的，当你调用getUser时，连接可能还没建立完成，导致查询静默失败。

修复方案1：等待连接成功后再导出模块 #

我们可以把连接逻辑改成异步的，等连接成功后再导出数据库操作函数，这样调用方拿到的模块一定是连接就绪的：

const { Client } = require('pg');

// 先创建客户端实例
const pgclient = new Client({ 
  connectionString: process.env.DATABASE_URL, 
  ssl: true 
});

// 封装连接逻辑，返回一个Promise
async function connectDB() {
  try {
    await pgclient.connect();
    console.log('数据库连接成功');
  } catch (err) {
    console.error('数据库连接失败:', err);
    throw err; // 连接失败就抛出错误，让调用方知道
  }
}

// 先连接数据库，再导出操作函数
module.exports = (async function() {
  await connectDB();
  
  return {
    getUser: function(phonenumber) {
      return new Promise((resolve, reject) => {
        const queryStr = 'SELECT * FROM users where phonenumber = $1';
        pgclient.query(queryStr, [phonenumber], (err, res) => {
          if (err) {
            console.error('查询出错:', err);
            return reject(err);
          }
          console.log("rows length " + res.rows.length);
          resolve(res.rows.length === 0 ? null : res.rows[0]);
        });
      });
    }
  };
})();

调用的时候，需要先等待模块加载完成（因为模块现在是一个Promise）：

// 调用方式改成这样
require('./database')
  .then(db => {
    return db.getUser('+19991112222');
  })
  .then(userObj => {
    if (userObj == null) {
      console.log("user not found");
    } else {
      console.log(userObj["phonenumber"]);
    }
  })
  .catch(err => console.error('操作失败:', err));

// 或者用async/await
async function init() {
  const db = await require('./database');
  const userObj = await db.getUser('+19991112222');
  // 后续逻辑...
}
init();

修复方案2：使用连接池（生产环境更推荐） #

在生产环境中，使用连接池比单个客户端连接更稳定高效，pg库本身支持连接池，这样也不用手动处理连接就绪的问题：

const { Pool } = require('pg');

// 创建连接池
const pool = new Pool({
  connectionString: process.env.DATABASE_URL,
  ssl: true
});

module.exports = {
  getUser: function(phonenumber) {
    return new Promise((resolve, reject) => {
      const queryStr = 'SELECT * FROM users where phonenumber = $1';
      pool.query(queryStr, [phonenumber], (err, res) => {
        if (err) {
          console.error('查询出错:', err);
          return reject(err);
        }
        console.log("rows length " + res.rows.length);
        resolve(res.rows.length === 0 ? null : res.rows[0]);
      });
    });
  }
}

连接池会自动管理连接的创建和复用，调用pool.query时如果没有可用连接，会自动等待连接就绪，这样就不用手动处理连接时机的问题了，调用方式和之前的Promise方式一致。

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