前言

本文主要給大家介紹的是關于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/updateexports.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 readexports.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 readexports.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 oneexports.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()