Nodejs脚本快速导出MySQL数据库数据

 更新时间:2024年10月23日 08:38:15   作者:JYeontu  
在数据库管理和数据迁移的过程中,常常需要将数据库中的表数据和结构进行导出,本文将使用Node.js编写一个脚本实现快速从MySQL数据库中导出所有表的数据和结构,并保存为单独的SQL文件,需要的可以参考下

说在前面

在数据库管理和数据迁移的过程中,常常需要将数据库中的表数据和结构进行导出,以便进行备份、共享或在不同环境中使用。数据库数据备份的方法有很多,今天让我们用 Node.js 来编写一个脚本,快速从 MySQL 数据库中导出所有表的数据和结构,并保存为单独的 SQL 文件。

脚本编写

1. 模块引入

const mysql = require("mysql");
const fs = require("fs");
  • mysql模块用于连接和操作MySQL数据库
  • fs模块用于文件操作,将数据写入文件。

2. 数据库连接配置

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.");
});

定义了数据库连接配置对象dbConfig,包含主机名、用户名、密码和数据库名等信息。然后使用mysql.createConnection创建数据库连接,并通过connection.connect方法进行连接,若连接成功则打印相应信息。

3. 导出表数据和结构的函数

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!");
            }
          });
        }
      );
    }
  );
}
  • 这个函数接受表名tableName作为参数,还有一个可选参数close,用于控制是否在导出完成后关闭数据库连接。
  • 首先查询表的创建语句:
connection.query(
  `SHOW CREATE TABLE ${tableName}`,
  (error, results, fields) => {
    //...
  }
);

然后查询表中的所有数据:

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

对于查询到的数据,将每行数据转换为INSERT INTO语句:

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");

最后将表的创建语句和所有数据的INSERT INTO语句组合起来写入到以表名命名的.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. 执行导出操作

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);
  });
});

通过查询数据库中的所有表,然后对每个表调用exportTableData函数进行数据和结构的导出,当处理到最后一个表时,会根据exportTableData函数的close参数设置来决定是否关闭数据库连接。

测试

创建数据库

CREATE DATABASE test;

创建表

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

插入数据

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

导出数据

到此这篇关于Nodejs脚本快速导出MySQL数据库数据的文章就介绍到这了,更多相关Nodejs导出MySQL数据库数据内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • nodejs连接mongodb数据库实现增删改查

    nodejs连接mongodb数据库实现增删改查

    本篇文章主要结合了nodejs操作mongodb数据库实现增删改查,包括对数据库的增加,删除,查找和更新,有兴趣的可以了解一下。
    2016-12-12
  • node+vue实现用户注册和头像上传的实例代码

    node+vue实现用户注册和头像上传的实例代码

    本篇文章主要介绍了node+vue实现用户注册和头像上传的实例代码,具有一定的参考价值,有兴趣的可以了解一下
    2017-07-07
  • 如何在node.js中使用​JsonWebToken模块进行token加密

    如何在node.js中使用​JsonWebToken模块进行token加密

    目前在web框架中最流行的身份验证是使用jsonwebtoken,简称jwt.可以设置加密方式,过期时间,存放个人信息,逆解析,下面这篇文章主要给大家介绍了关于如何在node.js中使用​JsonWebToken模块进行token加密的相关资料,需要的朋友可以参考下
    2023-03-03
  • 解决linux下node.js全局模块找不到的问题

    解决linux下node.js全局模块找不到的问题

    今天小编就为大家分享一篇解决linux下node.js全局模块找不到的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05
  • 解决Mac安装thrift因bison报错的问题

    解决Mac安装thrift因bison报错的问题

    今天小编就为大家分享一篇解决Mac安装thrift因bison报错的问题,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧
    2018-05-05
  • Node.js 实现简单的无侵入式缓存框架的方法

    Node.js 实现简单的无侵入式缓存框架的方法

    这篇文章主要介绍了Node.js 实现简单的无侵入式缓存框架的方法,本文给大家介绍的非常详细,具有一定的参考借鉴价值,需要的朋友可以参考下
    2019-07-07
  • Node.js中process模块常用的属性和方法

    Node.js中process模块常用的属性和方法

    Node.js中的process模块用来与当前进程互动,可以通过全局变量process访问,不必使用require命令加载。它是一个EventEmitter对象的实例。下面这篇文章给大家介绍了Node.js中process模块常用的属性和方法,有需要的朋友们可以参考借鉴,下面来一起看看吧。
    2016-12-12
  • NodeJs环境中NODE_ENV介绍和设置方法

    NodeJs环境中NODE_ENV介绍和设置方法

    这篇文章主要给大家介绍了关于NodeJs环境中NODE_ENV介绍和设置的相关资料,NODE_ENV其实就是环境变量之一,用于设置nodejs当前的运行环境,需要的朋友可以参考下
    2024-07-07
  • Node.js开发之套接字(socket)编程入门示例

    Node.js开发之套接字(socket)编程入门示例

    这篇文章主要介绍了Node.js开发之套接字(socket)编程,结合简单实例形式分析了node.js套接字socket客户端与服务器端相关实现与使用技巧,需要的朋友可以参考下
    2019-11-11
  • Node.js连接MySQL数据库的操作步骤

    Node.js连接MySQL数据库的操作步骤

    在现代 Web 开发中,与数据库的交互是不可避免的一部分,Node.js提供了许多库和模块,使得连接和操作 MySQL 数据库变得相对简单,本文将介绍如何使用Node.js连接MySQL数据库,并进行一些基本的操作,文中通过代码示例介绍的非常详细,需要的朋友可以参考下
    2023-11-11

最新评论