Flutter：从Future函数获取MariaDB查询返回值失败问题排查

你的问题核心是异步操作的结果没有正确返回：checkIfTableIsEmpty函数在异步数据库操作完成前就返回了初始值（null），而then回调里的赋值操作是异步执行的，外部无法同步获取到结果。以下是具体的修正方案：

修正后的代码实现 #

1. 重构checkIfTableIsEmpty函数 #

让函数返回Future<int>类型，通过async/await处理异步逻辑（比then链式调用更易读）：

import 'package:mysql1/mysql1.dart';

// 假设你的getConnection函数返回Future<MySqlConnection>
Future<MySqlConnection> getConnection() async {
  final settings = ConnectionSettings(
    host: 'localhost',
    port: 3306,
    user: 'your_username',
    password: 'your_password',
    db: 'your_database',
  );
  return await MySqlConnection.connect(settings);
}

Future<int> checkIfTableIsEmpty() async {
  MySqlConnection? conn;
  try {
    conn = await getConnection();
    // 注意：表名如果是关键字（比如table），需要用反引号包裹
    final results = await conn.query('SELECT EXISTS (SELECT 1 FROM `table`);');
    // 提取EXISTS返回的0或1
    return results.first.values.first as int;
  } catch (e) {
    print('查询出错: $e');
    // 异常场景可返回默认值或重新抛出
    return 0;
  } finally {
    // 确保无论成功失败都关闭连接
    if (conn != null) await conn.close();
  }
}

2. 正确调用函数 #

调用时必须用await获取异步结果：

void testFunction() async {
  int isEmpty = await checkIfTableIsEmpty();
  print(isEmpty); // 这里会输出0（表空）或1（表非空）
}

关键说明 #

1. 异步函数的返回值：数据库操作是异步的，函数必须返回Future类型，外部通过await等待结果，不能同步获取。
2. 连接资源管理：用finally块确保数据库连接被关闭，避免资源泄漏。
3. SQL语法注意：如果表名是SQL关键字（如table），必须用反引号`包裹，否则会触发语法错误。
4. 异常处理：添加try/catch捕获连接或查询过程中的异常，避免程序崩溃。

内容的提问来源于stack exchange，提问作者leonms