FeathersJS从1个REST调用将2条记录插入到MySql中

npm install @feathersjs/feathers @feathersjs/express @feathersjs/socketio feathers-sequelize mysql2

const feathers = require('@feathersjs/feathers');
const express = require('@feathersjs/express');
const Sequelize = require('sequelize');
const mysql2 = require('mysql2');

// 创建一个FeathersJS应用程序
const app = express(feathers());

// 配置MySQL数据库连接
const sequelize = new Sequelize('database', 'username', 'password', {
  dialect: 'mysql',
  dialectModule: mysql2,
  host: 'localhost',
  port: 3306
});

// 将Sequelize实例添加到应用程序的上下文中
app.set('sequelize', sequelize);

// 启动应用程序
app.listen(3000);

// 创建一个FeathersJS服务
app.use('/records', {
  async create(data) {
    const { record1, record2 } = data;

    // 获取Sequelize实例
    const sequelize = app.get('sequelize');

    // 获取MySQL模型
    const Record = sequelize.define('record', {
      record1: Sequelize.STRING,
      record2: Sequelize.STRING
    });

    // 插入记录到MySQL中
    await Record.bulkCreate([
      { record1, record2 },
      { record1, record2 }
    ]);

    return { success: true };
  }
});