Node.js如何對SQLite的async/await封裝詳解

來源：懂視網責編：小采時間：2020-11-27 22:00:54

Node.js如何對SQLite的async/await封裝詳解

Node.js如何對SQLite的async/await封裝詳解:前言本文主要給大家介紹的是關于Node.js對SQLite的async/await封裝的相關內容，分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹吧用于將每個SQLite函數同步化，并可以用await的接口。注意：需要SQLite for Node模塊和Node

推薦度：

點擊下載本文 文檔為doc格式

導讀Node.js如何對SQLite的async/await封裝詳解:前言本文主要給大家介紹的是關于Node.js對SQLite的async/await封裝的相關內容，分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹吧用于將每個SQLite函數同步化，并可以用await的接口。注意：需要SQLite for Node模塊和Node

前言

本文主要給大家介紹的是關于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

總結

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com