Thinkphp批量更新数据的方法汇总
程序员文章站
2024-04-02 15:15:04
以下小编给大家列出了三种实现thinkphp批量更新数据的方法,写的不好还请见谅,有意见欢迎提出,共同学习进步!
方法一:
//批量修改 data二维数组...
以下小编给大家列出了三种实现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批量更新数据的方法汇总,希望对大家有所帮助