使用cURL发送数据并在服务器端存储到MySQL数据库的教程

<?php

/**
 * 通过cURL向服务器发送用户数据
 *
 * @param string $user_id 用户ID
 * @param string $user_name 用户名
 * @param string $user_code 用户代码
 * @param string $user_type 用户类型
 * @param string $user_url 用户URL
 * @param string $user_email 用户邮箱
 * @return string 服务器的响应
 */
function sendUserDataToServer(
    $user_id,
    $user_name,
    $user_code,
    $user_type,
    $user_url,
    $user_email
) {
    $target_url = "http://myurl.com/apis/verified_user.php"; // 替换为你的服务器端处理脚本URL

    $post_data = array(
        'user_id'    => $user_id,
        'user_name'  => $user_name,
        'user_code'  => $user_code,
        'user_type'  => $user_type,
        'user_url'   => $user_url,
        'user_email' => $user_email
    );

    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $target_url);
    curl_setopt($ch, CURLOPT_POST, true);
    // 使用 http_build_query 确保数据正确编码
    curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($post_data));
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true); // 获取服务器响应作为字符串

    $server_output = curl_exec($ch);

    // 检查cURL错误
    if (curl_errno($ch)) {
        echo 'cURL Error: ' . curl_error($ch);
        $server_output = "fail: cURL error";
    }

    curl_close($ch);

    return $server_output;
}

// 示例调用
$response = sendUserDataToServer(
    '123',
    'John Doe',
    'ABC789',
    'Admin',
    'http://johndoe.com',
    'john.doe@example.com'
);

if ($response == "done") {
    echo "数据发送成功并保存到服务器。";
} else {
    echo "数据发送失败或服务器处理异常: " . $response;
}

?>

// 示例：从 $_POST 数组中获取数据
$user_id = $_POST['user_id'] ?? '';
$user_name = $_POST['user_name'] ?? '';
// ... 其他字段

// 数据库配置
define('DB_SERVER', 'localhost');
define('DB_USERNAME', 'your_username');
define('DB_PASSWORD', 'your_password');
define('DB_NAME', 'your_database_name');

// 创建数据库连接
$conn = new mysqli(DB_SERVER, DB_USERNAME, DB_PASSWORD, DB_NAME);

// 检查连接
if ($conn->connect_error) {
    die("数据库连接失败: " . $conn->connect_error);
}

<?php

header('Content-Type: text/plain'); // 设置响应头为纯文本

// 1. 数据库配置
define('DB_SERVER', 'localhost');
define('DB_USERNAME', 'root'); // 替换为你的MySQL用户名
define('DB_PASSWORD', 'your_db_password'); // 替换为你的MySQL密码
define('DB_NAME', 'your_database_name'); // 替换为你的数据库名

// 2. 创建数据库连接
$conn = new mysqli(DB_SERVER, DB_USERNAME, DB_PASSWORD, DB_NAME);

// 检查连接
if ($conn->connect_error) {
    error_log("数据库连接失败: " . $conn->connect_error);
    echo "fail: Database connection error";
    exit();
}

// 3. 接收POST数据
// 使用 ?? '' 操作符为可能不存在的键提供默认空字符串，防止Undefined index警告
$user_id    = $_POST['user_id'] ?? '';
$user_name  = $_POST['user_name'] ?? '';
$user_code  = $_POST['user_code'] ?? '';
$user_type  = $_POST['user_type'] ?? '';
$user_url   = $_POST['user_url'] ?? '';
$user_email = $_POST['user_email'] ?? '';

// 简单的输入验证 (生产环境中应更严格)
if (empty($user_id) || empty($user_name) || empty($user_email)) {
    echo "fail: Missing required data";
    $conn->close();
    exit();
}

// 4. 使用预处理语句插入数据
// 假设你的表名为 'users'，并且有对应的列
$sql = "INSERT INTO users (user_id, user_name, user_code, user_type, user_url, user_email, created_at) VALUES (?, ?, ?, ?, ?, ?, NOW())";

if ($stmt = $conn->prepare($sql)) {
    // 绑定参数
    // 'ssssss' 表示六个字符串类型的参数
    $stmt->bind_param("ssssss", $user_id, $user_name, $user_code, $user_type, $user_url, $user_email);

    // 执行语句
    if ($stmt->execute()) {
        echo "done"; // 成功响应
    } else {
        error_log("执行SQL失败: " . $stmt->error);
        echo "fail: SQL execution error";
    }

    // 关闭语句
    $stmt->close();
} else {
    error_log("预处理SQL失败: " . $conn->error);
    echo "fail: Prepare statement error";
}

// 5. 关闭数据库连接
$conn->close();

?>

CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    user_id VARCHAR(255) NOT NULL UNIQUE,
    user_name VARCHAR(255) NOT NULL,
    user_code VARCHAR(255),
    user_type VARCHAR(50),
    user_url VARCHAR(255),
    user_email VARCHAR(255) NOT NULL,
    created_at DATETIME DEFAULT CURRENT_TIMESTAMP
);