sqlcool 2.1.0

A library to work with Sqflite providing a simple api for crud operations and reactivity bindings

Sqlcool

A database helper library for Sqflite. Forget about implementation details and focus on the business logic. Features:

• Simple api for crud operations
• Changefeed: a stream to monitor database changes
• Select bloc: a ready to use bloc for select operations

Check the documentation for usage instructions

Simple crud

import 'package:sqlcool/sqlcool.dart';

void someFunc() async {
   Db db = Db();
   String dbpath = "db.sqlite"; // relative to the documents directory
   await db.init(path: dbpath, fromAsset: "assets/db.sqlite", verbose: true).catchError((e) {
       print("Error initializing the database: ${e.message}");
   });
   // insert
   Map<String, String> row = {
    slug: "my-item",
    name: "My item",
   };
   await db.insert(table: "category", row: row, verbose: true).catchError((e) {
       print("Error inserting data: ${e.message}");
   });
   // select
   List<Map<String, dynamic>> rows = await db.select(
     table: "product", limit: 20, columns: "id,name",
     where: "name LIKE '%something%'",
     orderBy: "name ASC").catchError((e) {
       print("Error selecting data: ${e.message}");
   });
   //update
   Map<String, String> row = {
    slug: "my-item-new",
    name: "My item new",
   };
   int updated = await db.update(table: "category", 
       row: row, where: "id=1", verbose: true).catchError((e) {
          print("Error updating data: ${e.message}");
   });
   // delete
   db.delete(table: "category", where: "id=3").catchError((e) {
       print("Error deleting data: ${e.message}");
   });
}

Changefeed

A stream of database change events is available

import 'dart:async';
import 'package:sqlcool/sqlcool.dart';

StreamSubscription _changefeed;

_changefeed = db.changefeed.listen((change) {
   print("CHANGE IN THE DATABASE:");
   print("Query: ${change.query}");
   if (change.type == DatabaseChange.update) {
     print("${change.value} items updated");
   }
 });
// _changefeed.cancel();

Reactive select bloc

The bloc will rebuild itself on any database change because of the reactive parameter set to true:

import 'package:flutter/material.dart';
import 'package:sqlcool/sqlcool.dart';

class _PageSelectBlocState extends State<PageSelectBloc> {
  SelectBloc bloc;

  @override
  void initState() {
    super.initState();
    this.bloc = SelectBloc(
        table: "items", orderBy: "name", reactive: true, verbose: true);
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text("My app"),
      ),
      body: StreamBuilder<List<Map>>(
          stream: bloc.items,
          builder: (BuildContext context, AsyncSnapshot snapshot) {
            if (snapshot.hasData) {
              // the select query has not found anything
              if (snapshot.data.length == 0) {
                return Center(
                  child: Text(
                      "No data"),
                );
              }
              // the select query has results
              return ListView.builder(
                  itemCount: snapshot.data.length,
                  itemBuilder: (BuildContext context, int index) {
                    var item = snapshot.data[index];
                    return ListTile(
                      title: GestureDetector(
                        child: Text(item["name"]),
                        onTap: () => print("Action"),
                      ),
                    );
                  });
            } else {
              // the select query is still running
              return CircularProgressIndicator();
            }
          }),
    );
  }
}

class PageSelectBloc extends StatefulWidget {
  @override
  _PageSelectBlocState createState() => _PageSelectBlocState();
}

Todo

• ❌ Upsert
• ❌ Batch operations