加載CSV值，然後在mysql數據庫中搜索匹配

Question

我正在嘗試爲從cs文件加載一些值的cron作業構建腳本。此CSV文件有2個字段

product_id 
price 

該腳本將從CSV中加載值，然後在mysql表中搜索product_id匹配項。如果找到，它將使用CSV中的相應價格更新表格中特定匹配的product_id的價格。

到目前爲止我已經到了下面的代碼，但我被困在需要比較CSV數組值和mysql數組值的部分。

<?php 
// DB part 
$con = mysqli_connect('localhost','user','pass','db'); 
if (!$con) 
    { 
    die('Could not connect: ' . mysqli_error($con)); 
    } 

mysqli_select_db($con,"products"); 

     $sql="SELECT product_id, price, FROM products"; 

     $result = mysqli_query($con,$sql); 
     $row = mysqli_fetch_array($result); 

// CSV part 
$file_handle = fopen("prices.csv", "r"); 


while (!feof($file_handle)) { 

    $line_of_text = fgetcsv($file_handle, 1024); 

    $code = str_replace(' ', '', $line_of_text[0]); // 
    $price = str_replace(' ', '', $line_of_text[1]); // 



    if (in_array($code, str_replace(' ', '', $row))) 
      { 
      echo "Match found"; 
      print $code . " - " . $price . "<br />"; 
      } 
      else 
      { 
      echo "Match not found"; 
      print $code . " - " . $price . "<br />"; 
      } 
    } 
fclose($file_handle); 
mysqli_close($con); 
?> 

Answer 1

你存儲只是你產品表$row第一線。然後你正在做一些難以理解的比較，但所有這些比較只是比較你的第一行。

這裏就是我想要做的：

// Untested Code Below, Not Suited For Production Use 

// ... 
// open the DB connection, open the file, etc. 
// ... 

// iterate over the complete CSV file 
while (!feof($file_handle)) { 
    $line_of_text = fgetcsv($file_handle, 1024); 
    $product_id = clean_product_id($line_of_text[0]); 
    $price = $line_of_text[1]; 
    // for any entry in the CSV file check if there is more than one result 
    $sql="SELECT COUNT(*) FROM products WHERE product_id='$product_id'"; 
    $result = mysqli_query($con,$sql); 
    $row = mysqli_fetch_array($result); 
    if($row[0] == 1) { 
     // update the table price for the corresponding row (product), if there is just a single result for this $product_id 
     $sql="UPDATE products SET price = '$price' WHERE product_id='$product_id' LIMIT 1"; // in production code use mysqli_real_escape_string() on $price and $product_id! 
     $result = mysqli_query($con,$sql); 
    } else { 
     // if there are more results for this $product_id, add an error to your report.txt file 
    } 
}