通过不带mysqldump的nodejs恢复MySQL sql转储

const fs = require('fs');
const mysql = require('mysql2');

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'username',
  password: 'password',
  database: 'database_name'
});

const sqlDump = fs.readFileSync('path/to/sql_dump.sql', 'utf8');

const sqlStatements = sqlDump.split(';');

connection.connect((err) => {
  if (err) {
    console.error('Error connecting to database:', err);
    return;
  }

  console.log('Connected to database.');
});

sqlStatements.forEach((sqlStatement) => {
  connection.query(sqlStatement, (err, results) => {
    if (err) {
      console.error('Error executing SQL statement:', err);
      return;
    }

    console.log('SQL statement executed successfully.');
  });
});

connection.end((err) => {
  if (err) {
    console.error('Error closing database connection:', err);
    return;
  }

  console.log('Database connection closed.');
});