node连接mysql查询事务处理的实现
时间：2022-10-27 10:46:46|栏目：NodeJS|点击： 次
自己用 mysql 很多次的，然后又是主玩nodejs的.专门写一篇文章来说说nodejs连接mysql数据库。在使用之前，请检查计算机是否具有一下环境!
进入正题 mysql 增删改查
首先，我们去下载一个叫mysql的依赖包，这个包就是通过 nodejs 代码去连接数据库，从而操作数据库。
创建一个文件夹，快速生成pakeage.json文件
D:\nodejs_mysql>npm init -y # 快速传创建包管理文件
安装依赖
D:\nodejs_mysql>npm i mysql -D # 安装mysql 依赖包
创建一个 index.js 文件，代码如下
const mysql = require("mysql");
// 创建 一个mysql 连接池
const pool = mysql.createPool({
host: "127.0.0.1", // 连接数据库的地址 127.0.0.1 为本地的mysql
user: "root", // 连接数据库的用户名 root 是最高权限
password: "", // 连接数据库的密码
database: "apm", // 操作的数据库名
port: "3306", // 连接mysql的端口号
multipleStatements: true, // 运行一次执行多条sql语句 可以忽略此项
});
function select() {
// 请求连接mysql
pool.getConnection((err, connection) => {
// 未连接成功 报错
if (err) throw err;
// 得到一个 连接对象 调用 query 方法 可以执行 sql 语句
let sql = "select * from goods";
// 运行sql语句 query 第二个参数为 sql语句需要的参数 ，没有可以不写
connection.query(sql, (errors, results, fields) => {
// 释放连接
connection.release();
// 如果运行sql语句有报错 抛出错误
if (errors) throw errors;
console.log(results);
console.log(fields);
});
});
}
select();
以上的代码是查询 数据库apm一个数据表goods的数据。results为从数据库取出的数据。
封装方法 使用Promise来查询数据库
// index.js
// ... 忽略前面的创建mysql连接池代码
function query(sql, params) {
return new Promise((resolve, reject) => {
pool.getConnection((err, connection) => {
// 未连接成功 报错
if (err) return reject(err);
// 得到一个 连接对象 调用 query 方法 可以执行 sql 语句
// 运行sql语句 query 第二个参数为 sql语句需要的参数 ，没有可以不写
connection.query(sql, params, (errors, results, fields) => {
// 释放连接
connection.release();
// 如果运行sql语句有报错 抛出错误
if (errors) return reject(errors);
resolve(results);
});
});
});
}
query("select * from goods", null).then((result) => {
console.log(result);
});
module.exports = {
query,
};
使用
// data.js
const index = require("./index.js");
var sql = "select * from goods";
index
.query(sql, null)
.then((result) => {
// do anything ....
})
.catch((err) => {
// error
console.log(err);
});
这样就向外暴露了一个数据库运行 sql 的接口。通过promise使用.then这种链式调用的代码风格。
mysql 事务处理
说到 mysql 事务，我也就不做过多介绍了，这里给个友情链接方便大家学习。MySQL 事务处理
我们直接步入正题，使用promise来封装 mysql 的事务处理.
// index.js
// .... 部分创建 pool 的代码
/**
* mysql 事务处理
* @param {Array} sqls 需要执行的sql语句
* @param {Array} params 对应上面sql语句的参数
* @returns {Promise} 返回一个Promise
*/
function transaction(sqls, params) {
return new Promise((resolve, reject) => {
pool.getConnection(function (err, connection) {
// 连接失败 promise直接返回失败
if (err) {
return reject(err);
}
// 如果 语句和参数数量不匹配 promise直接返回失败
if (sqls.length !== params.length) {
connection.release(); // 释放掉
return reject(new Error("语句与传值不匹配"));
}
// 开始执行事务
connection.beginTransaction((beginErr) => {
// 创建事务失败
if (beginErr) {
connection.release();
return reject(beginErr);
}
console.log("开始执行事务，共执行" + sqls.length + "条语句");
// 返回一个promise 数组
let funcAry = sqls.map((sql, index) => {
return new Promise((sqlResolve, sqlReject) => {
const data = params[index];
connection.query(sql, data, (sqlErr, result) => {
if (sqlErr) {
return sqlResolve(sqlErr);
}
sqlReject(result);
});
});
});
// 使用all 方法 对里面的每个promise执行的状态 检查
Promise.all(funcAry)
.then((arrResult) => {
// 若每个sql语句都执行成功了 才会走到这里 在这里需要提交事务，前面的sql执行才会生效
// 提交事务
connection.commit(function (commitErr, info) {
if (commitErr) {
// 提交事务失败了
console.log("提交事务失败:" + commitErr);
// 事务回滚，之前运行的sql语句不生效
connection.rollback(function (err) {
if (err) console.log("回滚失败：" + err);
connection.release();
});
// 返回promise失败状态
return reject(commitErr);
}
connection.release();
// 事务成功 返回 每个sql运行的结果 是个数组结构
resolve(arrResult);
});
})
.catch((error) => {
// 多条sql语句执行中 其中有一条报错 直接回滚
connection.rollback(function () {
console.log("sql运行失败： " + error);
connection.release();
reject(error);
});
});
});
});
});
}
module.exports = {
transaction,
};
之后只需要调用这个方法就可以执行 mysql 事务了
// data.js
const index = require("./index.js");
var sqls = [
"delete from goods where goods_id = ?", // 删除 语句
"update goods set num = ? where goods_id = ?;", // 更新语句
];
var params = [
[1], // parmas 是数组格式 与sqls里的sql语句里 ? 一一对应
[5, 3],
];
index
.transaction(sqls, params)
.then((arrResult) => {
// do anything ....
})
.catch((err) => {
// error
console.log(err);
});
