带数据库的留言板

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

const app = express();
app.use(express.json());

const db = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'message_board'
});

db.connect(err => {
  if (err) throw err;
  console.log('Database connected!');
});

app.post('/messages', (req, res) => {
  const { name, message } = req.body;
  const sql = 'INSERT INTO messages (name, message) VALUES (?, ?)';
  db.query(sql, [name, message], (err, result) => {
    if (err) return res.status(500).send(err);
    res.status(201).send('Message posted!');
  });
});

app.get('/messages', (req, res) => {
  const sql = 'SELECT * FROM messages';
  db.query(sql, (err, results) => {
    if (err) return res.status(500).send(err);
    res.json(results);
  });
});

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