emlog程序更换数据库为pdo方式

寻梦xunm| 900| 收集

3年前

超过1222天温馨提示

本文最后更新于2021年07月17日，已超过1222天没有更新，若内容或图片失效，请留言反馈。

修改include/lib/database.php 文件

public static function getInstance() {

        if(class_exists('pdo',false))
        {
            return mysqlPDO::getInstance();
        }elseif(class_exists('mysqli', FALSE)) {
            return MySqlii::getInstance();
        }
        else if (class_exists('mysql', FALSE)) {
            return MySql::getInstance();
        }
        else {
            emMsg('服务器空间PHP不支持MySql数据库');
        }
    }

增加mysqlpdo.php 文件，文件放置在include/lib目录下

<?php

class mysqlpdo{

    /**
     * 内部实例对象
     * @var object MySql
     */
    private static $instance = null;
    /**
     * 查询次数
     * @var int
     */
    private $queryCount = 0;

    /**
     * 内部数据连接对象
     * @var \PDO
     */
    private $conn;

    /**
     * 内部数据结果
     */
    private $result;


    private function __construct() {
        if (!class_exists('PDO')) {
            emMsg('服务器空间PHP不支持PDO函数');
        }

        try {
            $dsn = 'mysql:host=' . DB_HOST . ';port=' . DB_PORT . ';dbname=' . DB_NAME;
            $options = [];
            $dbh = new \PDO($dsn,DB_USER,DB_PASSWD,$options);
            $dbh->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);  //设置如果sql语句执行错误则抛出异常，事务会自动回滚
            $dbh->setAttribute(\PDO::ATTR_EMULATE_PREPARES, false); //禁用prepared statements的仿真效果(防SQL注入)

            $dbh->exec('SET NAMES utf8');
            $this->conn = $dbh;
        } catch (\PDOException $e) {
            emMsg("连接数据库失败，请检查数据库信息。错误原因：" . $e->getMessage());
        }

    }

    /**
     * 静态方法，返回数据库连接实例
     */
    public static function getInstance() {
        if (self::$instance == null) {
            self::$instance = new mysqlpdo();
        }

        return self::$instance;
    }


    /**
     * 关闭数据库连接
     */
    function close() {

        if (!is_null($this->conn)) $this->conn = null;
    }

    /**
     * 发送查询语句
     */
    function query($sql, $ignore_err = FALSE) {

        try {
//            $result = $this->conn->query($sql);
            $this->result = $this->conn->query($sql);
            $this->queryCount++;
            if (!$ignore_err && 1046 == $this->geterrno()) {
                emMsg("连接数据库失败，请填写数据库名");
            }
            if (!$ignore_err && !$this->result) {
                emMsg("SQL语句执行错误: {$sql}<br />" . $this->geterror());
            } else {
                return $this->result;
            }
        }catch (\PDOException $e)
        {
            return $e->getMessage();
        }

    }

    /**
     * 从结果集中取得一行作为关联数组/数字索引数组
     */
    function fetch_array($query, $type = \PDO::FETCH_ASSOC) {

        return $query->fetch($type);

    }

    /**
     * 从结果级中取一行
     * @param $sql
     * @return mixed
     */
    function once_fetch_array($sql) {
        try {
            $result = $this->conn->query($sql);

            $resultDb = $result->fetchAll(\PDO::FETCH_ASSOC);
            return $resultDb[0];
        }catch (\PDOException $e)
        {
            emMsg($e->getMessage());
        }

    }

    /**
     * 从结果集中取得一行作为数字索引数组
     */
    function fetch_row( $query) {
        return $query->rowCount();
    }

    /**
     * 取得行的数目
     *
     */
    function num_rows($query) {
        $rows = $query->fetch(PDO::FETCH_NUM);
        return isset($rows[0]) ? $rows[0] : 0;
    }

    /**
     * 取得结果集中字段的数目
     */
    function num_fields($query) {
        return $query->fetchColumn();
//        return $query->field_count;
    }

    /**
     * 取得上一步 INSERT 操作产生的 ID
     */
    function insert_id() {
        return $this->conn->lastInsertId();
    }

    /**
     * 获取mysql错误
     */
    function geterror() {
        return $this->conn->errorInfo();
    }

    /**
     * 获取mysql错误编码
     */
    function geterrno() {
        return $this->conn->errorCode();
    }

    /**
     * Get number of affected rows in previous MySQL operation
     */
    function affected_rows() {

        if($this->result)
        {
            return $this->result->rowCount();
        }
        return 0;
    }

    /**
     * 取得数据库版本信息
     */
    function getMysqlVersion() {
        $result = $this->conn->query('select version()')->fetchColumn();
        return $result;
    }

    /**
     * 取得数据库查询次数
     */
    function getQueryCount() {

        return $this->queryCount;
    }

    /**
     *  Escapes special characters
     */
    function escape_string($sql) {
        return trim($sql);
//        return $this->conn->real_escape_string($sql);
    }


}

教程 emlog 代码 pdo

0 赞 or 打赏

喜欢就打赏一点