node基于async/await對mysql進行封裝
更新時間：2019年06月20日 10:09:00 作者：煩囂的人
這篇文章主要介紹了node基于async/await對mysql進行封裝,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，,需要的朋友可以參考下
前言
node是基于異步的，因此在進行數(shù)據(jù)庫查詢操作的通常是通過回調(diào)來操作查詢結(jié)果。但是在有了es7的async/await，基本不再需要回調(diào)了，所以本篇是基于async/await對mysql進行一次操作封裝，讓查詢更加方便。（node版本需>=7.0）。
原理
簡單來說，async/await的實現(xiàn)原理是基于promise，根據(jù)promise的狀態(tài)來判斷是否真正返回，因此我們可以在mysql真正查詢到結(jié)果后將promise狀態(tài)切換為resolve，返回結(jié)果。如出現(xiàn)錯誤通過reject返回錯誤信息，reject需要用try/catch進行捕獲。
代碼
'use strict';
const mysql = require( 'mysql' );
var pool = mysql.createPool( {
connectionLimit : 50,
host : '',
user : '',
password : '',
database : '',
multipleStatements : true //是否允許執(zhí)行多條sql語句
} );
//將結(jié)果已對象數(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);
});
});
});
};
//返回一個對象
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 );
});
});
});
};
//返回單個查詢結(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 );
});
});
});
}
//模塊導出
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);
})();
以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
這篇文章主要介紹了node.js實現(xiàn)回調(diào)的方法,結(jié)合實例形式分析了node.js實現(xiàn)向回調(diào)函數(shù)傳遞參數(shù)、閉包的使用及鏈式回調(diào)相關(guān)操作技巧,需要的朋友可以參考下2017-03-03
這篇文章主要介紹了webpack打包nodejs項目(前端代碼),小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2018-09-09
windows系統(tǒng)下安裝npm(Node.js)方法教程
在Windows環(huán)境下進行Node.js的安裝并不是一件復雜的事情,但是在安裝過程中需要注意一些細節(jié),下面這篇文章主要給大家介紹了關(guān)于windows系統(tǒng)下安裝npm(Node.js)的相關(guān)資料,需要的朋友可以參考下2023-12-12
這篇文章主要介紹了如何使用nexus3搭建npm私有倉庫,包括安裝并運行私服的相關(guān)知識,本文結(jié)合實例代碼給大家介紹的非常詳細,感興趣的朋友跟隨小編一起看看吧2024-03-03
NodeJS?Express使用ORM模型訪問關(guān)系型數(shù)據(jù)庫流程詳解
這篇文章主要介紹了NodeJS?Express使用ORM模型訪問關(guān)系型數(shù)據(jù)庫流程，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習吧2023-01-01
npm包的更新速度很快,為了將項目或者全局依賴更新到最新版本,下面這篇文章主要給大家介紹了關(guān)于npm如何更新項目最新依賴包的相關(guān)資料,文中通過實例代碼介紹的非常詳細,需要的朋友可以參考下2023-01-01
node.js使用express-jwt報錯:expressJWT?is?not?a?function解決
這篇文章主要給大家介紹了關(guān)于node.js使用express-jwt報錯:expressJWT?is?not?a?function解決的相關(guān)資料,文中通過實例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2023-03-03
關(guān)于node+mysql數(shù)據(jù)庫連接池連接
這篇文章主要介紹了關(guān)于node+mysql數(shù)據(jù)庫連接池連接,mysql有兩種連接方式：一種是直接連接 另一種是池化連接，我們這篇講的是池化連接,需要的朋友可以參考下2023-04-04
今天小編就為大家分享一篇nodejs aes 加解密實例，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2018-10-10
這篇文章主要介紹了簡單了解node npm cnpm的具體使用方法，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧2019-02-02