首页 > 后端开发 > php教程 > php导入csv到sql文件自动插入数据库(示例)

php导入csv到sql文件自动插入数据库(示例)

WBOY
发布: 2016-07-25 08:54:59
原创
985 人浏览过
  1. /**

  2. * php header导入csv文件
  3. * 编辑:bbs.it-home.org
  4. */
  5. header('Content-type:text/html;charset=utf-8;');
  6. @date_default_timezone_set('Asia/Shanghai');
  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文件列为 省(province、city、area、position、address),注意要和数据库字段对应
  16. $sql_list = array();
  17. foreach(array(
  18. 'chongqing.csv' => array('name' => '重庆市','sort' => 4),
  19. 'guizhou.csv' => array('name' => '贵州省','sort' => 24),
  20. 'shanghai.csv' => array('name' => '上海','sort' => 2),
  21. 'sichuan.csv' => array('name' => '四川省','sort' => 23),
  22. 'yunnan.csv' => array('name' => '云南省','sort' => 25)
  23. ) as $filename => $_data) {
  24. $sql = $sql_start = "INSERT INTO `Tbl_Data` (`province`,`city`,`area`,`position`,`address`,`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',trim($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("\n\n",$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]."数据写入成功。\n\r";
  58. }else{
  59. echo '写入数据失败';
  60. echo $csv_arr[$i]."数据写入失败!!!\n\r";
  61. }
  62. $i++;
  63. }
  64. mysql_close($lnk);
  65. unset($sql,$sql_list,$write_result,$csv_arr,$query_result,$lnk);
  66. ?>
复制代码


来源:php.cn
本站声明
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板