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

在本示例中，我们将展示如何在Flutter项目中使用needle_orm_mariadb插件来管理和操作MariaDB数据库。needle_orm_mariadb是一个用于ORM（对象关系映射）的插件，它简化了数据库的操作。

初始化MariaDB连接

首先，我们需要创建一个MariaDB数据库连接。这通常在应用启动时完成。以下是一个简单的初始化方法：

import 'package:mysql1/mysql1.dart';
import 'package:needle_orm/needle_orm.dart';
import 'package:needle_orm_mariadb/needle_orm_mariadb.dart';

// 初始化MariaDB数据库连接
Future<Database> initMariaDb() async {
  var settings = ConnectionSettings(
    host: 'localhost', // 数据库主机地址
    port: 3306,        // 数据库端口号
    user: 'needle',    // 数据库用户名
    password: 'needle', // 数据库密码
    db: 'needle'       // 数据库名称
  );
  var conn = await MySqlConnection.connect(settings);
  return MariaDbDatabase(conn); // 返回MariaDbDatabase实例
}

创建表结构

接下来，我们定义一个简单的数据模型，并使用该模型创建表结构。以下是定义一个名为User的数据模型的示例：

import 'package:needle_orm_mariadb/needle_orm_mariadb.dart';

class User extends Entity {
  [@PrimaryKey](/user/PrimaryKey)(autoIncrement: true)
  int? id;

  String name;

  int age;

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

操作数据库

现在我们可以使用上述定义的模型进行数据库操作，如插入、查询等。以下是插入一条用户记录的示例：

void insertUser(Database db) async {
  var userRepository = UserRepository(db);

  // 创建一个用户实例
  var newUser = User(name: "张三", age: 28);

  // 插入用户记录
  await userRepository.create(newUser);
}

以下是从数据库中查询所有用户的示例：

Future<void> queryUsers(Database db) async {
  var userRepository = UserRepository(db);

  // 查询所有用户记录
  List<User> users = await userRepository.findAll();

  // 打印查询结果
  for (var user in users) {
    print('ID: ${user.id}, Name: ${user.name}, Age: ${user.age}');
  }
}

完整示例代码

将以上代码整合到一个完整的示例中，可以参考以下完整代码：

import 'package:mysql1/mysql1.dart';
import 'package:needle_orm/needle_orm.dart';
import 'package:needle_orm_mariadb/needle_orm_mariadb.dart';

class User extends Entity {
  [@PrimaryKey](/user/PrimaryKey)(autoIncrement: true)
  int? id;

  String name;

  int age;

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

void main() async {
  // 初始化MariaDB数据库连接
  var db = await initMariaDb();

  // 插入用户记录
  insertUser(db);

  // 查询所有用户记录
  await queryUsers(db);
}

Future<Database> initMariaDb() async {
  var settings = ConnectionSettings(
    host: 'localhost',
    port: 3306,
    user: 'needle',
    password: 'needle',
    db: 'needle'
  );
  var conn = await MySqlConnection.connect(settings);
  return MariaDbDatabase(conn);
}

void insertUser(Database db) async {
  var userRepository = UserRepository(db);

  // 创建一个用户实例
  var newUser = User(name: "张三", age: 28);

  // 插入用户记录
  await userRepository.create(newUser);
}

Future<void> queryUsers(Database db) async {
  var userRepository = UserRepository(db);

  // 查询所有用户记录
  List<User> users = await userRepository.findAll();

  // 打印查询结果
  for (var user in users) {
    print('ID: ${user.id}, Name: ${user.name}, Age: ${user.age}');
  }
}