Drift vs Isar Comparison

// Drift - Table definition + reactive query (drift.simonbinder.eu/setup/)
import 'package:drift/drift.dart';
import 'package:drift/native.dart';
import 'dart:io';
import 'package:path_provider/path_provider.dart';
import 'package:path/path.dart' as p;

part 'database.g.dart';

class Todos extends Table {
  IntColumn get id => integer().autoIncrement()();
  TextColumn get title => text().withLength(min: 1, max: 200)();
  BoolColumn get isDone => boolean().withDefault(const Constant(false))();
}

@DriftDatabase(tables: [Todos])
class AppDatabase extends _$AppDatabase {
  AppDatabase() : super(_openConnection());

  @override
  int get schemaVersion => 1;

  // Reactive stream: automatically emits whenever the table changes
  Stream<List<Todo>> watchPendingTodos() {
    return (select(todos)..where((t) => t.isDone.equals(false))).watch();
  }

  Future<int> addTodo(String title) {
    return into(todos).insert(TodosCompanion.insert(title: title));
  }
}

LazyDatabase _openConnection() {
  return LazyDatabase(() async {
    final dbFolder = await getApplicationDocumentsDirectory();
    final file = File(p.join(dbFolder.path, 'db.sqlite'));
    return NativeDatabase.createInBackground(file);
  });
}

// isar_community - Collection definition + query (pub.dev/packages/isar_community readme pattern)
import 'package:isar_community/isar.dart';
import 'package:path_provider/path_provider.dart';

part 'todo.g.dart';

@collection
class Todo {
  Id id = Isar.autoIncrement;

  @Index()
  late String title;

  bool isDone = false;
}

Future<Isar> openDb() async {
  final dir = await getApplicationDocumentsDirectory();
  return Isar.open(
    [TodoSchema],
    directory: dir.path,
  );
}

Future<void> addTodo(Isar isar, String title) async {
  final todo = Todo()..title = title;
  await isar.writeTxn(() async {
    await isar.todos.put(todo);
  });
}

// Reactive query: automatically emits whenever the collection changes
Stream<List<Todo>> watchPendingTodos(Isar isar) {
  return isar.todos.filter().isDoneEqualTo(false).watch(fireImmediately: true);
}