前言
node是基于異步的，因此在進(jìn)行數(shù)據(jù)庫查詢操作的通常是通過回調(diào)來操作查詢結(jié)果。但是在有了es7的async/await，基本不再需要回調(diào)了，所以本篇是基于async/await對mysql進(jìn)行一次操作封裝，讓查詢更加方便。（node版本需>=7.0）。
原理
簡單來說，async/await的實(shí)現(xiàn)原理是基于promise，根據(jù)promise的狀態(tài)來判斷是否真正返回，因此我們可以在mysql真正查詢到結(jié)果后將promise狀態(tài)切換為resolve，返回結(jié)果。如出現(xiàn)錯(cuò)誤通過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語句} );//將結(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); }); }); });};//返回一個(gè)對象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);})();以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持武林網(wǎng)。
新聞熱點(diǎn)
疑難解答
