在Flutter应用中通过PHP API安全地获取MySQL插入ID

<?php
// 假设 $connect 是已建立的数据库连接对象

if ("Sign_Up" == $action) {
    // 确保 action 变量已定义并从请求中获取

    // 验证并获取 POST 数据
    $phone = $_POST['phone'] ?? ''; // 使用 null 合并运算符提供默认值
    $email = $_POST['email'] ?? '';

    // 准备 SQL 语句：使用问号占位符
    $query = "INSERT INTO driver_details (phone, email) VALUES (?, ?)";

    // 预处理语句
    $stmt = $connect->prepare($query);

    // 检查预处理是否成功
    if ($stmt === false) {
        // 错误处理，例如记录日志
        echo json_encode(['msg' => 'API内部错误：无法准备SQL语句', 'status' => 99]);
        exit();
    }

    // 绑定参数：'ss' 表示两个字符串类型参数
    // 注意参数顺序与SQL语句中的占位符顺序一致
    $stmt->bind_param('ss', $phone, $email);

    // 执行语句
    $result = $stmt->execute();

    // 检查执行结果
    if ($result) {
        // 成功执行插入，获取新插入的ID
        $new_id = $connect->insert_id;

        // 返回JSON格式的响应，包含新ID、消息和状态
        $res = [
            'id' => $new_id,
            'msg' => "用户添加成功",
            'status' => 1
        ];
        echo json_encode($res);
    } else {
        // 插入失败
        $res = [
            'id' => null, // 插入失败，ID为null
            'msg' => '用户添加失败: ' . $stmt->error, // 包含错误信息便于调试
            'status' => 99
        ];
        echo json_encode($res);
    }

    // 关闭语句
    $stmt->close();
}
?>

import 'dart:convert'; // 用于JSON解码
import 'package:http/http.dart' as http;

class ApiService {
  static const String ROOT = "https://www.example.com/driverapp-apis";
  static const String _SignUp = 'Sign_Up';

  Future<Map<String, dynamic>?> signup({
    required String email,
    required String phone,
  }) async {
    try {
      var response = await http.post(
        Uri.parse(ROOT),
        body: {
          "email": email,
          "action": _SignUp,
          "phone": phone,
        },
      );

      // 检查响应状态码
      if (response.statusCode == 200) {
        // 解析JSON响应
        Map<String, dynamic> responseData = json.decode(response.body);
        return responseData;
      } else {
        // 服务器返回非200状态码
        print("API请求失败，状态码: ${response.statusCode}");
        return null;
      }
    } catch (e) {
      // 网络或其他异常
      print("请求发生错误: $e");
      return null;
    }
  }
}

// 假设在某个Widget或Controller中
void _handleSignUp() async {
  String email = emailController.text;
  String phone = phoneController.text;

  ApiService apiService = ApiService();
  Map<String, dynamic>? result = await apiService.signup(email: email, phone: phone);

  if (result != null) {
    int? insertedId = result['id'];
    String message = result['msg'];
    int status = result['status'];

    if (status == 1 && insertedId != null) {
      print("用户注册成功，新插入ID: $insertedId");
      // 可以使用 insertedId 进行后续操作，例如：
      // Navigator.pushReplacement(context, MaterialPageRoute(builder: (_) => HomePage(userId: insertedId)));
      // 或者更新本地数据库，保存用户ID
      ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text("$message, ID: $insertedId")));
    } else {
      print("用户注册失败: $message");
      ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text("注册失败: $message")));
    }
  } else {
    print("API请求或解析失败");
    ScaffoldMessenger.of(context).showSnackBar(SnackBar(content: Text("网络错误或API无响应")));
  }
}