自己用 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 为本地的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);
  });

免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：mmqy2019@163.com进行举报，并提供相关证据，查实之后，将立刻删除涉嫌侵权内容。

猜你喜欢

• TS中引用路径别名报错怎么回事，如何解决

  本文主要介绍了Typescript中使用引用路径别名报错的解决方法，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

• JavaScript怎样判断变量的类型，方法是什么？

  这篇文章给大家分享的是JavaScript怎样判断变量的类型的方法。小编觉得挺实用的，因此分享给大家做个参考，文中的示例代码介绍得很详细，有需要的朋友可以参考，接下来就跟随小编一起了解看看吧。

• JS中的相册图片怎样实现图片抖动放大的效果

  这篇文章主要介绍了JS相册图片抖动放大展示效果的示例代码,代码简单易懂，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

• 如何理解JS作用域链，作用域的分类有几种

  本篇文章给大家带来了关于JavaScript的相关知识，其中主要介绍了作用域链的相关内容，作用域是一套规则，负责收集并维护由所有声明的标识符（变量）组成的一系列查询，并实施一套非常严格的规则，确定当前执行的代码对这些标识符的访问权限；下面一起来看一下，希望对大家有帮助。

• 详解JS等于运算符，等于运算符使用这些要知

  本文主要给大家分享的时候JS等于运算符，很多朋友觉得JS等于运算符很好用，可能会出现滥用的情况，但其实等于运算符使用有些问题是需要了解的，下面我们就来看看。