Node.js如何實現(xiàn)MySQL數(shù)據(jù)庫連接池

更新時間：2024年11月25日 14:34:44 作者：橘貓吃不胖～

文章介紹了Node.js中實現(xiàn)MySQL數(shù)據(jù)庫連接池的方法,通過預先建立和管理數(shù)據(jù)庫連接對象,優(yōu)化數(shù)據(jù)庫連接的使用效率

什么是數(shù)據(jù)庫連接池

數(shù)據(jù)庫連接池是程序啟動時建立足夠數(shù)量的數(shù)據(jù)庫連接對象，并將這些連接對象組成一個池，由程序動態(tài)地對池中的連接對象進行申請、使用和釋放。

原理及優(yōu)點

數(shù)據(jù)庫連接池在初始化時將會創(chuàng)建一定數(shù)量的數(shù)據(jù)庫連接對象放到連接池中，連接池都將一直保證至少擁有這么多的連接數(shù)量，當有數(shù)據(jù)庫需要被連接的時候，它會向數(shù)據(jù)庫連接池申請資源和使用，使用完成后會釋放到數(shù)據(jù)庫連接池中。當然數(shù)據(jù)庫連接池中擁有最小連接數(shù)量和最大連接數(shù)量，當數(shù)據(jù)庫的連接超過連接池中最大的數(shù)量的時候，這些請求將被加入到等待隊列中。

用服裝店招聘導購來說明數(shù)據(jù)庫連接池。當只有顧客A時，服裝店招聘一個導購A，如果之后顧客B、C、D、E、F…也來了，那么就需要不斷招聘導購B、C、D、E、F…，這樣會帶來大量的人力成本。

如果讓一個主管去管理一定數(shù)量（以5為例）的導購，當顧客A、B、C、D、E來了，主管依次分配了導購A、B、C、D、E，但如果顧客F來了，由于已經(jīng)沒有空閑的導購了，因此顧客F需要排隊等待。

等A、B、C、D、E導購其中任何一個服務完成后（比如說導購D），他又重新回到了導購組中，這時主管會將他分配給顧客F。

數(shù)據(jù)庫的鏈接池也是這個意思，當網(wǎng)站某一天有很大的流量的時候，數(shù)據(jù)庫服務器需要為每次鏈接創(chuàng)建一次數(shù)據(jù)庫鏈接。

這樣就很浪費數(shù)據(jù)庫的資源，并且頻繁的創(chuàng)建和關閉數(shù)據(jù)庫的鏈接，很容易導致服務器內存溢出等情況發(fā)生。

連接池的作用

數(shù)據(jù)庫的連接池負責分配、管理和釋放數(shù)據(jù)庫連接對象的。

它允許應用程序重復使用一個現(xiàn)有的數(shù)據(jù)庫的連接對象。而不是重新創(chuàng)建一個。

實現(xiàn)連接池

1.導入mysql模塊

首先安裝mysql模塊：

npm install mysql

導入mysql模塊：

const mysql = require("mysql");

2.創(chuàng)建數(shù)據(jù)庫連接池

創(chuàng)建數(shù)據(jù)庫連接池語法如下：

const pool = mysql.createPool({
    host: "數(shù)據(jù)庫服務器地址",
    port: 3306, // MySQL數(shù)據(jù)庫端口號
    database: "數(shù)據(jù)庫名",
    user: "連接數(shù)據(jù)庫的用戶名",
    password: "連接數(shù)據(jù)庫的密碼",
    connectionLimit: "指定連接池中最大的鏈接數(shù)，默認是10",
    queueLimit: "指定允許掛起的最大連接數(shù)，如果掛起的連接數(shù)超過該數(shù)值，就會立刻拋出錯誤，默認屬性值為0，代表不允許被掛起的最大連接數(shù)",
    multipleStatements: "是否運行執(zhí)行多條sql語句，默認值為false"
})

示例：創(chuàng)建數(shù)據(jù)庫連接池

const mysql = require("mysql");
const pool = mysql.createPool({
    host: "127.0.0.1", // 主機地址
    port: 3306,
    database: "info", // 數(shù)據(jù)庫名字
    user: "root", // 連接數(shù)據(jù)庫的用戶名
    password: "123456", // 連接數(shù)據(jù)庫密碼
    connectionLimit: 20, // 連接池最大連接數(shù)
    multipleStatements: true // 允許執(zhí)行多條sql語句
})
module.exports = pool;

3.從連接池中獲取一個連接

語法：

pool.getConnection(function (err, connection) {
    // 代碼
});

err：該參數(shù)是指操作失敗時的錯誤對象。
connection：該值為一個對象，代表獲取到的連接對象。當連接失敗時，該值為undefined。

4.釋放連接對象（放回連接池）

connection.release();

5.從連接池中移除連接對象

connection.destory();

6.關閉該連接池

pool.end();

案例

使用連接池連接MySQL數(shù)據(jù)庫，查詢info數(shù)據(jù)庫中stu表中的所有信息，

stu表具體如下：

創(chuàng)建mydb.js，創(chuàng)建數(shù)據(jù)庫連接池，代碼如下：

const mysql = require("mysql");

// 創(chuàng)建數(shù)據(jù)庫連接池
const pool = mysql.createPool({
    host: "localhost",
    port: 3306,
    user: "root",
    password: "123456",
    database: "info",
    connectionLimit: 20,
});

// 將數(shù)據(jù)庫連接池對象導出
module.exports = pool;

創(chuàng)建test.js文件，使用連接池查詢數(shù)據(jù)庫，代碼如下：

const express = require("express"); // 導入express
const app = express(); // 創(chuàng)建實例
const pool = require("./mydb"); // 導入連接池
// http://localhost:3000/test
app.get("/test", ((req, res) => {
    // 從連接池中獲取數(shù)據(jù)庫的連接對象
    pool.getConnection(function (err, conn) {
        if (err) {
            console.log("數(shù)據(jù)庫連接失敗");
        } else {
            console.log("數(shù)據(jù)庫連接成功");
            // 定義sql查詢語句
            let sql = "select * from stu";
            // 查詢操作
            conn.query(sql, function (err, result) {
                if (err) {
                    console.log("數(shù)據(jù)庫查詢失敗");
                } else {
                    res.send(result);
                    conn.release();
                }
            })
        }
    })
}))
// 監(jiān)聽3000端口
app.listen(3000);

啟動服務器，在瀏覽器中打開http://localhost:3000/test，會看到成功查詢到了表stu中的數(shù)據(jù)。