要使用AppSync中的@connection指令进行查询,需要遵循以下步骤:
在AppSync控制台中,打开数据源,并确保已经设置了关联的数据模型。
在schema.graphql文件中定义数据模型和关联关系。例如,假设有一个User类型和Post类型,每个用户可以发布多个帖子:
type User {
id: ID!
name: String!
posts: [Post] @connection(keyName: "byUser", fields: ["id"])
}
type Post {
id: ID!
title: String!
content: String!
userId: ID!
user: User @connection(fields: ["userId"])
}
在上面的示例中,@connection指令用于指定连接关系。在User类型中,@connection指令指定了posts字段与Post类型的连接关系,并使用byUser作为连接关键字。
query GetUserPosts($userId: ID!) {
getUser(id: $userId) {
id
name
posts {
items {
id
title
content
}
}
}
}
在上面的查询中,getUser是一个查询操作,它接受一个名为$userId的参数,并返回用户的ID、名称和帖子列表。
query GetPostUser($postId: ID!) {
getPost(id: $postId) {
id
title
content
user {
id
name
}
}
}
在上面的查询中,getPost是一个查询操作,它接受一个名为$postId的参数,并返回帖子的ID、标题、内容以及作者的信息。
import Amplify, { API, graphqlOperation } from 'aws-amplify';
import awsconfig from './aws-exports';
Amplify.configure(awsconfig);
// 获取特定用户的所有帖子
const getUserPosts = async (userId) => {
const query = `
query GetUserPosts($userId: ID!) {
getUser(id: $userId) {
id
name
posts {
items {
id
title
content
}
}
}
}
`;
const variables = {
userId: userId
};
try {
const response = await API.graphql(graphqlOperation(query, variables));
console.log(response.data.getUser.posts.items);
} catch (error) {
console.log(error);
}
};
// 获取特定帖子的作者信息
const getPostUser = async (postId) => {
const query = `
query GetPostUser($postId: ID!) {
getPost(id: $postId) {
id
title
content
user {
id
name
}
}
}
`;
const variables = {
postId: postId
};
try {
const response = await API.graphql(graphqlOperation(query, variables));
console.log(response.data.getPost.user);
} catch (error) {
console.log(error);
}
};
// 使用示例
getUserPosts('user-id');
getPostUser('post-id');
在上面的示例代码中,我们首先配置了AWS Amplify,然后定义了两个异步函数getUserPosts和getPostUser,用于执行查询操作。在这些函数中,我们使用了AWS Amplify的API.graphql方法来执行GraphQL查询。