如何动态修改查询值？Express+Sequelize用户帖子类型统计

嘿，我来帮你搞定这两个问题：

在Express+Sequelize的开发场景里，动态修改查询值其实很常见，核心思路就是根据外部输入（比如请求参数、前端传的值）来动态构建查询条件、字段或者排序规则。给你几个常用的场景示例：

• 动态添加WHERE过滤条件
  比如前端可能会传type参数来筛选帖子，我们就可以根据这个参数是否存在，动态给查询加条件：

router.route('/posts').get(async (req, res) => {
  const { type } = req.query;
  const whereOpts = {};
  // 如果有type参数，就把它加入查询条件
  if (type) {
    whereOpts.type = type;
  }
  const posts = await Post.findAll({ where: whereOpts });
  res.json(posts);
});

• 动态指定返回字段
  如果前端需要灵活获取不同的用户字段，比如传fields=name,email，我们就可以拆分这个参数来动态设置查询的attributes：

router.route('/users/:id').get(async (req, res) => {
  const { fields } = req.query;
  // 默认返回id、name、email，有传fields就用传的字段
  const attributes = fields ? fields.split(',') : ['id', 'name', 'email'];
  const user = await User.findByPk(req.params.id, { attributes });
  res.json(user);
});

• 动态调整排序规则
  根据前端传的sortBy和order参数，动态设置查询的排序方式：

router.route('/posts').get(async (req, res) => {
  const { sortBy, order } = req.query;
  // 默认按创建时间倒序，有传参数就用指定的排序规则
  const orderOpts = sortBy ? [[sortBy, order || 'ASC']] : [['createdAt', 'DESC']];
  const posts = await Post.findAll({ order: orderOpts });
  res.json(posts);
});

针对你这个User和Post关联的场景，要返回{name: "...", typeOne: x, typeTwo: y, typeThree: z}的格式，我给你两种靠谱的实现方式：

方法一：用Sequelize模型查询（推荐，符合ORM风格） #

通过关联查询+聚合函数来统计不同type的帖子数量，代码如下：

router.route('/:id').get(async (req, res) => {
  try {
    const user = await User.findByPk(req.params.id, {
      attributes: [
        'name',
        // 统计type=1的帖子，别名typeOne
        [sequelize.fn('COUNT', sequelize.literal('CASE WHEN "Posts"."type" = 1 THEN 1 END')), 'typeOne'],
        // 统计type=2的帖子，别名typeTwo
        [sequelize.fn('COUNT', sequelize.literal('CASE WHEN "Posts"."type" = 2 THEN 1 END')), 'typeTwo'],
        // 统计type=3的帖子，别名typeThree
        [sequelize.fn('COUNT', sequelize.literal('CASE WHEN "Posts"."type" = 3 THEN 1 END')), 'typeThree']
      ],
      include: [
        {
          model: Post,
          attributes: [] // 不需要返回Post的具体字段，只用来统计
        }
      ],
      group: ['User.id', 'User.name'], // 按用户分组，确保统计的是当前用户的帖子
      raw: true // 返回原始对象，方便直接格式化返回
    });

    if (!user) {
      return res.status(404).json({ message: '用户不存在' });
    }

    // 把字符串类型的计数转成数字，避免前端处理麻烦
    const result = {
      name: user.name,
      typeOne: parseInt(user.typeOne) || 0,
      typeTwo: parseInt(user.typeTwo) || 0,
      typeThree: parseInt(user.typeThree) || 0
    };

    res.json(result);
  } catch (error) {
    console.error(error);
    res.status(500).json({ message: '服务器出错啦' });
  }
});

方法二：用原生SQL查询（更直观，适合复杂统计场景） #

如果觉得ORM的写法有点绕，直接写原生SQL会更清晰：

router.route('/:id').get(async (req, res) => {
  try {
    const [result] = await sequelize.query(`
      SELECT 
        u.name,
        COUNT(CASE WHEN p.type = 1 THEN 1 END) AS typeOne,
        COUNT(CASE WHEN p.type = 2 THEN 1 END) AS typeTwo,
        COUNT(CASE WHEN p.type = 3 THEN 1 END) AS typeThree
      FROM "Users" u
      LEFT JOIN "Posts" p ON u.id = p."userId"
      WHERE u.id = :userId
      GROUP BY u.id, u.name
    `, {
      replacements: { userId: req.params.id }, // 用参数化查询避免SQL注入
      type: sequelize.QueryTypes.SELECT
    });

    if (!result) {
      return res.status(404).json({ message: '用户不存在' });
    }

    const formattedResult = {
      name: result.name,
      typeOne: parseInt(result.typeOne) || 0,
      typeTwo: parseInt(result.typeTwo) || 0,
      typeThree: parseInt(result.typeThree) || 0
    };

    res.json(formattedResult);
  } catch (error) {
    console.error(error);
    res.status(500).json({ message: '服务器出错啦' });
  }
});

这里用LEFT JOIN是为了确保即使用户没有某类帖子，对应的计数也会是0，而不是返回null，刚好符合你的需求。

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