inex/famedlysdk
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Merge branch 'soru/wal' into 'master'

Browse source 
Better format switching to WAL mode

See merge request famedly/famedlysdk!349
This commit is contained in:
Marcel 2020-06-16 12:36:33 +00:00
parent 13b2c2602b 12bdddee03
commit b8c6decafc
1 changed files with 9 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
lib/src/database/database.dart
View file

@ -4,7 +4,6 @@ import 'dart:convert';
import 'package:famedlysdk/famedlysdk.dart' as sdk; import 'package:famedlysdk/famedlysdk.dart' as sdk;
import 'package:famedlysdk/matrix_api.dart' as api; import 'package:famedlysdk/matrix_api.dart' as api;
import 'package:olm/olm.dart' as olm; import 'package:olm/olm.dart' as olm;
import 'package:pedantic/pedantic.dart';
import '../../matrix_api.dart'; import '../../matrix_api.dart';
@ -21,20 +20,6 @@ class Database extends _$Database {
int get maxFileSize => 1 * 1024 * 1024; int get maxFileSize => 1 * 1024 * 1024;
@override
Future<void> beforeOpen(
QueryExecutor executor, OpeningDetails details) async {
await super.beforeOpen(executor, details);
if (executor.dialect == SqlDialect.sqlite) {
unawaited(customSelect('PRAGMA journal_mode=WAL').get().then((ret) {
if (ret.isNotEmpty) {
print('[Moor] Switched database to mode ' +
ret.first.data['journal_mode'].toString());
}
}));
}
}
@override @override
MigrationStrategy get migration => MigrationStrategy( MigrationStrategy get migration => MigrationStrategy(
onCreate: (Migrator m) { onCreate: (Migrator m) {
@ -61,6 +46,15 @@ class Database extends _$Database {
await m.createTable(outboundGroupSessions); await m.createTable(outboundGroupSessions);
} }
}, },
beforeOpen: (_) async {
if (executor.dialect == SqlDialect.sqlite) {
final ret = await customSelect('PRAGMA journal_mode=WAL').get();
if (ret.isNotEmpty) {
print('[Moor] Switched database to mode ' +
ret.first.data['journal_mode'].toString());
}
}
},
); );
Future<DbClient> getClient(String name) async { Future<DbClient> getClient(String name) async {