DB::chunk() 方法

2019-01-16  本文已影响11人  爱折腾的傻小子
// sql: select `product_id`,`sku` from `oc_product` where `sku` like '%-bingshopping' order by `sku` asc
// 这里查询oc_product表sku后缀xxxxshopping相关数据 
DB::connection('mysql_us')
        ->table('oc_product')
        ->select(['product_id','sku'])
        ->where('sku','like','%xxxxshopping')
        ->orderBy('sku','ASC')
        ->orderBy('product_id','ASC')
        ->chunk(50, function($datum) use ($bar){
            foreach ($datum as $item){
                // 删除数据 这里又删除查询出来sku后缀xxxxshopping相关数据 
                // 这样会导致存在部分数据被删除 (主要是limit分页的页数在逐渐增大 会到某一个值page查不到数据)
                $this->delete($item->product_id, $item->sku);
            }

            $bar->advance();
        });
上一篇 下一篇

猜你喜欢

热点阅读