Flutter数据库管理插件crazy_db的使用

使用此包作为库

在你的 pubspec.yaml 文件中添加以下依赖：

$ flutter pub add crazy_db

这将会在你的包的 pubspec.yaml 文件中添加如下行（并运行隐式的 flutter pub get）：

dependencies:
  crazy_db: ^1.0.4

你也可以通过编辑器支持的 flutter pub get 功能来实现。具体操作请查阅你的编辑器文档。

导入它

现在可以在你的 Dart 代码中使用以下导入语句：

import 'package:crazy_db/crazy_db.dart';

简介

什么是CrazyDB？

CrazyDB 是一个基于 sqflite 的二次封装，使用点语法更方便地操作数据库。

入门指南

1. 在根目录下创建 assets 文件夹

2. 在 assets 文件夹中创建 .sqlite 文件，默认名称为 crazyDB.sqlite

3. 在使用之前调用一次

import 'package:crazy_db/crazy_db.dart';
await CrazyDB.connection("crazyDB.sqlite");

这将把文件复制到沙盒文件，并在调试模式下打印 .sqlite 文件的位置。默认情况下打开数据库。

使用示例

插入数据

int ret = await CrazyDB.table("request_cache")
    .create({"url": "https://baidu.com"});

删除数据

int ret = await CrazyDB.table("request_cache")
  .where(column: "url", value: "https://baidu.com")
  .delete();

更新数据

int ret = await CrazyDB.table("request_cache")
  .where(column: "url", value: "https://baidu.com")
  .update({"json": "{}"});

查询数据

List list = await CrazyDB.table("request_cache")
        .where(column: "id", value: 1)
        .where(column: "url", value: "https://baidu.com")
        .whereNotNull(column: "url")
        .orWhere(column: "id", value: 2)
        .whereNotBetween("id",[500,600])
        .orderByDesc("id")
        .whereNotIn("id", [1,3])
        .get();

使用原生SQL处理

await CrazyDB.selectRaw("select * from request_cache");
await CrazyDB.insertRaw("insert into request_cache(url) values('http://')");
await CrazyDB.updateRaw("update request_cache set url='http://' where id = 1 ");
await CrazyDB.deleteRaw("delete from request_cache where id =1");

使用事务

// 注意：你必须至少使用一次 CrazyDB.commit() 或 CrazyDB.rollback()
try {
    await CrazyDB.transaction();
    // 你的SQL请在这里编写
    // 示例：
    int id = await CrazyDB.table("request_cache").create({"url":"https://sina.cn"});
    CrazyDB.table("request_cache").where(column: "id", value: id).delete();
    // 你必须使用该函数
    await CrazyDB.commit();
} catch (e) {
    // 你必须使用该函数
    CrazyDB.rollback();
    debugPrint("transaction=>$e");
}

API 文档

完整示例

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

void main() {
  runApp(const MyApp());
}

class MyApp extends StatefulWidget {
  const MyApp({Key? key}) : super(key: key);

  [@override](/user/override)
  State<MyApp> createState() => _MyAppState();
}

class _MyAppState extends State<MyApp> {
  [@override](/user/override)
  void initState() {
    super.initState();
    testDb();
  }

  [@override](/user/override)
  Widget build(BuildContext context) {
    return Container();
  }

  void testDb() async {
    await CrazyDB.connection("crazyDB.sqlite");

    int id = await CrazyDB.table("request_cache")
      .create({"url": "https://baidu.com"});

    int count1 = await CrazyDB.table("request_cache")
      .where(column: "url", value: "https://baidu.com")
      .delete();

    int count2 = await CrazyDB.table("request_cache")
      .where(column: "url", value: "https://baidu.com")
      .update({"json": "{}"});

    // Many to many
    List list = await CrazyDB.table("request_cache")
      .join(
          "request_detail", "request_cache.id", "=", "request_detail.url_id")
      .join(
          "request_time", "request_detail.id", "=", "request_time.detail_id")
      .where(column: "id", value: 1)
      .where(column: "url", value: "https://baidu.com")
      .whereNotNull(column: "url")
      .orWhere(column: "id", value: 2)
      .whereNotBetween("id",[500,600])
      .orderByDesc("id")
      .whereNotIn("id", [1,3])
      .where(
          column: "request_time.create_time",
          symbol: "<",
          value: "2022-6-10 15:47")
      .get(list: [
        "request_cache.id",
        "request_cache.url",
        "request_cache.json",
        "request_detail.id as detail_id",
        "request_detail.title",
        "request_detail.content",
        "request_time.auth",
        "request_time.create_time"
      ]);

    List? list1 = await CrazyDB.table("request_cache")
      .where(column: "id", value: "1")
      .groupBy("id")
      .having("count > 2")
      .having("json = '{}'")
      .get();

    // 打印SQL
    CrazyDB.getSql();

    // 事务
    try {
      CrazyDB.transaction();
      CrazyDB.table("request_cache").create({"url": "https://sina.cn"});
      Map map = await CrazyDB.table("request_cache").select().where(column: "id", value: 1).first();
      if (map.isNotEmpty) {
        CrazyDB.table("request_cache").where(column: "id", value: 1).delete();
      }

      await CrazyDB.commit();
    } catch (e) {
      CrazyDB.rollback();
      debugPrint("transaction=>$e");
    }

    await CrazyDB.table("request_cache").create({"url": "https://baidu.cn"});

    debugPrint("list1=>$list1");
    debugPrint(list.toString());
  }
}