-1

当我尝试进行一些数据库搜索时，我发现了两种代码可以做到这一点。但我不知道哪种更喜欢以及为什么..

// a.js
export default oracledb.createPool(configuration)

第一种方式（看起来效果很好，但不符合承诺规范）：

// b.js
import main from a.js;
main.then((pool)=>{
    pool.getConnection().then((connection)=>{
        connection.execute(sql).then((result)=>{
           console.log(result);
           connection.close();
        }).catch(err=>{
           if(connection){connection.close()}
        })
    });
})

这是第二种方式：

let connection;
main.then((pool)=>{
    return pool.getConnection()
}).then((connection)=>{
   return connection.execute(sql)
}).then((result)=>{
   console.log(result);
   connection.close();
}).catch(err=>{
   if (connection){connection.close()}
});

这个问题可能不仅仅是关于数据库操作，而是组织承诺链的正确方法。有人可以帮我吗？

4

2 回答 2

1

使用本文档https://oracle.github.io/node-oracledb/doc/api.html

const mypw = ...  // set mypw to the hr schema password

async function run() {

  let connection;

  try {
    connection = await oracledb.getConnection(  {
      user          : "hr",
      password      : mypw,
      connectString : "localhost/XEPDB1"
    });

    const result = await connection.execute(
      `SELECT manager_id, department_id, department_name
       FROM departments
       WHERE manager_id = :id`,
      [103],  // bind value for :id
    );
    console.log(result.rows);

  } catch (err) {
    console.error(err);
  } finally {
    if (connection) {
      try {
        await connection.close();
      } catch (err) {
        console.error(err);
      }
    }
  }
}

run();
于 2020-02-10T06:25:38.317 回答
1

使用 Promise 的主要思想之一是避免回调地狱，但您编写的第一个代码也可能成为级联地狱。第二种结构更好，更容易阅读和调试：

let connection

main
.then(pool => pool.getConnection())
.then(connection => connection.execute(sql))
.then(result => {
   console.log(result)
   connection.close()
})
.catch(err => {
   if (connection) connection.close()
})
于 2020-02-10T06:26:59.747 回答