Node.js如何对SQLite的async/await封装详解

const fs = require("fs")
const sqlite = require("aa-sqlite")
async function mainApp() {
 console.log(await sqlite.open('./users.db'))
 // Adds a table
 var r = await sqlite.run('CREATE TABLE users(ID integer NOT NULL PRIMARY KEY, name text, city text)')
 if(r) console.log("Table created")
 // Fills the table
 let users = {
  "Naomi": "chicago",
  "Julia": "Frisco",
  "Amy": "New York",
  "Scarlett": "Austin",
  "Amy": "Seattle"
 }
 var id = 1
 for(var x in users) {
  var entry = `'${id}','${x}','${users[x]}'`
  var sql = "INSERT INTO users(ID, name, city) VALUES (" + entry + ")"
  r = await sqlite.run(sql)
  if(r) console.log("Inserted.")
  id++
 }
 // Starting a new cycle to access the data
 await sqlite.close();
 await sqlite.open('./users.db')
 console.log("Select one user:")
 var sql = "SELECT ID, name, city FROM users WHERE name='Naomi'"
 r = await sqlite.get(sql)
 console.log("Read:", r.ID, r.name, r.city)
 console.log("Get all users:")
 sql = "SELECT * FROM users"
 r = await sqlite.all(sql, [])
 r.forEach(function(row) {
  console.log("Read:", row.ID, row.name, row.city)
 })
 console.log("Get some users:")
 sql = "SELECT * FROM users WHERE name=?"
 r = await sqlite.all(sql, ['Amy'])
 r.forEach(function(row) {
  console.log("Read:", row.ID, row.name, row.city)
 })
 console.log("One by one:")
 sql = "SELECT * FROM users"
 r = await sqlite.each(sql, [], function(row) {
  console.log("Read:", row.ID, row.name, row.city)
 })
 if(r) console.log("Done.")
 sqlite.close();
}
try {
 fs.unlinkSync("./users.db")
}
catch(e) {
}
mainApp()

由于all方法返回一个row数组，我们使用forEach来处理每一行的内容。

你可以在每个方法的情况下进行验证，即在程序显示“完成”之前处理返回的每一行。原始异步方法不会出现这种情况。

参考并翻译自：https://www.scriptol.com/sql/sqlite-async-await.php

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对软件开发网的支持。