基于PHP和MySQL开发RESTfulAPI的设计与实现

CREATE TABLE users (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(100) NOT NULL,
    email VARCHAR(100) NOT NULL UNIQUE,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

<?php
header('Content-Type: application/json');

// 数据库连接
$conn = new mysqli('localhost', 'username', 'password', 'database');
if ($conn->connect_error) {
    die(json_encode(['error' => 'Connection failed: ' . $conn->connect_error]));
}

// 处理不同HTTP方法
$method = $_SERVER['REQUEST_METHOD'];
$request = explode('/', trim($_SERVER['PATH_INFO'],'/'));
$input = json_decode(file_get_contents('php://input'), true);

switch ($method) {
    case 'GET':
        if (empty($request[0])) {
            // 获取所有用户
            $sql = "SELECT * FROM users";
            $result = $conn->query($sql);
            $users = $result->fetch_all(MYSQLI_ASSOC);
            echo json_encode($users);
        } else {
            // 获取单个用户
            $id = $request[0];
            $sql = "SELECT * FROM users WHERE id = ?";
            $stmt = $conn->prepare($sql);
            $stmt->bind_param('i', $id);
            $stmt->execute();
            $result = $stmt->get_result();
            $user = $result->fetch_assoc();
            echo json_encode($user);
        }
        break;
    case 'POST':
        // 创建新用户
        $name = $input['name'];
        $email = $input['email'];
        $sql = "INSERT INTO users (name, email) VALUES (?, ?)";
        $stmt = $conn->prepare($sql);
        $stmt->bind_param('ss', $name, $email);
        if ($stmt->execute()) {
            echo json_encode(['message' => 'User created successfully', 'id' => $conn->insert_id]);
        } else {
            echo json_encode(['error' => 'Error creating user: ' . $conn->error]);
        }
        break;
    case 'PUT':
        // 更新用户信息
        $id = $request[0];
        $name = $input['name'];
        $email = $input['email'];
        $sql = "UPDATE users SET name = ?, email = ? WHERE id = ?";
        $stmt = $conn->prepare($sql);
        $stmt->bind_param('ssi', $name, $email, $id);
        if ($stmt->execute()) {
            echo json_encode(['message' => 'User updated successfully']);
        } else {
            echo json_encode(['error' => 'Error updating user: ' . $conn->error]);
        }
        break;
    case 'DELETE':
        // 删除用户
        $id = $request[0];
        $sql = "DELETE FROM users WHERE id = ?";
        $stmt = $conn->prepare($sql);
        $stmt->bind_param('i', $id);
        if ($stmt->execute()) {
            echo json_encode(['message' => 'User deleted successfully']);
        } else {
            echo json_encode(['error' => 'Error deleting user: ' . $conn->error]);
        }
        break;
}

$conn->close();
?>