使用apollo-server-express时如何在Express侧调用Apollo mutation更新数据

有两种常见的落地方式，可根据你的项目场景选择：

方案1：抽离通用业务逻辑，两端复用（优先推荐） #

Apollo的Resolver本质是普通函数，你可以把Mutation对应的核心逻辑抽成独立的服务层函数，Express路由和Apollo Resolver共享调用即可，无额外HTTP开销，代码复用性最高。

步骤1：抽离通用用户更新逻辑 #

// user.service.js 通用服务层
export const updateUserService = async (userId, updateFields, operatorId) => {
  // 权限校验逻辑可统一放在这里
  if (userId !== operatorId) {
    throw new Error('无操作权限')
  }
  // 执行数据库更新操作，示例为Mongoose写法，可替换为你的ORM操作
  const updatedUser = await UserModel.findByIdAndUpdate(
    userId,
    updateFields,
    { new: true, runValidators: true }
  )
  return updatedUser
}

步骤2：Apollo Resolver调用服务层逻辑 #

// resolvers.js
import { updateUserService } from './user.service.js'

export const resolvers = {
  Mutation: {
    updateUser: async (_, { userId, input }, { user }) => {
      // 透传当前登录用户id作为操作人id
      return updateUserService(userId, input, user.id)
    }
  }
}

步骤3：Express路由直接调用服务层逻辑 #

// user.routes.js Express路由
import { updateUserService } from './user.service.js'
// 复用和Apollo Context相同的鉴权中间件，保证登录态逻辑一致
import { authMiddleware } from './auth.middleware.js'

app.put('/api/users/:userId', authMiddleware, async (req, res) => {
  try {
    const updatedUser = await updateUserService(
      req.params.userId,
      req.body,
      req.user.id // 从Express鉴权中间件获取登录用户id
    )
    res.status(200).json({ data: updatedUser })
  } catch (err) {
    res.status(400).json({ error: err.message })
  }
})

方案2：调用本地GraphQL端点执行Mutation（适合临时快速实现） #

如果不想调整现有代码结构，可在Express路由中直接请求本地Apollo服务的GraphQL端点，执行目标Mutation。

import fetch from 'node-fetch'
import { authMiddleware } from './auth.middleware.js'

app.patch('/api/users/:userId', authMiddleware, async (req, res) => {
  try {
    const gqlRes = await fetch('http://localhost:4000/graphql', { // 替换为你的Apollo服务地址
      method: 'POST',
      headers: {
        'Content-Type': 'application/json',
        'Authorization': req.headers.authorization || '', // 透传鉴权头
        'Apollo-Require-Preflight': 'true' // 若开启了Apollo CSRF防护需加此头
      },
      body: JSON.stringify({
        query: `
          mutation UpdateUser($userId: ID!, $input: UserUpdateInput!) {
            updateUser(userId: $userId, input: $input) {
              id
              nickname
              email
              avatar
            }
          }
        `,
        variables: {
          userId: req.params.userId,
          input: req.body
        }
      })
    })
    const result = await gqlRes.json()
    if (result.errors) {
      return res.status(400).json({ errors: result.errors })
    }
    res.status(200).json(result.data.updateUser)
  } catch (err) {
    res.status(500).json({ error: '请求失败：' + err.message })
  }
})

方案对比 #

• 方案1：无额外网络开销，逻辑统一维护，后续迭代只需要改一次服务层代码，适合长期维护的项目
• 方案2：不需要调整现有Apollo代码结构，但有额外HTTP请求开销，需要处理鉴权透传、CSRF等兼容问题，适合临时需求快速落地

注意：如果你的Apollo Server和Express服务部署在同一实例下，也可以直接调用Apollo Server的executeOperation方法执行mutation，不需要走网络请求，性能介于两者之间。

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