node.js中 mysql 增刪改查操作及async，await處理例項分析
阿新 • • 發佈：2020-02-12
本文例項講述了node.js中 mysql 增刪改查操作及async，await處理。分享給大家供大家參考，具體如下：
要對mysql進行操作，我們需要安裝一個mysql的庫。
一、安裝mysql庫
npm install mysql --save
二、對mysql進行簡單查詢操作
const mysql = require('mysql');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//使用者名稱
user: 'root',//密碼
password: '123456',//資料庫
database: 'test',//埠
port: 3306,//字符集
charset: 'utf8'
});
//連線資料庫
conn.connect(function (err) {
if (err) {
throw err;
}
console.log('連線成功');
});
//查詢資料庫
conn.query('select * from tb_user',function (err,data,field) {
if (err) {
throw err;
}
//data表示結果集資料，是一個數組
console.log(data);
data.forEach(function (value) {
console.log(value.id,value.user_name,value.addr);
});
//表字段的詳細資訊
console.log(field);
});
//關閉資料庫連線
conn.end();
二、對mysql進行增刪改操作
const mysql = require('mysql');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
//連線資料庫
conn.connect(function (err) {
if (err) {
throw err;
}
console.log('連線成功');
});
//插入資料，query()方法可以對sql語句進行引數繫結，用?號作為佔位符。
conn.query('insert into tb_user values(null,?,?)',['xxx','xxx'],data) {
if (err) {
throw err;
}
if (data && data.affectedRows) {
console.log('插入資料成功，id為',data.insertId);
}
});
//修改資料
conn.query('update tb_user set user_name = ? where id = ?',['ggg',7],data) {
if (err) {
throw err;
}
if (data && data.affectedRows) {
console.log('修改資料成功');
}
});
//刪除資料
conn.query('delete from tb_user where id = ?',[5],data) {
if (err) {
throw err;
}
if (data && data.affectedRows) {
console.log('刪除資料成功');
}
});
//關閉資料庫連線
conn.end();
三、使用mysql連線池來優化對資料庫的操作
頻繁的連線和斷開mysql是比較消耗資源的，我們可以建立一個連線池，複用連線池中的連線，提高效率。
const mysql = require('mysql');
//建立資料庫連線池
let pool = mysql.createPool({
//連線數量，預設是10
connectionLimit: 20,//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
//pool.query()方法可以自動的幫我們在連線池中獲取可用連線
pool.query('select * from tb_user',data) {
if (err) {
throw err;
}
data.forEach(function (value) {
console.log(value.id,value.addr);
});
});
//當然我們也可以手動獲取可用連線
pool.getConnection(function (err,conn) {
if (err) {
throw err;
}
conn.query('select * from `order`',data) {
if (err) {
throw err;
}
data.forEach(function (value) {
console.log(value.id,value.order_id,value.user_id);
});
//連線用完之後，需要釋放，重新放回連線池中。
//注意這裡並沒有銷燬該連線，該連線仍然可用，但需要重新獲取
conn.release();
});
});
//從連線池中獲取連線時，將觸發該事件
pool.on('acquire',function (conn) {
console.log('獲取連線',conn.threadId);
});
//在連線池中建立新連線時，將觸發該事件
pool.on('connection',function (conn) {
console.log('建立新連線',conn.threadId);
});
//等待可用連線時，將觸發該事件
pool.on('enqueue',function () {
console.log('等待可用連線');
});
//當連線釋放回池中時，觸發該事件
pool.on('release',function (conn) {
console.log('連線被釋放回池中',conn.threadId);
});
//結束池中所有的連線，不然node.js的事件迴圈會一直保持
setTimeout(function () {
pool.end(function (err) {
console.log('關閉連線池');
console.log(err);
});
},3000);
四、按流的方式進行查詢
const mysql = require('mysql');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
let query = conn.query('select * from tb_user');
//Query類繼承自Sequence，而Sequence繼承自EventEmitter
//所以Query類的例項是可以監聽事件
//發生錯誤時
query.on('error',function (err) {
console.log(err);
});
//獲取查詢欄位資訊
query.on('fields',function (fields) {
console.log(fields);
});
//獲取查詢結果
query.on('result',function (result) {
//暫停獲取結果
conn.pause();
//跟流的pause()和resume()很類似，控制獲取資料的頻率。
setTimeout(function () {
console.log(result);
//恢復獲取結果
conn.resume();
},1000);
});
//查詢結束
query.on('end',function () {
console.log('查詢結束');
});
conn.end();
通過query.stream()方法返回一個可讀流來獲取資料
const mysql = require('mysql');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
//從一個查詢中獲取一個可讀流
let qs = conn.query('select * from tb_user').stream({highWaterMark: 2});
let result = [];
qs.on('data',function (data) {
result.push(data);
});
qs.on('end',function () {
console.log('查詢結束');
console.log(result);
});
conn.end();
五、mysql的事務處理
const mysql = require('mysql');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
//連線資料庫
conn.connect(function (err) {
if (err) {
throw err;
}
console.log('連線成功');
});
//開啟一個事務
conn.beginTransaction(function (err) {
if (err) {
throw err;
}
conn.query('update account set money = money - 50 where name = ?',['A'],data) {
if (err) {
//如果有錯誤則回滾
return conn.rollback(function () {
throw err;
});
}
conn.query('update account set money = money + 50 where name = ?',['B'],data) {
if (err) {
//如果有錯誤則回滾
return conn.rollback(function () {
throw err;
});
}
//提交事務
conn.commit(function (err) {
if (err) {
//如果有錯誤則回滾
return conn.rollback(function () {
throw err;
});
}
console.log('處理成功');
conn.end();
});
});
});
});
六、解決mysql巢狀回撥的問題
有些時候我們的操作需要上一個操作的結果，這樣會導致比較深的巢狀問題，為了解決可以使用async和await來解決，而async和await又是基於promise的。
const mysql = require('mysql');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
function query(conn,sql,params = []) {
if (!conn) {
return;
}
return new Promise(function (resolve,reject) {
conn.query(sql,params,data) {
if (err) {
reject(err);
} else {
resolve(data);
}
});
});
}
(async function () {
let result = await query(conn,'select * from tb_user');
console.log(result);
let row = await query(conn,'select * from tb_user where id = ?',[result[0].id]);
console.log(row);
conn.end();
})();
當然我們還可以使用 util.promiseify() 進行包裝。
const mysql = require('mysql');
const util = require('util');
//建立資料庫連線
let conn = mysql.createConnection({
//主機地址
host: '127.0.0.1',//字符集
charset: 'utf8'
});
//注意通過util.promisify進行包裝的函式，必須滿足
//1、函式的最後一個引數是回撥函式
//2、回撥函式的引數為(err,result)，前者是錯誤，後者是正常結果
//注意這裡不要重新建立一個變數，不然會報錯。
conn.query = util.promisify(conn.query);
(async function () {
let result = await conn.query('select * from tb_user');
console.log(result);
let row = await conn.query('select * from tb_user where id = ?',[result[0].id]);
console.log(row);
conn.end();
})();
希望本文所述對大家node.js程式設計有所幫助。