Flutter中資料庫的使用教學詳解

import 'package:sqflite/sqflite.dart';

/// 資料庫幫助類
class DbHelper {

  final String path = "laoli.db"; // 資料庫名稱 一般不變
 //資料庫中的表名字 這裡是我存錯歷史搜尋記錄的表
  static final searchTab = "SearchHistory";
   //私有構造
  DbHelper._();
  static DbHelper? _instance;
  static DbHelper get instance => _getInstance();
  factory DbHelper() {
    return instance;
  }
  static DbHelper _getInstance() {
    if (_instance == null) {
      _instance = DbHelper._();
    }
    return _instance ?? DbHelper._();
  }

/// 資料庫預設儲存的路徑
  /// SQLite 資料庫是檔案系統中由路徑標識的檔案。如果是relative，
  /// 這個路徑是相對於 獲取的路徑getDatabasesPath()，
  /// Android預設的資料庫目錄，
  /// iOS/MacOS的documents目錄。

  Future<Database>? _db;

  Future<Database>? getDb() {
    _db ??= _initDb();
    return _db;
  }

  // Guaranteed to be called only once.保證只呼叫一次
  Future<Database> _initDb() async {
  // 這裡是我們真正建立資料庫的地方 vserion代表資料庫的版本，如果版本改變
  //，則db會呼叫onUpgrade方法進行更新操作
    final db =
        await openDatabase(this.path, version: 1, onCreate: (db, version) {
      // 資料庫建立完成
      // 建立表 一個自增id 一個text
db.execute("create table $searchTab (id integer primary key autoincrement, name text not null)");      
    }, onUpgrade: (db, oldV, newV) {
      // 升級資料庫呼叫 
    ///  db 資料庫
   ///   oldV 舊版本號
   //   newV 新版本號
   //   升級完成就不會在呼叫這個方法了
    });

return db;
  }

// 關閉資料庫
  close() async {
    await _db?.then((value) => value.close());
  }
}

/// 資料操作類
class DbSearchHistoryDao {
  /// 增
  static insert(String text) {
    // 去重
    queryAll().then((value) {
      bool isAdd = true;
      for (var data in value) {
        if (data.name == text) {
          isAdd = false;
          break;
        }
      }
      if (isAdd) {
        DbHelper.instance.getDb()?.then((value) => value.insert(
              DbHelper.searchTab,
              DbSearchHotBean(name: text).toJson(),
            ));
      }
    });
  }

  /// 刪 全部
  static deleteAll() {
    DbHelper.instance.getDb()?.then((value) => value.delete(
          DbHelper.searchTab,
        ));
  }

  /// 更新資料 通過id更新表內具體行的資料
  static update(DbSearchHotBean dbSearchHotBean) {
    DbHelper.instance.getDb()?.then((value) => value.update(
      DbHelper.searchTab,
      dbSearchHotBean.toJson(),//具體更新的資料
      where: "id = ?"//通過id查詢需要更新的資料
      ,whereArgs: [dbSearchHotBean.id]
    ));
  }

  /// 通過name查具體的實體類
  static Future<DbSearchHotBean?> getBean(String name) async {
  var db = await DbHelper.instance.getDb();
  var maps = await db?.query(DbHelper.searchTab,
    columns: ['id','name'],// 獲取實體類的哪些欄位 預設全部
    where: 'name = ?',//通過實體類中的name欄位
    whereArgs: [name]);//具體name的值 限定資料
  if(maps!=null && maps.length > 0) {
       return DbSearchHotBean.fromJson(maps.first);
  }
  return null;
  }

  /// 查 全部all
  static Future<List<DbSearchHotBean>> queryAll() async {
    List<DbSearchHotBean> list = [];
    await DbHelper.instance
        .getDb()
        ?.then((db) => db.query(DbHelper.searchTab).then((value) {
              for (var data in value) {
                list.add(DbSearchHotBean.fromJson(data));
              }
            }));
    return list;
  }
}

class DbSearchHotBean {
  int? id;
  String? name; // 搜尋詞

  DbSearchHotBean({this.id,required this.name});

  DbSearchHotBean.fromJson(Map<String, dynamic> json) {
    id = json['id'];
    name = json['name'];
  }

  Map<String, String?> toJson() {
    var map = <String, String?>{};
    map['id'] = id?.toString() ;
    map['name'] = name ?? "";

    return map;
  }
}

DbSearchHistoryDao.getBean("水").then((value){
  if(value!=null){
    DbSearchHistoryDao.update(DbSearchHotBean(id: value.id,name: "火"));
  }
});

batch = db.batch();
batch.insert('Test', {'name': 'item'});
batch.update('Test', {'name': 'new_item'}, where: 'name = ?', whereArgs: ['item']);
batch.delete('Test', where: 'name = ?', whereArgs: ['item']);
results = await batch.commit();