flutter 数据持久化之sqflite

sqflite: 是一款轻量级的关系型数据库，类似SQLite. 支持iOS和Android。适用于存储数据库 , 表类型的数据.
使用：
添加依赖

dependencies:flutter:sdk: flutter...#sqflite插件sqflite: ^1.1.6+1

先练习一下官方文档上面的一些基础使用方法

_createDB() async {//获取数据库默认路径var databasePath = await getDatabasesPath();print('database default path is $databasePath');//join 需要import 'package:path/path.dart';String path = join(databasePath, 'order.db');await deleteDatabase(path);//打开数据库Database database = await openDatabase(path, version: 1,onCreate: (Database db, int version) async {//建表await db.execute('CREATE TABLE Test (id INTEGER PRIMARY KEY, memberName TEXT, dynamicBottom TEXT, productName TEXT)');});//insertawait database.transaction((txn) async {int id1 = await txn.rawInsert('INSERT INTO Test(memberName, dynamicBottom, productName) VALUES("岑需顿", "2019/07/12创建", "2018款 朗逸 1.5L 手动风尚版")');print('inserted1: $id1');int id2 = await txn.rawInsert('INSERT INTO Test(memberName, dynamicBottom, productName) VALUES("余界才", "2019/07/10创建", "2018款 朗逸 1.5L 手动风尚版")');print('inserted2: $id2');});//update
//     int count = await database.rawUpdate(
//     'UPDATE Test SET name = ?, VALUE = ? WHERE name = ?',
//     ['updated name', '9876', 'some name']);
// print('updated: $count');List<Map> list = await database.rawQuery('SELECT * FROM Test');print(list);// Close the databaseawait database.close();}

然后以一个实际的订单列表页为例，做一下数据的存储，下面是我的书写代码的流程：

1.首先做一个列表的页面，就不放代码了，然后写一个入口可以跳转进入列表页，随便展示几个字段
2.建一个model 存放页面展示的元素属性

class Order {final String memberName;final String customerPhone;final String dynamicBottom;final String productName;StatusModel dynamicStatus;Order (this.memberName,this.customerPhone,this.dynamicBottom,this.productName,this.dynamicStatus,);Order.fromJson(Map json) : memberName = json['memberName'],customerPhone = json['customerPhone'],dynamicBottom = json['dynamicBottom'],productName = json['productName'],dynamicStatus = StatusModel.fromJson(json['dynamicStatus']);
}class StatusModel {final String color;final String label;StatusModel (this.color,this.label,);StatusModel.fromJson(Map json): color = json['color'],label = json['label'];
}

写到这里model创建完了，但是怎么和数据库结合起来呢。这里我的想法是拿到数据之后，一般我们都是要解析json转换成model，在转换的时候就可以创建数据库，建表，然后进行存储；然后在需要的时候（比如断网）再从数据库里取出，转换成model。

所以要给model加两方法，一个是从sql转化到model，一个是model转化到map（DB的insert，update等方法需要数据以Map类型传入）
API:

// INSERT helperFuture<int> insert(String table, Map<String, dynamic> values,{String nullColumnHack, ConflictAlgorithm conflictAlgorithm});Future<int> update(String table, Map<String, dynamic> values,{String where,List<dynamic> whereArgs,ConflictAlgorithm conflictAlgorithm});

所以加了下面这两个方法：

Order.fromSql(Map<String, dynamic> json) {memberName = json['memberName'];customerPhone = json['customerPhone'];dynamicBottom = json['dynamicBottom'];productName = json['productName'];dynamicStatus = StatusModel.fromJson(json['dynamicStatus']);}Map<String, dynamic> toJson() {final Map<String, dynamic> data = new Map<String, dynamic>();data['memberName'] = this.memberName;data['customerPhone'] = this.customerPhone;data['dynamicBottom'] = this.dynamicBottom;data['productName'] = this.productName;data['dynamicStatus'] = this.dynamicStatus;return data;}

3.写一个创建DB的类

写的过程中，为了实现update方法，又添加了一个唯一的属性orderNo,为了根据orderNo更新数据

class DatabaseHelper {static final DatabaseHelper _instance = new DatabaseHelper.internal();factory DatabaseHelper() => _instance;final String tableOrder = 'OrderTable';//表名称//每列名称final String columnId = 'id';final String memberName = 'memberName';final String dynamicBottom = 'dynamicBottom';final String productName = 'productName';final String customerPhone = 'customerPhone';final String color = 'color';final String label = 'label';final String orderNo = 'orderNo';static Database _db;DatabaseHelper.internal();Future<Database> get db async {//这里修改了判断条件，因为每次执行完都会关闭，只判断是否null 会导致下次执行时数据库是close状态if (_db != null && _db.isOpen) {return _db;}_db = await initDb();return _db;}initDb() async {String databasesPath = await getDatabasesPath();String path = join(databasesPath, 'orderlist.db');var db = await openDatabase(path, version: 1, onCreate: _onCreate);return db;}void _onCreate(Database db, int newVersion) async {await db.execute('CREATE TABLE $tableOrder ($columnId INTEGER PRIMARY KEY, $memberName TEXT, $dynamicBottom TEXT, $productName TEXT, $customerPhone TEXT, $color TEXT, $label TEXT, $orderNo TEXT)');}Future<int> insertOrder(Order order) async {var dbClient = await db;var result = await dbClient.insert(tableOrder, order.toJson());return result;}Future<List> selectOrders({int limit, int offset}) async {var dbClient = await db;var result = await dbClient.query(tableOrder,columns: [columnId, memberName, customerPhone, productName, color, label],limit: limit,offset: offset,);List<Order> orders = [];result.forEach((item) => orders.add(Order.fromSql(item)));return orders;}Future<int> getCount() async {var dbClient = await db;return Sqflite.firstIntValue(await dbClient.rawQuery('SELECT COUNT(*) FROM $tableOrder'));}Future<Order> getOrder(int id) async {var dbClient = await db;List<Map> result = await dbClient.query(tableOrder,columns: [columnId, memberName, customerPhone, productName, color, label],where: '$id = ?',whereArgs: [id]);if (result.length > 0) {return Order.fromSql(result.first);}return null;}Future<int> deleteNote(int id) async {var dbClient = await db;return await dbClient.delete(tableOrder, where: '$id = ?', whereArgs: [id]);}Future<int> updateNote(Order order) async {var dbClient = await db;return await dbClient.update(tableOrder, order.toJson(),where: "$orderNo = ?", whereArgs: [order.orderNo]);}Future close() async {var dbClient = await db;return dbClient.close();}
}

4.写一段json数据用于插入数据库

5.应用
先将本地json数据存入数据库

_saveOrderJson() async {var db = DatabaseHelper();String jsonStr = await DefaultAssetBundle.of(context).loadString("assets/json/order.json");List list = json.decode(jsonStr);List<Order> modelList = list.map((item) => Order.fromJson(item)).toList();modelList.forEach((v) => db.insertOrder(v));}

根据数据库路径找到并打开数据库可以看到存入的数据

除了遍历数组逐条插入还可以进行批量插入使用batch

Future<List> batchInsertOrders(List<Order> orders) async {var dbClient = await db;//这里事务用不用都可以// Batch batch = dbClient.batch();//   orders.forEach((v) => batch.insert(tableOrder, v.toJson()));//   var result = await batch.commit();//   return result;await dbClient.transaction((txn) async {Batch batch = txn.batch();orders.forEach((v) => batch.insert(tableOrder, v.toJson()));var result = await batch.commit();return result;});}

然后在取出数据库中的数据并展示的页面上

_getOrderFromDB() async {var db = DatabaseHelper();modelList = await db.selectAllOrders();print('model list count is ${modelList.length}');}

这里添加了一个selectAllOrders的方法，就是执行了SELECT * FROM $tableOrder这句SQL

到此，数据库的实践使用就完成了。

flutter 数据持久化之sqflite相关推荐

Flutter数据持久化
前言欢迎阅读Flutter系列教程,本文讲解Flutter的数据持久化.主要分三块内容: 1.使用Sqlite 2.读写文件 3.存储键值对 Sqlite的使用如果你的APP需要经常在本地存储查询 ...
Flutter知识点:数据存储之sqflite
sqflite是一款轻量级的关系型数据库,类似SQLite. 在Flutter平台我们使用sqflite库来同时支持Android 和iOS. 使用介绍 1.首选需要在pubspec.yaml 导入库 ...
Android数据持久化：SharePreference
SharePreference:作为Android数据持久化的一种,具有一定的便捷性,适合存储一些体积小的数据. 存储数据方式:键值对的方式,类似于Map: 利用SharePreference.Edi ...
Android数据持久化：文件存储
数据持久化: 数据可分为瞬时数据和关键数据.保存在内存之中的数据是瞬时数据,而对于一些关键性数据,后期需要持续使用的,应当保存在存储设备中: 持久化保存方式: 文件存储.SharePreference ...
仅需6步，教你轻易撕掉app开发框架的神秘面纱（5）：数据持久化
遇到的问题有的时候程序中需要全局皆可访问的变量,比如:用户是否登录,用户个人信息(用户名,地区,生日),或者一些其他信息如:是否是首次登录,是否需要显示新手引导等等. 其中有些数据需要持久化到本地硬 ...
数据持久化框架为什么放弃Hibernate、JPA、Mybatis，最终选择JDBCTemplate！
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试文章因为项目需要选择数据持久化框架,看了一下主要几个流行的和不流行的框 ...
Java 数据持久化系列之池化技术
点击上方"方志朋",选择"设为星标" 回复"666"获取新整理的面试资料在上一篇文章Java 数据持久化系列之JDBC中,我们了解到使用 ...
docker容器运行mysql持久化_docker容器实现数据持久化的两种方式及其区别
前言这篇博文是我对docker实现数据持久化几种方式的特征进行一个总结. 在docker中,它的存储文件系统是在dockerhost上原有的xfs或ext4架设了一层文件系统:overlay2(将此 ...
iOS中几种数据持久化方案总结
概论所谓的持久化,就是将数据保存到硬盘中,使得在应用程序或机器重启后可以继续访问之前保存的数据.在iOS开发中,有很多数据持久化的方案,接下来我将尝试着介绍一下5种方案: plist文件(属性列表) ...

flutter 数据持久化之sqflite

flutter 数据持久化之sqflite相关推荐

最新文章

热门文章