封装mysqli预处理

<?php
class MysqliDB {
    private $conn;

    public function __construct($host, $user, $password, $database) {
        $this->conn = new mysqli($host, $user, $password, $database);
        if ($this->conn->connect_error) {
            die("连接失败: " . $this->conn->connect_error);
        }
    }

    public function prepare($sql) {
        $stmt = $this->conn->prepare($sql);
        if (!$stmt) {
            throw new Exception("预处理失败: " . $this->conn->error);
        }
        return $stmt;
    }

    public function bindParam($stmt, $types, ...$params) {
        $bind_names = array();
        foreach ($params as $key => $value) {
            $bind_name = 'bind' . $key;
            $$bind_name = $value;
            $bind_names[] = &$$$bind_name;
        }
        call_user_func_array('mysqli_stmt_bind_param', array_merge(array($stmt, $types), $bind_names));
    }

    public function execute($stmt) {
        return $stmt->execute();
    }

    public function close() {
        $this->conn->close();
    }
}

// 使用示例
$db = new MysqliDB('localhost', 'root', 'password', 'testdb');

$sql = "INSERT INTO users (username, email) VALUES (?, ?)";
$stmt = $db->prepare($sql);

$db->bindParam($stmt, 'ss', 'john_doe', 'john@example.com');
$db->execute($stmt);

$db->close();
?>