本文实例讲述了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', //用户名 user: 'root', //密码 password: '123456', //数据库 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //连接数据库 conn.connect(function (err) { if (err) { throw err; } console.log('连接成功'); }); //插入数据,query()方法可以对sql语句进行参数绑定,用"htmlcode">const mysql = require('mysql'); //创建数据库连接池 let pool = mysql.createPool({ //连接数量,默认是10 connectionLimit: 20, //主机地址 host: '127.0.0.1', //用户名 user: 'root', //密码 password: '123456', //数据库 database: 'test', //端口 port: 3306, //字符集 charset: 'utf8' }); //pool.query()方法可以自动的帮我们在连接池中获取可用连接 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); }); }); //当然我们也可以手动获取可用连接 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(); }); }); //从连接池中获取连接时,将触发该事件 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', //用户名 user: 'root', //密码 password: '123456', //数据库 database: 'test', //端口 port: 3306, //字符集 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', //用户名 user: 'root', //密码 password: '123456', //数据库 database: 'test', //端口 port: 3306, //字符集 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', //用户名 user: 'root', //密码 password: '123456', //数据库 database: 'test', //端口 port: 3306, //字符集 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 = "htmlcode">const mysql = require('mysql'); //创建数据库连接 let conn = mysql.createConnection({ //主机地址 host: '127.0.0.1', //用户名 user: 'root', //密码 password: '123456', //数据库 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 = "htmlcode">const mysql = require('mysql'); const util = require('util'); //创建数据库连接 let conn = mysql.createConnection({ //主机地址 host: '127.0.0.1', //用户名 user: 'root', //密码 password: '123456', //数据库 database: 'test', //端口 port: 3306, //字符集 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程序设计有所帮助。
华山资源网 Design By www.eoogi.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
华山资源网 Design By www.eoogi.com
暂无评论...
更新日志
2024年09月23日
2024年09月23日
- Merryland《Merryland》[320K/MP3][69.48MB]
- 苏芮.1991-停在我心里的温柔【福茂】【WAV+CUE】
- 苏慧伦.2020-面面Every.Side.of.Me【相信音乐】【WAV+CUE】
- 群星.1991-不一样的感觉REMIX【宝丽金】【WAV+CUE】
- 银霞.1983-《你那好冷的小手》珍藏纪念版[WAV分轨]
- 银霞.2002-《国语巨星专辑VOL.3》2CD台湾版[WAV+CUE]
- 金池刘罡《昨日情歌HQ》头版限量编号[低速原抓WAV+CUE]
- 段奥娟.2024-23·岁碎念【白米范】【FLAC分轨】
- 顺子.2001-昨日·唯一·更多·顺子自选辑【魔岩】【WAV+CUE】
- 无印良品.1999-私藏三首·原创相对论(EP)【滚石】【WAV+CUE】
- Merryland《Merryland》[FLAC/分轨][170.22MB]
- 庄锭欣 ELKIE《没有你的未来》[320K/MP3][15.78MB]
- 庄锭欣 ELKIE《没有你的未来》[FLAC/分轨][36MB]
- TchaikovskySwanLake,Op.20柴可夫斯基天鹅湖(2013)SACD[Hi-Res]
- 24bit达人艺典《琴歌终极版》整轨WAV+CUE