Laravel query builder 使用子查询

1. SELECT COUNT(*) FROM  (SELECT * FROM abc GROUP BY col1) AS a; 

执行代码

1. $sub = Abc::where(..)->groupBy(..); // Eloquent Builder instance 
2.  
3. $count = DB::table( DB::raw("({$sub->toSql()}) as sub") ) 
4.     ->mergeBindings($sub->getQuery()) // you need to get underlying Query Builder 
5.     ->count(); 

需求2: 执行如下代码
 

1. SELECT  
2.     `p`.`id`, 
3.     `p`.`name`,  
4.     `p`.`img`,  
5.     `p`.`safe_name`,  
6.     `p`.`sku`,  
7.     `p`.`productstatusid`  
8. FROM `products` p  
9. WHERE `p`.`id` IN ( 
10.     SELECT  
11.         `product_id`  
12.     FROM `product_category` 
13.     WHERE `category_id` IN ('223', '15') 
14. ) 
15. AND `p`.`active`=1 

实现:
 

1. Products::whereIn('id', function($query){ 
2.     $query->select('paper_type_id') 
3.     ->from(with(new ProductCategory)->getTable()) 
4.     ->whereIn('category_id', ['223', '15']) 
5.     ->where('active', 1); 
6. })->get(); 

综合运用:

 

1. $query = \DB::table('message') 
2.     ->where(function ($query) use ($userId) { 
3.         $query->where([ 
4.             ['receiver_id', '=', "$userId"], 
5.             ['type', '=', Messages::PRIVATE_MESSAGE], 
6.         ]); 
7.     }); 
8. if (!empty($groupIds)) { 
9.     $query->orWhere(function ($queryq) use ($groupIds) { 
10.         $queryq 
11.             ->where([ 
12.                 ['type', '=', Messages::GROUP_MESSAGE], 
13.                 ['message.created_at', '>', \Auth::user()->created_at] 
14.             ]) 
15.             ->whereIn('receiver_id', $groupIds); 
16.     }); 
17. } 
18. /* 获取广播 */ 
19. $query->orWhere(function ($query) { 
20.     $query 
21.         ->where([ 
22.             ['type', '=', Messages::BROADCAST_MESSAGE], 
23.             ['dead_line', '>', Carbon::createFromTimestamp(time())], 
24.             ['message.created_at', '>', \Auth::user()->created_at] 
25.         ]); 
26. }); 
27. $query->leftJoin('message_log', function ($join) use ($userId) { 
28.     $join->on('message.id', '=', 'message_log.message_id') 
29.         ->where('message_log.user_id', '=', $userId); 
30. }) 
31.  
32.     ->leftJoin('subscribe', function ($join)  use ($userId) { 
33.         $join->on('subscribe.pcode_id', '=', 'message.receiver_id') 
34.             ->where('subscribe.user_id', '=', $userId); 
35.     }) 
36.  
37.     ->select([ 
38.         'message_log.id as message_log_id', 
39.         'message.id as message_id', 
40.         'message.content', 
41.         'message.type', 
42.         'message.sender_id', 
43.         'message.updated_at', 
44.         'message.created_at', 
45.         'message.dead_line', 
46.         \DB::raw('IF (message.`created_at` < subscribe.`created_at` , 1, 0) AS is_expired') 
47.     ]); 
48.  
49. $resQuery = \DB::table(\DB::raw("({$query->toSql()}) as sub")) 
50.     ->mergeBindings($query) 
51.     ->where('is_expired', '=', 0);