/** - * php header导入csv文件
- * 编辑：bbs.it-home.org
- */
- header('Content-type:text/html;charset=utf-8;');
- @date_default_timezone_set('Asia/Shanghai');
- @error_reporting(E_ALL);
- @ini_set('display_errors', 'On');
- @ini_set('memory_limit', '512M');
- define('DB_HOST', 'localhost');
- define('DB_USER', 'root');
- define('DB_PASS', '');
- define('DB_NAME', 'DB_XXX');
//批量导入csv格式数据并生成导入sql文件 - //csv文件列为 省（province、city、area、position、address），注意要和数据库字段对应
- $sql_list = array();
- foreach(array(
- 'chongqing.csv' => array('name' => '重庆市','sort' => 4),
- 'guizhou.csv' => array('name' => '贵州省','sort' => 24),
- 'shanghai.csv' => array('name' => '上海','sort' => 2),
- 'sichuan.csv' => array('name' => '四川省','sort' => 23),
- 'yunnan.csv' => array('name' => '云南省','sort' => 25)
- ) as $filename => $_data) {
- $sql = $sql_start = "INSERT INTO `Tbl_Data` (`province`,`city`,`area`,`position`,`address`,`sort`) VALUES ";
- $handle = fopen($filename,'r');
- $i=0;
- echo '
- ';<li> while( $row = fgetcsv($handle,1000,',') ){</li><li> if(!$row) continue;</li><li> if($i<1000000){</li><li> $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']."'),";</li><li> }else{</li><li> break;</li><li> }</li><li> $i++;</li><li> }</li><li> $sql = rtrim($sql,',');</li><li> $sql_list[] = $sql;</li><li> $csv = 'csv_import_'.$filename.'_'.date('Y-m-d').'.sql';</li><li> $csv_arr[] = $csv;</li><li> $write_result = file_put_contents($csv,implode("\n\n",$sql_list));</li><li> if($write_result){</li><li> echo $csv."文件生成成功。\n";</li><li> }else{</li><li> echo $csv."文件写入失败！！！\n";</li><li> }<p></p></li><li><p>}</p></li><li><p>//写入数据库(php导入csv文件生成的sql文件)</p></li><li>$lnk = mysql_connect(DB_HOST, DB_USER, DB_PASS);</li><li>mysql_select_db(DB_NAME, $lnk);</li><li>mysql_query('SET SQL_MODE=""', $lnk);</li><li>mysql_query('SET NAMES utf8', $lnk);</li><li>$i = 0;</li><li>foreach($sql_list as $sql) {</li><li> $query_result = mysql_query($sql,$lnk);</li><li> if($query_result){</li><li> echo '写入数据：';</li><li> echo $csv_arr[$i]."数据写入成功。\n\r";</li><li> }else{</li><li> echo '写入数据失败';</li><li> echo $csv_arr[$i]."数据写入失败！！！\n\r";</li><li> }</li><li> $i++;</li><li>}</li><li>mysql_close($lnk);</li><li>unset($sql,$sql_list,$write_result,$csv_arr,$query_result,$lnk);</li><li>?><p></p></li><li></li>
|
