node.js中 mysql 增刪改查操作及async,await處理實(shí)例分析
本文實(shí)例講述了node.js中 mysql 增刪改查操作及async,await處理。分享給大家供大家參考,具體如下:
要對(duì)mysql進(jìn)行操作,我們需要安裝一個(gè)mysql的庫。
一、安裝mysql庫
npm install mysql --save
二、對(duì)mysql進(jìn)行簡單查詢操作
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //連接數(shù)據(jù)庫 conn.connect(function (err) { if (err) { throw err; } console.log('連接成功'); }); //查詢數(shù)據(jù)庫 conn.query('select * from tb_user', function (err, data, field) { if (err) { throw err; } //data表示結(jié)果集數(shù)據(jù),是一個(gè)數(shù)組 console.log(data); data.forEach(function (value) { console.log(value.id, value.user_name, value.addr); }); //表字段的詳細(xì)信息 console.log(field); }); //關(guān)閉數(shù)據(jù)庫連接 conn.end();
二、對(duì)mysql進(jìn)行增刪改操作
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //連接數(shù)據(jù)庫 conn.connect(function (err) { if (err) { throw err; } console.log('連接成功'); }); //插入數(shù)據(jù),query()方法可以對(duì)sql語句進(jìn)行參數(shù)綁定,用?號(hào)作為占位符。 conn.query('insert into tb_user values(null, ?, ?)', ['xxx', 'xxx'], function (err, data) { if (err) { throw err; } if (data && data.affectedRows) { console.log('插入數(shù)據(jù)成功,id為', data.insertId); } }); //修改數(shù)據(jù) conn.query('update tb_user set user_name = ? where id = ?', ['ggg', 7], function (err, data) { if (err) { throw err; } if (data && data.affectedRows) { console.log('修改數(shù)據(jù)成功'); } }); //刪除數(shù)據(jù) conn.query('delete from tb_user where id = ?', [5], function (err, data) { if (err) { throw err; } if (data && data.affectedRows) { console.log('刪除數(shù)據(jù)成功'); } }); //關(guān)閉數(shù)據(jù)庫連接 conn.end();
三、使用mysql連接池來優(yōu)化對(duì)數(shù)據(jù)庫的操作
頻繁的連接和斷開mysql是比較消耗資源的,我們可以創(chuàng)建一個(gè)連接池,復(fù)用連接池中的連接,提高效率。
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接池 let pool = mysql.createPool({ //連接數(shù)量,默認(rèn)是10 connectionLimit: 20, //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //pool.query()方法可以自動(dòng)的幫我們?cè)谶B接池中獲取可用連接 pool.query('select * from tb_user', function (err, data) { if (err) { throw err; } data.forEach(function (value) { console.log(value.id, value.user_name, value.addr); }); }); //當(dāng)然我們也可以手動(dòng)獲取可用連接 pool.getConnection(function (err, conn) { if (err) { throw err; } conn.query('select * from `order`', function (err, data) { if (err) { throw err; } data.forEach(function (value) { console.log(value.id, value.order_id, value.user_id); }); //連接用完之后,需要釋放,重新放回連接池中。 //注意這里并沒有銷毀該連接,該連接仍然可用,但需要重新獲取 conn.release(); }); }); //從連接池中獲取連接時(shí),將觸發(fā)該事件 pool.on('acquire', function (conn) { console.log('獲取連接', conn.threadId); }); //在連接池中建立新連接時(shí),將觸發(fā)該事件 pool.on('connection', function (conn) { console.log('建立新連接', conn.threadId); }); //等待可用連接時(shí),將觸發(fā)該事件 pool.on('enqueue', function () { console.log('等待可用連接'); }); //當(dāng)連接釋放回池中時(shí),觸發(fā)該事件 pool.on('release', function (conn) { console.log('連接被釋放回池中', conn.threadId); }); //結(jié)束池中所有的連接,不然node.js的事件循環(huán)會(huì)一直保持 setTimeout(function () { pool.end(function (err) { console.log('關(guān)閉連接池'); console.log(err); }); }, 3000);
四、按流的方式進(jìn)行查詢
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); let query = conn.query('select * from tb_user'); //Query類繼承自Sequence,而Sequence繼承自EventEmitter //所以Query類的實(shí)例是可以監(jiān)聽事件 //發(fā)生錯(cuò)誤時(shí) query.on('error', function (err) { console.log(err); }); //獲取查詢字段信息 query.on('fields', function (fields) { console.log(fields); }); //獲取查詢結(jié)果 query.on('result', function (result) { //暫停獲取結(jié)果 conn.pause(); //跟流的pause()和resume()很類似,控制獲取數(shù)據(jù)的頻率。 setTimeout(function () { console.log(result); //恢復(fù)獲取結(jié)果 conn.resume(); }, 1000); }); //查詢結(jié)束 query.on('end', function () { console.log('查詢結(jié)束'); }); conn.end();
通過query.stream()方法返回一個(gè)可讀流來獲取數(shù)據(jù)
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //從一個(gè)查詢中獲取一個(gè)可讀流 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('查詢結(jié)束'); console.log(result); }); conn.end();
五、mysql的事務(wù)處理
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //連接數(shù)據(jù)庫 conn.connect(function (err) { if (err) { throw err; } console.log('連接成功'); }); //開啟一個(gè)事務(wù) conn.beginTransaction(function (err) { if (err) { throw err; } conn.query('update account set money = money - 50 where name = ?', ['A'], function (err, data) { if (err) { //如果有錯(cuò)誤則回滾 return conn.rollback(function () { throw err; }); } conn.query('update account set money = money + 50 where name = ?', ['B'], function (err, data) { if (err) { //如果有錯(cuò)誤則回滾 return conn.rollback(function () { throw err; }); } //提交事務(wù) conn.commit(function (err) { if (err) { //如果有錯(cuò)誤則回滾 return conn.rollback(function () { throw err; }); } console.log('處理成功'); conn.end(); }); }); }); });
六、解決mysql嵌套回調(diào)的問題
有些時(shí)候我們的操作需要上一個(gè)操作的結(jié)果,這樣會(huì)導(dǎo)致比較深的嵌套問題,為了解決可以使用async和await來解決,而async和await又是基于promise的。
const mysql = require('mysql'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); function query(conn, sql, params = []) { if (!conn) { return; } return new Promise(function (resolve, reject) { conn.query(sql, params, function (err, 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(); })();
當(dāng)然我們還可以使用 util.promiseify() 進(jìn)行包裝。
const mysql = require('mysql'); const util = require('util'); //創(chuàng)建數(shù)據(jù)庫連接 let conn = mysql.createConnection({ //主機(jī)地址 host: '127.0.0.1', //用戶名 user: 'root', //密碼 password: '123456', //數(shù)據(jù)庫 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //注意通過util.promisify進(jìn)行包裝的函數(shù),必須滿足 //1、函數(shù)的最后一個(gè)參數(shù)是回調(diào)函數(shù) //2、回調(diào)函數(shù)的參數(shù)為(err, result),前者是錯(cuò)誤,后者是正常結(jié)果 //注意這里不要重新創(chuàng)建一個(gè)變量,不然會(huì)報(bào)錯(cuò)。 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(); })();
希望本文所述對(duì)大家node.js程序設(shè)計(jì)有所幫助。
相關(guān)文章
node使用promise替代回調(diào)函數(shù)
這篇文章主要介紹了node使用promise替代回調(diào)函數(shù),小編覺得挺不錯(cuò)的,現(xiàn)在分享給大家,也給大家做個(gè)參考。一起跟隨小編過來看看吧2018-05-05node.js中的console.timeEnd方法使用說明
這篇文章主要介紹了node.js中的console.timeEnd方法使用說明,本文介紹了console.timeEnd的方法說明、語法、使用實(shí)例和實(shí)現(xiàn)源碼,需要的朋友可以參考下2014-12-12nodejs中函數(shù)的調(diào)用實(shí)例詳解
本文通過實(shí)例代碼給大家介紹了nodejs函數(shù)的調(diào)用,代碼簡單易懂,非常不錯(cuò),具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2018-10-10node+axios實(shí)現(xiàn)服務(wù)端文件上傳示例
這篇文章主要介紹了node+axios實(shí)現(xiàn)服務(wù)端文件上傳示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-06-06node.js中process進(jìn)程的概念和child_process子進(jìn)程模塊的使用方法示例
這篇文章主要介紹了node.js中process進(jìn)程的概念和child_process子進(jìn)程模塊的使用方法,結(jié)合實(shí)例形式分析了node.js中process進(jìn)程和child_process子進(jìn)程模塊相關(guān)概念、原理、使用方法及操作注意事項(xiàng),需要的朋友可以參考下2020-02-02npm?install常見報(bào)錯(cuò)以及問題詳解
npm?install總是一言難盡,下面這篇文章主要給大家介紹了關(guān)于npm?install常見報(bào)錯(cuò)以及問題的相關(guān)資料,文中通過圖文以及實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2023-02-02