🌟前言

哈喽小伙伴们，新的专栏 Node 已开启；这个专栏里边会收录一些Node的基础知识和项目实战；今天我们带领大家初识一下 Node第三方包 mysql2 ；让我们一起来看看吧🤘

🌟访问数据库

如果要在Nodejs中去访问一个MySQL数据库，必须安装一个MySQL驱动，有了这个MySQL驱动才能跟MySQL数据库建立连接，然后执行各种各样的SQL语句。

🌟MySQL驱动

如果我们要访问数据库，必须得跟数据库建立一个网络连接，那么这个连接由谁来建立呢？

其实答案就是这个MySQL驱动，他会在底层跟数据库建立网络连接，有网络连接，接着才能去发送请求给数据库服务器！

因此，操作MySQL需要Nodejs版本的MySQL驱动，对于Java、PHP、Perl、.NET、Python、Ruby等各种常见的编程语言，MySQL都会提供对应语言的MySQL驱动，让各种语言编写的系统通过MySQL驱动去访问数据库。

🌟mysql2

mysql2是一个高性能的MySQL驱动程序。

为什么使用mysql2而不是经典的mysql库？主要基于以下原因：

• 更高的性能！
• 支持PreparedStatement，多次查询性能更高，书写SQL更简单；
• 自带Promise包装器，可以直接使用async/await语法；
• 绝大部分api和mysql库兼容，意味着mysql的文档和线上资料亦可作为参考。

PreparedStatement是预编译的,对于批量处理可以大大提高效率会。也就是说PreparedStatement先初始化SQL，先把这个SQL提交到数据库中进行预处理，多次使用可提高效率。

🌟安装

npm install --save mysql2

示例

const mysql = require('mysql2');
// 创建到数据库的连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'root',
  database: 'test'
});

// 简单查询
connection.query(
  'SELECT * FROM `table` WHERE `name` = "Page" AND `age` > 45',
  function(err, results, fields) {
    console.log(results); // results contains rows returned by server
    console.log(fields); // fields contains extra meta data about results, if available
  }
);

// 使用占位符
connection.query(
  'SELECT * FROM `table` WHERE `name` = ? AND `age` > ?',
  ['Page', 45],
  function(err, results) {
    console.log(results);
  }
);

🌟方法

🌟连接数据库

使用数据库之前，需要先连接数据库。语法格式：

mysql.createConnection(option)

其中 option 为连接数据库的配置项。如下为部分配置项：

参数名称	参数描述
host	主机地址 （默认：localhost）
user	用户名
password	密码
port	端口号 （默认：3306）
database	数据库名
charset	连接字符集（默认：‘UTF8_GENERAL_CI’，注意字符集的字母必须大写）
connectTimeout	连接超时（单位：毫秒）
multipleStatements	是否许一个query中有多个MySQL语句（ 默认： false）

我们使用语句创建一个连接：

const mysql = require('mysql2');
// 创建到数据库的连接
const connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'root',
    database: 'test'
});

🌟通过 query() 方法执行SQL语句

连接数据库之后，可以使用query()方法对数据库执行SQL操作。语法格式：

connection.query(sql,params,callback)

参数名称	参数描述
sql	表示具体的SQL语句，可以使用 PreparedStatement 防止SQL注入。
params	表示参数，使用方法如下例。
callback	是一个回调函数，表示执行完成之后，返回结果。有三个参数(err, results, fields)，分别表示错误信息，结果，表的字段信息。

也可以通过组装SQL语句，可以用??代替表名、字段、索引名；用?代替数据。具体实例如下所示：

connection.query(
    'SELECT * from xxx where id=?',
    [100],
    function (error, results, fields) {
        if (error) throw error;
        console.log('The solution is: ', results[0].solution);
    }
);

🌟通过 execute() 方法执行SQL语句

execute()方法也是用于执行SQL语句

connection.execute(
    'select * from admin where AdminID = ?', [2],
    function(err, results, fields) {
        if (err) {
            console.log('[SELECT ERROR] - ', err.message);
            return;
        }
        console.log(results);
        // console.log(fields);
    }
)

execute()和query()之间的区别：

• query是在node装SQL语句，而 execute 则是利用MySQL 的 PreparedStatement 机制来预编译SQL语句
• execute 的优势是数据库原生支持的预编译机制，性能更高
• query 的优势是更灵活，例如可以用??代替表名、字段、索引名；用?代替数据

🌟使用连接池

🌟连接池技术介绍

服务器可以快速创建和断开数据库连接，但对于高并发的后端服务器而言，数据库连接的频繁创建与断开，是非常重的负担。若在客户端与服务端交互前，可以事先创建若干连接并提前放置在连接池中，需要时可以从连接池直接获取，数据传输完成后，将连接归还至连接池中，从而减少频繁创建和释放连接所造成的开销。

连接池技术的核心思想是：连接复用，通过建立一个数据库连接池以及一套连接使用、分配、管理策略，使得该连接池中的连接可以得到高效、安全的复用，避免了数据库连接频繁建立、关闭的开销。

在系统初始化时，根据相应的配置创建连接并放置在连接池中，以便需要使用时能从连接池中获取，这样就可以避免连接随意的建立、关闭造成的开销。

当客户请求数据库连接时，首先查看连接池中是否有空闲连接（指当前没有分配出去的连接）。如果存在空闲连接，则把连接分配给客户并作相应处理（即标记该连接为正在使用，引用计数加1）。如果没有空闲连接，则查看当前所开的连接数是不是已经达到maxConn（最大连接数），如果没达到就重新创建一个连接给请求的客户；如果达到就按设定的maxWaitTime（最大等待时间）进行等待，如果等待maxWaitTime后仍没有空闲连接，就抛出无空闲连接的异常给用户。

🌟mysql2连接池

具体的语法格式：

mysql.createPool()

其中的参数和createConnection()中的参数基本相同，但是多了几个对连接池的设定：

参数名称	参数描述
host	主机地址 （默认：localhost）
user	用户名
password	密码
port	端口号 （默认：3306）
database	数据库名
charset	连接字符集（默认：‘UTF8_GENERAL_CI’，注意字符集的字母必须大写）
connectTimeout	连接超时（单位：毫秒）
multipleStatements	是否许一个query中有多个MySQL语句（ 默认： false）
waitForConnections	表示连接超额是否等待
connectionLimit	一次创建的最大连接数
queueLimit	表示可以等待的连接的个数一次创建的最大连接数

const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    database: 'test',
    password: "123456",
    waitForConnections: true, //连接超额是否等待
    connectionLimit: 10, //一次创建的最大连接数
    queueLimit: 0 //可以等待的连接的个数
});

在创建完连接池之后，可以使用和createConnection()连接相同的方式使用池（使用pool.query()和pool.execute()。也可以通过连接池手动获取连接进行数据库操作。

🌟使用 Promise

通过query()和execute()操作数据库时都是通过回调函数的形式获取放返回的数据。而我们可以使用Promise将异步转化为同步，以同步的方式来完成对数据库的操作。

在使用 Promise 时，分为两种方式：

• 通过 async\await 来实现
• 通过 promise() 函数来实现

在使用 Promise 时，需要require mysql2/promise：

const mysql = require('mysql2/promise');

🌟async\await操作数据库

通过async\await 和createConnection()的方式结合进行数据库操作

const mysql = require('mysql2/promise');
async function pro_createConnection() {
    let connection = await mysql.createConnection({
        host: "localhost",
        user: "root",
        password: "123456",
        database: "student",
        multipleStatements: true
    });

    let [results] = await connection.execute(
        'select * from admin where AdminID = ?', [1]
    )
    console.log(results);
}
pro_createConnection();

通过async\await 和createPool()的方式结合进行数据库操作

const mysql = require('mysql2/promise');
const pool = mysql.createPool({
    host: "localhost",
    user: "root",
    password: "123456",
    database: "student",
    waitForConnections: true, //连接超额是否等待
    connectionLimit: 10, //一次创建的最大连接数
    queueLimit: 0 //可以等待的连接的个数
});
async function pro_createPool() {

    let [results] = await pool.execute(
        'select * from admin where AdminID = ?', [1]
    )
    console.log(results);
}
pro_createPool()

🌟promise()函数操作数据库

通过 promise() 函数和createConnection()的方式结合进行数据库操作

const mysql = require('mysql2');
let connection = mysql.createConnection({
    host: "localhost",
    user: "root",
    password: "123456",
    database: "student",
    multipleStatements: true
});
connection.promise().query('select * from admin where AdminID = ?', [1])
    .then(([rows, fields]) => {
        console.log(rows);
    })
    .catch(console.log)
    .then(() => connection.end());

通过 promise() 函数 和 createPool() 的方式结合进行数据库操作

const pool = mysql.createPool({
    host: "localhost",
    user: "root",
    password: "123456",
    database: "student",
    waitForConnections: true, //连接超额是否等待
    connectionLimit: 10, //一次创建的最大连接数
    queueLimit: 0 //可以等待的连接的个数
});
pool.promise().query('select * from admin where AdminID = ?', [1])
    .then(([rows, fields]) => {
        console.log(rows);
    })
    .catch(console.log)

在使用 Promise 完成数据库操作时，除了上述实例中需要添加的部分，其余部分，如创建连接和连接池，query() 和 execute() 等的使用方法不变。

🌟写在最后

更多Node知识以及API请大家持续关注，尽请期待。各位小伙伴让我们 let’s be prepared at all times！

✨原创不易，还希望各位大佬支持一下！
👍 点赞，你的认可是我创作的动力！
⭐️ 收藏，你的青睐是我努力的方向！
✏️ 评论，你的意见是我进步的财富！