0

fgetcsv（）を使用してPHPで.csvファイルを読み取っています。これで、.csvファイルから読み取ったデータをフェッチできるようになりました。次に、フェッチ結果でSKU列を確認する必要があり、それに応じて挿入または更新を実行する必要があります。SKUがすでに存在しているとすると、テーブルの行を更新する必要があります。そうでない場合は、新しいレコードを挿入する必要があります。私は次のコードを書いています...Plzchecknどこで間違いをしているのか教えてください-：

<?php
$row = 1; 
if (($handle = fopen("localhost/data/htdocs/magento/var/import/Price.csv", "r")) !== FALSE) 
{     
    while (($data = fgetcsv($handle, 8000, ",")) !== FALSE) 
    {         
        $num = count($data);         
        echo "<p> $num fields in line $row: <br /></p>\n";           
        for ($c=0; $c < $num; $c++) 
        {             
            $temp = $data;             
            $string = implode(";", $temp);           
        }
            $pieces = explode(";", $string);             
            $col1 = $pieces[0];  
            $col2 = $pieces[1];
            $col3 = $pieces[2];      
            $col4 = $pieces[3];             

            $db_name = "magento";
                        $con = mysql_connect("localhost", "magento", "password");
                     If (!$con)
            {
                die('Could not connect: ' . mysql_error());
                mysql_close($con);
            }
            $seldb = mysql_select_db($db_name, $con);

            $query_fetch = "SELECT `sku` from `imoprt_prices`";
            $result_fetch = mysql_query($query_fetch);
            $num_rows = mysql_num_rows($result_fetch); 

            for($i = 0; $i < $num_rows; $i++) 
            { 
                $value = mysql_result($result_fetch, i, 'sku');
                if(strcmp('".$value."', '".$col2."') == 0)
                {               
                    $flag = 1;
                    break;
                }
                else
                {
                    $flag = 0;
                        break;
                }
            }
                if($flag == 1)
                {
                    $query_upadte = "(UPDATE imoprt_prices SET customer_id= '".$col1."', sku ='".$col2."', price= '".$col3."', website= '".$col4."'
                    )";
                    mysql_query($query_upadte);
                        $row++;         
                }
                if($flag == 0)
                {
                    mysql_query("INSERT INTO `imoprt_prices`(`customer_id`,`sku`,`price`,`website`) VALUES('".$col1."','".$col2."','".$col3."','".$col4."')");
                    $row++;   
                } 

    } 
} 
?>
4

2 に答える 2

1

次のスニペット：

$query_upadte = "UPDATE imoprt_prices SET customer_id= '".$col1."', sku ='".$col2."', price= '".$col3."', website= '".$col4."'";

単一の行を更新するだけでなく、すべての行を繰り返し更新しようとしています。これは通常、MySQLでは許可されていません。unique更新する特定のIDを指定する必要があります。

于 2012-04-03T07:29:44.300 に答える
1

テーブルに実際のUNIQUEインデックスがある場合は、構文を使用して、コードを次のようなものに少し簡略化できます。（注、テストできないため、擬似コードとして参照してください）imoprt_pricesON DUPLICATE KEY UPDATE

$db_name = "magento";
$con = mysql_connect("localhost", "magento", "password") or die(mysql_error());
$seldb = mysql_select_db($db_name, $con);

if (($handle = fopen("localhost/data/htdocs/magento/var/import/Price.csv", "r")) !== FALSE) 
{     
    while (($data = fgetcsv($handle, 8000, ",")) !== FALSE) 
    {
        $col1 = $pieces[0];  
        $col2 = $pieces[1];
        $col3 = $pieces[2];      
        $col4 = $pieces[3]; 

        $query_upadte = "INSERT INTO imoprt_prices (customer_id, sku, price, website) ".
            "VALUES('".$col1."','".$col2."','".$col3."','".$col4."') ".
            "ON DUPLICATE KEY UPDATE customer_id='".$col1."', price='".$col3.
            "',website='".$col4."'";
        mysql_query($query_upadte);
    }
}

また、mysql_real_escape_string（）を使用するか、パラメーター化されたクエリを使用'して、挿入された値に値がないことを確認することもできます。これは、このようなSQL文字列を作成する場合は常に危険です。

ここに簡単なデモがあります。

于 2012-04-03T09:11:36.417 に答える