Thinkphp批量更新数据的方法汇总
来源: 阅读:2807 次 日期:2016-08-16 15:01:00
温馨提示: 小编为您整理了“Thinkphp批量更新数据的方法汇总”,方便广大网友查阅!

这篇文章主要介绍了Thinkphp批量更新数据的方法汇总的相关资料,非常不错,具有参考借鉴价值,需要的朋友可以参考下

方法一:

//批量修改 data二维数组 field关键字段 参考ci 批量修改函数 传参方式

function batch_update($table_name='',$data=array(),$field=''){

if(!$table_name||!$data||!$field){

return false;

}else{

$sql='UPDATE '.$table_name;

}

$con=array();

$con_sql=array();

$fields=array();

foreach ($data as $key => $value) {

$x=0;

foreach ($value as $k => $v) {

if($k!=$field&&!$con[$x]&&$x==0){

$con[$x]=" set {$k} = (CASE {$field} ";

}elseif($k!=$field&&!$con[$x]&&$x>0){

$con[$x]=" {$k} = (CASE {$field} ";

}

if($k!=$field){

$temp=$value[$field];

$con_sql[$x].= " WHEN '{$temp}' THEN '{$v}' ";

$x++;

}

}

$temp=$value[$field];

if(!in_array($temp,$fields)){

$fields[]=$temp;

}

$num=count($con)-1;

foreach ($con as $key => $value) {

foreach ($con_sql as $k => $v) {

if($k==$key&&$key<$num){

$sql.=$value.$v.' end),';

}elseif($k==$key&&$key==$num){

$sql.=$value.$v.' end)';

}

}

}

$str=implode(',',$fields);

$sql.=" where {$field} in({$str})";

$res=M($table_name)->execute($sql);

return $res;

}

//测试

function test(){

$update_array=array();

for ($i=2; $i <7 ; $i++) { 

$data=array();

$data['id']=$i;

$data['memeber_type']=2;

$data['memeber_type_state']=1;

$update_array[]=$data;

}

$res=$this->batch_update('yl_member',$update_array,id);

var_dump($res);

}

方法二:

即是循环一条一条的更新记录。一条记录update一次,这样性能很差,也很容易造成阻塞。

那么能不能一条sql语句实现批量更新呢?mysql并没有提供直接的方法来实现批量更新,但是可以用点小技巧来实现。

UPDATE categories 

SET display_order = CASE id 

WHEN 1 THEN 3 

WHEN 2 THEN 4 

WHEN 3 THEN 5 

END

WHERE id IN (1,2,3)

这句sql的意思是,更新display_order 字段,如果id=1 则display_order 的值为3,如果id=2 则 display_order 的值为4,如果id=3 则 display_order 的值为5。

即是将条件语句写在了一起。

这里的where部分不影响代码的执行,但是会提高sql执行的效率。确保sql语句仅执行需要修改的行数,这里只有3条数据进行更新,而where子句确保只有3行数据执行。

如果更新多个值的话,只需要稍加修改:

UPDATE categories 

SET display_order = CASE id 

WHEN 1 THEN 3 

WHEN 2 THEN 4 

WHEN 3 THEN 5 

END, 

title = CASE id 

WHEN 1 THEN 'New Title 1'

WHEN 2 THEN 'New Title 2'

WHEN 3 THEN 'New Title 3'

END

WHERE id IN (1,2,3)

实际运用

$display_order = array( 

1 => 4, 

2 => 1, 

3 => 2, 

4 => 3, 

5 => 9, 

6 => 5, 

7 => 8, 

8 => 9 

); 

$ids = implode(',', array_keys($display_order)); 

$sql = "UPDATE categories SET display_order = CASE id "; 

foreach ($display_order as $id => $ordinal) { 

$sql .= sprintf("WHEN %d THEN %d ", $id, $ordinal); 

$sql .= "END WHERE id IN ($ids)"; 

echo $sql;

方法二不建议使用。

方法三:

/*

* @param $saveWhere :想要更新主键ID数组

* @param $saveData :想要更新的ID数组所对应的数据

* @param $tableName : 想要更新的表明

* @param $saveWhere : 返回更新成功后的主键ID数组

* */

public function saveAll($saveWhere,&$saveData,$tableName){

if($saveWhere==null||$tableName==null)

return false;

//获取更新的主键id名称

$key = array_keys($saveWhere)[0];

//获取更新列表的长度

$len = count($saveWhere[$key]);

$flag=true;

$model = isset($model)?$model:M($tableName);

//开启事务处理机制

$model->startTrans();

//记录更新失败ID

$error=[];

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

//预处理sql语句

$isRight=$model->where($key.'='.$saveWhere[$key][$i])->save($saveData[$i]);

if($isRight==0){

//将更新失败的记录下来

$error[]=$i;

$flag=false;

}

//$flag=$flag&&$isRight;

}

if($flag ){

//如果都成立就提交

$model->commit();

return $saveWhere;

}elseif(count($error)>0&count($error)<$len){

//先将原先的预处理进行回滚

$model->rollback();

for($i=0;$i<count($error);$i++){

//删除更新失败的ID和Data

unset($saveWhere[$key][$error[$i]]);

unset($saveData[$error[$i]]);

}

//重新将数组下标进行排序

$saveWhere[$key]=array_merge($saveWhere[$key]);

$saveData=array_merge($saveData);

//进行第二次递归更新

$this->saveAll($saveWhere,$saveData,$tableName);

return $saveWhere;

}

else{

//如果都更新就回滚

$model->rollback();

return false;

}

}

在测试方法中调用:

public function test(){

//要更新的数据表的主键数组

$where['ID']=array(70,73,74,80,83);

//ID主键数组对应的待更新数据

$save=array(

array('School'=>'DK Univisity01','isExport'=>0),

array('School'=>'DK Univisity02','isExport'=>0),

array('School'=>'DK Univisity03','isExport'=>0),

array('School'=>'DK Univisity04','isExport'=>0),

array('School'=>'','isExport'=>0),

// array('School'=>' Univisity05','isExport'=>0),

);

$f=$this->saveAll($where,$save,'want');

if(count($f['ID'])>0){

//返回更新成功的ID数组

echo "This is success :</br>";

dump($f);

echo 'ok';

}else{

//更新失败操作

echo "This is failed :</br>";

dump($f);

echo 'error';

}

}

以上所述是小编给大家介绍的Thinkphp批量更新数据的方法汇总,希望对大家有所帮助

更多信息请查看网络编程
由于各方面情况的不断调整与变化, 提供的所有考试信息和咨询回复仅供参考,敬请考生以权威部门公布的正式信息和咨询为准!
关于我们 | 联系我们 | 人才招聘 | 网站声明 | 网站帮助 | 非正式的简要咨询 | 简要咨询须知 | 加入群交流 | 手机站点 | 投诉建议
工业和信息化部备案号:滇ICP备2023014141号-1 云南省教育厅备案号:云教ICP备0901021 滇公网安备53010202001879号 人力资源服务许可证:(云)人服证字(2023)第0102001523号
云南网警备案专用图标
联系电话:0871-65317125(9:00—18:00) 获取招聘考试信息及咨询关注公众号:hfpxwx
咨询QQ:526150442(9:00—18:00)版权所有:
云南网警报警专用图标
Baidu
map