Flutter 本地数据库sqflite实战操作「建议收藏」

Flutter 本地数据库sqflite实战操作「建议收藏」Flutter本地化数据库操作、sqflite操作方法、数据库操作

大家好,又见面了,我是你们的朋友全栈君。

Flutter 本地数据库sqflite实战操作

通过本文章将带你了解sqflite如何使用并管理,注意要学习本功能、要具备一定的sql数据库操作的基础知识!

知识点:

  • 本地化列表数据
  • 本地化列表详情数据
  • sqflite 本地化数据库增删改查操作
一、安装sqflite

https://pub.flutter-io.cn/packages/sqflite

二、创建Db数据库文件夹,创建Db文件

文件夹路径:Lib/Db/StepTasksDb/StepTasksDb.dart

三、编辑Db文件

StepTasksDb.dart全部代码

import 'package:path/path.dart';
import 'package:sqflite/sqflite.dart';

// 定义数据库Mock模型
final String tableName = 'step_task_table';                       // 数据库名称
final String columnId = '_id';                                    // 索引id
final String columnType = 'step_listType';                        // 列表类型
final String columnStepListData = 'step_listData';                // 列表数据
final String columnStepDataDetails = 'step_status';               // 列表详情数据


// 定义模板模型类
class StepTasks { 
   
  int id;
  String stepListType;                                            // 列表类型
  String stepListData;                                            // 列表数据
  String stepDataDetails;                                         // 详情数据

  StepTasks({ 
   this.id, this.stepListType, this.stepListData, this.stepDataDetails});

  // 模型转Map数据使用
  Map<String, Object> toMap() { 
   
    var map = <String ,Object>{ 
   
      columnType:stepListType,
      columnStepListData:stepListData,
      columnStepDataDetails:stepDataDetails
    };
    if (id != null) { 
   
      map[columnId] = id;
    }
    return map;
  }

  // 模型数据传入类中
  StepTasks.fromMap(Map<String, Object> map){ 
   
    id = map[columnId];
    stepListType = map[columnType];
    stepListData = map[columnStepListData];
    stepDataDetails = map[columnStepDataDetails];
  }
}

// 定义数据库
class StepTasksDb { 
   
  Database db;
  
  // 初始化数据库
  Future<String> initDatabase() async { 
   
    // 获取本地存储数据库路径
    var databasesPath = await getDatabasesPath();
    // 创建数据库db文件
    String path = join(databasesPath, 'stepTasks.db');
    return path;
  }

  // 打开并创建表
  Future open(String path) async { 
   
    print('------------------打开并创建表<StepTasksDb>------------------');
    db = await openDatabase(path, version:1, onCreate:(Database db, int version) async { 
   
      await db.execute('''
        create table $tableName (
          $columnId integer primary key autoincrement,
          $columnType text ,
          $columnStepListData text ,
          $columnStepDataDetails text
        )
      ''');
    });
  }

  // 添加数据
  Future<StepTasks> insert(StepTasks data) async { 
   
    data.id = await db.insert(tableName, data.toMap());
    return data;
  }

  // 获取数据(根据type条件查询)
  Future<List> getData({ 
   type = ''}) async { 
   
    List<Map> maps = [];
    maps = await db.query(tableName, columns:[columnId, columnType, columnStepListData, columnStepDataDetails], where: '$columnType = ?', whereArgs: [type]);

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

    List list = [];

    for(int i = 0; i<maps.length; i++){ 
   
      list.add(maps[i]);
    }

    return list;
  }


  // 修改数据(通过id匹配修改整个数据)
  Future<int> update(StepTasks data) async { 
   
    return await db.update(tableName, data.toMap(), where: '$columnId = ?', whereArgs: [data.id]);
  }

  // 删除数据(通过id匹配删除数据)
  Future<int> delete(int id) async { 
   
    return await db.delete(tableName, where:'$columnId = ?', whereArgs:[id]);
  }

  // 关闭此表的链接
  Future close() async => db.close();
}
四、使用创建的数据库文件

注意:
首先安装网络监听插件:connectivity,虽然本插件已经停止更新了,但是在Pub官方文档也有新的插件替代了旧插件,大家可以凭个人需求来,这里不强求用什么插件,只需要达到网络监听效果即可。

import 'dart:convert';
import 'package:flutter/material.dart';
import 'TestDb_Flutter/Db/StepTasksDb/StepTasksDb.dart';

class TestDbPage extends StatefulWidget { 
   

  @override
  State<TestDbPage> createState() => _TestDbPageState();
}

class _TestDbPageState extends State<TestDbPage> { 
   

  var listData = [];
  var _storageListData = [];          // 存储本地数据
  List cacheSelectList = [];          // 存储需要缓存的数据
  var networkStatus = -1;			  // -1:没有网络 1:wifi 2:4G
  StepTasksDb _stepTaskDb = StepTasksDb();

  @override
  void initState() { 
    
    super.initState();
    _initDatabase();
  }
  
 // 打开数据库
  Future _initDatabase() async { 
   
    String path = await _stepTaskDb.initDatabase();
    // await File(path).delete(); // 删除表
    await _stepTaskDb.open(path);       // 打开表
    _getListData();
  }

 // 网络请求数据
 Future _getListData() async { 
   
 	await _getStorageData();
 	if(networkStatus == 1){ 
   
 		var res = await api.request('https://xxx.xxxx/api');
		setState((){ 
   listData = res['data']})
		return res;
 	}else{ 
   
 		// 没有网络的话
	    setState(() { 
   
	      _listData = _storageListData;
	    });
	    return _storageListData;
 	}
	
 }

 // 获取本地数据
 Future _getStorageData() async { 
   
    var data = await _stepTaskDb.getData(type: 'process');   
    setState(() { 
   
      _storageListData = data;           // 先赋值一次 以便添加时使用
    });
  }
  
  @override
  void dispose() { 
   
    // 关闭数据库
    _stepTaskDb.close();
    super.dispose();
  }

  @override
  Widget build(BuildContext context) { 
   
    return ListView.builder(
      itemCount: listData.length,
      itemBuilder: (context, index){ 
   
        return InkWell(
        	child:Container(child:Text(listData[index]['title']));
        	onTap:(){ 
   
        	      // 创建要存储本地的数据
        		  var dataBase = { 
   
                    'step_listData': json.encode(listData[index]),
                  };
                  // 请求详情的参数
                  var params = { 
   id:'xxx'};
                  var res = await api.request('https://xxx.xxxx/api', formData: params);
				  // 不为空的话,证明拿到了正常数据,将其存储到要存储的数据参数中
                  if(res != null){ 
   
                    dataBase['assets_listDetails'] = json.encode(res['data']);
                  }
        		  // 进行本地缓存
                  var db_res = await _stepTaskDb.insert(StepTasks(stepListType:'process', stepListData:dataBase['step_listData'], stepDataDetails:dataBase['assets_listDetails']));
        	},
        	onLongPress: (){ 
   
        			// 只在获取了本地存储的情况下,才能够通过id删除数据
	       	      _stepTaskDb.delete(v['_id']);
	      	},
        );
      },
    );
  }
}

以上代码暂且只介绍了本地化操作的 增删查操作、至于修改操作,则和增操作大体类似,通过传入的本地数据id,来将新的数据替换掉旧的数据即可

例子:

var res = await _stepTaskDb.update(StepTasks(id:v['id'], stepListType:'process', stepListData:dataBase['listData'], stepDataDetails:dataBase['listDetails']));

目前为止,应该将最基本的增删改查操作介绍完了,并且附上了例子,如果不出大问题的话,大家应该可以达到本地化数据的操作,有问题请下方留言联系我~

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/138486.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • USB调试助手_蓝牙串口APP

    USB调试助手_蓝牙串口APP今天终于把USB调试助手做完了,程序看起来自己还算满意,虽然有些地方还需完善,但整体功能已经实现了,程序就叫“USB调试助手”吧,是一款USB设备测试工具,可用于研究学习USB协议或进行USB设备开发测试使用,程序已经上传到CSDN了(https://download.csdn.net/download/donghailin/11965800),以方便大家下载,也希望大家提宝贵意…

  • 让我郁闷的第一次做站[通俗易懂]

    让我郁闷的第一次做站[通俗易懂]我是今年7月份毕业的,我在学校学的软件专业,但是在学校的时候很贪玩,没学到多少东西,毕业后找本专业的工作处处碰壁找不到,后来去了个seo公司,他们是做英文的,这也是我第一次接触这个行业,原来不知道seo的存在。这个公司很小的,其实主要的业务都是给别人代发外链,我也就成了外链专员。因为刚接触连seo是什么都不知道,我就在网上到处找相关的论坛视频教程看,发现很多教程都是要收费的,不收费的讲的太潦草,有

  • Visio2013密钥_excel2013密钥

    Visio2013密钥_excel2013密钥C2FG9-N6J68-H8BTJ-BW3QX-RM3B3 2NYF6-QG2CY-9F8XC-GWMBW-29VV8 FJ2N7-W8TXC-JB8KB-DCQ7Q-7T7V3&

  • 初识js中的闭包_Js闭包中变量理解

    初识js中的闭包_Js闭包中变量理解今天看了关于js闭包方面的文章,还是有些云里雾里,对于一个菜鸟来说,学习闭包确实有一定的难度,不说别的,能够在网上找到一篇优秀的是那样的不易。当然之所以闭包难理解,个人觉得是基础知识掌握的不牢,因为

  • matlab求解时滞微分方程_matlab延迟环节传递函数

    matlab求解时滞微分方程_matlab延迟环节传递函数具有常时滞的DDERef:时滞微分方程—示例

  • LSTM模型介绍

    LSTM模型介绍递归神经网络(RNN)人类不会每时每刻都开始思考。当你阅读这篇文章时,你会根据你对之前单词的理解来理解每个单词。你不会忘掉掉所有东西,然后再从头开始思考。你的想法有持久性。传统的神经网络不能做到这一点,这是一个主要的缺点。例如,假设您想要对电影视频中每个点发生的事件进行分类。目前尚传统神经网络无法利用其对电影中先前事件的推理来预测后者。循环神经网络解决了这个问题。它们是带有循环的…

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号