php 在线导入mysql大数据程序_PHP教程
- WBOY原创
- 2016-07-13 09:51:06800浏览
php 在线导入mysql大数据程序
php 在线导入 mysql 大数据程序
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 |
header("content-type:text/html;charset=utf-8"); error_reporting(E_ALL); set_time_limit(0); $file='./test.sql'; $data=file($file);
echo " ";
<p>//print_r($data);</p>
<p>$data_new=array();</p>
<p>$tmp=array();</p>
<p>foreach ($data as $line) {</p>
<p> </p>
<p>$line=trim($line);</p>
<p>if(strlen($line)==0){</p>
<p>continue;</p>
<p>}</p>
<p>if(substr($line,0,2)=='--'){</p>
<p>continue;</p>
<p>}</p>
<p>if(substr($line,0,2)=='/*'){</p>
<p>continue;</p>
<p>}</p>
<p>$tmp[]=$line;</p>
<p>if(substr($line,-1)==';'){</p>
<p>$query=implode('',$tmp);</p>
<p>$tmp=array();</p>
<p>$data_new[]=$query;</p>
<p>}</p>
<p>}</p>
<p> </p>
<p>$mysqli=new mysqli('localhost','root','root','test');</p>
<p>if($mysqli->connect_errno){</p>
<p>exit('数据库连接失败！');</p>
<p>}</p>
<p>$mysqli->query("set names utf8");</p>
<p> </p>
<p>$error=array();</p>
<p>foreach($data_new as $sql){</p>
<p>$mysqli->query($sql);</p>
<p>$r=$mysqli->error;</p>
<p>if($r) $error[]=$r;</p>
<p>}</p>
<p>print_r($r);</p>
<p> </p>
<p>/*</p>
<p> </p>
<p>mysql>ALTER TABLE tbl2 DISABLE KEYS;</p>
<p>Query OK, 0 rows affected (0.00 sec)</p>
<p> </p>
<p>mysql>INSERT INTO tbl2 SELECT * FROM tbl1;</p>
<p>Query OK, 2000000 row affected (36.30 sec)</p>
<p>Records: 2000000 Duplicates: 0 Warnings: 0</p>
<p> </p>
<p>mysql>ALTER TABLE tbl2 ENABLE KEYS;</p>
<p>Query OK, 0 rows affected (44.55 sec)</p>
<p> </p>
<p>*/</p>
|
适用情况：phpmyadmin导出的sql文件过大，无法导入到线上phpmyadmin中
把该程序和sql文件上传到空间中，用完后删除即可。
分享一个其他网友的方法吧，小伙伴们也可以参考下
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 |
$rate_info = file("$table.txt"); print $n_s = chop($rate_info[0]); for($start=1;$start { $value=""; for ($i=$start;$i { $tmp = str_replace("&&jimmy&&"," ",chop($rate_info[$i])); $value .= "'".addslashes($tmp)."',"; } $tmp = str_replace("&&jimmy&&"," ",chop($rate_info[$start+$n_s-1])); $value .= "'".$tmp."'"; $query = "insert into $table values (".$value.")"; print mysql_error(); mysql_query($query); print $start." "; } print "ostart"; ?> |
以上所述就是本文的全部内容了，希望大家能够喜欢。