<?php/**
 * 基于单例模式的MySQL数据库操作类
 */class MySQLDB{
    // 单例对象
    private static $instance = null;
    
    // 数据库连接
    private $conn = null;
    
    // 数据库配置
    private $config = array(
        'host'     => 'localhost',
        'port'     => 3306,
        'user'     => 'root',
        'password' => '',
        'dbname'   => 'test',
        'charset'  => 'utf8mb4'
    );
    
    /**
     * 私有化构造函数，防止外部实例化
     */
    private function __construct($config = array())
    {
        // 合并配置
        if (!empty($config)) {
            $this->config = array_merge($this->config, $config);
        }
        
        // 连接数据库
        $this->connect();
    }
    
    /**
     * 私有化克隆方法，防止克隆
     */
    private function __clone()
    {
    }
    
    /**
     * 获取单例实例
     */
    public static function getInstance($config = array())
    {
        if (!self::$instance instanceof self) {
            self::$instance = new self($config);
        }
        return self::$instance;
    }
    
    /**
     * 连接数据库
     */
    private function connect()
    {
        try {
            $dsn = "mysql:host={$this->config['host']};port={$this->config['port']};dbname={$this->config['dbname']};charset={$this->config['charset']}";
            
            $options = array(
                PDO::ATTR_ERRMODE            => PDO::ERRMODE_EXCEPTION,
                PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC,
                PDO::ATTR_EMULATE_PREPARES   => false,
            );
            
            $this->conn = new PDO($dsn, $this->config['user'], $this->config['password'], $options);
        } catch (PDOException $e) {
            die("数据库连接失败: " . $e->getMessage());
        }
    }
    
    /**
     * 执行SQL查询，返回结果集
     */
    public function query($sql, $params = array())
    {
        try {
            $stmt = $this->conn->prepare($sql);
            $stmt->execute($params);
            return $stmt;
        } catch (PDOException $e) {
            $this->error($e, $sql, $params);
            return false;
        }
    }
    
    /**
     * 执行SQL操作，返回影响行数
     */
    public function execute($sql, $params = array())
    {
        try {
            $stmt = $this->conn->prepare($sql);
            $stmt->execute($params);
            return $stmt->rowCount();
        } catch (PDOException $e) {
            $this->error($e, $sql, $params);
            return false;
        }
    }
    
    /**
     * 获取单条记录
     */
    public function getOne($sql, $params = array())
    {
        $stmt = $this->query($sql, $params);
        return $stmt ? $stmt->fetch() : false;
    }
    
    /**
     * 获取多条记录
     */
    public function getAll($sql, $params = array())
    {
        $stmt = $this->query($sql, $params);
        return $stmt ? $stmt->fetchAll() : false;
    }
    
    /**
     * 获取单个字段值
     */
    public function getScalar($sql, $params = array())
    {
        $stmt = $this->query($sql, $params);
        if ($stmt) {
            $result = $stmt->fetch(PDO::FETCH_NUM);
            return $result ? $result[0] : false;
        }
        return false;
    }
    
    /**
     * 获取最后插入的ID
     */
    public function lastInsertId()
    {
        return $this->conn->lastInsertId();
    }
    
    /**
     * 开启事务
     */
    public function beginTransaction()
    {
        return $this->conn->beginTransaction();
    }
    
    /**
     * 提交事务
     */
    public function commit()
    {
        return $this->conn->commit();
    }
    
    /**
     * 回滚事务
     */
    public function rollBack()
    {
        return $this->conn->rollBack();
    }
    
    /**
     * 错误处理
     */
    private function error($e, $sql = '', $params = array())
    {
        $error = array(
            'code'    => $e->getCode(),
            'message' => $e->getMessage(),
            'sql'     => $sql,
            'params'  => $params
        );
        
        // 记录错误日志
        error_log('MySQL Error: ' . json_encode($error, JSON_UNESCAPED_UNICODE));
        
        // 开发环境直接输出错误
        if (defined('APP_DEBUG') && APP_DEBUG) {
            echo '<pre>';
            print_r($error);
            echo '</pre>';
        }
    }
    
    /**
     * 防止序列化
     */
    public function __sleep()
    {
        throw new Exception('Serialization of MySQLDB is not allowed');
    }
    
    /**
     * 防止反序列化
     */
    public function __wakeup()
    {
        throw new Exception('Unserialization of MySQLDB is not allowed');
    }}

<?php// 引入数据库类require_once 'MySQLDB.php';// 配置数据库连接$config = array(
    'host'     => '127.0.0.1',
    'user'     => 'root',
    'password' => '123456',
    'dbname'   => 'test_db');// 获取数据库实例$db = MySQLDB::getInstance($config);// 1. 查询单条记录$user = $db->getOne("SELECT * FROM users WHERE id = ?", [1]);print_r($user);// 2. 查询多条记录$users = $db->getAll("SELECT * FROM users WHERE status = ?", [1]);print_r($users);// 3. 查询单个值$count = $db->getScalar("SELECT COUNT(*) FROM users");echo "用户总数: $count\n";// 4. 插入数据$insertId = $db->execute(
    "INSERT INTO users (username, email, password) VALUES (?, ?, ?)",
    ['testuser', 'test@example.com', password_hash('123456', PASSWORD_DEFAULT)]);echo "插入ID: $insertId\n";// 5. 更新数据$affectedRows = $db->execute(
    "UPDATE users SET status = ? WHERE id = ?",
    [0, 1]);echo "影响行数: $affectedRows\n";// 6. 事务处理try {
    $db->beginTransaction();
    
    $db->execute(
        "UPDATE account SET balance = balance - ? WHERE user_id = ?",
        [100, 1]
    );
    
    $db->execute(
        "UPDATE account SET balance = balance + ? WHERE user_id = ?",
        [100, 2]
    );
    
    $db->commit();
    echo "转账成功\n";} catch (Exception $e) {
    $db->rollBack();
    echo "转账失败: " . $e->getMessage() . "\n";}