mysql大批量插入數據四種方法

mysql大批量插入數據四種方法

方法一:循環插入

這個也是最普通的方式,若是數據量不是很大,可使用,可是每次都要消耗鏈接數據庫的資源。
大體思惟以下
(我這裏寫僞代碼,具體編寫能夠結合本身的業務邏輯或者框架語法編寫)php

for($i=1;$i<=100;$i++){
    $sql = 'insert...............';
    //querysql
}
foreach($arr as $key => $value){
$sql = 'insert...............';
    //querysql
}
while($i <= 100){
$sql = 'insert...............';
    //querysql
    $i++
}

由於太過普通同時也沒什麼難度同時也不是我今天主要寫的因此這裏我很少說mysql

方法二:減小鏈接資源,拼接一條sql

僞代碼以下sql

//這裏假設arr的key和數據庫字段同步,其實大多數框架中在php操做數據庫的時候都是這麼設計的
$arr_keys        = array_keys($arr);
$sql             = 'INSERT INTO tablename (' . implode(',' ,$arr_keys) . ') values';
$arr_values      = array_values($arr);
$sql             .= " ('" . implode("','" ,$arr_values) . "'),";
$sql             = substr($sql ,0 ,-1);
//拼接以後大概就是  INSERT INTO tablename ('username','password') values 
('xxx','xxx'),('xxx','xxx'),('xxx','xxx'),('xxx','xxx'),('xxx','xxx'),('xxx','xxx')
.......
//querysql

這樣寫正常插入一萬條基本問題不大,除非數據很長,應付普通的批量插入夠用了,好比:批量生成卡號,批量生成隨機碼等等。。。數據庫

方法三:使用存儲過程

這個我手裏正好再用這個就把sql付出來,具體業務邏輯你們本身組合一下就能夠。框架

delimiter $$$
create procedure zqtest()
begin
declare i int default 0;
set i=0;
start transaction;
while i<80000 do
    //your insert sql 
set i=i+1;
end while;
commit;
end
$$$
delimiter;
call zqtest();

這個也只是個測試代碼,具體參數你們自行定義
我這裏是一次插入8萬條,雖然很少可是,每一條數據量都很大,有不少varchar4000 和text字段
耗時 6.524s測試

方法四:使用MYSQL LOCAL_INFILE

這個我目前正在使用,因此順便把pdo的代碼也覆上來,以便你們參考this

//設置pdo開啓MYSQL_ATTR_LOCAL_INFILE
/*hs96.cn@gmail.com
public function pdo_local_info ()
{
     global $system_dbserver;
     $dbname  = 'hs96.cn@gmail.com';
     $ip      = 'hs96.cn@gmail.com';
     $user    = 'hs96.cn@gmail.com';
     $pwd     = 'hs96.cn@gmail.com';
     $dsn     = 'mysql:dbname=' . $dbname . ';host=' . $ip . ';port=3306';
     $options = [PDO::MYSQL_ATTR_LOCAL_INFILE => true];
     $db      = new PDO($dsn ,$user ,$pwd ,$options);
     return $db;
 }
//僞代碼以下
public function test(){
     $arr_keys         = array_keys($arr);
     $root_dir         = $_SERVER["DOCUMENT_ROOT"] . '/';
     $my_file          = $root_dir . "hs96.cn@gmail.com/sql_cache/" . $order['OrderNo'] . '.sql';
     $fhandler         = fopen($my_file,'a+');
     if ($fhandler) {
        $sql = implode("\t" ,$arr);
          $i   = 1;
          while ($i <= 80000)
          {
              $i++;
              fwrite($fhandler ,$sql . "\r\n");
          }
          $sql = "LOAD DATA local INFILE '" . $myFile . "' INTO TABLE ";
          $sql .= "tablename (" . implode(',' ,$arr_keys) . ")";
          $pdo = $this->pdo_local_info ();
          $res = $pdo->exec($sql);
          if (!$res) {
               //TODO 插入失敗
          }
          @unlink($my_file);
      }
}

這個一樣每一條數據量都很大,有不少varchar4000 和text字段
耗時 2.160s
以上知足基本需求,100萬數據問題不大,要不數據實在太大也涉及分庫分表了,或者使用隊列插入了。設計

你們可能會說,代碼粘貼上運行不了啊?
個人僞代碼 只講思惟 有了本身的思惟才能一通百通code

相關文章
相關標籤/搜索