Explorar o código

Migrate getFilesInCollection from sqflite to sqlite_async

ashilkn hai 1 ano
pai
achega
785beeb9b3
Modificáronse 1 ficheiros con 11 adicións e 12 borrados
  1. 11 12
      mobile/lib/db/files_db.dart

+ 11 - 12
mobile/lib/db/files_db.dart

@@ -670,19 +670,18 @@ class FilesDB {
     bool? asc,
     bool? asc,
     int visibility = visibleVisibility,
     int visibility = visibleVisibility,
   }) async {
   }) async {
-    final db = await instance.database;
+    final db = await instance.sqliteAsyncDB;
     final order = (asc ?? false ? 'ASC' : 'DESC');
     final order = (asc ?? false ? 'ASC' : 'DESC');
-    const String whereClause =
-        '$columnCollectionID = ? AND $columnCreationTime >= ? AND $columnCreationTime <= ?';
-    final List<Object> whereArgs = [collectionID, startTime, endTime];
-
-    final results = await db.query(
-      filesTable,
-      where: whereClause,
-      whereArgs: whereArgs,
-      orderBy:
-          '$columnCreationTime ' + order + ', $columnModificationTime ' + order,
-      limit: limit,
+    String query =
+        'SELECT * FROM $filesTable WHERE $columnCollectionID = ? AND $columnCreationTime >= ? AND $columnCreationTime <= ? ORDER BY $columnCreationTime $order, $columnModificationTime $order';
+    final List<Object> args = [collectionID, startTime, endTime];
+    if (limit != null) {
+      query += ' LIMIT ?';
+      args.add(limit);
+    }
+    final results = await db.getAll(
+      query,
+      args,
     );
     );
     final files = convertToFiles(results);
     final files = convertToFiles(results);
     return FileLoadResult(files, files.length == limit);
     return FileLoadResult(files, files.length == limit);