0

我使用 MongoDB 作为我的联合 Apollo GraphQL API 的数据库。

（我的代码在 TypeScript 中）

我已经为解析器对象创建了一个__resolveReference方法，当我从如下调用它时它工作正常：Postuser service

User: {
...
    firstPost(user: any) {
            return { __typename: "Post", _id: user.firstPost };
        },
     }
...
}

但是，当我在数组上调用它时，它不起作用。以下是我的称呼：

User: {
...
      posts(user: any) {
            user.posts.map((x: any) => {
                return { __typename: "Post", _id: x };
            });
      },
...
}

邮编__resolveReference如下：

Post: {
...
async __resolveReference(reference: any, { db }: any) {
            console.log(reference);
            console.log(reference._id);
            try {
                let r = (await db
                    .collection("posts")
                    .findOne({ _id: new ObjectID(reference._id) })) as Post;

                console.log(r.content);

                return r;
            } catch (err) {
                console.log(err.stack);
            }
        },
...

我知道从对象上的解析器__resolveReference调用时没有“命中”，因为终端中没有显示 s，同样，仅来自解析器而不是。postsUserconsole.log()postsfirstPost

我需要一些帮助来获得__resolveReference数组的工作。

谢谢你。

4

2 回答 2

0

在 Apollo Federation 中__resolveReference，如果要返回数组，则返回数组无法正常工作，解决方案是创建一个新类型。例如，如果您在一个服务中User实现并在另一个服务中发布，则模型User和Post模型的简单表示是这样的：

typescript
-- User Service
    type User{
        id: ID!
        email: String!
        password: String!
    }

-- Post Service
    type Post{
        id: ID!
        content: String!
        postedBy: ID!
        date: Date
        comments: [String]!
    } 

Add a reference to Post type

    //define a key in Post
    type Post @key(fields:"id") 
    
    //Add a field on User like
    type User{
        id: ID!
        email: String!
        password: String!
        post: [Post]!
    }
    
    extend type Post @key(fields:"id"){
        id: ID! @external
    }

这种方法行不通。一个解决方案是在 中创建一个新类型Post Service：

    type PostList @key(fields: "idUser"){
        idUser: ID!
        posts: [Post]!
    }
    
    PostList : {
        __resolveReference(reference){
            //data is a array of post
            let userPost = data.filter((p)=>{p.postedBy==reference.idUser})
            return {idUser: reference.idUser, posts: userPost}
        }
    }

在您的User服务中这样做：

    type User{
        id: ID!
        email: String!
        password: String!
        posts: PostList
    }
    
    extend type PostList @key(fields:"idUser"){
        idUser: ID! @external
    }
    
    in User resolver
    User : {
        posts(_parent){
            return {__typename: "PostList", idUser: _parent.id}
        }
    }

并查看是否__resolveReference使用async/await功能。

于 2021-03-29T10:39:16.567 回答
0

处理此问题的另一种方法是使用服务上extend的User类型Post。

我在这个例子中使用了prisma，你可以使用任何 fetch 函数来解析你的数据，但是实践是一样的。

邮政服务

const resolvers = {
  User: {
    posts: async (root: any) => await prisma.post.findMany({ where: { userId: root.id } }),
  },
};

const typeDefs = gql`
  type Post {
    id: ID!
  }

  extend type User @key(fields: "id") {
    id: ID! @external
    posts: [Post]!
  }
`

用户服务

const resolvers = {
  Query: {
    user: async (_root: any, args: any) => await prisma.user.findUnique({ where: { id: args.id } })
  },
  User: {
    __resolveReference: async (root: any) => await prisma.user.findUnique({ where: { id: root.id } }),
  },
};

const typeDefs = gql`
  type Query {
    user(id: ID!): User
  }

  type User @key(fields: "id") {
    id: ID!
  }
`
于 2021-07-24T00:19:35.673 回答