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

在Flutter中，如果你需要使用SQLite数据库进行本地数据存储，可以使用 sqflite 插件。sqflite 是一个流行的Flutter插件，它提供了对SQLite数据库的访问和管理功能。以下是使用 sqflite 插件的基本步骤：

1. 添加依赖

首先，在 pubspec.yaml 文件中添加 sqflite 和 path 依赖：

dependencies:
  flutter:
    sdk: flutter
  sqflite: ^2.0.0+4
  path: ^1.8.0

然后运行 flutter pub get 来安装依赖。

2. 创建数据库

接下来，你可以创建一个数据库并定义表结构。以下是一个简单的例子：

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

class DatabaseHelper {
  static final DatabaseHelper _instance = DatabaseHelper._internal();
  static Database? _database;

  factory DatabaseHelper() {
    return _instance;
  }

  DatabaseHelper._internal();

  Future<Database> get database async {
    if (_database != null) return _database!;
    _database = await _initDatabase();
    return _database!;
  }

  Future<Database> _initDatabase() async {
    String path = join(await getDatabasesPath(), 'my_database.db');
    return await openDatabase(
      path,
      version: 1,
      onCreate: _onCreate,
    );
  }

  Future<void> _onCreate(Database db, int version) async {
    await db.execute(
      'CREATE TABLE my_table(id INTEGER PRIMARY KEY, name TEXT, age INTEGER)',
    );
  }
}

3. 插入数据

你可以使用 insert 方法向数据库中插入数据：

Future<void> insertData(String name, int age) async {
  final db = await DatabaseHelper().database;
  await db.insert(
    'my_table',
    {'name': name, 'age': age},
    conflictAlgorithm: ConflictAlgorithm.replace,
  );
}

4. 查询数据

你可以使用 query 方法从数据库中查询数据：

Future<List<Map<String, dynamic>>> getData() async {
  final db = await DatabaseHelper().database;
  return await db.query('my_table');
}

5. 更新数据

你可以使用 update 方法更新数据库中的数据：

Future<void> updateData(int id, String name, int age) async {
  final db = await DatabaseHelper().database;
  await db.update(
    'my_table',
    {'name': name, 'age': age},
    where: 'id = ?',
    whereArgs: [id],
  );
}

6. 删除数据

你可以使用 delete 方法删除数据库中的数据：

Future<void> deleteData(int id) async {
  final db = await DatabaseHelper().database;
  await db.delete(
    'my_table',
    where: 'id = ?',
    whereArgs: [id],
  );
}

7. 关闭数据库

在应用程序退出时，你可以关闭数据库以释放资源：

Future<void> closeDatabase() async {
  final db = await DatabaseHelper().database;
  await db.close();
}

示例代码

以下是一个完整的示例代码，展示了如何使用 sqflite 插件进行数据库操作：

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

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

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('SQLite Example'),
        ),
        body: Center(
          child: Column(
            mainAxisAlignment: MainAxisAlignment.center,
            children: [
              ElevatedButton(
                onPressed: () async {
                  await DatabaseHelper().insertData('Alice', 30);
                  print('Data inserted');
                },
                child: Text('Insert Data'),
              ),
              ElevatedButton(
                onPressed: () async {
                  List<Map<String, dynamic>> data = await DatabaseHelper().getData();
                  print('Data: $data');
                },
                child: Text('Query Data'),
              ),
              ElevatedButton(
                onPressed: () async {
                  await DatabaseHelper().updateData(1, 'Alice Smith', 31);
                  print('Data updated');
                },
                child: Text('Update Data'),
              ),
              ElevatedButton(
                onPressed: () async {
                  await DatabaseHelper().deleteData(1);
                  print('Data deleted');
                },
                child: Text('Delete Data'),
              ),
            ],
          ),
        ),
      ),
    );
  }
}

class DatabaseHelper {
  static final DatabaseHelper _instance = DatabaseHelper._internal();
  static Database? _database;

  factory DatabaseHelper() {
    return _instance;
  }

  DatabaseHelper._internal();

  Future<Database> get database async {
    if (_database != null) return _database!;
    _database = await _initDatabase();
    return _database!;
  }

  Future<Database> _initDatabase() async {
    String path = join(await getDatabasesPath(), 'my_database.db');
    return await openDatabase(
      path,
      version: 1,
      onCreate: _onCreate,
    );
  }

  Future<void> _onCreate(Database db, int version) async {
    await db.execute(
      'CREATE TABLE my_table(id INTEGER PRIMARY KEY, name TEXT, age INTEGER)',
    );
  }

  Future<void> insertData(String name, int age) async {
    final db = await database;
    await db.insert(
      'my_table',
      {'name': name, 'age': age},
      conflictAlgorithm: ConflictAlgorithm.replace,
    );
  }

  Future<List<Map<String, dynamic>>> getData() async {
    final db = await database;
    return await db.query('my_table');
  }

  Future<void> updateData(int id, String name, int age) async {
    final db = await database;
    await db.update(
      'my_table',
      {'name': name, 'age': age},
      where: 'id = ?',
      whereArgs: [id],
    );
  }

  Future<void> deleteData(int id) async {
    final db = await database;
    await db.delete(
      'my_table',
      where: 'id = ?',
      whereArgs: [id],
    );
  }
}