php - 无法使用 for() 将 php 数据插入 mysql

Question

我尝试使用 php 将数据插入到 mysql，方法是检查该值是否存在然后它会更新如果不存在则它会插入，但它失败了我使用 for () 我的脚本有什么问题？

if(isset($_POST['submit'])){
    $fieldA = $_POST['fieldA'];
    $fieldB = $_POST['fieldB'];
    $fieldC = $_POST['fieldC'];
    $fieldD = $_POST['fieldD'];

    if (empty($fieldA)) {
        echo 'fieldA cannot empty';
    } 
    else 
    {
        for ($i=1; $i<= $nomer; $i++) {
            $query = mysql_query("SELECT * FROM tb1 ".
                "WHERE fieldA = '$fieldA' ".
                "AND fieldB = '$fieldB' ".
                "AND fieldC = '$fieldC' ".
                "AND fieldD = '$fieldD'");
            $get1 = mysql_fetch_assoc($query);
            $get2 = mysql_num_rows($query);

            if ($get2 != 0) {
                mysql_query("UPDATE tb1 SET kd_kelas = '2' ".
                    "WHERE fieldA = '$fieldA' ".
                    "AND fieldB = '$fieldB' ".
                    "AND fieldC = '$fieldC' ".
                    "AND fieldD = '$fieldD'");
            } else {

                mysql_query("INSERT INTO tb1(fieldA, fieldB, ".
                    "fieldC, fieldD) VALUES ".
                    "('$fieldA', '$fieldB', ".
                    "'$fieldC', '$fieldD')");
            }


        }
    }


    //re-direct
    $go = "mydata.php";
    redirect($go); 
}

Answer 1

所有与mysql_* 相关的方法现已弃用。使用 mysqli_*。

然后试试这个片段:

if (isset($_POST['submit']) && !empty($_POST['fieldA'])) {

    $fieldA = $_POST['fieldA'];
    $fieldB = $_POST['fieldB'];
    $fieldC = $_POST['fieldC'];
    $fieldD = $_POST['fieldD'];

    for ($i = 1; $i <= $nomer; $i++) {
        $sql = sprintf("SELECT * FROM tb1 WHERE fieldA = '%s' AND fieldB = '%s' AND fieldC = '%s' AND fieldD = '%s'",
            $fieldA, $fieldB, $fieldC, $fieldD);
        $result = mysqli_query($link, $sql);

        if (mysqli_num_rows($result) > 0) {
            $updateSql = sprintf("UPDATE tb1 SET kd_kelas = '2' WHERE fieldA = '%s' AND fieldB = '%s' AND fieldC = '%s' AND fieldD = '%s'",
                $fieldA, $fieldB, $fieldC, $fieldD);
            mysqli_query($link, $updateSql);
        }
        else {
            $insertSql = sprintf("INSERT INTO tb1(fieldA, fieldB,fieldC, fieldD) VALUES ('%s','%s','%s','%s')", $fieldA,
                $fieldB, $fieldC, $fieldD);
            mysqli_query($link, $insertSql);
        }
    }

    //re-direct
    $go = "mydata.php";
    redirect($go);
}

这里的$link是连接字符串

$link = mysqli_connect('localhost', 'root', 'password', 'database');