php 文本文件操作读取txt文件保存到mysql数据库

本文章收藏了二个相关的实现，利用php的fopen打开文本文件然后保存到数据库了，方法很简单下面我们来看看吧。

<script>ec(2);</script>

实例1、php 读txt文件插入数据库

代码如下

复制代码

$m = mysql_connect('127.0.0.1','root','') or die("Invalid query: " . mysql_error()); mysql_select_db('discuz', $m) or die("Invalid query: " . mysql_error()); $handle = fopen("aa.txt", "r"); while (!feof($handle)) {     $buffer =  ($handle);     $ss[] = explode(' ', $buffer);     } //var_dump($ss); mysql_query("set names 'utf8'",$m); foreach($ss as $k => $v){   //addslashes($v);   //foreach($v as $k = $value){   //$vv = addslashes($value);  //mysql_query("insert into match_view_test_2 (`kanum`, `username`, `mid`, `rank`, `num` ,`zunum` ,`sex` ,`yucolor` ,`eye` ,`backtime` ,`kongju` ,`fengspeed` )   //values ('123','123', 20111014060110765 ,1,'123','123','123','123','123','123','123','123')") or die("Invalid query: " . mysql_error());  //}  $kanum = $v[1];  $username = $v[2];    $rank = (int)$v[0];    $num = $v[3];  $zunum = $v[4];  $sex = $v[5];  //echo $sex;  $yucolor = $v[6];  //$eye = $v[7];  $backtime = $v[8].' '.$v[9];  $kongju = $v[10];  $fengspeed = $v[11];  mysql_query("insert into match_view_test (`kanum`, `username`, `mid`, `rank`, `num` ,`zunum` ,`sex` ,`yucolor` ,`eye` ,`backtime` ,`kongju` ,`fengspeed` )   VALUES('$kanum','$username', 20111014060110765,$rank,'$num','$zunum','$sex','$yucolor','$eye','$backtime','$kongju','$fengspeed')") or die("Invalid query: " . mysql_error());  } ?>

php读取txt文件组成SQL并插入数据库的代码

先看数据结构

 

代码如下	复制代码
-- 数据表结构： -- 100000_insert,1000000_insert CREATE TABLE `100000_insert` ( `id` int(11) NOT NULL AUTO_INCREMENT, `parentid` int(11) NOT NULL, `name` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 100000 （10万）行插入：Insert 100000_line_data use 2.5534288883209 seconds 1000000（100万）行插入：Insert 1000000_line_data use 19.677318811417 seconds

php文件

代码如下

复制代码

/** * $splitChar 字段分隔符 * $file 数据文件文件名 * $table 数据库表名 * $conn 数据库连接 * $fields 数据对应的列名 * $insertType 插入操作类型，包括INSERT,REPLACE */ function loadTxtDataIntoDatabase($splitChar,$file,$table,$conn,$fields=array(),$insertType='INSERT'){ if(empty($fields)) $head = "{$insertType} INTO `{$table}` VALUES('"; else $head = "{$insertType} INTO `{$table}`(`".implode('`,`',$fields)."`) VALUES('"; //数据头 $end = "')"; $sqldata = trim(file_get_contents($file)); if(preg_replace('/s*/i','',$splitChar) == '') { $splitChar = '/(w+)(s+)/i'; $replace = "$1','"; $specialFunc = 'preg_replace'; }else { $splitChar = $splitChar; $replace = "','"; $specialFunc = 'str_replace'; } //处理数据体，二者顺序不可换，否则空格或Tab分隔符时出错 $sqldata = preg_replace('/(s*)(n+)(s*)/i',''),('',$sqldata); //替换换行 $sqldata = $specialFunc($splitChar,$replace,$sqldata); //替换分隔符 $query = $head.$sqldata.$end; //数据拼接 if(mysql_query($query,$conn)) return array(true); else { return array(false,mysql_error($conn),mysql_errno($conn)); } } //调用示例1 require 'db.php'; $splitChar = '|'; //竖线 $file = 'sqldata1.txt'; $fields = array('id','parentid','name'); $table = 'cengji'; $result = loadTxtDataIntoDatabase($splitChar,$file,$table,$conn,$fields); if (array_shift($result)){ echo 'Success! '; }else { echo 'Failed!--Error:'.array_shift($result).' '; } /*sqlda ta1.txt |0|A |1|B |1|C |2|D -- cengji CREATE TABLE `cengji` ( `id` int(11) NOT NULL AUTO_INCREMENT, `parentid` int(11) NOT NULL, `name` varchar(255) DEFAULT NULL, PRIMARY KEY (`id`), UNIQUE KEY `parentid_name_unique` (`parentid`,`name`) USING BTREE ) ENGINE=InnoDB AUTO_INCREMENT=1602 DEFAULT CHARSET=utf8 */ //调用示例2 require 'db.php'; $splitChar = ' '; //空格 $file = 'sqldata2.txt'; $fields = array('id','make','model','year'); $table = 'cars'; $result = loadTxtDataIntoDatabase($splitChar,$file,$table,$conn,$fields); if (array_shift($result)){ echo 'Success! '; }else { echo 'Failed!--Error:'.array_shift($result).' '; } /* sqldata2.txt Aston DB19 2009 Aston DB29 2009 Aston DB39 2009 -- cars CREATE TABLE `cars` ( `id` int(11) NOT NULL AUTO_INCREMENT, `make` varchar(16) NOT NULL, `model` varchar(16) DEFAULT NULL, `year` varchar(16) DEFAULT NULL, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=14 DEFAULT CHARSET=utf8 */ //调用示例3 require 'db.php'; $splitChar = ' '; //Tab $file = 'sqldata3.txt'; $fields = array('id','make','model','year'); $table = 'cars'; $insertType = 'REPLACE'; $result = loadTxtDataIntoDatabase($splitChar,$file,$table,$conn,$fields,$insertType); if (array_shift($result)){ echo 'Success! '; }else { echo 'Failed!--Error:'.array_shift($result).' '; } /* sqldata3.txt Aston DB19 2009 Aston DB29 2009 Aston DB39 2009 */ //调用示例3 require 'db.php'; $splitChar = ' '; //Tab $file = 'sqldata3.txt'; $fields = array('id','value'); $table = 'notExist'; //不存在表 $result = loadTxtDataIntoDatabase($splitChar,$file,$table,$conn,$fields); if (array_shift($result)){ echo 'Success! '; }else { echo 'Failed!--Error:'.array_shift($result).' '; } //附：db.php /* //注释这一行可全部释放 ?> static $connect = null; static $table = 'jilian'; if(!isset($connect)) { $connect = mysql_connect("localhost","root",""); if(!$connect) { $connect = mysql_connect("localhost","Zjmainstay",""); } if(!$connect) { die('Can not connect to database.Fatal error handle by /test/db.php'); } mysql_select_db("test",$connect); mysql_query("SET NAMES utf8",$connect); $conn = &$connect; $db = &$connect; } ?>

如果出现MySQL server has gone away 是因为导入数据包过大，导入mysql挂机了，我们解决方法是修改my.ini/my.cnf max_allowed_packet=20M 。