1

我正在尝试用 firebase、sqlite 和 sqlBrite 构建一个聊天存储系统。这样做的目的是在不必重建页面的情况下流式传输新消息。来自 sqlBrite 的流仅在 setstate 上重建,例如当键盘被拉回时。

如何让流在保存时自动更新。

数据库文件

///INSERT INTO DB
    Future<int> insertNewMessage(String id, int result, BriteDatabase briteDb,
          Map<String, dynamic> row) async {
        messageList.add(id);
    
        await ifexists(id, messageId, briteDb)
            ? print('message already In')
            : result = await briteDb.insert(messageTable, row);
        return result;
      }

////STREAM MESSAGES
    Stream<List<Map<String, dynamic>>> getMessageMapListbyId(
          {String sendId, String receiveId, database}) async* {
        try {
          BriteDatabase briteDb = await database;
        yield* briteDb.createQuery(messageTable,
                  distinct: false,
                  where:
                      ' $senderId=? $receiverId = ? ',
                  whereArgs: [
                      sendId,
                      receiverId,
                    ])});

提供者文件

///ADD MESSAGES
    addMessageTodb(message) async {
        await ldbH
            .msg_insertMessage(
                message.id, modelFuncs.messageMaping(message, msgFuncs))
            .then((value) async {
         
          await getMessageYieldBase(message.senderId, message.receiverId);
        });}

    ///STREAM NEW DATA
getMessageYieldBase(senderId, receiverId) async* {
        yield* ldbH.msg_getAllMessagesbyId(senderId, receiverId);}

ui端

StreamBuilder(
            stream: messageStream.getMessageYieldBase(
                widget._currentUserId, widget.receiver.uid),
            builder: (context, AsyncSnapshot<dynamic> snapshot) {
              var d = snapshot.data;
              var newList = snapshot.hasData ? d.reversed.toList() : [];
              return
                 
                  ListView.builder(
                      reverse: true,
                      padding: EdgeInsets.all(10),
                      controller: widget._listScrollController,
                      itemCount: newList.length,
                      itemBuilder: (BuildContext context, int index) {
                        

                        return DisplayMessage(
                          currentUserId: widget._currentUserId,
                          receiver: widget.receiver,
                          message: newList[index],
                        );
                      });
            })

因此,只有当页面以某种方式重建时,新文本才会不断出现。感谢您提供的任何帮助。

4

1 回答 1

0

如果您遇到此问题,请使用 moor 库 sqlbrite 将不起作用,但这是一个帮助链接.... https://resocoder.com/2019/06/26/moor-room-for-flutter-tables-查询-流利的-sqlite-数据库/

Matt Rešetár 详细解释,因此很容易实现......

于 2021-09-03T13:54:49.030 回答