cd my-express-app
npm i mysql -S

// app.js
const express = require('express');
const mysql = require('mysql2');

配置mysql

// dbConfig.js
const dbConfig = {
  host: 'localhost',
  user: 'root',
  password: 'your_password',
  database: 'your_database'
};

const pool = mysql.createPool(dbConfig);

在express应用中设置路由，用于处理与MySQL数据库的交互：

 // 查询操作
app.get('/users', (req, res) => {
  const sql = 'SELECT * FROM users';
  pool.query(sql, (error, results) => {
    if (error) throw error;
    res.json(results);
  });
});

// 插入操作
app.post('/users', (req, res) => {
  const user = req.body;
  const sql = 'INSERT INTO users (username, password) VALUES (?, ?)';
  pool.query(sql, [user.username, user.password], (error, results) => {
    if (error) throw error;
    res.json({ message: 'User created successfully', id: results.insertId });
  });
});

// 更新操作
app.put('/users/:id', (req, res) => {
  const id = req.params.id;
  const updates = req.body;
  const sql = 'UPDATE users SET username = ?, password = ? WHERE id = ?';
  pool.query(sql, [updates.username, updates.password, id], (error, results) => {
    if (error) throw error;
    res.json({ message: 'User updated successfully', affectedRows: results.affectedRows });
  });
});

// 删除操作
app.delete('/users/:id', (req, res) => {
  const id = req.params.id;
  const sql = 'DELETE FROM users WHERE id = ?';
  pool.query(sql, [id], (error, results) => {
    if (error) throw error;
    res.json({ message: 'User deleted successfully', affectedRows: results.affectedRows });
  });
});

启动Express应用

const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`Server is running on port ${PORT}`);
});