前言
本文主要給大家介紹了關(guān)于mysql大批量插入數(shù)據(jù)的4種方法，分享出來(lái)供大家參考學(xué)習(xí)，下面話不多說(shuō)了，來(lái)一起看看詳細(xì)的介紹吧
方法一：循環(huán)插入
這個(gè)也是最普通的方式，如果數(shù)據(jù)量不是很大，可以使用，但是每次都要消耗連接數(shù)據(jù)庫(kù)的資源。
大致思維如下
（我這里寫(xiě)偽代碼，具體編寫(xiě)可以結(jié)合自己的業(yè)務(wù)邏輯或者框架語(yǔ)法編寫(xiě)）
for($i=1;$i=100;$i++){
$sql = 'insert...............';
//querysql
}
foreach($arr as $key => $value){
$sql = 'insert...............';
//querysql
}
while($i = 100){
$sql = 'insert...............';
//querysql
$i++
}
因?yàn)樘^(guò)普通同時(shí)也沒(méi)什么難度同時(shí)也不是我今天主要寫(xiě)的所以這里我不多說(shuō)
方法二：減少連接資源，拼接一條sql
偽代碼如下
//這里假設(shè)arr的key和數(shù)據(jù)庫(kù)字段同步，其實(shí)大多數(shù)框架中在php操作數(shù)據(jù)庫(kù)的時(shí)候都是這么設(shè)計(jì)的
$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
這樣寫(xiě)正常插入一萬(wàn)條基本問(wèn)題不大，除非數(shù)據(jù)很長(zhǎng)，應(yīng)付普通的批量插入夠用了，比如：批量生成卡號(hào)，批量生成隨機(jī)碼等等。。。
方法三：使用存儲(chǔ)過(guò)程
這個(gè)我手里正好再用這個(gè)就把sql付出來(lái)，具體業(yè)務(wù)邏輯大家自己組合一下就可以。
delimiter $$$
create procedure zqtest()
begin
declare i int default 0;
set i=0;
start transaction;
while i80000 do
//your insert sql
set i=i+1;
end while;
commit;
end
$$$
delimiter;
call zqtest();
這個(gè)也只是個(gè)測(cè)試代碼，具體參數(shù)大家自行定義
我這里是一次插入8萬(wàn)條，雖然不多但是，每一條數(shù)據(jù)量都很大，有很多varchar4000 和text字段
耗時(shí) 6.524s
方法四：使用MYSQL LOCAL_INFILE
這個(gè)我目前正在使用，所以順便把pdo的代碼也復(fù)上來(lái)，以便大家參考
//設(shè)置pdo開(kāi)啟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);
}
}
這個(gè)同樣每一條數(shù)據(jù)量都很大，有很多varchar4000 和text字段
耗時(shí) 2.160s
以上滿足基本需求，100萬(wàn)數(shù)據(jù)問(wèn)題不大，要不數(shù)據(jù)實(shí)在太大也涉及分庫(kù)分表了，或者使用隊(duì)列插入了。
總結(jié)
以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，謝謝大家對(duì)腳本之家的支持。
您可能感興趣的文章:- MYSQL批量插入數(shù)據(jù)的實(shí)現(xiàn)代碼
- MySQL實(shí)現(xiàn)批量插入以優(yōu)化性能的教程
- MySQL批量插入遇上唯一索引避免方法
- MySQL批量插入數(shù)據(jù)腳本
- MySQL批量SQL插入性能優(yōu)化詳解
- MySQL批量插入和唯一索引問(wèn)題的解決方法
- MySQL如何快速批量插入1000w條數(shù)據(jù)
- MySQL中幾種插入和批量語(yǔ)句實(shí)例詳解
