欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2023-02-12 20:28:18
前言 本文主要给大家介绍的是关于node.js对sqlite的async/await封装的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧 用于...

前言

本文主要给大家介绍的是关于node.js对sqlite的async/await封装的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧

用于将每个sqlite函数同步化,并可以用await的接口。

注意:需要sqlite for node模块和node.js 8.0+,并支持async / await。

sqlite最常用作本地或移动应用程序的存储单元,当需要从程序的各个部分访问数据时,回调不是最佳解决方案。

为了在程序程序中更自然地访问数据,我编写了一个将回调转换为promises的接口,因此我们可以将每个函数与await关键字一起使用。 它不是异步函数的替代品,它是一个补充,可以将原始函数和同步函数一起使用。

aa-sqlite模块

sqlite的接口是一个名为aa-sqlite的模块,您必须将其存储在应用程序的node_modules部分中。这是完整的源代码

const sqlite3 = require('sqlite3').verbose()
var db
 
exports.db = db
 
exports.open=function(path) {
 return new promise(function(resolve) {
 this.db = new sqlite3.database(path,
  function(err) {
   if(err) reject("open error: "+ err.message)
   else resolve(path + " opened")
  }
 ) 
 })
}
 
// any query: insert/delete/update
exports.run=function(query) {
 return new promise(function(resolve, reject) {
  this.db.run(query,
   function(err) {
    if(err) reject(err.message)
    else resolve(true)
  })
 }) 
}
 
// first row read
exports.get=function(query, params) {
 return new promise(function(resolve, reject) {
  this.db.get(query, params, function(err, row) {
   if(err) reject("read error: " + err.message)
   else {
    resolve(row)
   }
  })
 })
}
 
// set of rows read
exports.all=function(query, params) {
 return new promise(function(resolve, reject) {
  if(params == undefined) params=[]
 
  this.db.all(query, params, function(err, rows) {
   if(err) reject("read error: " + err.message)
   else {
    resolve(rows)
   }
  })
 })
}
 
// each row returned one by one
exports.each=function(query, params, action) {
 return new promise(function(resolve, reject) {
  var db = this.db
  db.serialize(function() {
   db.each(query, params, function(err, row) {
    if(err) reject("read error: " + err.message)
    else {
     if(row) {
      action(row)
     } 
    }
   })
   db.get("", function(err, row) {
    resolve(true)
   })   
  })
 })
}
 
exports.close=function() {
 return new promise(function(resolve, reject) {
  this.db.close()
  resolve(true)
 })
}

使用示例

下面的示例展示了aa-sqlite的每个功能的示例。在第一部分中,我们打开一个数据库,添加一个表并用一些行填充该表。然后关闭数据库,我们再次打开它并执行一些同步查询。

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

总结

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