php - 如何将下面这段代码中的mysql修改为mysqli?-PHP中文网问答

服务器升级到了PHP，但是使用的PHP代码中使用的是mysql_connet链接数据库，自己尝试着修改，但是还是妨碍吸纳问题。

function _makeConnection() 
    {
        $this->logBenchmark('_makeConnection() {');
        
        $connected = false;
        if (@mysql_connect($this->db['server'],$this->db['username'],$this->db['password']))
        {
            if (@mysql_select_db($this->db['database']))
            {
                $connected = true;
            }
            else
            {
                $this->logError('MySQL Error: '.mysql_error().'. ('.mysql_errno().')', 2);
            }
        }
        else
        {
            $this->logError('MySQL Error: '.mysql_error().'. ('.mysql_errno().')', 2);
        }
        if (!$connected)
        {
            $this->logErrorNote('Mint was unable to connect to the database. Please make sure that the correct values have been added to /config/db.php.');
        }
        $this->logBenchmark('}');
        return $connected;
    }

function query($query)
    {
        $this->logBenchmark('query("'.substr($query, 0, 24).'...") {');
        
        $this->queries[] = $query;
        if (!($result = mysqli_query($query)))
        {
            $this->logError('MySQL Error: '.mysqli_error().'. ('.mysqli_errno().')
Query: '.$query);
            $result = false;
        }
        
        $this->logBenchmark('}');
        return $result;
    }

修改后的代码：

    function _makeConnection() 
    {
        $this->logBenchmark('_makeConnection() {');
        
        $connected = false;
        if (@mysqli_connect($this->db['server'],$this->db['username'],$this->db['password'],$this->db['database']))
        {
            $connected = true;
        }
        else
        {
            $this->logError('MySQL Error: '.mysqli_error().'. ('.mysqli_errno().')', 2);
        }
        if (!$connected)
        {
            $this->logErrorNote('Mint was unable to connect to the database. Please make sure that the correct values have been added to /config/db.php.');
        }
        $this->logBenchmark('}');
        return $connected;
    }

function query($query)
    {
        $this->logBenchmark('query("'.substr($query, 0, 24).'...") {');
        
        $this->queries[] = $query;
        if (!($result = mysqli_query($query)))
        {
            $this->logError('MySQL Error: '.mysqli_error().'. ('.mysqli_errno().')
Query: '.$query);
            $result = false;
        }
        
        $this->logBenchmark('}');
        return $result;
    }

错误原因，mysqli_query需要传递2个参数，$link和$query,但是原始方法中并没有传入$link

//面向对象风格 $mysqli = new mysql("localhost", "root", "", "test"); if(mysqli_connect_error()){ //数据库链接错误 unset($mysqli); die(mysqli_connect_error()); } $query = "SELECT * FROM `user`" $result = $mysqli->query($query); if($result){ while($row = $result->fetch_row()){ //... } $result->free(); }else{ //执行sql语句失败 die($mysqli->error); } $mysqli->close();

//过程化风格 $mysqli = mysqli_connect("localhost", "root", "", "test"); if(mysqli_connect_error()){ //数据库连接错误 unset($mysqli); die(mysqli_connect_error()); } $query = "SELECT * FROM `user`" $result = $mysqli_query($mysqli,$query); if($result){ while($row = mysqli_fetch_row($result)){ //... } mysqli_free_result($result); }else{ //执行sql语句失败 die(mysqli_error($mysqli)); } mysqli_close($mysqli);