node基于async/await對(duì)mysql進(jìn)行封裝
更新時(shí)間：2019年06月20日 10:09:00 作者：煩囂的人
這篇文章主要介紹了node基于async/await對(duì)mysql進(jìn)行封裝,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，,需要的朋友可以參考下
前言
node是基于異步的，因此在進(jìn)行數(shù)據(jù)庫(kù)查詢操作的通常是通過(guò)回調(diào)來(lái)操作查詢結(jié)果。但是在有了es7的async/await，基本不再需要回調(diào)了，所以本篇是基于async/await對(duì)mysql進(jìn)行一次操作封裝，讓查詢更加方便。（node版本需>=7.0）。
原理
簡(jiǎn)單來(lái)說(shuō)，async/await的實(shí)現(xiàn)原理是基于promise，根據(jù)promise的狀態(tài)來(lái)判斷是否真正返回，因此我們可以在mysql真正查詢到結(jié)果后將promise狀態(tài)切換為resolve，返回結(jié)果。如出現(xiàn)錯(cuò)誤通過(guò)reject返回錯(cuò)誤信息，reject需要用try/catch進(jìn)行捕獲。
代碼
'use strict';
const mysql = require( 'mysql' );
var pool = mysql.createPool( {
connectionLimit : 50,
host : '',
user : '',
password : '',
database : '',
multipleStatements : true //是否允許執(zhí)行多條sql語(yǔ)句
} );
//將結(jié)果已對(duì)象數(shù)組返回
var row=( sql , ...params )=>{
return new Promise(function(resolve,reject){
pool.getConnection(function(err,connection){
if(err){
reject(err);
return;
}
connection.query( sql , params , function(error,res){
connection.release();
if(error){
reject(error);
return;
}
resolve(res);
});
});
});
};
//返回一個(gè)對(duì)象
var first=( sql , ...params )=>{
return new Promise(function(resolve,reject){
pool.getConnection(function(err,connection){
if(err){
reject(err);
return;
}
connection.query( sql , params , function(error,res){
connection.release();
if(error){
reject(error);
return;
}
resolve( res[0] || null );
});
});
});
};
//返回單個(gè)查詢結(jié)果
var single=(sql , ...params )=>{
return new Promise(function(resolve,reject){
pool.getConnection(function(err,connection){
if(err){
reject(err);
return;
}
connection.query( sql , params , function(error,res){
connection.release();
if(error){
reject( error );
return;
}
for( let i in res[0] )
{
resolve( res[0][i] || null );
return;
}
resolve(null);
});
});
});
}
//執(zhí)行代碼，返回執(zhí)行結(jié)果
var execute=(sql , ...params )=>{
return new Promise(function(resolve,reject){
pool.getConnection(function(err,connection){
if(err){
reject(err);
return;
}
connection.query( sql , params , function(error,res){
connection.release();
if(error){
reject(error);
return;
}
resolve( res );
});
});
});
}
//模塊導(dǎo)出
module.exports = {
ROW : row ,
FIRST : first ,
SINGLE : single ,
EXECUTE : execute
}
使用示例
const mysql = require('./mysql.js');
(async ()=>{
let s = await mysql.row(sql,params);
console.log(s);
})();
以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章介紹了Node.js打包管理工具NPM的用法，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2022-04-04
node.js中的fs.statSync方法使用說(shuō)明
這篇文章主要介紹了node.js中的fs.statSync方法使用說(shuō)明,本文介紹了fs.statSync的方法說(shuō)明、語(yǔ)法、接收參數(shù)、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12
這篇文章主要介紹了淺談express.js框架中間件（middleware），小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2019-04-04
NodeJS實(shí)現(xiàn)不可逆加密與密碼密文保存的方法
這篇文章主要介紹了NodeJS實(shí)現(xiàn)不可逆加密與密碼密文保存的方法,簡(jiǎn)單講述了不可逆加密與密碼密文保存的原理并結(jié)合實(shí)例形式分析了nodejs相關(guān)加密操作實(shí)現(xiàn)技巧,需要的朋友可以參考下2018-03-03
Node.js 中exports 和 module.exports 的區(qū)別
這篇文章主要介紹了Node.js 中exports 和 module.exports 的區(qū)別的相關(guān)資料,需要的朋友可以參考下2017-03-03
Nodejs異步回調(diào)之異常處理實(shí)例分析
這篇文章主要介紹了Nodejs異步回調(diào)之異常處理,結(jié)合實(shí)例形式分析了nodejs基于中間件進(jìn)行異步回調(diào)異常處理過(guò)程出現(xiàn)的問(wèn)題與相應(yīng)的解決方法,需要的朋友可以參考下2018-06-06
這篇文章主要介紹了nodejs中實(shí)現(xiàn)修改用戶路由功能，本文通過(guò)實(shí)例代碼給大家介紹的非常詳細(xì)，具有一定的參考借鑒價(jià)值 ,需要的朋友可以參考下2019-05-05
詳解如何在Node.js中實(shí)現(xiàn)HTTP/2推送信息
HTTP/2 是一種現(xiàn)代化的網(wǎng)絡(luò)協(xié)議,它引入了多路復(fù)用、頭部壓縮和服務(wù)器推送等特性,其中,服務(wù)器推送允許服務(wù)器在客戶端請(qǐng)求資源時(shí),主動(dòng)推送額外的資源,提升頁(yè)面加載速度,下面將介紹如何在 Node.js 中實(shí)現(xiàn) HTTP/2 推送信息,需要的朋友可以參考下2024-12-12
詳解node child_process模塊學(xué)習(xí)筆記
這篇文章主要介紹了詳解node child_process模塊學(xué)習(xí)筆記，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2018-01-01
這篇文章主要介紹了node.js中的fs.rmdir方法使用說(shuō)明,本文介紹了fs.rmdir方法說(shuō)明、語(yǔ)法、接收參數(shù)、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12