将 csv 文件中的记录插入数据库表将不会从系列中的第一列获取记录

Question

我将向您发送我用于将数据从 csv 文件插入数据库表的代码，但它不会从开头插入数据并连续到最后一条记录，而是随机获取记录请建议我更改当前代码这样它就会从开始连续获取记录，直到最后从 csv 文件中获取每条记录

 <?php
 $connect = mysql_connect("localhost","root","");
 set_time_limit(0);
 if (!$connect) 
 {
 die('Could not connect to MySQL: ' . mysql_error());
 }
 $cid=mysql_select_db("bond1",$connect);
 define("CSV_PATH","D:/wamp/www/csvfile/");                                                       

 $csv_file=CSV_PATH."file.csv";
 $csvfile=fopen($csv_file, 'r');
 $theData=fgets($csvfile);
 $i=0;

 while(!feof($csvfile))
 {
 $csv_data[] = fgets($csvfile,1024);
 $csv_array=explode(",", $csv_data[$i]);
 $insert_csv=array();
 $insert_csv['name']=$csv_array[0];
 $insert_csv['address']='http://'.$csv_array[1];
 $insert_csv['duns_number']=$csv_array[2];
 $insert_csv['idnum']=$csv_array[3];

 $query="insert into  companyinfo(name,address,duns_number,id_number)values('".$insert_csv['name']."','".$insert_csv['address']."','".$insert_csv['duns_number']."','".$insert_csv['idnum']."')";
  $n=mysql_query($query,$connect);
  ++$i;
  }
  fclose($csvfile);
  echo "File data successfully imported to database!!";
  mysql_close($connect);
  ?>

Answer 1

http://php.net/manual/en/function.str-getcsv.php

使用该函数自动将 csv 解析为数组。

Answer 2

而不是检查文件指针的while循环feof

点赞while(!feof($csvfile))

将 fgets($csvfile,1024); 移到 while 循环中

 while (($csv_data = fgets($csvfile, 4096)) !== false) {

并在下面更改您的代码。希望它能解决您的问题。

Answer 3

这将进一步帮助您

<?php

set_time_limit(0);
$i = 0;

//create database connection
$con=mysqli_connect("localhost","root","","my_db");

// Check connection
if (mysqli_connect_errno()) 
{
  echo "Failed to connect to MySQL: " . mysqli_connect_error();
}

while (!feof($csvfile)) 
{
    $csv_data = fgets($csvfile, 1024);

//if it is first row skip here  || if any value is empty then skip the row
 if($i==0 || 
    (empty($csv_array[0]) || 
     empty($csv_array[1]) ||
     empty($csv_array[2]) ||
     empty($csv_array[3])))
    {
        ++$i;

        //continue the loop
        continue;
    }

    $csv_array = explode(",", $csv_data);
    $insert_csv = array();
    $insert_csv['name'] = $csv_array[0];
    $insert_csv['address'] = 'http://' . $csv_array[1];
    $insert_csv['duns_number'] = $csv_array[2];
    $insert_csv['idnum'] = $csv_array[3];

    $sql = "INSERT INTO companyinfo(name,address,duns_number,id_number)
            VALUES('" . $insert_csv['name'] . "',‌
            ​'" . $insert_csv['address'] . "',
            '" . $insert_csv['duns_number'] . "',
            '" . $insert_csv['idn‌​um'] . "')";

    //insert the query
    if (!mysqli_query($con,$sql)) 
    {
      die('Error: ' . mysqli_error($con));
    }
}