使用 DataStore 的 AWS FlutterAmplify

Question

我们如何通过查询获取用户对话。理想情况是对用户 table 进行查询并加载所有用户对话。示例：

final user = await Amplify.DataStore.query(User.classType, where: User.ID.eq(id))

user.conversations 加载对话列表。

如果无法做到这一点，下一步就是获取具有特定用户的所有对话。示例不工作：

await Amplify.DataStore.query(UserConversation.classType
          where: UserConversation.USER.eq(user.id)
         )

type Message @model @auth(rules: [{allow: public}]) {
  id: ID!
  ConversationId: Conversation @connection
  UserId: User @connection
  body: String
  createdDate: AWSDateTime!
}

type Conversation @model @auth(rules: [{allow: public}]) {
  id: ID!
  date: AWSDateTime
  readBy: [ReadBy] @connection(keyName: "byConversation", fields: ["id"])
  users: [UserConversation] @connection(keyName: "byConversation", fields: ["id"])
  name: String
  image: String
}

type ReadBy @model @auth(rules: [{allow: public}]) @key(name: "byConversation", fields: ["conversationID"]) {
  id: ID!
  date: AWSDateTime
  RedByUsers: User @connection
  conversationID: ID
}

type User @model @auth(rules: [{allow: public}]) {
  id: ID!
  firstName: String
  lastName: String
  userImg: String
  createdDate: AWSDateTime
  updatedDate: AWSDateTime
  email: AWSEmail
  conversations: [UserConversation] @connection(keyName: "byUser", fields: ["id"])
}

type UserConversation @model(queries: null) @key(name: "byUser", fields: ["userID", "conversationID"]) @key(name: "byConversation", fields: ["conversationID", "userID"]) @auth(rules: [{allow: public}, {allow: public}]) {
  id: ID!
  userID: ID!
  conversationID: ID!
  user: User! @connection(fields: ["userID"])
  conversation: Conversation! @connection(fields: ["conversationID"])
}

Answer 1

我通过执行以下操作获得了第二个版本：

await Amplify.DataStore.query(UserConversation.classType
      where: User.ID.eq(user.id)
     );

以上将执行所有用户对话的选择，这些对话的用户 ID 等于 user 变量的 ID。一开始有点困惑为什么你需要为查询传递 User.ID，但据我所知，这是由于 AWS DataStore 如何创建 SQL 查询，它正在做在幕后进行连接，因此将使用第二个 table 的列（在本例中为用户 table）执行连接。我希望我能指出一些关于此的文档，但我找不到任何文档。我有点幸运地尝试了一堆东西并在错误消息中注意到 SQL 查询是如何生成的。

使用 DataStore 的 AWS FlutterAmplify

AWS FlutterAmplify using DataStore

aws-amplify

flutteramplify