快捷導(dǎo)航

Nodejs腳本快速導(dǎo)出MySQL數(shù)據(jù)庫(kù)數(shù)據(jù)

更新時(shí)間：2024年10月23日 08:38:15 作者：JYeontu

在數(shù)據(jù)庫(kù)管理和數(shù)據(jù)遷移的過(guò)程中,常常需要將數(shù)據(jù)庫(kù)中的表數(shù)據(jù)和結(jié)構(gòu)進(jìn)行導(dǎo)出,本文將使用Node.js編寫(xiě)一個(gè)腳本實(shí)現(xiàn)快速?gòu)腗ySQL數(shù)據(jù)庫(kù)中導(dǎo)出所有表的數(shù)據(jù)和結(jié)構(gòu),并保存為單獨(dú)的SQL文件,需要的可以參考下

說(shuō)在前面

在數(shù)據(jù)庫(kù)管理和數(shù)據(jù)遷移的過(guò)程中，常常需要將數(shù)據(jù)庫(kù)中的表數(shù)據(jù)和結(jié)構(gòu)進(jìn)行導(dǎo)出，以便進(jìn)行備份、共享或在不同環(huán)境中使用。數(shù)據(jù)庫(kù)數(shù)據(jù)備份的方法有很多，今天讓我們用 Node.js 來(lái)編寫(xiě)一個(gè)腳本，快速?gòu)?MySQL 數(shù)據(jù)庫(kù)中導(dǎo)出所有表的數(shù)據(jù)和結(jié)構(gòu)，并保存為單獨(dú)的 SQL 文件。

腳本編寫(xiě)

1. 模塊引入

const mysql = require("mysql");
const fs = require("fs");

mysql模塊用于連接和操作MySQL數(shù)據(jù)庫(kù)
fs模塊用于文件操作，將數(shù)據(jù)寫(xiě)入文件。

2. 數(shù)據(jù)庫(kù)連接配置

const dbConfig = {
  host: "localhost",
  user: "root",
  password: "password",
  database: "test",
};

const connection = mysql.createConnection(dbConfig);

connection.connect((error) => {
  if (error) throw error;
  console.log("Successfully connected to the database.");
});

定義了數(shù)據(jù)庫(kù)連接配置對(duì)象dbConfig，包含主機(jī)名、用戶(hù)名、密碼和數(shù)據(jù)庫(kù)名等信息。然后使用mysql.createConnection創(chuàng)建數(shù)據(jù)庫(kù)連接，并通過(guò)connection.connect方法進(jìn)行連接，若連接成功則打印相應(yīng)信息。

3. 導(dǎo)出表數(shù)據(jù)和結(jié)構(gòu)的函數(shù)

function exportTableData(tableName, close = false) {
  connection.query(
    `SHOW CREATE TABLE ${tableName}`,
    (error, results, fields) => {
      if (error) throw error;

      const createTableStatement = results[0]["Create Table"];

      connection.query(
        `SELECT * FROM ${tableName}`,
        (error, results, fields) => {
          if (error) throw error;

          const insertStatements = results
            .map((row) => {
              const keys = [],
                values = [];
              Object.entries(row).forEach((item) => {
                keys.push(item[0]);
                values.push(`'${item[1]}'`);
              });
              return `INSERT INTO ${tableName} (${keys.join(
                ","
              )}) VALUES (${values.join(",")});`;
            })
            .join("\n");

          const sql = `${createTableStatement};\n\n${insertStatements}`;

          fs.writeFile(`${tableName}.sql`, sql, (err) => {
            if (err) throw err;
            console.log(`Data from ${tableName} exported successfully.`);
            if (close) {
              connection.end();
              console.log("All exported!");
            }
          });
        }
      );
    }
  );
}

這個(gè)函數(shù)接受表名tableName作為參數(shù)，還有一個(gè)可選參數(shù)close，用于控制是否在導(dǎo)出完成后關(guān)閉數(shù)據(jù)庫(kù)連接。
首先查詢(xún)表的創(chuàng)建語(yǔ)句：

connection.query(
  `SHOW CREATE TABLE ${tableName}`,
  (error, results, fields) => {
    //...
  }
);

然后查詢(xún)表中的所有數(shù)據(jù)：

connection.query(
  `SELECT * FROM ${tableName}`,
  (error, results, fields) => {
    //...
  }
);

對(duì)于查詢(xún)到的數(shù)據(jù)，將每行數(shù)據(jù)轉(zhuǎn)換為INSERT INTO語(yǔ)句：

const insertStatements = results
 .map((row) => {
    const keys = [],
      values = [];
    Object.entries(row).forEach((item) => {
      keys.push(item[0]);
      values =append('${item[1]}');
    });
    return `INSERT INTO ${tableName} (${keys.join(
      ","
    )}) VALUES (${values.join(",")});`;
  })
 .join("\n");

最后將表的創(chuàng)建語(yǔ)句和所有數(shù)據(jù)的INSERT INTO語(yǔ)句組合起來(lái)寫(xiě)入到以表名命名的.sql文件中：

const sql = `${createTableStatement};\n\n${insertStatements}`;

fs.writeFile(`${tableName}.sql`, sql, (err) => {
  if (err) throw err;
  console.log(`Data from ${tableName} exported successfully.`);
  if (close) {
    connection.end();
    console.log("All exported!");
  }
});

4. 執(zhí)行導(dǎo)出操作

connection.query("SHOW TABLES", (error, results, fields) => {
  if (error) throw error;

  results.forEach((result, index) => {
    const tableName = result[`Tables_in_${dbConfig.database}`];
    exportTableData(tableName, index === results.length - 1);
  });
});

通過(guò)查詢(xún)數(shù)據(jù)庫(kù)中的所有表，然后對(duì)每個(gè)表調(diào)用exportTableData函數(shù)進(jìn)行數(shù)據(jù)和結(jié)構(gòu)的導(dǎo)出，當(dāng)處理到最后一個(gè)表時(shí)，會(huì)根據(jù)exportTableData函數(shù)的close參數(shù)設(shè)置來(lái)決定是否關(guān)閉數(shù)據(jù)庫(kù)連接。

測(cè)試

創(chuàng)建數(shù)據(jù)庫(kù)

CREATE DATABASE test;

創(chuàng)建表

CREATE TABLE `t_user` (
  `id` int NOT NULL AUTO_INCREMENT,
  `name` varchar(255) NOT NULL,
  `age` int NOT NULL,
  PRIMARY KEY (`id`)
)

插入數(shù)據(jù)

INSERT INTO t_user (name,age) VALUES ('張三', 25);
INSERT INTO t_user (name,age) VALUES ('李四', 24);

導(dǎo)出數(shù)據(jù)

到此這篇關(guān)于Nodejs腳本快速導(dǎo)出MySQL數(shù)據(jù)庫(kù)數(shù)據(jù)的文章就介紹到這了,更多相關(guān)Nodejs導(dǎo)出MySQL數(shù)據(jù)庫(kù)數(shù)據(jù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: