beenull/ente
1
0
Fork 0
Code Issues Pull requests Actions Packages Projects Releases Wiki Activity

[mob][photos] Remove unnecessary write transactions

Browse source
This commit is contained in:
laurenspriem 2024-04-29 15:20:01 +05:30
parent d03d8d564d
commit 8058c6b621
1 changed files with 8 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

29
mobile/lib/face/db.dart
View file

@ -99,9 +99,7 @@ class FaceMLDataDB {
]; ];
}).toList(); }).toList();
await db.writeTransaction((tx) async { await db.executeBatch(sql, parameterSets);
await tx.executeBatch(sql, parameterSets);
});
} }
} }
@ -122,9 +120,8 @@ class FaceMLDataDB {
ON CONFLICT($fcFaceId) DO UPDATE SET $fcClusterID = excluded.$fcClusterID ON CONFLICT($fcFaceId) DO UPDATE SET $fcClusterID = excluded.$fcClusterID
'''; ''';
final parameterSets = batch.map((e) => [e.key, e.value]).toList(); final parameterSets = batch.map((e) => [e.key, e.value]).toList();
await db.writeTransaction((tx) async {
await tx.executeBatch(sql, parameterSets); await db.executeBatch(sql, parameterSets);
});
} }
} }
@ -475,9 +472,7 @@ class FaceMLDataDB {
'''; ''';
final parameterSets = final parameterSets =
faceIDToClusterID.entries.map((e) => [e.key, e.value]).toList(); faceIDToClusterID.entries.map((e) => [e.key, e.value]).toList();
await db.writeTransaction((tx) async { await db.executeBatch(sql, parameterSets);
await tx.executeBatch(sql, parameterSets);
});
} }
Future<void> removePerson(String personID) async { Future<void> removePerson(String personID) async {
@ -756,9 +751,7 @@ class FaceMLDataDB {
'''; ''';
final parameterSets = final parameterSets =
clusterToPersonID.entries.map((e) => [e.value, e.key]).toList(); clusterToPersonID.entries.map((e) => [e.value, e.key]).toList();
await db.writeTransaction((tx) async { await db.executeBatch(sql, parameterSets);
await tx.executeBatch(sql, parameterSets);
});
// final batch = db.batch(); // final batch = db.batch();
// for (final entry in clusterToPersonID.entries) { // for (final entry in clusterToPersonID.entries) {
// final clusterID = entry.key; // final clusterID = entry.key;
@ -798,9 +791,7 @@ class FaceMLDataDB {
final parameterSets = final parameterSets =
clusterToPersonID.entries.map((e) => [e.value, e.key]).toList(); clusterToPersonID.entries.map((e) => [e.value, e.key]).toList();
await db.writeTransaction((tx) async { await db.executeBatch(sql, parameterSets);
await tx.executeBatch(sql, parameterSets);
});
} }
Future<void> removeClusterToPerson({ Future<void> removeClusterToPerson({
@ -867,9 +858,7 @@ class FaceMLDataDB {
int batchCounter = 0; int batchCounter = 0;
for (final entry in summary.entries) { for (final entry in summary.entries) {
if (batchCounter == 400) { if (batchCounter == 400) {
await db.writeTransaction((tx) async { await db.executeBatch(sql, parameterSets);
await tx.executeBatch(sql, parameterSets);
});
batchCounter = 0; batchCounter = 0;
parameterSets.clear(); parameterSets.clear();
} }
@ -879,9 +868,7 @@ class FaceMLDataDB {
parameterSets.add([clusterID, avg, count]); parameterSets.add([clusterID, avg, count]);
batchCounter++; batchCounter++;
} }
await db.writeTransaction((tx) async { await db.executeBatch(sql, parameterSets);
await tx.executeBatch(sql, parameterSets);
});
// var batch = db.batch(); // var batch = db.batch();
// int batchCounter = 0; // int batchCounter = 0;