try {
Db::startTrans();
// 获取$amount 条数据
$list = Db::table("tp_address")
->lock(true)
->limit(200)
->column('telephone');
// dump($list);exit;
if ($list) {
$ee = Db::table('tp_address')
->where('telephone', 'in', $list)
->delete();
$result = ['code'=>0, 'msg'=>'下载成功', 'data'=>$list];
} else {
// 数据下载完了,提示上传数据
$result = ['code'=>0, 'msg'=>'下载失败,没有数据了,请上传数据'];
}
Db::commit();
return json($result);
} catch(Exception $e) {
Db::rollback();
// 代码异常
$result = ['code'=>400, 'msg'=>$e->getMessage()];
return json($result);
}
常用于InnoDB
事务操作,回滚
注意:Db::startTrans();// 开启事务
Db::commit(); //提交事务
Db::rollback);// 回滚事务