Flutter中无需StreamBuilder实现FireStore数据同步至SQLite

我想要读取FireStore集合中的所有文档并将其存入SQLite数据库，已通过如下代码利用StreamBuilder实现该流程：

// instance of SQL controller 
DbController sqlController = DbController();
@override
Widget build(BuildContext context) {
    return scaffold (
    body : 
    //! button to start fetching 
        elevationButton(
            on tap: (){
                StreamBuilder(
                    stream: FirebaseFirestore.instance.collection("orders").snapshots(),
                    builder: (context, snapshot) {
                        int count = snapshot.data!.docs.length;
                        for(int i = 0 ; i< count ; i++){
                            Map<String , dynamic> model = snapshot.data!.docs[i].data();                        
                            int modelID = int.parse(snapshot.data!.docs[i].id);
                            sqlController.add(
                                CustomerModel(
                                    id: modelID,
                                    name: model["name"],
                                    phone: model["phone"],
                               )
                            );
                       }
                       return Container();
                    },
                );
            }
        )
    );
}

现咨询如何不使用StreamBuilder完成该数据的获取与存储操作。

如果只是需要一次性获取FireStore集合的所有文档并存入SQLite，完全不需要依赖StreamBuilder（它的核心作用是监听实时数据更新），直接用Firestore的get()方法（返回Future）就能实现，具体步骤如下：

• 将按钮的点击事件改为异步函数，适配Firestore的异步操作特性
• 调用collection("orders").get()获取集合的单次数据快照
• 遍历快照中的每篇文档，转换为CustomerModel后存入SQLite
• 添加异常处理，避免网络问题或数据格式错误导致崩溃

修改后的完整代码：

// instance of SQL controller 
DbController sqlController = DbController();

@override
Widget build(BuildContext context) {
  return Scaffold(
    body: ElevatedButton(
      onPressed: _fetchAndSaveOrders, // 绑定异步处理方法
      child: const Text("同步FireStore数据到SQLite"),
    ),
  );
}

// 异步方法：完成FireStore数据拉取与SQLite存储
Future<void> _fetchAndSaveOrders() async {
  try {
    // 获取orders集合的所有文档快照
    final querySnapshot = await FirebaseFirestore.instance.collection("orders").get();
    
    // 遍历每一篇文档
    for (final doc in querySnapshot.docs) {
      final modelData = doc.data();
      final modelID = int.parse(doc.id); // 确保文档ID可转换为int类型
      
      // 转换模型并存入SQLite
      await sqlController.add(
        CustomerModel(
          id: modelID,
          name: modelData["name"],
          phone: modelData["phone"],
        ),
      );
    }
    
    // 同步完成后提示（可选）
    if (mounted) {
      ScaffoldMessenger.of(context).showSnackBar(
        const SnackBar(content: Text("数据同步完成")),
      );
    }
  } catch (e) {
    // 异常捕获与提示
    if (mounted) {
      ScaffoldMessenger.of(context).showSnackBar(
        SnackBar(content: Text("同步失败：${e.toString()}")),
      );
    }
  }
}

关键细节说明 #

• get()方法仅会拉取一次当前集合的全部数据，完全匹配一次性同步的需求
• 用await等待异步操作完成，避免出现未处理的Future导致逻辑混乱
• 通过mounted判断组件状态，确保更新UI时组件仍在视图树中
• 异常处理能有效提升代码稳定性，避免因意外情况崩溃

内容的提问来源于stack exchange，提问作者Eddy Hezarian