mysql 批量插入更新

时间：2016-04-25 19:13:56 阅读：234 评论：0 收藏：0 [点我收藏+]

标签：

<?php

ini_set("max_execution_time", "1800");

/**

* insert 10000条数据

* T1() 164.98570299149 //只循环 $sth->bindValue();$sth->execute();

* T2() 365.94625711441 //循环 $sth = $dbh->prepare();$sth->bindValue();$sth->execute();

* T3() 1.2607250213623 //拼装批量SQL，直接执行

*

* update 10000条数据

* u1() 162.98394322395 //只循环 $sth->bindValue();$sth->execute();

* u2() 193.30426812172 //循环 $sth = $dbh->prepare();$sth->bindValue();$sth->execute();

*  u3()   0.32934808731079     //拼装批量SQL，直接执行（where条件为主键：0.32934808731079，where条件不为主键：1.28左右）

*

* CREATE TABLE IF NOT EXISTS `new_table` (

`id` int(11) NOT NULL AUTO_INCREMENT,

`name` varchar(20) NOT NULL COMMENT ‘姓名‘,

`age` int(11) NOT NULL COMMENT ‘年龄‘,

`addtime` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT ‘添加时间‘,

PRIMARY KEY (`id`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=10001 ;

*

*/

class db {

function getDb() {

$dsn = ‘mysql:dbname=test;host=127.0.0.1‘;

$user = ‘root‘;

$pass = ‘123456‘;

$dbh = new PDO($dsn, $user, $pass);

return $dbh;

}

class test {

function t1() {

$db = new db ();

$dbh = $db->getDb();

$start = microtime(true);

$sql = "INSERT INTO `new_table` (`name` ,`age`)VALUES (:name, :age)";

$sth = $dbh->prepare($sql, array(

PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY

));

for ($i = 0; $i < 10000; $i++) {

$sth->bindValue(‘:name‘, ‘zf_‘ . $i);

$sth->bindValue(‘:age‘, $i);

$sth->execute();

}

$end = microtime(true);

echo $end - $start;

}

function t2() {

$db = new db ();

$dbh = $db->getDb();

$start = microtime(true);

for ($i = 0; $i < 10000; $i++) {

$sql = "INSERT INTO `new_table` (`name` ,`age`)VALUES (:name, :age)";

$sth = $dbh->prepare($sql, array(

PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY

));

$sth->bindValue(‘:name‘, ‘zf_‘ . $i);

$sth->bindValue(‘:age‘, $i);

$sth->execute();

}

$end = microtime(true);

echo $end - $start;

}

function t3() {

$db = new db ();

$dbh = $db->getDb();

$start = microtime(true);

$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$dbh->beginTransaction();

try {

for ($j = 0; $j < 100; $j++) {

$sql = "INSERT INTO `new_table` (`name` ,`age`)VALUES ";

$sql_arr = array();

$sql_other = ‘‘;

for ($i = 0; $i < 100; $i++) {

$sql_arr [] = "(‘zf_" . $m . "‘, " . $m . ")";

}

$sql_other = implode(‘,‘, $sql_arr);

$sql.=$sql_other;

$sth = $dbh->prepare($sql);

$sth->execute();

}

$dbh->commit();

} catch (Exception $e) {

$dbh->rollBack();

echo $e->getMessage() . ‘<br>‘;

}

$end = microtime(true);

$use_time = $end - $start;

echo ‘use time:‘ . $use_time;

}

function u1() {

$db = new db ();

$dbh = $db->getDb();

$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$start = microtime(true);

try {

$sql = "update `new_table` set `name`=:name where id=:id";

$sth = $dbh->prepare($sql, array(

PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY

));

for ($i = 1; $i <= 10000; $i++) {

$sth->bindValue(‘:name‘, ‘zz_‘ . $i);

$sth->bindValue(‘:id‘, $i);

$sth->execute();

echo $i . ‘ ‘;

}

} catch (Exception $e) {

echo $e->getMessage();

}

$end = microtime(true);

$use_time = $end - $start;

echo ‘use time:‘ . $use_time;

}

function u2() {

$db = new db ();

$dbh = $db->getDb();

$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$start = microtime(true);

try {

for ($i = 1; $i <= 10000; $i++) {

$sql = "update `new_table` set `name`=:name where `id`=:id";

$sth = $dbh->prepare($sql, array(

PDO::ATTR_CURSOR => PDO::CURSOR_FWDONLY

));

$sth->bindValue(‘:name‘, ‘zf_‘ . $i);

$sth->bindValue(‘:id‘, $i);

$sth->execute();

}

} catch (Exception $e) {

echo $e->getMessage();

}

$end = microtime(true);

$use_time = $end - $start;

echo ‘use time:‘ . $use_time;

}

function u3() {

$db = new db ();

$dbh = $db->getDb();

$start = microtime(true);

$m = 1;

$dbh->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$dbh->beginTransaction();

try {

for ($j = 0; $j < 100; $j++) {

$sql = "update `new_table` set name=‘zf‘ where ";

$sql_arr = array();

$sql_other = ‘‘;

for ($i = 0; $i < 100; $i++) {

$sql_arr [] = "id=" . $m;

$m++;

}

$sql_other = implode(‘ or ‘, $sql_arr);

$sql.=$sql_other;

//echo $sql . ‘<br>‘;

$sth = $dbh->prepare($sql);

$sth->execute();

}

$dbh->commit();

} catch (Exception $e) {

$dbh->rollBack();

echo $e->getMessage() . ‘<br>‘;

}

$end = microtime(true);

$use_time = $end - $start;

echo ‘use time:‘ . $use_time;

}

$T = new test ();

$T->t1();

//$T->t2();

//$T->t3();

//$T->u1();

//$T->u2();

//$T->u3();

?>

参考：http://bbs.csdn.net/topics/390114674

mysql 批量插入更新

标签：

原文地址：http://www.cnblogs.com/faster/p/5431871.html

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行