MySQL使用Knex.js进行多行插入

在本文中，我们将探讨如何使用Knex.js来实现MySQL数据库的多行插入。Knex.js是一个基于Node.js的SQL查询构建器，它支持多种数据库，例如：MySQL、PostgreSQL、SQLite等。针对MySQL数据库的多行插入，我们可以通过以下两种方法来实现：使用Knex.js的batchInsert()方法或使用原生的INSERT INTO语句。

阅读更多：MySQL 教程

使用batchInsert()方法插入数据

batchInsert()方法是Knex.js提供的一个插入多行数据的方法。它可以在一次数据库查询中插入多个数据，提高了性能。与传统的insert()方法不同，我们需要将数据格式化成一个数组，然后再传递给batchInsert()方法。

假设我们有一个users表，其包含如下字段：

那么，我们可以使用以下代码来实现多行插入：

const users = [
  { name: 'user1', age: 18, email: 'user1@example.com' },
  { name: 'user2', age: 20, email: 'user2@example.com' },
  { name: 'user3', age: 22, email: 'user3@example.com' }
];

knex('users')
  .batchInsert(users)
  .then(() => {
    console.log('数据插入成功');
  })
  .catch((err) => {
    console.log('数据插入失败：', err);
  });

如果我们需要一次性插入更多的数据，我们可以对batchInsert()方法进行如下调整：

knex('users')
  .batchInsert(users, 1000) // 一次插入1000条数据
  .then(() => {
    console.log('数据插入成功');
  })
  .catch((err) => {
    console.log('数据插入失败：', err);
  });

当我们需要在插入之前进行一些数据预处理时，我们可以定义一个mapper函数，例如：

const mapUsers = (users) => {
  return users.map((user) => {
    return {
      name: user.firstName + ' ' + user.lastName,
      age: user.age,
      email: user.email
    };
  });
};

const rawData = [
  { firstName: 'Adam', lastName: 'Smith', age: 18, email: 'adam@example.com' },
  { firstName: 'John', lastName: 'Doe', age: 22, email: 'john@example.com' },
  { firstName: 'Jane', lastName: 'Doe', age: 20, email: 'jane@example.com' }
];

const users = mapUsers(rawData);

knex('users')
  .batchInsert(users)
  .then(() => {
    console.log('数据插入成功');
  })
  .catch((err) => {
    console.log('数据插入失败：', err);
  });

使用INSERT INTO语句插入数据

在某些特殊情况下，我们可能需要使用原生的INSERT INTO语句来插入多行数据。这通常是因为我们需要使用MySQL的特殊功能，例如：ON DUPLICATE KEY UPDATE等。在这种情况下，我们可以通过以下代码来实现：

const users = [
  { name: 'user1', age: 18, email: 'user1@example.com' },
  { name: 'user2', age: 20, email: 'user2@example.com' },
  { name: 'user3', age: 22, email: 'user3@example.com' }
];

const placeholders = users.map(() => '(?, ?, ?)').join(', ');

const values = users.reduce((acc, user) => [...acc, user.name, user.age, user.email], []);

const sql = `INSERT INTO users (name, age, email) VALUES ${placeholders} ON DUPLICATE KEY UPDATE age=VALUES(age),email=VALUES(email)`;

knex.raw(sql, values)
  .then(() => {
    console.log('数据插入成功');
  })
  .catch((err) => {
    console.log('数据插入失败：', err);
  });

在上面的代码中，我们首先使用map()函数生成占位符，然后使用reduce()函数将所有数据值组成一个数组。最后，我们将这些占位符和值插入到INSERT INTO语句中，并在它之后添加ON DUPLICATE KEY UPDATE语句。

总结

使用Knex.js的batchInsert()方法或使用原生的INSERT INTO语句都可以实现MySQL数据库的多行插入。batchInsert()方法适用于大多数情况下，但我们需要使用MySQL的特殊功能时，我们应该使用原生的INSERT INTO语句。通过本文介绍的两种方法，我们可以更好地管理和处理MySQL数据库中的数据。