PHP csv文件30w+数据导入mysql数据库

1<?php
2class Add
3{
4    public function data()
5    {
6        ini_set('memory_limit', '-1');  //PHP内存设置
7        $handle=fopen("201501.csv","r");
8        $fileName="201501.csv";
9        //将文件一次性全部读出来
10        $excelData = array();
11        $content = trim(file_get_contents($fileName));
12        $excelData = explode("\n",$content);
13
14        $chunkData = array_chunk($excelData , 500); //批量插入500条数据
15        $count = count($chunkData);
16        for ($i = 0; $i < $count; $i++) {
17            $insertRows = array();
18            foreach($chunkData[$i] as $value){
19                $string = mb_convert_encoding(trim(strip_tags($value)), 'utf-8', 'utf-8');//转码
20                $v = explode(',', trim($string));
21                $v = str_replace("'", " ", $v);
22                $v = str_replace(" ", "", $v);
23                $sqlString       = '('."'".implode( "','", $v  ) . "'".')'; //批量
24                $insertRows[]    = $sqlString;
25            }
26             //var_dump($insertRows);
27            // $sql=$insertRows[0];
28            // echo $sql;
29            $result = $this->add($insertRows); //批量将sql插入数据库。
30        }
31    }
32
33    public function add($insertRows)
34    {
35        set_time_limit(0);
36        $pdo= new PDO("mysql:host=xxxxxx;dbname=xxx",'root','xxx');
37
38        // //采取批量插入
39        $data = implode(',', $insertRows);
40        $sql = "INSERT into `bsy_201501`(id,sid,oid,nickname,tel,phone,contacts,province,city,area,address,link1,link2,omoney,gname,gsign,gnum,onum,gpaymoney,gtotalmoney,gsinglemoney)
41                    VALUES {$data}";
42        // var_dump($sql);die;
43        $result = $pdo->query($sql);
44    }
45
46}
47$model = new Add();
48$model->data();