node.js - 在函数nodejs中从mariadb返回值

Question

这是我的代码:

const mariadb = require('mariadb');
var test = async function(){
  var ret = "";
  await mariadb.createConnection({
        host: "localhost",
        user: "dave",
        connectionLimit: 5,
        password: "!@#",
        database: "db",
        rowsAsArray: false
  }).then((data)=>{
    ret = "test";
  });
  return ret;
}

console.log(test());

如何使用await获得返回值？

我知道在很多情况下都提出了类似的问题，但我找不到任何使用 mariadb 的问题。

Answer 1

我已经看到了一些陷阱，作为初学者，您将在这段代码中遇到这些陷阱:

• avait 正在等待返回结果，因为他会得到 Promisses 来解决它
• then 异步解决 Promise
• 定义为async的函数始终返回promise

在一阵喜悦之后，“async/await”现在我试图避开他。主要是因为我使用异步函数的每个函数也必须是异步的，直到您使用then，例如进行小测试:

  let test = async function() {
    let x = await 11
    return 1;
  }
  console.log(test()) //returns: Promise { <pending> }

那里没有什么异步的，但是添加async/wait导致了困惑。

现在修复您的代码

const mariadb = require('mariadb');
// use local scope `let` instead global `var`
let test = async function(){
  let conn = await mariadb.createConnection({
        host: "localhost",
        user: "dave",
        connectionLimit: 5,
        password: "!@#",
        database: "db",
        rowsAsArray: false
  });
  return conn.query("SELECT 1 as val") // no sense using `avait` because `test()` returns `promise`
}

test().then(function(rows) { console.log(rows)});

并且没有 asnc。 then 可以返回 Promise，这可以通过下一个 then

解决

mariadb.createConnection(...).then(conn => { // create connection
    return conn.query("SELECT 1 as val") // make query
}).then(rows => { //get result
    console.log(rows)
}).catch(err => console.error(err)) // get errors

顺便说一句:对查询构建器感兴趣，例如 knex.js。它允许编写独立于数据库引擎的代码。

更新

让我们从 Node 基于事件的事实开始。

我们举一个从数据库接收数据的例子。在 PHP/C++ 中，您进行查询、等待、接收结果。此行为由 await 模拟。 (Await 出现在版本 8 附近)

通常情况下，Node 中的代码会执行查询，Node 会创建一个新线程。旧的运行下一条指令，在新的中你将得到结果。 (好吧，我在撒谎，但这样更容易解释)。

所以，你必须处理接收数据的事件。更具体地说，是提供数据的 promise 。通过await、.then ()或回调( hell )

第一段代码解释:

您尝试返回ret，但此代码首先使返回ret，然后进行分配。

await“返回”数据，因此您应该使用let var_name = wait asyncFunction()

我猜你想要这个:

let getSomeDataFromDB = function(){
  return mariadb.createConnection([skip]).then(conn => {
    return conn.query("SELECT 1 as val") 
  })
}
let rows = await getSomeDataFromDB()

在这个函数中你返回promise，谁返回promise。通过 await 这个 promise 链就得到了解决。

但是代码中有一个“小”错误。因为你正在连接并且你不会在任何地方结束你的连接。因此，最好有一个全局连接对象，或者使用类似这样的东西:

let getSomeDataFromDB = function(){
  return new Promise(function(resolve, reject){
    mariadb.createConnection([skip]).then(conn => {
      conn.query("SELECT 1 as val")
        .then(rows=>resolve(rows))
        .catch(e=>reject(e))
        .then(()=>conn.close())
    }).catch(e => reject(e))
  })
}
let rows = await getSomeDataFromDB()

在这里您会发现另一件重要的事情:resolve 不会中断代码的执行。尽管数据已返回给用户，您仍然可以执行某些操作。

或者与await相同

let getSomeDataFromDB = async function(){
  let conn = await reateConnection([skip])
  let rows = await conn.query("SELECT 1 as val")
  await conn.close();
  return rows;
}
let rows = await getSomeDataFromDB()