云数据库MySQL限时秒杀

const express = require('express');
const app = express();
const bodyParser = require('body-parser');
const mysql = require('mysql');

app.use(bodyParser.json());

// 创建数据库连接池
const pool = mysql.createPool({
  host: 'your_database_host',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database_name',
  connectionLimit: 100 // 根据需要调整连接数
});

// 秒杀接口
app.post('/seckill', (req, res) => {
  const { userId, productId } = req.body;

  pool.getConnection((err, connection) => {
    if (err) throw err;

    // 开启事务
    connection.beginTransaction(err => {
      if (err) {
        connection.release();
        return res.status(500).send('Transaction failed.');
      }

      // 检查库存
      connection.query('SELECT stock FROM products WHERE id = ?', [productId], (err, results) => {
        if (err) {
          return connection.rollback(() => {
            connection.release();
            res.status(500).send('Failed to check stock.');
          });
        }

        const stock = results[0].stock;
        if (stock <= 0) {
          return connection.rollback(() => {
            connection.release();
            res.status(400).send('Out of stock.');
          });
        }

        // 减少库存并记录订单
        connection.query('UPDATE products SET stock = stock - 1 WHERE id = ?', [productId], (err) => {
          if (err) {
            return connection.rollback(() => {
              connection.release();
              res.status(500).send('Failed to update stock.');
            });
          }

          connection.query('INSERT INTO orders (user_id, product_id) VALUES (?, ?)', [userId, productId], (err) => {
            if (err) {
              return connection.rollback(() => {
                connection.release();
                res.status(500).send('Failed to create order.');
              });
            }

            // 提交事务
            connection.commit(err => {
              if (err) {
                return connection.rollback(() => {
                  connection.release();
                  res.status(500).send('Transaction commit failed.');
                });
              }
              connection.release();
              res.status(200).send('Seckill successful!');
            });
          });
        });
      });
    });
  });
});

app.listen(3000, () => console.log('Server running on port 3000'));