Flutter MySQL数据库连接插件mysql1的使用

mysql1 是一个用于Dart编程语言的MySQL驱动程序。它可以在Flutter和服务器端工作。这个库旨在提供一个易于使用的MySQL接口，mysql1 最初是SQLJocky驱动程序的一个分支。

使用方法

连接到数据库

要连接到MySQL数据库，您需要创建一个 ConnectionSettings 对象，并使用 MySqlConnection.connect 方法来建立连接。下面是一个简单的例子：

var settings = ConnectionSettings(
  host: 'localhost', 
  port: 3306,
  user: 'bob',
  password: 'wibble',
  db: 'mydb'
);
var conn = await MySqlConnection.connect(settings);

执行带参数的查询

您可以执行带有参数的查询以确保安全性和效率。以下是如何执行这样的查询并处理结果：

var userId = 1;
var results = await conn.query('select name, email from users where id = ?', [userId]);

for (var row in results) {
  print('Name: ${row[0]}, email: ${row[1]}');
}

插入数据

插入新记录到表中也很简单：

var result = await conn.query('insert into users (name, email, age) values (?, ?, ?)', ['Bob', 'bob@bob.com', 25]);
print("New user's id: ${result.insertId}");

如果您的表中有自增列，那么插入操作的结果将包含新行的ID。

更新数据

更新现有记录同样直观：

await conn.query('update users set age=? where name=?', [26, 'Bob']);

多次插入

如果您有多个数据集要插入，可以一次性完成：

var results = await conn.queryMulti(
    'insert into users (name, email, age) values (?, ?, ?)',
    [['Bob', 'bob@bob.com', 25],
    ['Bill', 'bill@bill.com', 26],
    ['Joe', 'joe@joe.com', 37]]);

注意事项 - Flutter Web

需要注意的是，此包通过打开一个到数据库的套接字来工作。由于Web平台不支持套接字，因此该包在Flutter Web上无法使用。

完整示例代码

以下是一个完整的示例，展示了如何创建表格、插入数据、查询数据、更新数据以及关闭连接：

import 'dart:async';
import 'package:mysql1/mysql1.dart';

Future main() async {
  // 建立与数据库的连接（假设testdb已经存在）
  final conn = await MySqlConnection.connect(ConnectionSettings(
      host: 'localhost',
      port: 3306,
      user: 'root',
      db: 'testdb',
      password: 'secret'));

  try {
    // 创建一个名为users的表
    await conn.query(
        'CREATE TABLE IF NOT EXISTS users (id int NOT NULL AUTO_INCREMENT PRIMARY KEY, name varchar(255), email varchar(255), age int)');

    // 向users表中插入一条数据
    var result = await conn.query(
        'insert into users (name, email, age) values (?, ?, ?)',
        ['Bob', 'bob@bob.com', 25]);
    print('Inserted row id=${result.insertId}');

    // 查询刚刚插入的数据
    var results = await conn.query(
        'select name, email, age from users where id = ?', [result.insertId]);
    for (var row in results) {
      print('Name: ${row[0]}, email: ${row[1]} age: ${row[2]}');
    }

    // 更新用户年龄
    await conn.query('update users set age=? where name=?', [26, 'Bob']);

    // 再次查询更新后的数据
    var results2 = await conn.query(
        'select name, email, age from users where id = ?', [result.insertId]);
    for (var row in results2) {
      print('Name: ${row[0]}, email: ${row[1]} age: ${row[2]}');
    }
  } finally {
    // 关闭数据库连接
    await conn.close();
  }
}

请根据实际情况调整数据库配置信息（如主机名、用户名、密码等），并确保您的应用程序具有适当的权限来执行上述操作。