当前位置:Gxlcms > PHP基础 > thinkphp 批量更新数据字段

thinkphp 批量更新数据字段

时间:2021-07-01 10:21:17 帮助过:233人阅读

  1. /*

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

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

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

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

  6.      * */

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

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

  9.             return false;

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

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

  12.         //获取更新列表的长度

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

  14.         $flag=true;

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

  16.         //开启事务处理机制

  17.         $model->startTrans();

  18.         //记录更新失败ID

  19.         $error=[];

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

  21.             //预处理sql语句

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

  23.             if($isRight==0){

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

  25.                 $error[]=$i;

  26.                 $flag=false;

  27.             }

  28.             //$flag=$flag&&$isRight;

  29.         }

  30.         if($flag ){

  31.             //如果都成立就提交

  32.             $model->commit();

  33.             return $saveWhere;

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

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

  36.             $model->rollback();

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

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

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

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

  41.             }

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

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

  44.             $saveData=array_merge($saveData);

  45.             //进行第二次递归更新

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

  47.             return $saveWhere;

  48.         }

  49.         else{

  50.             //如果都更新就回滚

  51.             $model->rollback();

  52.             return false;

  53.         }

  54.     }

在测试方法中调用

  1. public function test(){

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

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

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

  5.         $save=array(

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

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

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

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

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

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

  12.         );

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

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

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

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

  17.             dump($f);

  18.             echo 'ok';

  19.         }else{

  20.            //更新失败操作

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

  22.             dump($f);

  23.             echo 'error';

  24.         }

  25.     }


人气教程排行