Usage

final db = PocketSync.instance.database;

// Insert a record
final id = await db.insert(
  'todos',
  {
    'title': 'Buy groceries',
    'completed': 0,
    'created_at': DateTime.now().millisecondsSinceEpoch,
  },
);

// Get all records
final todos = await db.query('todos');

// Get a specific record
final todo = await db.query(
  'todos',
  where: 'id = ?',
  whereArgs: [1],
);

// Get records with conditions
final incompleteTodos = await db.query(
  'todos',
  where: 'completed = ?',
  whereArgs: [0],
  orderBy: 'created_at DESC',
);

// Update a record
final count = await db.update(
  'todos',
  {'completed': 1},
  where: 'id = ?',
  whereArgs: [1],
);

// Delete a record
final count = await db.delete(
  'todos',
  where: 'id = ?',
  whereArgs: [1],
);

// Delete all records
final count = await db.delete('todos');

// Perform multiple operations in a transaction
await db.transaction((txn) async {
  await txn.insert('todos', {'title': 'Buy groceries'});
  await txn.insert('todos', {'title': 'Buy milk'});
});

// Perform multiple operations in a batch
await db.batch((batch) {
  batch.insert('todos', {'title': 'Buy groceries'});
  batch.insert('todos', {'title': 'Buy milk'});
});

// Execute a raw SQL query
final todos = await db.rawQuery('SELECT * FROM todos');

// Watch changes to a table
final stream = db.watch('todos');

// Listen to changes
stream.listen((event) {
  print(event);
});