node连接mysql查询事务处理的实现 node连接mysql查询事务处理的实

进入正题 mysql 增删改查
mysql 事务处理

自己用 mysql 很多次的，然后又是主玩nodejs的.专门写一篇文章来说说nodejs连接mysql数据库。在使用之前，请检查计算机是否具有一下环境!

nodejs 执行环境。
mysql数据库环境（下载地址）。
navicat 连接 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 为本地的mysqluser: "root", //连接数据库的用户名 root 是最高权限password: "", //连接数据库的密码database: "apm", // 操作的数据库名port: "3306", // 连接mysql的端口号multipleStatements: true, // 运行一次执行多条sql语句可以忽略此项}); function select() {// 请求连接mysqlpool.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.jsconst index = require("./index.js"); var sql = "select * from goods"; index.query(sql, null).then((result) => {// do anything ....}).catch((err) => {// errorconsole.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 = https://www.it610.com/article/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.jsconst 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) => {// errorconsole.log(err); });

【node连接mysql查询事务处理的实现】到此这篇关于node连接mysql查询事务处理的实现的文章就介绍到这了,更多相关node连接mysql查询事务处理内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！