您的位置:

使用mysqli_query()执行MySQL查询

一、mysqli_query()的概述

在PHP中,数据库操作是开发最常用的部分之一。mysqli_query()函数是PHP中一个重要的函数,它用于执行MySQL数据库的查询(Query)。mysqli_query()函数使用MySQLi扩展库中的函数来执行查询操作。

mysqli_query()语法如下:

mysqli_query(connection,query,resultmode);

其中,

  • mysqli_query():函数名
  • connection:必需。规定要使用的MySQL连接。
  • query:必需。规定查询字符串。
  • resultmode:可选。常量,默认MYSQLI_STORE_RESULT。如果指定MYSQLI_USE_RESULT,则返回结果集将不会被缓存,这对处理大量数据非常有用。

二、mysqli_query()的用法及示例

用mysqli_query()函数执行SELECT语句并返回结果集,然后再通过一遍遍历把结果集中的数据取出来,示例代码如下:

$conn = mysqli_connect('localhost', 'root', '','test'); 
if (!$conn){    
    die("连接数据库失败:" . mysqli_connect_error()); 
} 

$sql = "SELECT * FROM user"; 
$result = mysqli_query($conn,$sql); 

if(mysqli_num_rows($result)>0){
    while($row = mysqli_fetch_assoc($result)){ 
        echo "name: " . $row['name']. " - pwd:" . $row['pwd']. "
"; } }else{ echo '没有数据'; } mysqli_close($conn);

该示例代码用mysqli_query()函数执行一条SELECT语句,在结果集中取出全部数据并输出。其中,mysqli_fetch_assoc()函数用于从结果集中取出数据行并将其封装成一个关联数组(key=>value),方便开发者使用。

三、mysqli_query()函数的常见问题

1. mysqli_query()函数返回值的问题

当执行SELECT语句时,mysqli_query()函数会返回一个结果集。当执行非SELECT语句时,mysqli_query()函数会返回一个boolean类型值,关于mysqli_query()函数返回值的问题,下面是一些需要关注的问题:

  • 当查询遇到错误时,mysqli_query()函数返回false值,

    $sql = "SELECT * FROM user"; 
    $result = mysqli_query($conn,$sql); 
    if(!$result){ 
        die('Invalid query: ' . mysqli_error($conn)); 
    }
  • 在使用INSERT、UPDATE、或DELETE语句时,mysqli_query()返回的是影响的行数:

    $sql = "UPDATE user SET pwd=456 WHERE pwd=123"; 
    $result = mysqli_query($conn,$sql); 
    if($result){ 
        echo "数据更新成功"; 
    }else{ 
        echo "数据更新失败"; 
    }
  • 当mysql_query()函数执行的是不合规的语句时,返回false值。如果出现语法错误,则会报告一个 1064 错误,请检查拼写错误和语法错误:

    $sql = "select * from user wherr username='aaa'"; 
    $result = mysqli_query($conn,$sql); 
    if(!$result){ 
        die('Invalid query: ' . mysqli_error($conn)); 
    }

2. mysqli_query()函数的性能问题

对于非SELECT语句的执行,可以选择加入mysqli_use_result()或mysqli_store_result()参数,避免在执行语句时将结果全部存储在客户端内存中。

mysqli_store_result()存储结果集在客户端用于处理。该函数适合于返回非常大的数据量的查询。

mysqli_use_result()会立即返回查询结果,避免在查询时将所有数据载入PHP内存。下面我们来对比一下这两个PHP函数在获取较大数据量的SELECT查询结果中的时间性能表现。

require_once "config.php"; 
require_once "common.php"; 

$conn = mysqli_connect(DB_HOST,DB_USER,DB_PASSWORD,DB_DATABASE); 
if (!$conn){    
    die("连接数据库失败:" . mysqli_connect_error()); 
} 

$sql = "SELECT * FROM user_letter"; 
$start_time = get_millisecond();//获取当前毫秒时间戳

$result = mysqli_query($conn,$sql,MYSQLI_STORE_RESULT); 

if(mysqli_num_rows($result)>0){ 
    //遍历每个记录并输出 
    while($row = mysqli_fetch_assoc($result)){ 
        //echo "id: ".$row["id"]." - content:".$row["content"]." - create_time:".$row["create_time"]."
"; } }else{ echo '没有数据'; } $end_time = get_millisecond();//获取当前毫秒时间戳 echo "Get result from DB using mysqli_store_result() costs ".($end_time-$start_time)."ms."; mysqli_free_result($result); $start_time = get_millisecond(); $result = mysqli_query($conn,$sql,MYSQLI_USE_RESULT); if(mysqli_num_rows($result)>0){ while($row = mysqli_fetch_assoc($result)){ //echo "id: ".$row["id"]." - content:".$row["content"]." - create_time:".$row["create_time"]."
"; } }else{ echo '没有数据'; } $end_time = get_millisecond(); echo "
Get result from DB using mysqli_use_result() costs ".($end_time-$start_time)."ms."; mysqli_free_result($result); mysqli_close($conn);

该示例代码中,首先我们连接数据库,接着,我们在所连接的数据库中执行一条SELECT语句,并使用mysqli_query()函数在结果集中取出全部记录。我们在遍历每个记录时可以看到注释掉的输出动作。

时间测试结果表明使用mysqli_use_result()明显优于使用mysqli_store_result()。这是因为resultset一旦被关闭,系统会立即将其从服务器内存中删除。

四、结尾

以上是使用mysqli_query()执行MySQL查询的相关内容,我们可以看到mysqli_query()是PHP中常用的函数之一,我们可以针对不同的查询进行优化,在开发过程中,还需注意到查询字符串时需要对单引号和双引号的使用,安全问题和数据库连接的释放等问题,这些也是不可忽视的。