NodeJS - mysql的包在执行了INSERT INTO...准备好了？

const mysql = require('mysql');

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

connection.connect((err) => {
  if (err) {
    console.error('Error connecting to MySQL database: ' + err.stack);
    return;
  }
  console.log('Connected to MySQL database as id ' + connection.threadId);
});

const sql = 'INSERT INTO mytable (column1, column2) VALUES (?, ?)';
const values = ['value1', 'value2'];

connection.query(sql, values, (err, result) => {
  if (err) {
    console.error('Error executing INSERT INTO query: ' + err.stack);
    return;
  }
  console.log('INSERT INTO query executed successfully');
  console.log('Affected rows: ' + result.affectedRows);
});

connection.end((err) => {
  if (err) {
    console.error('Error closing MySQL connection: ' + err.stack);
    return;
  }
  console.log('MySQL connection closed');
});

const mysql = require('mysql');

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

const connect = () => {
  return new Promise((resolve, reject) => {
    connection.connect((err) => {
      if (err) {
        reject(err);
      } else {
        resolve();
      }
    });
  });
};

const executeQuery = (sql, values) => {
  return new Promise((resolve, reject) => {
    connection.query(sql, values, (err, result) => {
      if (err) {
        reject(err);
      } else {
        resolve(result);
      }
    });
  });
};

const closeConnection = () => {
  return new Promise((resolve, reject) => {
    connection.end((err) => {
      if (err) {
        reject(err);
      } else {
        resolve();
      }
    });
  });
};

const sql = 'INSERT INTO mytable (column1, column2) VALUES (?, ?)';
const values = ['value1', 'value2'];

connect()
  .then(() => {
    console.log('Connected to MySQL database as id ' + connection.threadId);
    return executeQuery(sql, values);
  })
  .then((result) => {
    console.log('INSERT INTO query executed successfully');
    console.log('Affected rows: ' + result.affectedRows);
    return closeConnection();
  })
  .then(() => {
    console.log('MySQL connection closed');
  })
  .catch((err) => {
    console.error('Error: ' + err.stack);
  });