[mob][photos] Migrate to sqlite_async(13): Use getAll() instead of execute() for SELECT commands

This commit is contained in:
ashilkn 2024-05-21 16:53:49 +05:30
parent cae3748995
commit b2a359ca59

View File

@ -1120,7 +1120,7 @@ class FilesDB {
return {}; return {};
} }
final inParam = hashes.map((e) => "'$e'").join(','); final inParam = hashes.map((e) => "'$e'").join(',');
final rows = await db.execute(''' final rows = await db.getAll('''
SELECT * FROM $filesTable WHERE $columnHash IN ($inParam) AND $columnOwnerID = $userID; SELECT * FROM $filesTable WHERE $columnHash IN ($inParam) AND $columnOwnerID = $userID;
'''); ''');
final matchedFiles = convertToFiles(rows); final matchedFiles = convertToFiles(rows);
@ -1319,7 +1319,7 @@ class FilesDB {
Set<int> hiddenCollections, Set<int> hiddenCollections,
) async { ) async {
final db = await instance.sqliteAsyncDB; final db = await instance.sqliteAsyncDB;
final count = await db.execute( final count = await db.getAll(
'SELECT COUNT(distinct($columnUploadedFileID)) as COUNT FROM $filesTable where ' 'SELECT COUNT(distinct($columnUploadedFileID)) as COUNT FROM $filesTable where '
'$columnMMdVisibility' '$columnMMdVisibility'
' = $visibility AND $columnOwnerID = $ownerID AND $columnCollectionID NOT IN (${hiddenCollections.join(', ')})', ' = $visibility AND $columnOwnerID = $ownerID AND $columnCollectionID NOT IN (${hiddenCollections.join(', ')})',
@ -1373,7 +1373,7 @@ class FilesDB {
} }
inParam = inParam.substring(0, inParam.length - 1); inParam = inParam.substring(0, inParam.length - 1);
final db = await instance.sqliteAsyncDB; final db = await instance.sqliteAsyncDB;
final rows = await db.execute( final rows = await db.getAll(
''' '''
SELECT $columnLocalID SELECT $columnLocalID
FROM $filesTable FROM $filesTable
@ -1393,7 +1393,7 @@ class FilesDB {
Future<Map<int, int>> getCollectionIDToMaxCreationTime() async { Future<Map<int, int>> getCollectionIDToMaxCreationTime() async {
final enteWatch = EnteWatch("getCollectionIDToMaxCreationTime")..start(); final enteWatch = EnteWatch("getCollectionIDToMaxCreationTime")..start();
final db = await instance.sqliteAsyncDB; final db = await instance.sqliteAsyncDB;
final rows = await db.execute( final rows = await db.getAll(
''' '''
SELECT $columnCollectionID, MAX($columnCreationTime) AS max_creation_time SELECT $columnCollectionID, MAX($columnCreationTime) AS max_creation_time
FROM $filesTable FROM $filesTable
@ -1730,7 +1730,7 @@ class FilesDB {
Future<Map<FileType, int>> fetchFilesCountbyType(int userID) async { Future<Map<FileType, int>> fetchFilesCountbyType(int userID) async {
final db = await instance.sqliteAsyncDB; final db = await instance.sqliteAsyncDB;
final result = await db.execute( final result = await db.getAll(
''' '''
SELECT $columnFileType, COUNT(DISTINCT $columnUploadedFileID) SELECT $columnFileType, COUNT(DISTINCT $columnUploadedFileID)
FROM $filesTable WHERE $columnUploadedFileID != -1 AND FROM $filesTable WHERE $columnUploadedFileID != -1 AND