重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
phpexcel
目前累计服务客户1000+,积累了丰富的产品开发及服务经验。以网站设计水平和技术实力,树立企业形象,为客户提供成都网站制作、成都做网站、网站策划、网页设计、网络营销、VI设计、网站改版、漏洞修补等服务。创新互联始终以务实、诚信为根本,不断创新和提高建站品质,通过对领先技术的掌握、对创意设计的研究、对客户形象的视觉传递、对应用系统的结合,为客户提供更好的一站式互联网解决方案,携手广大客户,共同发展进步。
可以实现xls,xlsx,csv文件的读取。
当然我也有详细代码
直接引入带key和value的数组$data :
$keys = array_keys($data);
$values = array_values($data);
if($keys $values ){
$sql="INSERT INTO zaitugongdan (" . implode(',',$keys) . ") VALUES ('" . implode(',',$values ) . "')";
}
fgetcsv 可以读取fopen打开的文件,并读取一行,
这样可以防止文件太大而内存溢出
然后每读取一定行数,入库一次,
思路:
读取csv文件,每读取一行数据,就插入数据库
示例
文件夹结构
/
file.csv //csv大文件,这里只模拟三行数据,不考虑运行效率(PS:csv文件格式很简单,文件一般较小,解析很快,运行效率的瓶颈主要在写入数据库操作)
index.php //php文件
file.csv
singi,20
lily,19
daming,23
index.php
/**
* 读取csv文件,每读取一行数据,就插入数据库
*/
//获取数据库实例
$dsn = 'mysql:dbname=test;host=127.0.0.1';
$user = 'root';
$password = '';
try {
$db = new PDO($dsn, $user, $password);
} catch (PDOException $e) {
echo 'Connection failed: ' . $e-getMessage();
}
//读取file.csv文件
if (($handle = fopen("file.csv", "r")) !== FALSE) {
while (($row = fgetcsv($handle, 1000, ",")) !== FALSE) {
//写入数据库
$sth = $db-prepare('insert into test set name=:name,age=:age');
$sth-bindParam(':name',$row[0],PDO::PARAM_STR,255);
$sth-bindParam(':age',$row[1],PDO::PARAM_INT);
$sth-execute();
}
fclose($handle);
}
数据表
CREATE TABLE `test` (
`id` INT(10) UNSIGNED NOT NULL AUTO_INCREMENT,
`name` VARCHAR(255) NULL DEFAULT '' COLLATE 'utf8mb4_bin',
`age` INT(10) NULL DEFAULT '0',
PRIMARY KEY (`id`)
)
COLLATE='utf8mb4_bin'
ENGINE=InnoDB;
运行结束后,数据库中会插入csv中的三行数据
1. 把现有表中的 email 字段设为 "唯一" 或者 "主键";2. 用SQL语句导入csv文件:LOAD DATA INFILE 'file_name.csv' IGNORE #注意, 这里的IGNORE是关键, 不导入重复的行
INTO TABLE tbl_name
FIELDS
TERMINATED BY ',' #用逗号分割字段
OPTIONALLY ENCLOSED BY '"' #根据csv文件的字符串是否用引号括起来设置
?php
$data=file("data.csv");
$j=count($data);
for($i=2;$i$j;$i++){
$val="'".str_replace(",","','",trim($data[$i]))."'";
$sql="insert into tab values(".$val.")";
mysql_query($sql,$mylink);
}
?//最简单的形式]
//我不了解csv 现在给你改下
?php
$fp=fopen("a.csv","r");
while(! feof($fp)){
$data=fgetcsv($fp);
if(!is_array($data))
continue;
$sql=$p="";
foreach($data as $val){
$sql.=$p."'".$val."'";
$p=",";
}
$sql="insert into tab values(".$sql.")";
echo $sql;
//mysql_query($sql,$mylink);
}
fclose($fp);
?