Express / MYSQL请求加入用户和消息

CREATE TABLE users (
  id INT PRIMARY KEY AUTO_INCREMENT,
  name VARCHAR(255),
  email VARCHAR(255)
);

CREATE TABLE messages (
  id INT PRIMARY KEY AUTO_INCREMENT,
  user_id INT,
  message TEXT,
  FOREIGN KEY (user_id) REFERENCES users(id)
);

const express = require('express');
const mysql = require('mysql');

const app = express();

// 创建与MYSQL数据库的连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'your_username',
  password: 'your_password',
  database: 'your_database'
});

// 连接到MYSQL数据库
connection.connect();

// 添加用户的路由
app.post('/users', (req, res) => {
  const { name, email } = req.body;

  // 将用户数据插入到MYSQL数据库中的"users"表中
  const query = `INSERT INTO users (name, email) VALUES ('${name}', '${email}')`;

  connection.query(query, (error, results) => {
    if (error) throw error;

    res.send('User added successfully!');
  });
});

// 添加消息的路由
app.post('/messages', (req, res) => {
  const { user_id, message } = req.body;

  // 将消息数据插入到MYSQL数据库中的"messages"表中
  const query = `INSERT INTO messages (user_id, message) VALUES (${user_id}, '${message}')`;

  connection.query(query, (error, results) => {
    if (error) throw error;

    res.send('Message added successfully!');
  });
});

// 启动Express应用程序
app.listen(3000, () => {
  console.log('Server is running on port 3000');
});