在Flutter中连接MySQL数据库可以使用 mysql_connector 插件。这个插件允许你在Flutter应用中直接与MySQL数据库进行交互。以下是如何使用 mysql_connector 插件的步骤：

1. 添加依赖

首先，你需要在 pubspec.yaml 文件中添加 mysql_connector 插件的依赖：

dependencies:
  flutter:
    sdk: flutter
  mysql_connector: ^1.0.0  # 请检查最新版本

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

2. 创建数据库连接

在你的Flutter项目中，你可以创建一个类来管理数据库连接。例如：

import 'package:mysql_connector/mysql_connector.dart';

class DatabaseHelper {
  late MySqlConnection _connection;

  Future<void> connect() async {
    _connection = await MySqlConnection.connect(
      host: 'your_host',       // 数据库主机地址
      port: 3306,              // 数据库端口，默认是3306
      user: 'your_username',   // 数据库用户名
      password: 'your_password', // 数据库密码
      db: 'your_database',     // 数据库名称
    );
  }

  Future<void> close() async {
    await _connection.close();
  }

  Future<List<Map<String, dynamic>>> query(String sql) async {
    var results = await _connection.query(sql);
    return results.toList();
  }
}

3. 使用数据库连接

你可以在你的应用中使用这个类来执行SQL查询。例如：

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

  var dbHelper = DatabaseHelper();
  await dbHelper.connect();

  try {
    var results = await dbHelper.query('SELECT * FROM your_table');
    for (var row in results) {
      print(row);
    }
  } catch (e) {
    print('Error: $e');
  } finally {
    await dbHelper.close();
  }
}

4. 处理查询结果

query 方法返回的是一个 List<Map<String, dynamic>>，你可以遍历这个列表来获取每一行的数据。

5. 处理异常

在实际应用中，你应该处理可能的异常，例如网络问题、数据库连接失败等。

6. 关闭连接

在完成数据库操作后，记得关闭数据库连接以释放资源。

注意事项

• mysql_connector 插件是直接与MySQL数据库进行通信的，因此你的Flutter应用需要能够访问到数据库服务器。
• 在生产环境中，不建议直接在客户端应用中直接连接数据库，因为这可能会暴露数据库的敏感信息。通常建议使用后端服务来处理数据库操作，Flutter应用通过API与后端服务进行通信。

示例代码

以下是一个完整的示例代码：

import 'package:flutter/material.dart';
import 'package:mysql_connector/mysql_connector.dart';

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

  var dbHelper = DatabaseHelper();
  await dbHelper.connect();

  try {
    var results = await dbHelper.query('SELECT * FROM your_table');
    for (var row in results) {
      print(row);
    }
  } catch (e) {
    print('Error: $e');
  } finally {
    await dbHelper.close();
  }

  runApp(MyApp());
}

class MyApp extends StatelessWidget {
  [@override](/user/override)
  Widget build(BuildContext context) {
    return MaterialApp(
      home: Scaffold(
        appBar: AppBar(
          title: Text('Flutter MySQL Example'),
        ),
        body: Center(
          child: Text('Check the console for database query results.'),
        ),
      ),
    );
  }
}

class DatabaseHelper {
  late MySqlConnection _connection;

  Future<void> connect() async {
    _connection = await MySqlConnection.connect(
      host: 'your_host',
      port: 3306,
      user: 'your_username',
      password: 'your_password',
      db: 'your_database',
    );
  }

  Future<void> close() async {
    await _connection.close();
  }

  Future<List<Map<String, dynamic>>> query(String sql) async {
    var results = await _connection.query(sql);
    return results.toList();
  }
}