Express.js中检查参数是否为空并存储非空参数及指定邮箱

嘿，我来一步步帮你实现这个需求，咱们分模块来，代码都是可直接运行的，我会尽量写清楚每个步骤的作用：

1. 准备工作：初始化项目与依赖 #

首先确保你已经初始化了Express项目，然后安装数据库相关的依赖（这里用MySQL为例，你也可以换成SQLite、PostgreSQL等，思路完全通用）：

npm install express mysql2

2. 数据库连接配置 #

先创建一个数据库连接文件db.js，用连接池来管理数据库连接（比单连接更高效稳定）：

const mysql = require('mysql2/promise');

// 替换成你的数据库实际配置
const dbConfig = {
  host: 'localhost',
  user: 'your_db_username',
  password: 'your_db_password',
  database: 'your_db_name'
};

const pool = mysql.createPool(dbConfig);

module.exports = pool;

3. 核心功能实现：参数过滤、表格创建与数据插入 #

接下来在你的Express主文件（比如app.js）或者单独的路由文件里写核心逻辑：

const express = require('express');
const pool = require('./db');
const app = express();

// 解析请求体（如果参数是POST方式传递，必须加这两个中间件）
app.use(express.urlencoded({ extended: true }));
app.use(express.json());

app.post('/store-data', async (req, res) => {
  try {
    // 第一步：过滤请求中的非空参数
    // 这里默认取req.body的参数，如果是URL查询参数，改成req.query即可
    const nonEmptyParams = {};
    for (const [key, value] of Object.entries(req.body)) {
      // 过滤空字符串、null、undefined的参数，你可以根据需求调整规则
      if (value !== '' && value != null) {
        nonEmptyParams[key] = value;
      }
    }

    // 如果没有非空参数，直接返回错误
    if (Object.keys(nonEmptyParams).length === 0) {
      return res.status(400).json({ message: '没有可存储的非空参数' });
    }

    // 第二步：创建表格（如果表格不存在的话）
    // 这里用通用的key-value结构，适配任意参数，也可以根据参数动态生成列（看你需求）
    await pool.execute(`
      CREATE TABLE IF NOT EXISTS request_data (
        id INT AUTO_INCREMENT PRIMARY KEY,
        param_key VARCHAR(255) NOT NULL,
        param_value TEXT NOT NULL,
        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
      )
    `);

    // 第三步：批量插入所有非空参数
    const paramInsertPromises = [];
    for (const [key, value] of Object.entries(nonEmptyParams)) {
      paramInsertPromises.push(
        pool.execute(
          'INSERT INTO request_data (param_key, param_value) VALUES (?, ?)',
          [key, value]
        )
      );
    }
    // 并行执行插入，提升效率
    await Promise.all(paramInsertPromises);

    // 第四步：插入指定邮箱到表格
    const targetEmails = ['m1@yourdomain.com', 'm2@yourdomain.com', 'm9@yourdomain.com', 'm11@yourdomain.com'];
    const emailInsertPromises = [];
    for (const email of targetEmails) {
      emailInsertPromises.push(
        pool.execute(
          'INSERT INTO request_data (param_key, param_value) VALUES (?, ?)',
          ['email', email]
        )
      );
    }
    await Promise.all(emailInsertPromises);

    res.status(200).json({ message: '所有数据存储成功！' });
  } catch (error) {
    console.error('存储数据时出错:', error);
    res.status(500).json({ message: '服务器内部错误，请稍后重试' });
  }
});

// 启动服务器
const PORT = process.env.PORT || 3000;
app.listen(PORT, () => {
  console.log(`服务器运行在 http://localhost:${PORT}`);
});

4. 可选优化：动态生成表格列（如果需要） #

如果你希望表格的列直接对应请求参数的键（比如参数有username、phone，就创建username、phone列），可以替换表格创建和数据插入的逻辑：

// 动态生成表格列
const paramColumns = Object.keys(nonEmptyParams).map(key => `${key} TEXT`).join(', ');
// 添加邮箱相关的列（如果需要单独存邮箱）
const fullColumns = `${paramColumns}, email TEXT`;

// 创建动态结构的表格
await pool.execute(`
  CREATE TABLE IF NOT EXISTS dynamic_request_data (
    id INT AUTO_INCREMENT PRIMARY KEY,
    ${fullColumns},
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
  )
`);

// 插入数据时，把参数和邮箱组合（这里假设每个邮箱对应一条记录，你可以根据需求调整）
for (const email of targetEmails) {
  const insertData = { ...nonEmptyParams, email };
  const keys = Object.keys(insertData).join(', ');
  const placeholders = Object.keys(insertData).map(() => '?').join(', ');
  await pool.execute(
    `INSERT INTO dynamic_request_data (${keys}) VALUES (${placeholders})`,
    Object.values(insertData)
  );
}

不过这种动态列的方式灵活性较低，推荐优先用之前的key-value结构，适配更多参数场景。

内容的提问来源于stack exchange，提问作者Taieb