Flutter数据库查询插件jaguar_query_sqflite的使用

jaguar_query_sqflite 是一个基于 sqflite 的适配器，用于与 jaguar_query 和 jaguar_orm 配合使用。它允许开发者通过简洁的 DSL（领域特定语言）来操作 SQLite 数据库。

使用方法

以下是一个简单的使用示例：

1. 导入必要的包

import 'dart:io';
import 'dart:async';
import 'package:sqflite/sqflite.dart';
import 'package:jaguar_query_sqflite/jaguar_query_sqflite.dart';

2. 定义数据模型

class Post {
  Post();

  Post.make(this.id, this.msg, this.author);

  int id;
  String msg;
  String author;

  @override
  String toString() => '$id $msg $author';
}

3. 创建数据表适配器

SqfliteAdapter _adapter;

4. 定义数据表 Bean

class PostBean {
  // 定义字段
  final IntField id = new IntField('_id');
  final StrField msg = new StrField('msg');
  final StrField author = new StrField('author');

  // 表名
  String get tableName => 'posts';

  // 创建表
  Future<void> createTable() async {
    final st = new Create(tableName, ifNotExists: true)
        .addInt('_id', primary: true)
        .addStr('msg', isNullable: true)
        .addStr('author', isNullable: true);

    await _adapter.createTable(st);
  }

  // 插入数据
  Future<int> insert(Post post) async {
    Insert inserter = new Insert(tableName);

    inserter.set(id, post.id);
    inserter.set(msg, post.msg);
    inserter.set(author, post.author);

    return await _adapter.insert(inserter);
  }

  // 更新数据
  Future<int> update(int id, String author) async {
    Update updater = new Update(tableName);
    updater.where(this.id.eq(id));
    updater.set(this.author, author);

    return await _adapter.update(updater);
  }

  // 查找单条数据
  Future<Post> findOne(int id) async {
    Find finder = new Find(tableName);
    finder.where(this.id.eq(id));

    Map<String, dynamic> map = await _adapter.findOne(finder);

    Post post = new Post();
    post.id = map['_id'];
    post.msg = map['msg'];
    post.author = map['author'];

    return post;
  }

  // 查找所有数据
  Future<List<Post>> findAll() async {
    Find finder = new Find(tableName);
    List<Map<String, dynamic>> maps = await (await _adapter.find(finder)).toList();

    List<Post> posts = [];

    for (var map in maps) {
      Post post = new Post();
      post.id = map['_id'];
      post.msg = map['msg'];
      post.author = map['author'];
      posts.add(post);
    }

    return posts;
  }

  // 删除单条数据
  Future<int> remove(int id) async {
    Remove remover = new Remove(tableName);
    remover.where(this.id.eq(id));

    return await _adapter.remove(remover);
  }

  // 删除所有数据
  Future<int> removeAll() async {
    Remove remover = new Remove(tableName);
    return await _adapter.remove(remover);
  }
}

5. 主函数执行逻辑

void main() async {
  // 初始化适配器
  _adapter = new SqfliteAdapter(await getDatabasesPath());
  await _adapter.connect();

  // 实例化 Bean
  final bean = new PostBean();

  // 创建表
  await bean.createTable();

  // 清空表数据
  await bean.removeAll();

  // 插入数据
  await bean.insert(new Post.make(1, 'Whatever 1', 'mark'));
  await bean.insert(new Post.make(2, 'Whatever 2', 'bob'));

  // 查询单条数据
  Post post = await bean.findOne(1);
  print(post);

  // 查询所有数据
  List<Post> posts = await bean.findAll();
  print(posts);

  // 更新数据
  await bean.update(1, 'rowling');

  // 再次查询单条数据
  post = await bean.findOne(1);
  print(post);

  // 删除数据
  await bean.remove(1);
  await bean.remove(2);

  // 尝试查询已删除的数据
  try {
    post = await bean.findOne(1);
    print(post);
  } on JaguarOrmException catch (e) {
    print(e);
  }

  // 关闭连接
  await _adapter.close();
  exit(0);
}

运行结果

运行上述代码后，控制台将输出类似以下内容：

Instance of 'Post'
[Instance of 'Post']
Instance of 'Post'
Error: No such record found