Flutter持久化存储之数据库存储

前言

数据库存储是咱们经常使用的存储方式之一，对大批量数据有增、删、改、查操做需求时，咱们就会想到使用数据库，Flutter中提供了一个sqflite插件供咱们用于大量数据执行CRUD操做。本篇咱们就来一块儿学习sqflite的使用。

sqflite使用

引入插件

在pubspec.yaml文件中添加path_provider插件，最新版本为1.0.0，以下：

dependencies:
  flutter:
    sdk: flutter
  #sqflite插件
  sqflite: 1.0.0
复制代码

而后命令行执行flutter packages get便可将插件下载到本地。

数据库操做方法介绍

1. 插入操做

插入数据操做有两个方法：

Future<int> rawInsert(String sql, [List<dynamic> arguments]);

Future<int> insert(String table, Map<String, dynamic> values,
      {String nullColumnHack, ConflictAlgorithm conflictAlgorithm});
复制代码

rawInsert方法第一个参数为一条插入sql语句，可使用?做为占位符，经过第二个参数填充数据。

insert方法第一个参数为操做的表名，第二个参数map中是想要添加的字段名和对应字段值。

2. 查询操做

查询操做一样实现了两个方法：

Future<List<Map<String, dynamic>>> query(String table,
      {bool distinct,
      List<String> columns,
      String where,
      List<dynamic> whereArgs,
      String groupBy,
      String having,
      String orderBy,
      int limit,
      int offset});
      
Future<List<Map<String, dynamic>>> rawQuery(String sql,
      [List<dynamic> arguments]);
复制代码

query方法第一个参数为操做的表名，后边的可选参数依次表示是否去重、查询字段、WHERE子句（可以使用?做为占位符）、WHERE子句占位符参数值、GROUP BY子句、HAVING子句、ORDER BY子句、查询的条数、查询的偏移位等。

rawQuery方法第一个参数为一条查询sql语句，可使用?做为占位符，经过第二个参数填充数据。

3. 修改操做

修改操做一样实现了两个方法：

Future<int> rawUpdate(String sql, [List<dynamic> arguments]);

Future<int> update(String table, Map<String, dynamic> values,
      {String where,
      List<dynamic> whereArgs,
      ConflictAlgorithm conflictAlgorithm});
复制代码

rawUpdate方法第一个参数为一条更新sql语句，可使用?做为占位符，经过第二个参数填充数据。

update方法第一个参数为操做的表名，第二个参数为修改的字段和对应值，后边的可选参数依次表示WHERE子句（可以使用?做为占位符）、WHERE子句占位符参数值、发生冲突时的操做算法（包括回滚、终止、忽略等等）。

4. 删除操做

修改操做一样实现了两个方法：

Future<int> rawDelete(String sql, [List<dynamic> arguments]);

Future<int> delete(String table, {String where, List<dynamic> whereArgs});
复制代码

rawDelete方法第一个参数为一条删除sql语句，可使用?做为占位符，经过第二个参数填充数据。

delete方法第一个参数为操做的表名，后边的可选参数依次表示WHERE子句（可以使用?做为占位符）、WHERE子句占位符参数值。

举个栗子

咱们以图书管理系统来举例。

首先，咱们建立一个书籍类，包括书籍ID、书名、做者、价格、出版社等信息。

final String tableBook = 'book';
final String columnId = '_id';
final String columnName = 'name';
final String columnAuthor = 'author';
final String columnPrice = 'price';
final String columnPublishingHouse = 'publishingHouse';

class Book {
  int id;
  String name;
  String author;
  double price;
  String publishingHouse;
  
  Map<String, dynamic> toMap() {
    var map = <String, dynamic>{
      columnName: name,
      columnAuthor: author,
      columnPrice: price,
      columnPublishingHouse: publishingHouse
    };
    if (id != null) {
      map[columnId] = id;
    }
    return map;
  }

  Book();

  Book.fromMap(Map<String, dynamic> map) {
    id = map[columnId];
    name = map[columnName];
    author = map[columnAuthor];
    price = map[columnPrice];
    publishingHouse = map[columnPublishingHouse];
  }
}
复制代码

其次，咱们开始实现数据库相关操做：

1. 建立数据库文件和对应的表

// 获取数据库文件的存储路径
    var databasesPath = await getDatabasesPath();
    String path = join(databasesPath, 'demo.db');

//根据数据库文件路径和数据库版本号建立数据库表
    db = await openDatabase(path, version: 1,
        onCreate: (Database db, int version) async {
      await db.execute(''' CREATE TABLE $tableBook ( $columnId INTEGER PRIMARY KEY, $columnName TEXT, $columnAuthor TEXT, $columnPrice REAL, $columnPublishingHouse TEXT) ''');
    });
复制代码

2. CRUD操做实现

// 插入一条书籍数据
  Future<Book> insert(Book book) async {
    book.id = await db.insert(tableBook, book.toMap());
    return book;
  }

  // 查找全部书籍信息
  Future<List<Book>> queryAll() async {
    List<Map> maps = await db.query(tableBook, columns: [
      columnId,
      columnName,
      columnAuthor,
      columnPrice,
      columnPublishingHouse
    ]);

    if (maps == null || maps.length == 0) {
      return null;
    }

    List<Book> books = [];
    for (int i = 0; i < maps.length; i++) {
      books.add(Book.fromMap(maps[i]));
    }

    return books;
  }

  // 根据ID查找书籍信息
  Future<Book> getBook(int id) async {
    List<Map> maps = await db.query(tableBook,
        columns: [
          columnId,
          columnName,
          columnAuthor,
          columnPrice,
          columnPublishingHouse
        ],
        where: '$columnId = ?',
        whereArgs: [id]);
    if (maps.length > 0) {
      return Book.fromMap(maps.first);
    }
    return null;
  }

  // 根据ID删除书籍信息
  Future<int> delete(int id) async {
    return await db.delete(tableBook, where: '$columnId = ?', whereArgs: [id]);
  }

  // 更新书籍信息
  Future<int> update(Book book) async {
    return await db.update(tableBook, book.toMap(),
        where: '$columnId = ?', whereArgs: [book.id]);
  }
复制代码

3. 关闭数据库

数据库对象使用完以后要在适当的时候关闭掉，可在helper类中实现如下方法。

Future close() async => db.close();
复制代码

运行效果：

事务

sqflite同时支持事务，经过事务能够将多条原子操做放在一块儿执行，保证操做要么所有执行完成，要么都不执行。 好比有两条书籍数据必须所有插入书库中才算添加成功，则使用以下方法

Future<bool> insertTwoBook(Book book1, Book book2) async {
    return await db.transaction((Transaction txn) async {
      book1.id = await db.insert(tableBook, book1.toMap());

      book2.id = await db.insert(tableBook, book2.toMap());

      print('book1.id = ${book1.id}, book2.id = ${book2.id}');
      return book1.id != null && book2.id != null;
    });
  }
复制代码

写在最后

以上介绍了sqflite中咱们经常使用的几个操做，有了sqflite咱们就能够开发更丰富的应用程序，在开发实践中你们遇到任何问题均可以给咱们发消息反馈，你们一块儿交流探讨共同进步。针对一些用户的反馈咱们将在下一篇介绍Flutter的代码调试。

说明：

文章转载自对应的“Flutter编程指南”微信公众号，更多Flutter相关技术文章打开微信扫描二维码关注微信公众号获取。