ホームページ >バックエンド開発 >PHPチュートリアル >PHPはcsvをSQLファイルにインポートし、自動的にデータベースに挿入します(例)

PHPはcsvをSQLファイルにインポートし、自動的にデータベースに挿入します(例)

WBOY
WBOYオリジナル
2016-07-25 08:54:59986ブラウズ
  1. /**

  2. * php ヘッダーの CSV ファイルのインポート
  3. * 編集者: bbs.it-home.org
  4. */
  5. header('Content-type:text/html;charset=utf-8;');
  6. @date_default_timezone_set('Asia /上海');
  7. @error_reporting(E_ALL);
  8. @ini_set('display_errors', 'On');
  9. @ini_set('memory_limit', '512M');
  10. define('DB_HOST', 'localhost');
  11. define('DB_USER', 'root');
  12. define('DB_PASS', '');
  13. define('DB_NAME', 'DB_XXX');

  14. // CSV を一括インポートデータをフォーマットし、インポートされた SQL ファイルを生成します

  15. //csv ファイルは州 (県、市、地域、位置、住所) としてリストされます。データベースのフィールドに対応するように注意してください
  16. $sql_list = array();
  17. foreach(array(
  18. '重慶.csv' => array('name' => '重慶市','sort' => 4),
  19. 'guizhou.csv' => '貴州省',' 並べ替え' => 24),
  20. 'shanghai.csv' => array('name' => '上海','sort' => 2),
  21. '四川省.csv' => ; array(' name' => '四川省','sort' => 23),
  22. 'yunnan.csv' => array('name' => '雲南省','sort' =>) ; 25)
  23. ) as $filename => $_data) {
  24. $sql = $sql_start = "INSERT INTO `Tbl_Data` (`県`,`市`,`地域`,`位置`,`住所`,` sort`) VALUES ";
  25. $handle = fopen($filename,'r');
  26. $i=0;
  27. echo '
    ';
  28. while( $row = fgetcsv($handle,1000,', ') ){
  29. if(!$row) continue;
  30. if($i $sql .= "('".iconv('gbk','utf-8',trim($row[0 ])). "','".iconv('gbk','utf-8',trim($row[1]))."','".iconv('gbk','utf-8',トリム($row [2]))."','".iconv('gbk','utf-8',trim($row[3]))."','".iconv('gbk', 'utf-8 ',trim($row[4]))."','".$_data['sort']."'),";
  31. }else{
  32. Break;
  33. }
  34. $i++;
  35. }
  36. $sql = rtrim($sql,',');
  37. $sql_list[] = $sql;
  38. $csv = 'csv_import_'.$filename.'_'.date('Y-m-d').'。 sql';
  39. $csv_arr[] = $csv;
  40. $write_result = file_put_contents($csv,implode("nn",$sql_list));
  41. if($write_result){
  42. echo $csv."ファイルの生成に成功しました。 n";
  43. }else{
  44. echo $csv."ファイルの書き込みに失敗しました! ! ! n";
  45. }

  46. }

  47. //データベースへの書き込み(phpでcsvファイルをインポートして生成したSQLファイル)

  48. $lnk = mysql_connect(DB_HOST, DB_USER , DB_PASS);
  49. mysql_select_db(DB_NAME, $lnk);
  50. mysql_query('SET SQL_MODE=""', $lnk);
  51. mysql_query('SET NAMES utf8', $lnk);
  52. $i = 0;
  53. foreach ( $sql_list as $sql) {
  54. $query_result = mysql_query($sql,$lnk);
  55. if($query_result){
  56. echo 'データの書き込み:';
  57. echo $csv_arr[$i]."データは正常に書き込まれました。 nr";
  58. }else{
  59. echo 'データの書き込みに失敗しました';
  60. echo $csv_arr[$i]."データの書き込みに失敗しました! ! ! nr";
  61. }
  62. $i++;
  63. }
  64. mysql_close($lnk);
  65. unset($sql,$sql_list,$write_result,$csv_arr,$query_result,$lnk);
  66. ?>

コードをコピー


声明:
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。