首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >mysqli准备的UPDATE语句没有更新数据库中的值

mysqli准备的UPDATE语句没有更新数据库中的值
EN

Stack Overflow用户
提问于 2019-06-25 05:53:22
回答 3查看 1.1K关注 0票数 2

在搜索和参考了各种文档之后,我不知道自己做错了什么。

我想做什么,

我试图使用以下函数在数据库上执行预先准备好的update语句:

代码语言:javascript
复制
function _UPDATE_IP_BAD(&$mysqli, $id_of_ip, &$value){

    ini_set('display_errors', 1); ini_set('log_errors',1); error_reporting(E_ALL); mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);

    $timestamp = time();

    //  UPDATE `dbmxpca_ipinfo`.`list` SET `is_bad` = '0.0111000000000000000', `cached_bad` = '1553849540' WHERE (`id` = '2');
    $exec_data = array();

    $prepare = "UPDATE dbmxpca_ipinfo.list SET `is_bad`=?, `cached_bad`=? WHERE `id`=?";
    //$prepare = 'UPDATE dbmxpca_ipinfo.list SET `is_bad`=?, `cached_bad`=? WHERE `id`=?;';
    //$prepare = 'UPDATE dbmxpca_ipinfo.list SET is_bad=?, cached_bad=? WHERE id=?;';



    // $prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET is_bad=?, cached_bad=? WHERE id=?;';


    //$prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET ( `is_bad`, `cached_bad` ) VALUES (?, ?) WHERE (`id`=' . $id_of_ip . ');';

    //$prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET ( `is_bad`, `cached_bad` ) VALUES (?, ?) WHERE (`id`=' . $id_of_ip . ');';
    //$prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET `is_bad`=?, `cached_bad`=? WHERE (`id`=?);';

    //$prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET `is_bad`=?, `cached_bad`=? WHERE (`id`=?);';
    //$prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET `is_bad` = ?, `cached_bad` = ? WHERE (`id` = ?);';
    // $prepare = 'UPDATE `dbmxpca_ipinfo`.`list` SET `is_bad` = \'?\', `cached_bad` = \'?\' WHERE (`id` = \'?\');';
    //$bind_types = 'iii';
    $bind_types = 'dii';
    //$bind_types = 'idi';
    // $bind_types = 'di';
    //$bind_values = array($value, $timestamp);
    $bind_values = array($value, $timestamp, $id_of_ip);
    $exec_result = DB_EXEC2($mysqli, $prepare, $bind_types, $bind_values, $exec_data);

    if ($exec_result){

        return true;
    }

    return false;
}

我是这样说的:

UPDATE_IP_BAD($mysqli, 2, 0);

($mysqli已在其他地方定义和初始化)。

问题

问题是,DB_EXEC2()报告了一个成功的查询(应该影响1行),但是没有在数据库中更新这两个值。没有报告错误,但是数据库值保持不变。我做错了什么吗?

我尝试过许多不同的方法来编写准备好的语句(注释掉的代码行都不起作用),而未注释的语句也不起作用。我甚至尝试过不同的绑定类型(整数和双),但都没有效果。我已经看了好几个小时了,完全搞不懂这个问题是什么。即使在函数顶部添加额外的错误报告,我也见过这样的建议,但没有产生任何错误。

DB_EXEC2()是执行准备好的语句的自定义函数。它将操作结果记录到文件中。功能定义如下:

代码语言:javascript
复制
function DB_EXEC2(&$mysqli, $prepare, $bind_types, &$bind_values, &$result_data = null){

    //  Get number of bind types.
    $nBindTypeCount = strlen($bind_types);

    //  Get number of bind values.
    $nBindValCount = count($bind_values);

    //  Make sure they match.
    if ($nBindTypeCount != $nBindValCount){

        $errmsg = 'DB_EXEC2 Error: [Number of bind types does not match number of bind parameters].';
        if (ENABLE_LOG_DB){
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
        }

        return false;
    }

    //  Prepare
    $stmt = $mysqli->prepare($prepare);
    if ($stmt === false){

        //  ------------ Prepared statement error ------------

        $errmsg = 'SQL Prepared-Statement Error: [' . $mysqli->errno . ': ' . $mysqli->error . '].';
        if (ENABLE_LOG_DB){
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
        }

        $stmt->close();

        return false;
    }

    //  Make array of all params.
    $fparams = array();
    array_push($fparams, $bind_types);
    foreach($bind_values as $bvk){
        array_push($fparams, $bvk);
    }
    //  "hack" for a function I don't like: call_user_func_array().
    $ptrParams = array();
    $nParamCount = count($fparams);
    for ($i = 0; $i < $nParamCount; $i++){
        $ptrParams[$i] = &$fparams[$i];
    }

    //  Dump values to log file for debugging.
    if (ENABLE_LOG_DB){

        \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', 'ptrParams Dump:');
        \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', '-----------------------');
        foreach ($ptrParams as $ptrParamsK){
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', '  ' . $ptrParamsK);
        }
        \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', '-----------------------');
    }

    //  Bind.
    call_user_func_array(array($stmt, 'bind_param'), $ptrParams);

    //  Attempt to execute.
    if ($stmt->execute() === true){

        //  ------------ Execution success ------------

        $errmsg = 'SQL execution successful:';
        if (ENABLE_LOG_DB){

            $errmsg = 'SQL execution successful.';
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', $errmsg);

            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', 'Affected Rows = [' . $stmt->affected_rows . '].');
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', 'Error = [' . $stmt->error . '].');

        }

        //  TODO: If $result_data is null, just return true on success.     

        $result = $stmt->get_result();      
        if (!$result){

            //  ------------ GetResult Execution error ------------
            if (ENABLE_LOG_DB){
                $errmsg = 'GetResult Error: [' . $mysqli->error . ' - ' . mysqli_error($mysqli) . '].';
                \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
            }

            $stmt->close();
            return false;
        }
        else{

            //  ------------ GetResult Execution success ------------

            //  Create structure to store the results.
            if (!isset($result_data)){

                $result_data = array();
            }

            if (mysqli_num_rows($result) > 0){

                //  $result_data should hold all resulting rows. If we get 1 result as
                //  we normally should, all payload should be at $result_data[0].

                while($row = mysqli_fetch_assoc($result)){

                    array_push($result_data, $row);
                }

                $stmt->close();
                return true;
            }
            else{

                //  No results
                $stmt->close();
                return true;
            }
        }


        $stmt->close();

        return true;

    }
    else{

        //  ------------ Execution error ------------

        $errsql = $stmt->error;
        $errsql2 = 'N/A';
        $errmsg = 'SQL Error: [' . $errsql . ': ' . $errsql2 . '].';
        if (ENABLE_LOG_DB){
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
        }

        $stmt->close();

        return false;
    }

}

日志输出(供参考):

代码语言:javascript
复制
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]: ptrParams Dump:
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]: -----------------------
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]:   dii
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]:   0
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]:   1561439914
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]:   2
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]: -----------------------
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]: SQL execution successful.
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]: Affected Rows = [1].
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_EXEC2]: Error = [].
[06/25/2019 @ 01:18:34 AM EDT] [ERROR] [@DB_EXEC2]: GetResult Error: [ - ].
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_CLOSE]: Closing database connection...
[06/25/2019 @ 01:18:34 AM EDT] [INFO] [@DB_CLOSE]: Done.

**更新1 **

由于@您的常识,添加了此代码:

代码语言:javascript
复制
    $stmt = DB_EXEC3($mysqli, $sql, $aParams, $strBindTypes);

    if ($stmt === true){

        \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', "Success!");
        return true;
    }

    \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', "stmt->execute() did not return true.");
    \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', "-- Error ID: $stmt->errno");
    \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', "-- Error: $stmt->error");
    if (isset($stmt->error_list)){

        \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', "-- Error List:");
        foreach ($stmt->error_list as $errk => $errv){
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', "---- $errk -> $errv");
        }
    }
    \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', "-- Affected rows: $stmt->affected_rows");

生成的日志输出如下:

代码语言:javascript
复制
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@DB_CONNECT]: Attempting mysqli initialization... please wait.
[06/25/2019 @ 04:14:25 AM EDT] [ERROR] [@UPDATE_IP_BAD]: stmt->execute() did not return true.
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@UPDATE_IP_BAD]: -- Error ID: 0
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@UPDATE_IP_BAD]: -- Error: 
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@UPDATE_IP_BAD]: -- Error List:
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@UPDATE_IP_BAD]: -- Affected rows: 1
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@DB_CLOSE]: Closing database connection...
[06/25/2019 @ 04:14:25 AM EDT] [INFO] [@DB_CLOSE]: Done.

因此,基本上,系统没有报告任何错误(尽管启用了所有错误报告,多亏了报告 )

这似乎表明一切进展顺利(1行受影响),但事实上,由于一些神秘的原因,行数据保持不变.

EN

回答 3

Stack Overflow用户

回答已采纳

发布于 2019-06-26 02:26:23

解决方案

结果,设置了以下选项:SET AUTOCOMMIT = 0DB_CONNECT()函数中(未包含在原始post中)。移除它似乎解决了这个问题。

因此,确实有可能产生第三种结果(与评论中所说的相反)。

票数 0
EN

Stack Overflow用户

发布于 2019-06-25 06:07:17

我注释掉了错误日志记录部分(因为我不想设置内容和文件路径等),更改表名,代码似乎正在工作:

代码语言:javascript
复制
UPDATE_IP_BAD($mysqli, 1, 0);

function UPDATE_IP_BAD(&$mysqli, $id_of_ip, $value){

    ini_set('display_errors', 1); ini_set('log_errors',1); error_reporting(E_ALL); mysqli_report(MYSQLI_REPORT_ERROR | MYSQLI_REPORT_STRICT);

    $timestamp = time();
    $exec_data = array();

    $prepare = "UPDATE list SET `is_bad`=?, `cached_bad`=? WHERE `id`=?";
    $bind_types = 'dii';
    $bind_values = array($value, $timestamp, $id_of_ip);
    $exec_result = DB_EXEC2($mysqli, $prepare, $bind_types, $bind_values, $exec_data);

    if ($exec_result){

        return true;
    }

    return false;
}



    function DB_EXEC2(&$mysqli, $prepare, $bind_types, &$bind_values, &$result_data = null)
     {

       //  Get number of bind types.
       $nBindTypeCount = strlen($bind_types);

       //  Get number of bind values.
       $nBindValCount = count($bind_values);

       //  Make sure they match.
       if ($nBindTypeCount != $nBindValCount)
        {
            $errmsg = 'DB_EXEC2 Error: [Number of bind types does not match number of bind parameters].';
          /*  if (ENABLE_LOG_DB)
              {
                 \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
              }
*/
             return false;
         }

          //  Prepare
         $stmt = $mysqli->prepare($prepare);
         if($stmt === false)
          {
             //  ------------ Prepared statement error ------------
             $errmsg = 'SQL Prepared-Statement Error: [' . $mysqli->errno . ': ' . $mysqli->error . '].';
           /*  if (ENABLE_LOG_DB)
              { 
                  \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
              } */
          $stmt->close();
          return false;
         }

         //  Make array of all params.
         $fparams = array();
         array_push($fparams, $bind_types);
         foreach($bind_values as $bvk)
          {
            array_push($fparams, $bvk);
          }

         // "hack" for a function I don't like: call_user_func_array().
         $ptrParams = array();
         $nParamCount = count($fparams);
          for ($i = 0; $i < $nParamCount; $i++)
            {
               $ptrParams[$i] = &$fparams[$i];
            }

          //  Dump values to log file for debugging.
       /*  if(ENABLE_LOG_DB)
          {
             \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', 'ptrParams Dump:');
              \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', '-----------------------');
             foreach ($ptrParams as $ptrParamsK)
               {
                    \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', '  ' . $ptrParamsK);
               }
              \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', '-----------------------');
           } */

         //  Bind.
         call_user_func_array(array($stmt, 'bind_param'), $ptrParams);

         //  Attempt to execute.
         if ($stmt->execute() === true)
           {

              //  ------------ Execution success ------------
              $errmsg = 'SQL execution successful:';
            /*  if(ENABLE_LOG_DB)
               {
                   $errmsg = 'SQL execution successful.';
                   \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', $errmsg);
                   \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', 'Affected Rows = [' . $stmt->affected_rows . '].');
                   \SYSTEM\DBMSLOG2(DB_LOGNAME, 'INFO', 'Error = [' . $stmt->error . '].');
               }
*/
        //  TODO: If $result_data is null, just return true on success.     

        $result = $stmt->get_result();      
        if (!$result){

            //  ------------ GetResult Execution error ------------
        /*    if (ENABLE_LOG_DB){
                $errmsg = 'GetResult Error: [' . $mysqli->error . ' - ' . mysqli_error($mysqli) . '].';
                \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
            }
 */
            $stmt->close();
            return false;
        }
        else{

            //  ------------ GetResult Execution success ------------

            //  Create structure to store the results.
            if (!isset($result_data)){

                $result_data = array();
            }

            if (mysqli_num_rows($result) > 0){

                //  $result_data should hold all resulting rows. If we get 1 result as
                //  we normally should, all payload should be at $result_data[0].

                while($row = mysqli_fetch_assoc($result)){

                    array_push($result_data, $row);
                }

                $stmt->close();
                return true;
            }
            else{

                //  No results
                $stmt->close();
                return true;
            }
        }


        $stmt->close();

        return true;

    }
    else{

        //  ------------ Execution error ------------

        $errsql = $stmt->error;
        $errsql2 = 'N/A';
        $errmsg = 'SQL Error: [' . $errsql . ': ' . $errsql2 . '].';
    /*    if (ENABLE_LOG_DB){
            \SYSTEM\DBMSLOG2(DB_LOGNAME, 'ERROR', $errmsg);
        }
*/
        $stmt->close();

        return false;
    }

}
票数 0
EN

Stack Overflow用户

发布于 2019-06-25 08:03:43

老实说,你的功能很难读懂。让我建议你一个我写的非常简单的mysqli辅助函数。有了它,您的代码将成为

代码语言:javascript
复制
function UPDATE_IP($mysqli, $id_of_ip, $value){
    $prepare = "UPDATE list SET `is_bad`=?, `cached_bad`=? WHERE `id`=?";
    $bind_values = array($value, time(), $id_of_ip);
    return mysqli($mysqli, $prepare, $bind_values)->affected_rows();
}

现在你可以这样称呼它了

代码语言:javascript
复制
$num_rows = UPDATE_IP_BAD($mysqli, 2, 0);
echo $num_rows;

它应该显示受影响的行数。

我刚刚注意到ipinfo.list.list不是一个有效的表名,所以必须是一个错误。为了查看mysql错误,您必须正确配置mysqli。请参考这个规范mysqli连接码,我写到,除了其他的事情外,还有错误报告。设置好后,您将立即看到错误。

票数 0
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/56747630

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档