Node.js如何对SQLite的async/await封装详解
前言
本文主要给大家介绍的是关于Node.js对SQLite的async/await封装的相关内容，分享出来供大家参考学习，下面话不多说了，来一起看看详细的介绍吧
用于将每个SQLite函数同步化，并可以用await的接口。
注意：需要SQLiteforNode模块和Node.js8.0+，并支持async/await。
SQLite最常用作本地或移动应用程序的存储单元，当需要从程序的各个部分访问数据时，回调不是最佳解决方案。
为了在程序程序中更自然地访问数据，我编写了一个将回调转换为promises的接口，因此我们可以将每个函数与await关键字一起使用。它不是异步函数的替代品，它是一个补充，可以将原始函数和同步函数一起使用。
aa-sqlite模块
SQLite的接口是一个名为aa-sqlite的模块，您必须将其存储在应用程序的node_modules部分中。这是完整的源代码
constsqlite3=require('sqlite3').verbose()
vardb
exports.db=db
exports.open=function(path){
returnnewPromise(function(resolve){
this.db=newsqlite3.Database(path,
function(err){
if(err)reject("Openerror:"+err.message)
elseresolve(path+"opened")
}
)
})
}
//anyquery:insert/delete/update
exports.run=function(query){
returnnewPromise(function(resolve,reject){
this.db.run(query,
function(err){
if(err)reject(err.message)
elseresolve(true)
})
})
}
//firstrowread
exports.get=function(query,params){
returnnewPromise(function(resolve,reject){
this.db.get(query,params,function(err,row){
if(err)reject("Readerror:"+err.message)
else{
resolve(row)
}
})
})
}
//setofrowsread
exports.all=function(query,params){
returnnewPromise(function(resolve,reject){
if(params==undefined)params=[]
this.db.all(query,params,function(err,rows){
if(err)reject("Readerror:"+err.message)
else{
resolve(rows)
}
})
})
}
//eachrowreturnedonebyone
exports.each=function(query,params,action){
returnnewPromise(function(resolve,reject){
vardb=this.db
db.serialize(function(){
db.each(query,params,function(err,row){
if(err)reject("Readerror:"+err.message)
else{
if(row){
action(row)
}
}
})
db.get("",function(err,row){
resolve(true)
})
})
})
}
exports.close=function(){
returnnewPromise(function(resolve,reject){
this.db.close()
resolve(true)
})
}
使用示例
下面的示例展示了aa-sqlite的每个功能的示例。在第一部分中，我们打开一个数据库，添加一个表并用一些行填充该表。然后关闭数据库，我们再次打开它并执行一些同步查询。
constfs=require("fs")
constsqlite=require("aa-sqlite")
asyncfunctionmainApp(){
console.log(awaitsqlite.open('./users.db'))
//Addsatable
varr=awaitsqlite.run('CREATETABLEusers(IDintegerNOTNULLPRIMARYKEY,nametext,citytext)')
if(r)console.log("Tablecreated")
//Fillsthetable
letusers={
"Naomi":"chicago",
"Julia":"Frisco",
"Amy":"NewYork",
"Scarlett":"Austin",
"Amy":"Seattle"
}
varid=1
for(varxinusers){
varentry=`'${id}','${x}','${users[x]}'`
varsql="INSERTINTOusers(ID,name,city)VALUES("+entry+")"
r=awaitsqlite.run(sql)
if(r)console.log("Inserted.")
id++
}
//Startinganewcycletoaccessthedata
awaitsqlite.close();
awaitsqlite.open('./users.db')
console.log("Selectoneuser:")
varsql="SELECTID,name,cityFROMusersWHEREname='Naomi'"
r=awaitsqlite.get(sql)
console.log("Read:",r.ID,r.name,r.city)
console.log("Getallusers:")
sql="SELECT*FROMusers"
r=awaitsqlite.all(sql,[])
r.forEach(function(row){
console.log("Read:",row.ID,row.name,row.city)
})
console.log("Getsomeusers:")
sql="SELECT*FROMusersWHEREname=?"
r=awaitsqlite.all(sql,['Amy'])
r.forEach(function(row){
console.log("Read:",row.ID,row.name,row.city)
})
console.log("Onebyone:")
sql="SELECT*FROMusers"
r=awaitsqlite.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
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对毛票票的支持。