Nodejs使用mysql2操作數(shù)據(jù)庫的方法完整講解

更新時間：2024年01月24日 16:00:16 作者：wusp1994

MySQL2是一個基于Node.js的MySQL數(shù)據(jù)庫驅(qū)動程序,它是MySQL官方推薦的驅(qū)動之一,下面這篇文章主要給大家介紹了關(guān)于Nodejs使用mysql2操作數(shù)據(jù)庫的相關(guān)資料,需要的朋友可以參考下

mysql2 相比于 mysql 的優(yōu)勢

mysql2 是一個基于 Node.js 的 MySQL 客戶端庫，相比于 mysql 庫，它具有以下幾個優(yōu)勢：

性能更好：mysql2 庫在性能方面進(jìn)行了優(yōu)化，使用了更高效的底層實現(xiàn)。它使用了更快的連接池管理和查詢執(zhí)行機制，可以處理更高的并發(fā)請求，提供更好的性能表現(xiàn)。
支持 Promise 和 async/await：mysql2 庫原生支持 Promise 和 async/await，使得編寫異步代碼更加方便和直觀。您可以使用 promise().query() 方法執(zhí)行查詢，并使用 await 關(guān)鍵字等待查詢結(jié)果。
支持流式查詢：mysql2 庫支持流式查詢，可以通過創(chuàng)建可讀流來處理大型查詢結(jié)果集。這對于處理大量數(shù)據(jù)或需要逐行處理結(jié)果的情況非常有用，可以減少內(nèi)存占用并提高性能。
更好的錯誤處理：mysql2 庫提供了更好的錯誤處理機制，可以更詳細(xì)地捕獲和處理數(shù)據(jù)庫操作中的錯誤。它返回的錯誤對象包含更多有用的信息，如 SQL 語句、錯誤代碼和錯誤堆棧等，有助于更好地調(diào)試和排查問題。
支持預(yù)處理語句：mysql2 庫支持預(yù)處理語句，可以使用占位符來安全地構(gòu)建和執(zhí)行 SQL 查詢。這可以防止 SQL 注入攻擊，并提高應(yīng)用程序的安全性。

安裝

npm install mysql2

連接數(shù)據(jù)庫

要使用 mysql2 連接到 MySQL 數(shù)據(jù)庫，您需要安裝 mysql2 包，并使用適當(dāng)?shù)倪B接參數(shù)來創(chuàng)建連接。以下是一個示例，展示了如何使用 mysql2 連接到 MySQL 數(shù)據(jù)庫：

const mysql = require("mysql2");

// 創(chuàng)建數(shù)據(jù)庫連接
const connection = mysql.createConnection({
  host: "localhost", // 主機地址
  user: "root", // 用戶名
  password: "password", // 密碼
  port: 3306, // 端口號，默認(rèn)為 3306
  database: "mydatabase", // 數(shù)據(jù)庫名稱
  charset: "UTF8_GENERAL_CI", // 連接字符集，默認(rèn)為 UTF8_GENERAL_CI
  connectTimeout: 10000, // 連接超時時間，單位為毫秒
  multipleStatements: false // 是否允許一個 query 中有多個 MySQL 語句，默認(rèn)為 false
});

// 連接到數(shù)據(jù)庫
connection.connect((err) => {
  if (err) {
    console.error("Error connecting to database:", err);
    return;
  }
  console.log("Connected to database");
  
  // 在這里執(zhí)行數(shù)據(jù)庫操作
});

// 在數(shù)據(jù)庫連接關(guān)閉時觸發(fā)
connection.on("end", () => {
  console.log("Database connection closed");
});

// 在發(fā)生錯誤時觸發(fā)
connection.on("error", (err) => {
  console.error("Database error:", err);
});

// 關(guān)閉數(shù)據(jù)庫連接
connection.end();

在這個示例中，我們使用 mysql.createConnection() 方法創(chuàng)建了一個數(shù)據(jù)庫連接，并傳遞了連接參數(shù)（主機名、用戶名、密碼和數(shù)據(jù)庫名稱）。然后，我們使用 connection.connect() 方法來連接到數(shù)據(jù)庫。

在連接成功后，您可以在回調(diào)函數(shù)中執(zhí)行數(shù)據(jù)庫操作。在這個示例中，我們只是簡單地輸出連接成功的消息，但您可以在這里執(zhí)行任何數(shù)據(jù)庫操作，如查詢、插入、更新等。

請注意，為了確保數(shù)據(jù)庫連接的正確關(guān)閉，我們監(jiān)聽了 end 事件，并在事件處理程序中關(guān)閉了連接。此外，我們還監(jiān)聽了 error 事件，以處理可能發(fā)生的數(shù)據(jù)庫錯誤。

最后，我們使用 connection.end() 方法來關(guān)閉數(shù)據(jù)庫連接。

請根據(jù)您的實際情況修改連接參數(shù)，以適應(yīng)您的 MySQL 數(shù)據(jù)庫的配置。

通過 query() 方法執(zhí)行SQL語句

連接數(shù)據(jù)庫之后，可以使用query()方法對數(shù)據(jù)庫進(jìn)行增刪改查操作。

具體的語法格式：connection.query(sql,params,callback),以下是對 query() 方法的參數(shù)進(jìn)行詳細(xì)說明：

sql：要執(zhí)行的 SQL 查詢語句，可以是 SELECT、INSERT、UPDATE、DELETE 等。
params（可選）：一個數(shù)組，包含要傳遞給 SQL 查詢的參數(shù)。這些參數(shù)可以用于預(yù)處理語句中的占位符。
callback：一個回調(diào)函數(shù)，用于處理查詢結(jié)果或錯誤?；卣{(diào)函數(shù)接收兩個參數(shù)：err 和 results。err 是一個錯誤對象（如果有錯誤發(fā)生），results 是查詢結(jié)果。

以下是一個示例，展示了如何使用 query() 方法執(zhí)行 SQL 查詢并處理結(jié)果：

const mysql = require("mysql2");

// 創(chuàng)建數(shù)據(jù)庫連接
const connection = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "password",
  database: "mydatabase"
});

// 連接到數(shù)據(jù)庫
connection.connect((err) => {
  if (err) {
    console.error("Error connecting to database:", err);
    return;
  }
  console.log("Connected to database");

  // 執(zhí)行 SQL 查詢,可以用??代替表名、字段、索引名；用?代替數(shù)據(jù)。
  const sql = "SELECT * FROM users WHERE age > ?";
  const params = [18];
  connection.query(sql, params, (err, results) => {
    if (err) {
      console.error("Error executing query:", err);
      return;
    }
    console.log("Query results:", results);
  });
});

// 在數(shù)據(jù)庫連接關(guān)閉時觸發(fā)
connection.on("end", () => {
  console.log("Database connection closed");
});

// 在發(fā)生錯誤時觸發(fā)
connection.on("error", (err) => {
  console.error("Database error:", err);
});

// 關(guān)閉數(shù)據(jù)庫連接
connection.end();

在這個示例中，我們執(zhí)行了一個 SELECT 查詢，查找年齡大于 18 的用戶。我們使用了預(yù)處理語句，并將參數(shù) [18] 傳遞給 query() 方法。

在回調(diào)函數(shù)中，我們處理了查詢結(jié)果或錯誤。如果查詢成功，我們打印出查詢結(jié)果 results。

請根據(jù)您的實際需求修改 SQL 查詢語句、參數(shù)和處理邏輯。您可以執(zhí)行任何有效的 SQL 查詢，并根據(jù)需要處理查詢結(jié)果或錯誤。

通過 execute() 方法執(zhí)行SQL語句

以下是一個使用mysql2模塊執(zhí)行SQL查詢的示例：

const mysql = require('mysql2');

// 創(chuàng)建數(shù)據(jù)庫連接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'mydatabase'
});

// 執(zhí)行SQL查詢
connection.execute(
  'SELECT * FROM users WHERE age > ?',
  [18],
  function(err, results, fields) {
    if (err) {
      console.log('[SELECT ERROR] - ', err.message);
      return;
    }
    console.log(results);
    // console.log(fields);
  }
);

// 關(guān)閉數(shù)據(jù)庫連接
connection.end();

在這個例子中，我們創(chuàng)建了一個名為mydatabase的數(shù)據(jù)庫連接，并執(zhí)行了一個查詢語句，查找年齡大于18歲的用戶。如果查詢成功，結(jié)果將會在控制臺打印出來。你可以取消注釋掉console.log(fields)這行代碼來查看字段信息。

請確保將localhost、root、password和mydatabase替換為你自己的數(shù)據(jù)庫連接信息。

execute()和query()之間的區(qū)別：

下面是execute()和query()之間的區(qū)別：

參數(shù)化查詢：execute()方法支持參數(shù)化查詢，可以使用占位符（例如?）來代替查詢中的參數(shù)，而query()方法不支持參數(shù)化查詢，需要通過字符串拼接來傳遞參數(shù)。
回調(diào)函數(shù)：execute()和query()方法都接受一個回調(diào)函數(shù)作為參數(shù)，用于處理查詢結(jié)果。但是，execute()方法的回調(diào)函數(shù)有三個參數(shù)（err, results, fields），分別表示錯誤信息、查詢結(jié)果和字段信息；而query()方法的回調(diào)函數(shù)有兩個參數(shù)（err, results），只表示錯誤信息和查詢結(jié)果。
錯誤處理：在execute()方法中，需要手動處理錯誤，通過判斷err參數(shù)是否存在來確定是否有錯誤發(fā)生。而query()方法會自動處理錯誤，如果發(fā)生錯誤，會將錯誤信息傳遞給回調(diào)函數(shù)的err參數(shù)。
返回結(jié)果：無論是execute()還是query()方法，都會返回一個結(jié)果集對象。但是，execute()方法返回的結(jié)果集對象中包含更多的信息，如受影響的行數(shù)等。
預(yù)編譯：execute()方法支持預(yù)編譯，可以提前編譯SQL語句，以提高執(zhí)行效率。而query()方法不支持預(yù)編譯。

連接池

通過重新使用以前的連接，連接池可以保持打開狀態(tài)，從而減少連接到MySQL服務(wù)器的時間。在Node.js中，可以使用mysql.createPool()方法來創(chuàng)建連接池。它的語法格式如下：

const mysql = require('mysql2');

// 創(chuàng)建連接池
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase',
    connectionLimit: 10, // 最大連接數(shù)
    queueLimit: 0, // 排隊等待連接的最大請求數(shù)，0表示無限制
    waitForConnections: true // 當(dāng)連接池達(dá)到最大連接數(shù)時，是否等待可用連接
});

使用連接池進(jìn)行數(shù)據(jù)庫操作可以使用pool.query()和pool.execute()方法，也可以手動獲取連接進(jìn)行操作。下面是使用連接池進(jìn)行數(shù)據(jù)庫操作的示例代碼：

使用pool.query()方法：

const mysql = require('mysql2');

// 創(chuàng)建連接池
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase',
    connectionLimit: 10
});

// 使用pool.query()方法執(zhí)行查詢
pool.query('SELECT * FROM users', function(err, results, fields) {
    if (err) {
        console.log('[QUERY ERROR] - ', err.message);
        return;
    }

    console.log(results);
});

// 關(guān)閉連接池
pool.end();

使用pool.execute()方法：

const mysql = require('mysql2');

// 創(chuàng)建連接池
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase',
    connectionLimit: 10
});

// 使用pool.execute()方法執(zhí)行查詢
pool.execute('SELECT * FROM users', function(err, results, fields) {
    if (err) {
        console.log('[EXECUTE ERROR] - ', err.message);
        return;
    }

    console.log(results);
});

// 關(guān)閉連接池
pool.end();

手動獲取連接進(jìn)行數(shù)據(jù)庫操作：

const mysql = require('mysql2');

// 創(chuàng)建連接池
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase',
    connectionLimit: 10
});

// 從連接池中獲取連接
pool.getConnection(function(err, connection) {
    if (err) {
        console.log('[CONNECTION ERROR] - ', err.message);
        return;
    }

    // 執(zhí)行查詢操作
    connection.query('SELECT * FROM users', function(err, results, fields) {
        connection.release(); // 釋放連接回連接池

        if (err) {
            console.log('[QUERY ERROR] - ', err.message);
            return;
        }

        console.log(results);
    });
});

// 關(guān)閉連接池
pool.end();

使用 Promise

在之前通過query()和execute()操作數(shù)據(jù)庫時都是通過回調(diào)函數(shù)的形式獲取放返回的數(shù)據(jù)。而我們可以使用Promise將異步轉(zhuǎn)化為同步使用Promise來實現(xiàn)異步操作可以通過async/await和promise()函數(shù)兩種方式。

一種是通過 async\await 來實現(xiàn)，
種是通過 promise() 函數(shù)來實現(xiàn)。

下面是使用async/await和createConnection()、createPool()的方式創(chuàng)建數(shù)據(jù)庫操作的示例代碼：

使用async/await和createConnection()的方式：

const mysql = require('mysql2');

// 創(chuàng)建連接
const connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase'
});

// 封裝查詢函數(shù)
function query(sql) {
    return new Promise((resolve, reject) => {
        connection.query(sql, function(err, results, fields) {
            if (err) {
                reject(err);
            } else {
                resolve(results);
            }
        });
    });
}

// 使用async/await進(jìn)行數(shù)據(jù)庫操作
async function fetchData() {
    try {
        const results = await query('SELECT * FROM users');
        console.log(results);
    } catch (err) {
        console.log('[QUERY ERROR] - ', err.message);
    } finally {
        connection.end();
    }
}

fetchData();

使用async/await和createPool()的方式：

const mysql = require('mysql2');

// 創(chuàng)建連接池
const pool = mysql.createPool({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase',
    connectionLimit: 10
});

// 封裝查詢函數(shù)
function query(sql) {
    return new Promise((resolve, reject) => {
        pool.query(sql, function(err, results, fields) {
            if (err) {
                reject(err);
            } else {
                resolve(results);
            }
        });
    });
}

// 使用async/await進(jìn)行數(shù)據(jù)庫操作
async function fetchData() {
    let connection;
    try {
        connection = await pool.promise().getConnection();
        const results = await connection.query('SELECT * FROM users');
        console.log(results);
    } catch (err) {
        console.log('[QUERY ERROR] - ', err.message);
    } finally {
        if (connection) {
            connection.release();
        }
        pool.end();
    }
}

fetchData();

使用promise()函數(shù)和createConnection()的方式：

const mysql = require('mysql2');

// 創(chuàng)建連接
const connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'password',
    database: 'mydatabase'
});

// 封裝查詢函數(shù)
function query(sql) {
    return new Promise((resolve, reject) => {
        connection.query(sql, function(err, results, fields) {
            if (err) {
                reject(err);
            } else {
                resolve(results);
            }
        });
    });
}

// 使用promise()函數(shù)進(jìn)行數(shù)據(jù)庫操作
query('SELECT * FROM users')
    .then(results => {
        console.log(results);
    })
    .catch(err => {
        console.log('[QUERY ERROR] - ', err.message);
    })
    .finally(() => {
        connection.end();
    });

無論是使用async/await還是promise()函數(shù)，都可以將異步操作轉(zhuǎn)化為同步的方式來完成對數(shù)據(jù)庫的操作。根據(jù)個人的喜好和項目需求，選擇適合的方式來使用Promise。