Node Express在中间件中从数据库获取用户

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

const app = express();

// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'username',
  password: 'password',
  database: 'database_name'
});

// 连接数据库
connection.connect((err) => {
  if (err) {
    console.error('Error connecting to database: ' + err.stack);
    return;
  }
  console.log('Connected to database as id ' + connection.threadId);
});

// 中间件
app.use((req, res, next) => {
  // 从数据库获取用户数据
  connection.query('SELECT * FROM users', (err, results) => {
    if (err) {
      console.error('Error querying database: ' + err.stack);
      return;
    }
    // 处理用户数据或进行进一步操作
    req.users = results;
    next();
  });
});

// 路由处理程序
app.get('/users', (req, res) => {
  // 使用从数据库获取的用户数据进行响应
  res.json(req.users);
});

// 启动服务器
app.listen(3000, () => {
  console.log('Server started on port 3000');
});