求助一个MySQL问题

591vps

500M的TXT 存mysql 单表 老哥 你这有点凶残啊， php 单表插入呗

忘江湖

q952417961 发表于 2018-5-21 12:08
老哥   能加个QQ讨论一下吗  没用过这个软件

请看我上面的帖子，给你编辑了详细的步骤。还有软件下载地址

hooray

社。工。库？

asdqwe876

一句话导入，需要的话私信

xuliliang

不 BB, 看代码.

1. 
   
2. <?php
   
3. 
   
4. /// 数据库连接
   
5. function conn($config) {
   
6.     $db = new mysqli(
   
7.         $config["host"],
   
8.         $config["user"],
   
9.         $config["pwd"],
   
10.         $config["database"],
    
11.         $config["port"]
    
12.     );
    
13. 
    
14.     if (!$db) {
    
15.         throw new \Exception("error: can't connect db");
    
16.     }
    
17. 
    
18.     $db->query("set character set 'utf8'");
    
19.     $db->query("set names 'utf8'");
    
20. 
    
21.     return $db;
    
22. }
    
23. 
    
24. function import($filename, $delimiter = '-') {
    
25.     $handle = fopen($filename, "r");
    
26.     $ar = Array();
    
27.    
    
28. 
    
29.     while (($buffer = fgets($handle, 4096)) !== false) {
    
30.         array_push($ar, explode($delimiter, $buffer));
    
31.     }
    
32. 
    
33.     if (!feof($handle)) {
    
34.         echo "Error: unexpected fgets() fail\n";
    
35.     }
    
36. 
    
37.     return $ar;
    
38. }
    
39. 
    
40. function _save($middle, $conn, $table) {
    
41.     if (!$middle) {
    
42.         return NULL;
    
43.     }
    
44. 
    
45.     $middle = rtrim($middle, ',');
    
46.     $query  =<<<QEOF
    
47.     INSERT INTO ${table}(`uname`, `pwd`) VALUES ${middle};
    
48. QEOF;
    
49. 
    
50.     return $conn->query($query);
    
51. }
    
52. 
    
53. /// 数据写入
    
54. function save($conn, $ar, $table = 'sometable', $count = 50) {
    
55.     $middle = '';
    
56. 
    
57.     foreach($ar as $i => $item) {
    
58.         $uname = $item[0];
    
59.         $pwd   = rtrim($item[1], "\n");
    
60. 
    
61.         $middle .= "('${uname}', '${pwd}'),";
    
62.    
    
63.         if (($i + 1) % $count == 0) {
    
64.             _save($middle, $conn, $table);
    
65.             $middle = '';
    
66.         }
    
67.     }
    
68.     _save($middle, $conn, $table);
    
69. }
    
70. 
    
71. $conn = conn([
    
72.     'host'     => '127.0.0.1',  /// 地址
    
73.     'user'     => 'root',       /// 用户名
    
74.     'pwd'      => '',           /// 密码
    
75.     'port'     => '3306',       /// 端口
    
76.     'database' => 'test',       /// 数据库
    
77. ]);
    
78. 
    
79. $ar = import('test.txt');
    
80. 
    
81. save($conn, $ar, 'test');
    
82. 
    

复制代码