Nodejs 同步查询问题

Nodejs 同步查询问题

异步代码如下，想问如何将query方法修改成同步的

var p = pools.getOrCreate('postgres://'+config.user+':'+config.password+'@'+config.host+':'+config.port+'/'+config.database);

//查询
exports.query = function(sql, cb){
	
	if(!cb) return;

    try{
	
        p.acquire(function(err, client) {
            if (err) {
                cb(false);
            } else {
                client.query(sql, [], function(err,res,fields){
                    p.release(client);
                    var rows = res?res.rows:res;
                    cb(rows);
                });
            }
        });

    }catch(e){
        cb(false);
    }

};

\n```

4 回复

当然可以！在 Node.js 中，大多数数据库操作都是异步的，因为它们需要与外部系统进行通信，而这些外部系统可能会有延迟。然而，如果你希望将 query 方法修改为同步的，可以考虑使用一些同步机制，例如 async_hooks 或者通过引入 async/await 结合 util.promisify 来实现。

下面是将 query 方法修改为同步版本的一个示例：

  1. 使用 util.promisify 和 async/await

首先，你需要安装 util 模块（Node.js 内置模块），然后使用 promisify 将回调函数转换为 Promise，最后使用 async/await 来处理异步操作。

const util = require('util');
const { Pool } = require('pg'); // 假设你使用的是 pg 模块

// 创建一个全局的数据库连接池
let p = new Pool({
    user: config.user,
    password: config.password,
    host: config.host,
    port: config.port,
    database: config.database
});

// 使用 util.promisify 将 callback 转换为 promise
const queryPromise = util.promisify(p.query).bind(p);

// 修改后的同步查询方法
exports.querySync = async function(sql) {
    try {
        const result = await queryPromise(sql);
        return result.rows; // 返回查询结果
    } catch (err) {
        console.error("Query error:", err);
        throw err; // 抛出错误以便调用者处理
    }
};
  1. 使用 async_hooks 实现同步调用（不推荐）

虽然可以使用 async_hooks 来模拟同步行为，但这种方法通常复杂且容易出错。因此，上面的方法更推荐使用。

解释

  • util.promisify: 这个方法将带有回调函数的函数转换为返回 Promise 的函数。这样我们就可以使用 async/await 来处理异步操作。
  • async/await: 这使得异步代码看起来更像同步代码，更易于理解和维护。
  • p.query: 这是 PostgreSQL 客户端库中的一个方法，用于执行 SQL 查询。我们将它转换为返回 Promise 的形式。

示例调用

(async () => {
    try {
        const result = await exports.querySync('SELECT * FROM your_table');
        console.log(result);
    } catch (err) {
        console.error("Failed to execute query:", err);
    }
})();

这样，你就可以以同步的方式调用 querySync 方法了。


不用node，换fibjs就能同步了。不然，可以试试Promise，Async，Generator等等，在形式做成像同步的，虽然都非常ugly

我了个去，好狰狞的try catch！

在Node.js中，大多数数据库操作都是异步的，因为它们通常涉及I/O操作，如网络请求或磁盘访问。不过，你可以使用一些库来实现同步查询，例如async_hooks或通过引入await/async语法来简化异步代码。

这里提供一个简单的方法，使用async/await语法来实现同步查询。这需要在你的代码中创建一个异步函数，并在其中调用数据库查询。

首先，我们需要对你的代码做一些调整。我们将在query方法内部创建一个新的异步函数，并在其中使用await关键字来等待数据库查询的结果。

var p = pools.getOrCreate('postgres://'+config.user+':'+config.password+'@'+config.host+':'+config.port+'/'+config.database);

// 查询方法
exports.query = async function(sql) {
    return new Promise((resolve, reject) => {
        p.acquire(async function(err, client) {
            if (err) {
                reject(err);
            } else {
                try {
                    let res = await new Promise((resolve, reject) => {
                        client.query(sql, [], function(err, result) {
                            p.release(client);
                            if (err) reject(err);
                            resolve(result);
                        });
                    });
                    resolve(res.rows);
                } catch (e) {
                    reject(e);
                }
            }
        });
    });
};

在使用这个方法时，你需要在一个异步函数中调用它：

const result = await query("SELECT * FROM table_name");
console.log(result);

注意：上述代码中，我们使用了Promise来包裹数据库操作，这样可以更方便地使用await关键字。这种方法使你的代码看起来更加同步，但实际上仍然是异步的。如果你确实需要完全同步的行为，可能需要考虑使用其他编程语言或环境，但这通常不是最佳实践。

回到顶部