AWS Amplify单表设计下GraphQL更新UserV0字段丢失问题求助

问题场景 #

使用AWS Amplify开发应用，采用单表设计，尝试通过GraphQL突变仅更新UserV0的profile字段（S3密钥），但执行后UserV0的其余字段（name、email）被置为null，整个嵌套对象被重置。

GraphQL Schema #

type SingleTable @model {
  pk: String! @primaryKey(sortKeyFields: ["sk"])
  sk: String!
  user: UserV0
  post: PostV0
}

type UserV0 {
  name: String
  username: String
  email: String
  profile: String
}

type PostV0 {
  ...
}

相关查询与突变 #

# 查询用户信息
query getUserInfo {
  getSingleTable(pk: "TEST", sk: "TEST") {
    user {
      username
      name
      profile
      email
    }
  }
}

# 创建初始数据
mutation createTable {
  createSingleTable(input: {pk: "TEST", sk: "TEST", user: {email: "email@email.com", name: "testname", profile: "testPath", username: "testusername"}}) {
    updatedAt
  }
}

# 导致字段丢失的更新突变
mutation updateTable {
  updateSingleTable(input: {pk: "TEST", sk: "TEST", user: {profile: "TESTING", username: "TESTING123"}}) {
    createdAt
  }
}

执行结果 #

• 创建数据后查询结果正常：

{
  "data": {
    "getSingleTable": {
      "user": {
        "username": "testusername",
        "name": "testname",
        "profile": "testPath",
        "email": "email@email.com"
      }
    }
  }
}

• 执行更新突变后，name和email被置为null：

{
  "data": {
    "getSingleTable": {
      "user": {
        "username": "TESTING123",
        "name": null,
        "profile": "TESTING",
        "email": null
      }
    }
  }
}

解决方案 #

方法1：使用深层字段路径进行部分更新 #

Amplify GraphQL支持通过点符号指定嵌套字段的路径，直接更新目标字段，无需传入整个嵌套对象。这种方式只会修改指定的字段，不会影响其他字段的值：

mutation updateTable {
  updateSingleTable(input: {
    pk: "TEST", 
    sk: "TEST", 
    "user.profile": "TESTING",
    "user.username": "TESTING123"
  }) {
    user {
      username
      name
      profile
      email
    }
  }
}

方法2：自定义Resolver实现增量更新（进阶） #

如果需要更复杂的更新逻辑，可以自定义DynamoDB的UpdateExpression来实现增量更新：

1. 在Amplify项目中生成自定义Resolver模板
2. 修改updateSingleTable的Resolver，将原来的替换逻辑改为使用SET操作更新指定字段：

#set($updateExpression = "SET")
#if($ctx.args.input.user)
  #foreach($key in $ctx.args.input.user.keySet())
    #set($updateExpression = "$updateExpression user.$key = :user_$key,")
    #set($ctx.args.input["user_$key"] = $ctx.args.input.user[$key])
  #end
#end
#set($ctx.args.input.updateExpression = $updateExpression.substring(0, $updateExpression.length() - 1))

这种方式需要熟悉Amplify的Resolver模板语法，适合复杂场景。

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