Node.js對SQLite的async/await封裝
摘要：
用於將每個SQLite函式同步化，並可以用await的介面。
注意：需要SQLite for Node模組和Node.js 8.0+，並支援async / await。
SQLite最常用作本地或移動應用程式的儲存單元，當需要從程式的各個部分訪問資料時，回撥不是最佳解決方案。
為了...
用於將每個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)
elseresolve(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)
elseresolve(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