node.js中 mysql 增删改查操作及async，await处理实例分析

网络编程 2024/12/24 佚名

2 0 1

蝙蝠岛资源网 Design By www.hbtsch.com

本文实例讲述了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程序设计有所帮助。

                                
                                
                                    node.js,mysql,增删改查,async,await 
                                
                                    标签：
                                        node.js,mysql,增删改查,async,await
                                     

                                蝙蝠岛资源网 Design By www.hbtsch.com

广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com

蝙蝠岛资源网 Design By www.hbtsch.com

评论“node.js中 mysql 增删改查操作及async，await处理实例分析”

暂无node.js中 mysql 增删改查操作及async，await处理实例分析的评论...

www.hbtsch.com 蝙蝠岛资源网

139,976影音资源

144,792福利资源

21,817软件资源

631,128技术资源

稳了！魔兽国服回归的3条重磅消息！官宣时间再确认！

昨天有一位朋友在大神群里分享，自己亚服账号被封号之后居然弹出了国服的封号信息对话框。

这里面让他访问的是一个国服的战网网址，com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后，确实是网易的网址，也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情，因为以前都没有出现这样的情况，现在突然提示跳转到国服战网的网址，是不是说明了简体中文客户端已经开始进行更新了呢？

更新日志

2024年12月24日

node.js中 mysql 增删改查操作及async，await处理实例分析

node.js,mysql,增删改查,async,await

JavaScript实现拖拽功能

基于Angular 8和Bootstrap 4实现动态主题切换的示例代码

评论“node.js中 mysql 增删改查操作及async，await处理实例分析”

稳了！魔兽国服回归的3条重磅消息！官宣时间再确认！

更新日志

友情链接