php调用mysql存储过程，及Commands out of sync报错的实验分析(mysqli)

zhgc

php调用mysql存储过程，及Commands out of sync报错的实验分析


存储过程:

1. DELIMITER $
   
2. 
   
3. DROP PROCEDURE IF EXISTS `sfc`.`TEST2`$
   
4. 
   
5. CREATE DEFINER=`root`@`localhost` PROCEDURE `TEST2`(
   
6. )
   
7. BEGIN
   
8. declare l_count int;
   
9. -- 1. just update
   
10. update sfc.r107 set in_station_time=now() limit 12;
    
11. 
    
12. -- 2. return record;
    
13. select serial_number,model_name from sfc.r107 limit 3;
    
14. 
    
15. 
    
16. END$
    
17. 
    
18. DELIMITER ;

复制代码

PHP代码：

1. <?php
   
2. $con=mysqli_connect("127.0.0.1","root","****","sfc");
   
3. if (mysqli_connect_errno($con))
   
4. {
   
5.     echo "连接 MySQL 失败: " . mysqli_connect_error();
   
6. }
   
7. 
   
8. $sql = "call sfc.TEST2();";
   
9. echo "以下为主数据：\r\n";
   
10. if($result = mysqli_query($con,$sql)){
    
11.         if($result!==true){
    
12.                 while($row=mysqli_fetch_row($result)){
    
13.                         printf("%s \r\n",$row[0]);
    
14.                 }
    
15.                 mysqli_free_result($result);
    
16.         }
    
17. }
    
18. 
    
19. 
    
20. $i=1;
    
21. echo "以下为附加数据：\r\n";
    
22. while(mysqli_more_results($con)) {
    
23.         printf("--------- {$i} -----------\r\n");
    
24.         if(mysqli_next_result($con)){
    
25.                 if ($result = mysqli_store_result($con)) {
    
26.                         while ($row = mysqli_fetch_row($result)) {
    
27.                 printf("%s \r\n",$row[0]);
    
28.                         }
    
29.             mysqli_free_result($result);
    
30.         } else         {
    
31.                         echo "no record!\r\n";
    
32.                 }
    
33.         }
    
34.         $i++;
    
35. }
    
36. 
    
37. mysqli_close($con);
    
38. ?>
    

复制代码

zhgc

当SP为：
update sfc.r107 set in_station_time=now() limit 12;

结果是：

1. C:\Apache24\htdocs\test>php t2.php
   
2. 以下为主数据
   
3. 以下为附加数据
   

复制代码

当SP为：
update sfc.r107 set in_station_time=now() limit 12;
select serial_number,model_name from sfc.r107 limit 3;\

结果是：

1. C:\Apache24\htdocs\test>php t2.php
   
2. 以下为主数据：
   
3. 19040171000001
   
4. 19040171000002
   
5. 19040171000003
   
6. 以下为附加数据：
   
7. --------- 1 -----------
   
8. no record!
   

复制代码

当SP为：
update sfc.r107 set in_station_time=now() limit 12;
select serial_number,model_name from sfc.r107 limit 3;\
select serial_number from sfc.r109 limit 2;

结果是：

1. C:\Apache24\htdocs\test>php t2.php
   
2. 以下为主数据：
   
3. 19040171000001
   
4. 19040171000002
   
5. 19040171000003
   
6. 以下为附加数据：
   
7. --------- 1 -----------
   
8. X000041
   
9. PF1642000VK
   
10. --------- 2 -----------
    
11. no record!
    

复制代码

zhgc

所以结论是：

如果SP没有返回值 ，那没有问题
但一但有record ,那结果集是N+1 。多出来的是什么内容不清楚，读内容是空的，但如果不读，就会Commands out of sync

zhgc

所以，建议调SP的处理方式 ：


读主recrod:

1. if($result = mysqli_query($con,$sql)){
   
2.         if($result!==true){
   
3.                 while($row=mysqli_fetch_row($result)){
   
4.                         printf("%s \r\n",$row[0]);
   
5.                 }
   
6.                 mysqli_free_result($result);
   
7.         }
   
8. }

复制代码

清多余数据：

1. while(mysqli_more_results($con)) {
   
2.         if(mysqli_next_result($con)){
   
3.                 if ($result = mysqli_store_result($con)) {
   
4.                         mysqli_free_result($result);
   
5.                 }
   
6.         }
   
7. }

复制代码

zhgc

完整代码 ：


<?php
error_reporting(E_ALL);

$con=mysqli_connect("127.0.0.1","root","****","sfc");
if (!$con)
{
    die( "连接 MySQL 失败: " . mysqli_connect_error());
}

$sql = "call sfc.TEST2();";
echo "以下为主数据：\r\n";
if($result = mysqli_query($con,$sql)){
        if($result!==true){
                while($row=mysqli_fetch_row($result)){
                        printf("%s \r\n",$row[0]);
                }
                mysqli_free_result($result);
        }
}


while(mysqli_more_results($con)) {
        if(mysqli_next_result($con)){
                if ($result = mysqli_store_result($con)) {
                        mysqli_free_result($result);
                }
        }
}
               
$sql = "select version();";
if($result = mysqli_query($con,$sql)){
        if($result!==true){
                while($row=mysqli_fetch_row($result)){
                        printf("%s \r\n",$row[0]);
                }
                mysqli_free_result($result);
        }
}else{
        echo mysqli_error($con);
}

mysqli_close($con);
?>

zhgc

$strsql="CALL smt.APP_SMT_SCAN('{$trsn}','{$emp}','{$machine}','{$action}','{$device}');";
                $info=$info."<p style=\"margin-top:0px;margin-bottom:0px;\"><b>执行操作：</b>{$strsql}</p>";
                $this->app->AjaxAttr("info",$info);
               
                $this->app->prepare_mes();
                $recordSet=$this->app->mes->execute($strsql);
                if(isset($recordSet->fields)){
                        if($recordSet->EOF){
                                $msg= "SQL没有返回数据";
                        }else{
                                $msg= "SQL没有RES返回参数";
                                $rs=$recordSet->fields;
                                if (array_key_exists('prompt', $rs)){
          $prompt=$this->app->LL($rs["prompt"]);
                                }
                                if (array_key_exists('machine', $rs)){
          $machine=$rs["machine"];
                                }
                                if (array_key_exists('res', $rs)){
          $msg=$rs["res"];
                                }
                        }
                }else{
                        $msg="数据库连接失败!".strToUtf8($this->app->mes->ErrorMsg());
                };


                $this->app->AjaxAttr("prompt",$prompt);
                $this->app->AjaxAttr("machine",$machine);
                if(substr($msg,0,2)=="OK"){
                        $this->app->AjaxAttr("sound","0");
                        $this->app->AjaxOK(array(),$msg);
                }else{
                        $this->app->AjaxAttr("sound","1");
                        $this->app->AjaxFail("{$msg}", 100);
                        return ;
                }
               
                if(strlen($trsn)<5){
                        return;
                }
                 while($recordSet->nextRecordSet()){};