【问题标题】:Insert sqlite flutter without freezing the interface插入sqlite颤振而不冻结界面
【发布时间】:2019-10-14 01:33:44
【问题描述】:

我正在尝试使用颤振在 sqlite 内存数据库中插入很多行(大约 12k 或更多)。

我从 API 获取数据并使用计算函数来处理来自 Json 的数据。 现在我需要将这些数据添加到内存中的数据库中,为此我使用批处理的事务。

batchInsertEventSong(List<EventSong> rows) async {
   Database db = await instance.database;
   db.transaction((txn) async {
      Batch batch = txn.batch();
      for (var song in rows) {
         Map<String, dynamic> row = {
           DatabaseHelper.columnIdSong: song.id,
           DatabaseHelper.columnTitle: song.title,
           DatabaseHelper.columnInterpreter: song.interpreter
         };
         batch.insert(table, row);
       }
      batch.commit();
   }
}

但是这个函数在插入过程中阻塞了我的 UI,我也尝试了计算,但我无法通过类 db 或类批处理。 我不清楚如何在另一个线程中执行这个进程,或者(因为我不能使用隔离)在不阻塞我的 UI 的情况下执行。

有什么建议吗?

【问题讨论】:

  • 抱歉我忘了说,大概12K左右
  • for 大约需要 2 秒,提交大约需要 4 秒。以较小的块添加到batch 是什么意思?不是在最后执行batch.commit();,而是在一些循环之后执行?
  • 我尝试添加一个 if(i % 1000 == 0) batch.commit(noResult: true); 以便它每 1000 个项目提交行并在循环结束时提交。但这会让我的 UI 或多或少地阻塞 12 秒......是否有抖动的睡眠或 processEvents(如在 Qt 中)让主线程有一点空气来执行?

标签: sqlite flutter dart sqflite


【解决方案1】:

更新 2020 - 05 - 15

这将不起作用,请参阅:


注意:完整的代码在最后提供

第 1 步:将您的方法设为静态并使其无效

  static batchInsertEventSong(List<EventSong> rows) {
    Database db = await instance.database;
    db.transaction((txn) async {
        Batch batch = txn.batch();
        for (var song in rows) {
            Map<String, dynamic> row = {
            DatabaseHelper.columnIdSong: song.id,
            DatabaseHelper.columnTitle: song.title,
            DatabaseHelper.columnInterpreter: song.interpreter
            };
            batch.insert(table, row);
        }
        batch.commit();
    }
  }

第 2 步:创建新方法(通常但不需要为同名添加 Async)

  Future batchInsertEventSongAsync(List<EventSong> rows) {

  }

第 3 步:使用静态方法调用计算并返回

  return compute(batchInsertEventSong, rows);

步骤 [1,2,3] 代码审查

  Future batchInsertEventSongAsync(List<EventSong> rows) {
    return compute(_batchInsertEventSong, rows);
  }

  static _batchInsertEventSong(List<EventSong> rows) {
    Database db = await instance.database;
    db.transaction((txn) async {
        Batch batch = txn.batch();
        for (var song in rows) {
            Map<String, dynamic> row = {
            DatabaseHelper.columnIdSong: song.id,
            DatabaseHelper.columnTitle: song.title,
            DatabaseHelper.columnInterpreter: song.interpreter
            };
            batch.insert(table, row);
        }
        batch.commit();
    }
  }

完整代码

import 'dart:async';
import 'package:flutter/foundation.dart';
import 'package:flutter/material.dart';

void main() => runApp(MyApp());

class MyApp extends StatelessWidget {
  // This widget is the root of your application.
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        primarySwatch: Colors.blue,
      ),
      home: Scaffold(body: MyHomePage(title: 'Flutter Demo Home Page')),
    );
  }
}

class MyHomePage extends StatefulWidget {
  MyHomePage({Key key, this.title}) : super(key: key);

  final String title;

  @override
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text(widget.title),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            FlatButton.icon(
              icon: Icon(Icons.backup),
              label: Text("Long Opreation"),
              onPressed: () async {
                var rows = await RsetApi.getRawsAsync();
                await Database._saveRaws(rows);
              },
            ),
            FlatButton.icon(
              icon: Icon(Icons.backup),
              label: Text("Short Opreation"),
              onPressed: () {
                Scaffold.of(context).hideCurrentSnackBar();
                Scaffold.of(context).showSnackBar(new SnackBar(
                  content: new Text(DateTime.now().toIso8601String()),
                ));
              },
            ),
          ],
        ),
      ),
    );
  }
}

class RsetApi {
  static Future<List<EventSong>> getRawsAsync() {
    return compute(_getRaws, null);
  }

  static List<EventSong> _getRaws(pram1) {
    var rows = List<EventSong>();
    for (var i = 1; i < 12000; i++) {
      rows.add(EventSong(i));
      print("fetching raws " + (i / 12000).toString());
    }
    return rows;
  }
}

class Database {
  static Future saveRawsAsync(List<EventSong> rows) {
    return compute(_saveRaws, rows);
  }

  static _saveRaws(List<EventSong> rows) {
    for (var i = 1; i < rows.length; i++) {
      print("saving raws " + (i / rows.length).toString());
    }
  }
}

class EventSong {
  int id;
  EventSong(this.id);
}

参考:

非重要参考:

【讨论】:

  • 我认为 PlatformChannels (sqflite insert) 不适用于隔离 (compute)。这个例子有效吗?
  • @Martyns 你有这个事实的参考(一个网址),所以我可以稍后检查它?,这对我有很大帮助?
  • GH有几个问题,这是主要的github.com/flutter/flutter/issues/13937
  • @MohamedElrashid 感谢您的回答,我不知道为什么您的方法有效,但我尝试了同样的方法,但仍然收到此错误error: native function 'Window_sendPlatformMessage' (4 arguments) cannot be found。我想是因为compute仍然不支持flutter插件
  • 您可以在计算调用中使用 batchInsertEventSong 发布您的完整代码吗?我无法让这个例子工作。
猜你喜欢
  • 2020-07-22
  • 2021-07-01
  • 1970-01-01
  • 2021-10-01
  • 2013-04-05
  • 1970-01-01
  • 1970-01-01
  • 2014-05-05
  • 2020-02-26
相关资源
最近更新 更多