在Node JS中调用函数并在MySQL中并行插入

npm install mysql mysql2

const mysql = require('mysql2');

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'your_database_name'
});

// 函数调用
function insertData(data) {
  return new Promise((resolve, reject) => {
    // 执行插入语句
    connection.query('INSERT INTO your_table_name SET ?', data, (error, results) => {
      if (error) {
        reject(error);
      } else {
        resolve(results);
      }
    });
  });
}

// 并行插入数据
async function parallelInsert() {
  try {
    const data = [
      { name: 'John', age: 25 },
      { name: 'Jane', age: 30 },
      { name: 'Bob', age: 35 }
    ];

    // 创建并行任务数组
    const tasks = data.map(insertData);

    // 等待所有插入任务完成
    const results = await Promise.all(tasks);
    console.log('Data inserted:', results);
  } catch (error) {
    console.error('Error inserting data:', error);
  } finally {
    // 关闭数据库连接
    connection.end();
  }
}

// 执行并行插入
parallelInsert();