您好,登錄后才能下訂單哦!
前言
本文主要給大家介紹的是關(guān)于Node.js對(duì)SQLite的async/await封裝的相關(guān)內(nèi)容,分享出來(lái)供大家參考學(xué)習(xí),下面話(huà)不多說(shuō)了,來(lái)一起看看詳細(xì)的介紹吧
用于將每個(gè)SQLite函數(shù)同步化,并可以用await的接口。
注意:需要SQLite for Node模塊和Node.js 8.0+,并支持async / await。
SQLite最常用作本地或移動(dòng)應(yīng)用程序的存儲(chǔ)單元,當(dāng)需要從程序的各個(gè)部分訪(fǎng)問(wèn)數(shù)據(jù)時(shí),回調(diào)不是最佳解決方案。
為了在程序程序中更自然地訪(fǎng)問(wèn)數(shù)據(jù),我編寫(xiě)了一個(gè)將回調(diào)轉(zhuǎn)換為promises的接口,因此我們可以將每個(gè)函數(shù)與await關(guān)鍵字一起使用。 它不是異步函數(shù)的替代品,它是一個(gè)補(bǔ)充,可以將原始函數(shù)和同步函數(shù)一起使用。
aa-sqlite模塊
SQLite的接口是一個(gè)名為aa-sqlite的模塊,您必須將其存儲(chǔ)在應(yīng)用程序的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的每個(gè)功能的示例。在第一部分中,我們打開(kāi)一個(gè)數(shù)據(jù)庫(kù),添加一個(gè)表并用一些行填充該表。然后關(guān)閉數(shù)據(jù)庫(kù),我們?cè)俅未蜷_(kāi)它并執(zhí)行一些同步查詢(xún)。
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方法返回一個(gè)row數(shù)組,我們使用forEach來(lái)處理每一行的內(nèi)容。
你可以在每個(gè)方法的情況下進(jìn)行驗(yàn)證,即在程序顯示“完成”之前處理返回的每一行。原始異步方法不會(huì)出現(xiàn)這種情況。
參考并翻譯自:https://www.scriptol.com/sql/sqlite-async-await.php
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了,希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問(wèn)大家可以留言交流,謝謝大家對(duì)億速云的支持。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀(guān)點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。