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

sa_sqflite_lego 是一个用于 Flutter 的数据库管理插件，它基于 sqflite 库，提供了更高级的抽象和简化的 API，使得在 Flutter 应用中使用 SQLite 数据库更加方便。以下是如何使用 sa_sqflite_lego 的基本步骤和示例。

1. 添加依赖

首先，在 pubspec.yaml 文件中添加 sa_sqflite_lego 依赖：

dependencies:
  flutter:
    sdk: flutter
  sa_sqflite_lego: ^latest_version

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

2. 初始化数据库

在你的 Dart 文件中导入 sa_sqflite_lego 并初始化数据库：

import 'package:sa_sqflite_lego/sa_sqflite_lego.dart';

void main() async {
  WidgetsFlutterBinding.ensureInitialized();

  // 初始化数据库
  final database = await SaDatabase.openDatabase(
    name: 'my_database.db',
    version: 1,
    onCreate: (db, version) async {
      // 创建表
      await db.execute('''
        CREATE TABLE User(
          id INTEGER PRIMARY KEY AUTOINCREMENT,
          name TEXT,
          age INTEGER
        )
      ''');
    },
    onUpgrade: (db, oldVersion, newVersion) async {
      // 数据库升级逻辑
    },
  );

  runApp(MyApp(database: database));
}

3. 定义模型类

定义一个模型类来表示数据库中的数据：

class User {
  int? id;
  String name;
  int age;

  User({this.id, required this.name, required this.age});

  Map<String, dynamic> toMap() {
    return {
      'id': id,
      'name': name,
      'age': age,
    };
  }

  factory User.fromMap(Map<String, dynamic> map) {
    return User(
      id: map['id'],
      name: map['name'],
      age: map['age'],
    );
  }
}

4. 插入数据

使用 SaDatabase 实例插入数据：

Future<void> insertUser(User user) async {
  final db = database;
  await db.insert('User', user.toMap());
}

5. 查询数据

使用 SaDatabase 实例查询数据：

Future<List<User>> getUsers() async {
  final db = database;
  final List<Map<String, dynamic>> maps = await db.query('User');

  return List.generate(maps.length, (i) {
    return User.fromMap(maps[i]);
  });
}

6. 更新数据

使用 SaDatabase 实例更新数据：

Future<void> updateUser(User user) async {
  final db = database;
  await db.update(
    'User',
    user.toMap(),
    where: 'id = ?',
    whereArgs: [user.id],
  );
}

7. 删除数据

使用 SaDatabase 实例删除数据：

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

8. 使用示例

在 Flutter 应用中使用上述方法：

class MyApp extends StatelessWidget {
  final SaDatabase database;

  MyApp({required this.database});

  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('sa_sqflite_lego Example'),
        ),
        body: Center(
          child: Column(
            mainAxisAlignment: MainAxisAlignment.center,
            children: <Widget>[
              ElevatedButton(
                onPressed: () async {
                  final user = User(id: null, name: 'John Doe', age: 30);
                  await insertUser(user);
                },
                child: Text('Insert User'),
              ),
              ElevatedButton(
                onPressed: () async {
                  final users = await getUsers();
                  print(users);
                },
                child: Text('Get Users'),
              ),
              ElevatedButton(
                onPressed: () async {
                  final user = User(id: 1, name: 'Jane Doe', age: 25);
                  await updateUser(user);
                },
                child: Text('Update User'),
              ),
              ElevatedButton(
                onPressed: () async {
                  await deleteUser(1);
                },
                child: Text('Delete User'),
              ),
            ],
          ),
        ),
      ),
    );
  }
}

9. 关闭数据库

在应用关闭时，记得关闭数据库连接：

void dispose() async {
  await database.close();
}