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

php中文网

发布时间：2016-07-25 08:54:59

1088人浏览过

来源于php中文网

原创

/**
* 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 '
```
';
```
while( $row = fgetcsv($handle,1000,',') ){
if(!$row) continue;
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']."'),";
}else{
break;
}
$i++;
}
$sql = rtrim($sql,',');
$sql_list[] = $sql;
$csv = 'csv_import_'.$filename.'_'.date('Y-m-d').'.sql';
$csv_arr[] = $csv;
$write_result = file_put_contents($csv,implode("\n\n",$sql_list));
if($write_result){
echo $csv."文件生成成功。\n";
}else{
echo $csv."文件写入失败！！！\n";
}
}

Difeye-敏捷的轻量级PHP框架
Difeye是一款超轻量级PHP框架，主要特点有： Difeye是一款超轻量级PHP框架，主要特点有： ◆数据库连接做自动主从读写分离配置，适合单机和分布式站点部署； ◆支持Smarty模板机制，可灵活配置第三方缓存组件； ◆完全分离页面和动作，仿C#页面加载自动执行Page_Load入口函数； ◆支持mysql，mongodb等第三方数据库模块，支持读写分离，分布式部署； ◆增加后台管理开发示例

下载
//写入数据库(php导入csv文件生成的sql文件)
$lnk = mysql_connect(DB_HOST, DB_USER, DB_PASS);
mysql_select_db(DB_NAME, $lnk);
mysql_query('SET SQL_MODE=""', $lnk);
mysql_query('SET NAMES utf8', $lnk);
$i = 0;
foreach($sql_list as $sql) {
$query_result = mysql_query($sql,$lnk);
if($query_result){
echo '写入数据：';
echo $csv_arr[$i]."数据写入成功。\n\r";
}else{
echo '写入数据失败';
echo $csv_arr[$i]."数据写入失败！！！\n\r";
}
$i++;
}
mysql_close($lnk);
unset($sql,$sql_list,$write_result,$csv_arr,$query_result,$lnk);
?>