Flutter数据库基础设施插件db_infra的使用

Flutter数据库基础设施插件db_infra的使用

在本示例中，我们将展示如何使用db_infra插件来处理数据库操作。我们将创建一个简单的Flutter应用，该应用能够连接到SQLite数据库并执行基本的CRUD（创建、读取、更新、删除）操作。

示例代码

首先，确保你已经添加了db_infra依赖到你的pubspec.yaml文件中：

dependencies:
  flutter:
    sdk: flutter
  db_infra: ^1.0.0

然后，运行flutter pub get以安装依赖项。

接下来，我们来看一下完整的示例代码。

import 'package:flutter/foundation.dart';
import 'package:flutter/material.dart';
import 'package:db_infra/db_infra.dart'; // 导入db_infra库

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

///
class MyApp extends StatelessWidget {
  ///
  const MyApp({Key? key}) : super(key: key);

  // 这个小部件是你的应用的根。
  @override
  Widget build(BuildContext context) {
    return MaterialApp(
      title: 'Flutter Demo',
      theme: ThemeData(
        // 这是你应用的主题。
        primarySwatch: Colors.blue,
      ),
      home: const MyHomePage(title: 'Flutter Demo Home Page'),
    );
  }
}

///
class MyHomePage extends StatefulWidget {
  ///
  const MyHomePage({required this.title, Key? key}) : super(key: key);

  // 这个小部件是你的应用的主页面。它是一个有状态的小部件，意味着它有一个包含影响其外观字段的状态对象。
  // 这个类是状态的配置。它持有由父级（在这个例子中是App小部件）提供的值（在这个例子中是标题），并用于构建方法的状态构建。
  // 小部件子类中的字段总是标记为“final”。

  ///
  final String title;

  @override
  _MyHomePageState createState() => _MyHomePageState();
}

class _MyHomePageState extends State<MyHomePage> {
  int _counter = 0;
  DatabaseHelper dbHelper = DatabaseHelper(); // 创建DatabaseHelper实例

  void _incrementCounter() {
    setState(() {
      _counter++;
    });
  }

  @override
  Widget build(BuildContext context) {
    return Scaffold(
      appBar: AppBar(
        title: Text(widget.title),
      ),
      body: Center(
        child: Column(
          mainAxisAlignment: MainAxisAlignment.center,
          children: <Widget>[
            const Text('你按下了按钮次数：'),
            Text(
              '$_counter',
              style: Theme.of(context).textTheme.headline4,
            ),
            ElevatedButton(
              onPressed: () async {
                await dbHelper.insertData('test', {'name': 'John Doe'});
                print('数据插入成功');
              },
              child: Text('插入数据'),
            ),
            ElevatedButton(
              onPressed: () async {
                var data = await dbHelper.getData('test');
                print('查询结果: $data');
              },
              child: Text('查询数据'),
            ),
            ElevatedButton(
              onPressed: () async {
                await dbHelper.updateData('test', 1, {'name': 'Jane Doe'});
                print('数据更新成功');
              },
              child: Text('更新数据'),
            ),
            ElevatedButton(
              onPressed: () async {
                await dbHelper.deleteData('test', 1);
                print('数据删除成功');
              },
              child: Text('删除数据'),
            ),
          ],
        ),
      ),
      floatingActionButton: FloatingActionButton(
        onPressed: _incrementCounter,
        tooltip: 'Increment',
        child: const Icon(Icons.add),
      ),
    );
  }
}

数据库帮助类 DatabaseHelper

为了简化数据库操作，我们可以创建一个帮助类DatabaseHelper来封装所有的数据库操作逻辑。

import 'package:db_infra/db_infra.dart';

class DatabaseHelper {
  static final DatabaseHelper _instance = DatabaseHelper._internal();
  factory DatabaseHelper() => _instance;
  DatabaseHelper._internal();

  Database? _database;

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

  Future<Database> initializeDatabase() async {
    Directory documentsDirectory = await getApplicationDocumentsDirectory();
    String path = join(documentsDirectory.path, 'app_database.db');
    return await openDatabase(path, version: 1, onCreate: _onCreate);
  }

  void _onCreate(Database db, int version) async {
    await db.execute("CREATE TABLE test(id INTEGER PRIMARY KEY, name TEXT)");
  }

  Future<void> insertData(String tableName, Map<String, dynamic> row) async {
    final db = await database;
    await db.insert(tableName, row);
  }

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

  Future<int> updateData(String tableName, int id, Map<String, dynamic> row) async {
    final db = await database;
    return await db.update(tableName, row, where: 'id = ?', whereArgs: [id]);
  }

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