Я пробовал следующий код, но получаю некоторые ошибки. Здесь я могу прочитать входной файл, но я получаю следующую ошибку: Устаревший: функция split () устарела в C: \ wamp \ www \ aaj2 \ index.php в строке 63. O / P: найдено всего 5124 записей в этом csv-файле.
<?php $databasehost = "localhost"; $databasename = "test"; $databasetable = "sample"; $databaseusername="test"; $databasepassword = ""; $fieldseparator = ","; $lineseparator = "\n"; $csvfile = "filename.csv"; $addauto = 0; $save = 1; $outputfile = "output.sql"; if(!file_exists($csvfile)) { echo "File not found. Make sure you specified the correct path.\n"; exit; } $file = fopen($csvfile,"r"); if(!$file) { echo "Error opening data file.\n"; exit; } $size = filesize($csvfile); if(!$size) { echo "File is empty.\n"; exit; } $csvcontent = fread($file,$size); fclose($file); $con = @mysql_connect($databasehost,$databaseusername,$databasepassword) or die(mysql_error()); @mysql_select_db($databasename) or die(mysql_error()); $lines = 0; $queries = ""; $linearray = array(); foreach(split($lineseparator,$csvcontent) as $line) { $lines++; $line = trim($line," \t"); $line = str_replace("\r","",$line); /************************************ This line escapes the special character. remove it if entries are already escaped in the csv file ************************************/ $line = str_replace("'","\'",$line); /*************************************/ $linearray = explode($fieldseparator,$line); $linemysql = implode("','",$linearray); if($addauto) $query = "insert into $databasetable values('','$linemysql');"; else $query = "insert into $databasetable values('$linemysql');"; $queries .= $query . "\n"; @mysql_query($query); } @mysql_close($con); if($save) { if(!is_writable($outputfile)) { echo "File is not writable, check permissions.\n"; } else { $file2 = fopen($outputfile,"w"); if(!$file2) { echo "Error writing to the output file.\n"; } else { fwrite($file2,$queries); fclose($file2); } } } echo "Found a total of $lines records in this csv file.\n"; ?> EDIT: Ошибка: файл не доступен для записи, проверьте разрешения. Всего найдено 5124 записей в этом CSV-файле.
Несколько советов:
Не используйте устаревший ext / mysql , если вы можете использовать ext / mysqli или PDO.
Не читайте весь файл csv в переменной PHP. Что происходит, когда файл составляет 500 МБ?
Не следует писать собственный PHP-код для анализа данных csv, когда вы можете использовать встроенную функцию fgetcsv () .
Не создавайте новый оператор SQL для каждой строки данных, когда вы можете использовать подготовленные инструкции .
Не интерполируйте данные из внешнего файла в операторы SQL. Это опасно для уязвимостей SQL-инъекций , так же, как при интерполяции недоверенного ввода пользователем.
Не разбирайте и не вставляйте данные csv по строке, если вы можете использовать команду LOAD DATA INFILE MySQL. Это в 20 раз быстрее, чем вставка строки за строкой.
Вот более простое решение:
<?php $databasehost = "localhost"; $databasename = "test"; $databasetable = "sample"; $databaseusername="test"; $databasepassword = ""; $fieldseparator = ","; $lineseparator = "\n"; $csvfile = "filename.csv"; if(!file_exists($csvfile)) { die("File not found. Make sure you specified the correct path."); } try { $pdo = new PDO("mysql:host=$databasehost;dbname=$databasename", $databaseusername, $databasepassword, array( PDO::MYSQL_ATTR_LOCAL_INFILE => true, PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION ) ); } catch (PDOException $e) { die("database connection failed: ".$e->getMessage()); } $affectedRows = $pdo->exec(" LOAD DATA LOCAL INFILE ".$pdo->quote($csvfile)." INTO TABLE `$databasetable` FIELDS TERMINATED BY ".$pdo->quote($fieldseparator)." LINES TERMINATED BY ".$pdo->quote($lineseparator)); echo "Loaded a total of $affectedRows records from this csv file.\n"; ?>
Я тестировал это с помощью PHP 5.3.26 на Mac, подключившись к MySQL 5.6.14 на Linux.
Попробуй это:
<?php // specify connection info $connect = mysql_connect('localhost','root','12345'); if (!$connect) { die('Could not <span id="IL_AD1" class="IL_AD"> connect to</span> MySQL: ' . mysql_error()); } $cid =mysql_select_db('test',$connect); //specify db name define('CSV_PATH','C:/wamp/www/csvfile/'); // specify CSV file path $csv_file = CSV_PATH . "infotuts.csv"; // Name of your CSV file $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['ID'] = $csv_array[0]; $insert_csv['name'] = $csv_array[1]; $insert_csv['email'] = $csv_array[2]; $query = "INSERT INTO csvdata(ID,name,email) VALUES('','".$insert_csv['name']."','".$insert_csv['email']."')"; $n=mysql_query($query, $connect ); $i++; } fclose($csvfile); echo "File data successfully imported to database!!"; mysql_close($connect); // closing connection ?>.<?php // specify connection info $connect = mysql_connect('localhost','root','12345'); if (!$connect) { die('Could not <span id="IL_AD1" class="IL_AD"> connect to</span> MySQL: ' . mysql_error()); } $cid =mysql_select_db('test',$connect); //specify db name define('CSV_PATH','C:/wamp/www/csvfile/'); // specify CSV file path $csv_file = CSV_PATH . "infotuts.csv"; // Name of your CSV file $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['ID'] = $csv_array[0]; $insert_csv['name'] = $csv_array[1]; $insert_csv['email'] = $csv_array[2]; $query = "INSERT INTO csvdata(ID,name,email) VALUES('','".$insert_csv['name']."','".$insert_csv['email']."')"; $n=mysql_query($query, $connect ); $i++; } fclose($csvfile); echo "File data successfully imported to database!!"; mysql_close($connect); // closing connection ?>
**Data Import And Export** **CSV To Mysql AND Mysql To CSV Using Mysqli** <!DOCTYPE html> <!-- To change this license header, choose License Headers in Project Properties. To change this template file, choose Tools | Templates and open the template in the editor. --> <html> <head> <meta charset="UTF-8"> <title></title> </head> <body> <form method="post"> <button type="submit" name="btn_export">Data Export</button> <button type="submit" name="btn_import">Data Import</button> </form> <?php $host = "localhost"; $uname = "root"; $pass = ""; $database = "demo"; //Change Your Database Name $conn = new mysqli($host, $uname, $pass, $database)or die("No Connection"); echo mysql_error(); //MYSQL MYADDMINPHP TO CSV if (isset($_REQUEST['btn_export'])) { $data_op = ""; $sql = $conn->query("select * from users"); //Change Your Table Name while ($row1 = $sql->fetch_field()) { $data_op .= '"' . $row1->name . '",'; } $data_op .="\n"; while ($row = $sql->fetch_assoc()) { foreach ($row as $key => $value) { $data_op .='"' . $value . '",'; } $data_op .="\n"; } $filename = "Database.csv"; //Change File type CSV/TXT etc header('Content-type: application/csv'); //Change File type CSV/TXT etc header('Content-Disposition: attachment; filename=' . $filename); echo $data_op; exit; } //CSV To MYSQL MYADDMINPHP if (isset($_REQUEST['btn_import'])) { $filename = 'Database.csv'; $fp = fopen($filename, "r"); while (($row = fgetcsv($fp, "40", ",")) != FALSE) { $sql = "INSERT INTO users (name,pass,city,id) VALUES('" . implode("','", $row) . "')"; if (!$conn->query($sql)) { echo '<br>Data No Insert<br>'; } } fclose($fp); } ?> </body> </html>
Я думаю, вам нужно сначала преобразовать CSV-файл в коллекцию. После этого вы можете добавить запросы вставки цикла и вызова для вставки данных.
Здесь вы получите код для преобразования CSV-файла в массив коллекции. лучший способ к загрузке-и-чтения CSV-файл-в-PHP