2015-08-26 00:27:21 -04:00
< ? php
/**
2015-09-22 09:43:25 -04:00
* Comment API : WP_Comment_Query class
2015-08-26 00:27:21 -04:00
*
* @ package WordPress
2015-09-22 09:45:26 -04:00
* @ subpackage Comments
2015-09-03 21:38:24 -04:00
* @ since 4.4 . 0
*/
/**
* Core class used for querying comments .
*
* @ since 3.1 . 0
*
* @ see WP_Comment_Query :: __construct () for accepted arguments .
2015-08-26 00:27:21 -04:00
*/
class WP_Comment_Query {
2015-09-03 21:38:24 -04:00
2015-08-26 00:27:21 -04:00
/**
* SQL for database query .
*
* @ since 4.0 . 1
* @ access public
* @ var string
*/
public $request ;
/**
* Metadata query container
*
* @ since 3.5 . 0
* @ access public
* @ var object WP_Meta_Query
*/
public $meta_query = false ;
2015-09-18 15:28:51 -04:00
/**
* Metadata query clauses .
*
* @ since 4.4 . 0
* @ access protected
* @ var array
*/
protected $meta_query_clauses ;
2015-09-25 10:09:25 -04:00
/**
* SQL query clauses .
*
* @ since 4.4 . 0
* @ access protected
* @ var array
*/
protected $sql_clauses = array (
'select' => '' ,
'from' => '' ,
'where' => array (),
'groupby' => '' ,
'orderby' => '' ,
'limits' => '' ,
);
2015-08-26 00:27:21 -04:00
/**
* Date query container
*
* @ since 3.7 . 0
* @ access public
* @ var object WP_Date_Query
*/
public $date_query = false ;
/**
* Query vars set by the user .
*
* @ since 3.1 . 0
* @ access public
* @ var array
*/
public $query_vars ;
/**
* Default values for query vars .
*
* @ since 4.2 . 0
* @ access public
* @ var array
*/
public $query_var_defaults ;
/**
* List of comments located by the query .
*
* @ since 4.0 . 0
* @ access public
* @ var array
*/
public $comments ;
2015-09-25 10:35:24 -04:00
/**
* The amount of found comments for the current query .
*
* @ since 4.4 . 0
* @ access public
* @ var int
*/
public $found_comments = 0 ;
/**
* The number of pages .
*
* @ since 4.4 . 0
* @ access public
* @ var int
*/
public $max_num_pages = 0 ;
2015-08-26 00:27:21 -04:00
/**
* Make private / protected methods readable for backwards compatibility .
*
* @ since 4.0 . 0
* @ access public
*
* @ param callable $name Method to call .
* @ param array $arguments Arguments to pass when calling .
* @ return mixed | false Return value of the callback , false otherwise .
*/
public function __call ( $name , $arguments ) {
if ( 'get_search_sql' === $name ) {
return call_user_func_array ( array ( $this , $name ), $arguments );
}
return false ;
}
/**
* Constructor .
*
* Sets up the comment query , based on the query vars passed .
*
2015-09-15 12:23:39 -04:00
* @ since 4.2 . 0
* @ since 4.4 . 0 `$parent__in` and `$parent__not_in` were added .
2015-09-25 11:13:24 -04:00
* @ since 4.4 . 0 Order by `comment__in` was added . `$update_comment_meta_cache` , `$no_found_rows` ,
* and `$hierarchical` were added .
2015-08-26 00:27:21 -04:00
* @ access public
*
* @ param string | array $query {
* Optional . Array or query string of comment query parameters . Default empty .
*
* @ type string $author_email Comment author email address . Default empty .
* @ type array $author__in Array of author IDs to include comments for . Default empty .
* @ type array $author__not_in Array of author IDs to exclude comments for . Default empty .
* @ type array $comment__in Array of comment IDs to include . Default empty .
* @ type array $comment__not_in Array of comment IDs to exclude . Default empty .
* @ type bool $count Whether to return a comment count ( true ) or array of comment
* objects ( false ) . Default false .
* @ type array $date_query Date query clauses to limit comments by . See WP_Date_Query .
* Default null .
* @ type string $fields Comment fields to return . Accepts 'ids' for comment IDs only or
* empty for all fields . Default empty .
* @ type int $ID Currently unused .
* @ type array $include_unapproved Array of IDs or email addresses of users whose unapproved comments
* will be returned by the query regardless of `$status` . Default empty .
* @ type int $karma Karma score to retrieve matching comments for . Default empty .
* @ type string $meta_key Include comments with a matching comment meta key . Default empty .
* @ type string $meta_value Include comments with a matching comment meta value . Requires
* `$meta_key` to be set . Default empty .
* @ type array $meta_query Meta query clauses to limit retrieved comments by .
* See WP_Meta_Query . Default empty .
* @ type int $number Maximum number of comments to retrieve . Default null ( no limit ) .
* @ type int $offset Number of comments to offset the query . Used to build LIMIT clause .
* Default 0.
2015-09-25 10:35:24 -04:00
* @ type bool $no_found_rows Whether to disable the `SQL_CALC_FOUND_ROWS` query .
* Default : true .
2015-08-26 00:27:21 -04:00
* @ type string | array $orderby Comment status or array of statuses . To use 'meta_value' or
* 'meta_value_num' , `$meta_key` must also be defined . To sort by
* a specific `$meta_query` clause , use that clause ' s array key .
* Accepts 'comment_agent' , 'comment_approved' , 'comment_author' ,
* 'comment_author_email' , 'comment_author_IP' ,
* 'comment_author_url' , 'comment_content' , 'comment_date' ,
* 'comment_date_gmt' , 'comment_ID' , 'comment_karma' ,
* 'comment_parent' , 'comment_post_ID' , 'comment_type' , 'user_id' ,
2015-09-15 12:35:44 -04:00
* 'comment__in' , 'meta_value' , 'meta_value_num' , the value of $meta_key , and the
2015-08-26 00:27:21 -04:00
* array keys of `$meta_query` . Also accepts false , an empty array ,
* or 'none' to disable `ORDER BY` clause .
* Default : 'comment_date_gmt' .
* @ type string $order How to order retrieved comments . Accepts 'ASC' , 'DESC' .
* Default : 'DESC' .
* @ type int $parent Parent ID of comment to retrieve children of . Default empty .
2015-09-15 12:23:39 -04:00
* @ type array $parent__in Array of parent IDs of comments to retrieve children for . Default empty .
* @ type array $parent__not_in Array of parent IDs of comments * not * to retrieve children for . Default empty .
2015-08-26 00:27:21 -04:00
* @ type array $post_author__in Array of author IDs to retrieve comments for . Default empty .
* @ type array $post_author__not_in Array of author IDs * not * to retrieve comments for . Default empty .
* @ type int $post_ID Currently unused .
* @ type int $post_id Limit results to those affiliated with a given post ID . Default 0.
* @ type array $post__in Array of post IDs to include affiliated comments for . Default empty .
* @ type array $post__not_in Array of post IDs to exclude affiliated comments for . Default empty .
* @ type int $post_author Comment author ID to limit results by . Default empty .
* @ type string $post_status Post status to retrieve affiliated comments for . Default empty .
* @ type string $post_type Post type to retrieve affiliated comments for . Default empty .
* @ type string $post_name Post name to retrieve affiliated comments for . Default empty .
* @ type int $post_parent Post parent ID to retrieve affiliated comments for . Default empty .
* @ type string $search Search term ( s ) to retrieve matching comments for . Default empty .
* @ type string $status Comment status to limit results by . Accepts 'hold'
* ( `comment_status=0` ), 'approve' ( `comment_status=1` ), 'all' , or a
* custom comment status . Default 'all' .
* @ type string | array $type Include comments of a given type , or array of types . Accepts
* 'comment' , 'pings' ( includes 'pingback' and 'trackback' ), or any
* custom type string . Default empty .
* @ type array $type__in Include comments from a given array of comment types . Default empty .
* @ type array $type__not_in Exclude comments from a given array of comment types . Default empty .
* @ type int $user_id Include comments for a specific user ID . Default empty .
2015-09-25 11:13:24 -04:00
* @ type bool | string $hierarchical Whether to include comment descendants in the results .
* 'threaded' returns a tree , with each comment ' s children stored
* in a `children` property on the `WP_Comment` object . 'flat'
* returns a flat array of found comments plus their children .
* Pass `false` to leave out descendants . The parameter is ignored
* ( forced to `false` ) when `$fields` is 'ids' or 'counts' .
* Accepts 'threaded' , 'flat' , or false . Default : false .
2015-09-17 15:30:27 -04:00
* @ type bool $update_comment_meta_cache Whether to prime the metadata cache for found comments .
* Default true .
2015-08-26 00:27:21 -04:00
* }
*/
public function __construct ( $query = '' ) {
$this -> query_var_defaults = array (
'author_email' => '' ,
'author__in' => '' ,
'author__not_in' => '' ,
'include_unapproved' => '' ,
'fields' => '' ,
'ID' => '' ,
'comment__in' => '' ,
'comment__not_in' => '' ,
'karma' => '' ,
'number' => '' ,
'offset' => '' ,
2015-09-25 10:35:24 -04:00
'no_found_rows' => true ,
2015-08-26 00:27:21 -04:00
'orderby' => '' ,
'order' => 'DESC' ,
'parent' => '' ,
'post_author__in' => '' ,
'post_author__not_in' => '' ,
'post_ID' => '' ,
'post_id' => 0 ,
'post__in' => '' ,
'post__not_in' => '' ,
'post_author' => '' ,
'post_name' => '' ,
'post_parent' => '' ,
'post_status' => '' ,
'post_type' => '' ,
'status' => 'all' ,
'type' => '' ,
'type__in' => '' ,
'type__not_in' => '' ,
'user_id' => '' ,
'search' => '' ,
'count' => false ,
'meta_key' => '' ,
'meta_value' => '' ,
'meta_query' => '' ,
'date_query' => null , // See WP_Date_Query
2015-09-25 11:13:24 -04:00
'hierarchical' => false ,
2015-09-17 15:30:27 -04:00
'update_comment_meta_cache' => true ,
2015-08-26 00:27:21 -04:00
);
if ( ! empty ( $query ) ) {
$this -> query ( $query );
}
}
/**
* Parse arguments passed to the comment query with default query parameters .
*
* @ since 4.2 . 0 Extracted from WP_Comment_Query :: query () .
*
* @ access public
*
* @ param string | array $query WP_Comment_Query arguments . See WP_Comment_Query :: __construct ()
*/
public function parse_query ( $query = '' ) {
if ( empty ( $query ) ) {
$query = $this -> query_vars ;
}
$this -> query_vars = wp_parse_args ( $query , $this -> query_var_defaults );
do_action_ref_array ( 'parse_comment_query' , array ( & $this ) );
}
/**
* Sets up the WordPress query for retrieving comments .
*
* @ since 3.1 . 0
* @ since 4.1 . 0 Introduced 'comment__in' , 'comment__not_in' , 'post_author__in' ,
* 'post_author__not_in' , 'author__in' , 'author__not_in' , 'post__in' ,
* 'post__not_in' , 'include_unapproved' , 'type__in' , and 'type__not_in'
* arguments to $query_vars .
* @ since 4.2 . 0 Moved parsing to WP_Comment_Query :: parse_query () .
* @ access public
*
* @ param string | array $query Array or URL query string of parameters .
* @ return array | int List of comments , or number of comments when 'count' is passed as a query var .
*/
public function query ( $query ) {
$this -> query_vars = wp_parse_args ( $query );
return $this -> get_comments ();
}
/**
* Get a list of comments matching the query vars .
*
* @ since 4.2 . 0
* @ access public
*
* @ global wpdb $wpdb WordPress database abstraction object .
*
* @ return int | array The list of comments .
*/
public function get_comments () {
global $wpdb ;
$this -> parse_query ();
// Parse meta query
$this -> meta_query = new WP_Meta_Query ();
$this -> meta_query -> parse_query_vars ( $this -> query_vars );
/**
* Fires before comments are retrieved .
*
* @ since 3.1 . 0
*
* @ param WP_Comment_Query & $this Current instance of WP_Comment_Query , passed by reference .
*/
do_action_ref_array ( 'pre_get_comments' , array ( & $this ) );
// Reparse query vars, in case they were modified in a 'pre_get_comments' callback.
$this -> meta_query -> parse_query_vars ( $this -> query_vars );
if ( ! empty ( $this -> meta_query -> queries ) ) {
2015-09-18 15:28:51 -04:00
$this -> meta_query_clauses = $this -> meta_query -> get_sql ( 'comment' , $wpdb -> comments , 'comment_ID' , $this );
2015-08-26 00:27:21 -04:00
}
// $args can include anything. Only use the args defined in the query_var_defaults to compute the key.
$key = md5 ( serialize ( wp_array_slice_assoc ( $this -> query_vars , array_keys ( $this -> query_var_defaults ) ) ) );
$last_changed = wp_cache_get ( 'last_changed' , 'comment' );
if ( ! $last_changed ) {
$last_changed = microtime ();
wp_cache_set ( 'last_changed' , $last_changed , 'comment' );
}
2015-09-18 15:28:51 -04:00
$cache_key = " get_comment_ids: $key : $last_changed " ;
2015-08-26 00:27:21 -04:00
2015-09-18 15:28:51 -04:00
$comment_ids = wp_cache_get ( $cache_key , 'comment' );
if ( false === $comment_ids ) {
$comment_ids = $this -> get_comment_ids ();
wp_cache_add ( $cache_key , $comment_ids , 'comment' );
}
// If querying for a count only, there's nothing more to do.
if ( $this -> query_vars [ 'count' ] ) {
// $comment_ids is actually a count in this case.
return intval ( $comment_ids );
}
$comment_ids = array_map ( 'intval' , $comment_ids );
2015-09-25 10:35:24 -04:00
$this -> comment_count = count ( $this -> comments );
if ( $comment_ids && $this -> query_vars [ 'number' ] && ! $this -> query_vars [ 'no_found_rows' ] ) {
/**
* Filter the query used to retrieve found comment count .
*
* @ since 4.4 . 0
*
* @ param string $found_comments_query SQL query . Default 'SELECT FOUND_ROWS()' .
* @ param WP_Comment_Query $comment_query The `WP_Comment_Query` instance .
*/
$found_comments_query = apply_filters ( 'found_comments_query' , 'SELECT FOUND_ROWS()' , $this );
$this -> found_comments = ( int ) $wpdb -> get_var ( $found_comments_query );
$this -> max_num_pages = ceil ( $this -> found_comments / $this -> query_vars [ 'number' ] );
}
2015-09-18 15:28:51 -04:00
if ( 'ids' == $this -> query_vars [ 'fields' ] ) {
$this -> comments = $comment_ids ;
2015-08-26 00:27:21 -04:00
return $this -> comments ;
}
2015-09-18 15:28:51 -04:00
_prime_comment_caches ( $comment_ids , $this -> query_vars [ 'update_comment_meta_cache' ] );
// Fetch full comment objects from the primed cache.
$_comments = array ();
foreach ( $comment_ids as $comment_id ) {
if ( $_comment = wp_cache_get ( $comment_id , 'comment' ) ) {
$_comments [] = $_comment ;
}
}
/**
* Filter the comment query results .
*
* @ since 3.1 . 0
*
* @ param array $results An array of comments .
* @ param WP_Comment_Query & $this Current instance of WP_Comment_Query , passed by reference .
*/
$_comments = apply_filters_ref_array ( 'the_comments' , array ( $_comments , & $this ) );
// Convert to WP_Comment instances
$comments = array_map ( 'get_comment' , $_comments );
2015-09-25 11:13:24 -04:00
if ( $this -> query_vars [ 'hierarchical' ] ) {
$comments = $this -> fill_descendants ( $comments );
}
2015-09-18 15:28:51 -04:00
$this -> comments = $comments ;
return $this -> comments ;
}
/**
* Used internally to get a list of comment IDs matching the query vars .
*
* @ since 4.4 . 0
* @ access protected
*
* @ global wpdb $wpdb
*/
protected function get_comment_ids () {
global $wpdb ;
2015-08-26 00:27:21 -04:00
// Assemble clauses related to 'comment_approved'.
$approved_clauses = array ();
// 'status' accepts an array or a comma-separated string.
$status_clauses = array ();
$statuses = $this -> query_vars [ 'status' ];
if ( ! is_array ( $statuses ) ) {
$statuses = preg_split ( '/[\s,]+/' , $statuses );
}
// 'any' overrides other statuses.
if ( ! in_array ( 'any' , $statuses ) ) {
foreach ( $statuses as $status ) {
switch ( $status ) {
case 'hold' :
$status_clauses [] = " comment_approved = '0' " ;
break ;
case 'approve' :
$status_clauses [] = " comment_approved = '1' " ;
break ;
case 'all' :
case '' :
$status_clauses [] = " ( comment_approved = '0' OR comment_approved = '1' ) " ;
break ;
default :
$status_clauses [] = $wpdb -> prepare ( " comment_approved = %s " , $status );
break ;
}
}
if ( ! empty ( $status_clauses ) ) {
$approved_clauses [] = '( ' . implode ( ' OR ' , $status_clauses ) . ' )' ;
}
}
// User IDs or emails whose unapproved comments are included, regardless of $status.
if ( ! empty ( $this -> query_vars [ 'include_unapproved' ] ) ) {
$include_unapproved = $this -> query_vars [ 'include_unapproved' ];
// Accepts arrays or comma-separated strings.
if ( ! is_array ( $include_unapproved ) ) {
$include_unapproved = preg_split ( '/[\s,]+/' , $include_unapproved );
}
$unapproved_ids = $unapproved_emails = array ();
foreach ( $include_unapproved as $unapproved_identifier ) {
// Numeric values are assumed to be user ids.
if ( is_numeric ( $unapproved_identifier ) ) {
$approved_clauses [] = $wpdb -> prepare ( " ( user_id = %d AND comment_approved = '0' ) " , $unapproved_identifier );
// Otherwise we match against email addresses.
} else {
$approved_clauses [] = $wpdb -> prepare ( " ( comment_author_email = %s AND comment_approved = '0' ) " , $unapproved_identifier );
}
}
}
// Collapse comment_approved clauses into a single OR-separated clause.
if ( ! empty ( $approved_clauses ) ) {
if ( 1 === count ( $approved_clauses ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'approved' ] = $approved_clauses [ 0 ];
2015-08-26 00:27:21 -04:00
} else {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'approved' ] = '( ' . implode ( ' OR ' , $approved_clauses ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
}
$order = ( 'ASC' == strtoupper ( $this -> query_vars [ 'order' ] ) ) ? 'ASC' : 'DESC' ;
// Disable ORDER BY with 'none', an empty array, or boolean false.
if ( in_array ( $this -> query_vars [ 'orderby' ], array ( 'none' , array (), false ), true ) ) {
$orderby = '' ;
} elseif ( ! empty ( $this -> query_vars [ 'orderby' ] ) ) {
$ordersby = is_array ( $this -> query_vars [ 'orderby' ] ) ?
$this -> query_vars [ 'orderby' ] :
preg_split ( '/[,\s]/' , $this -> query_vars [ 'orderby' ] );
$orderby_array = array ();
$found_orderby_comment_ID = false ;
foreach ( $ordersby as $_key => $_value ) {
if ( ! $_value ) {
continue ;
}
if ( is_int ( $_key ) ) {
$_orderby = $_value ;
$_order = $order ;
} else {
$_orderby = $_key ;
$_order = $_value ;
}
2015-09-15 12:35:44 -04:00
if ( ! $found_orderby_comment_ID && in_array ( $_orderby , array ( 'comment_ID' , 'comment__in' ) ) ) {
2015-08-26 00:27:21 -04:00
$found_orderby_comment_ID = true ;
}
$parsed = $this -> parse_orderby ( $_orderby );
if ( ! $parsed ) {
continue ;
}
2015-09-15 12:35:44 -04:00
if ( 'comment__in' === $_orderby ) {
$orderby_array [] = $parsed ;
continue ;
}
2015-08-26 00:27:21 -04:00
$orderby_array [] = $parsed . ' ' . $this -> parse_order ( $_order );
}
// If no valid clauses were found, order by comment_date_gmt.
if ( empty ( $orderby_array ) ) {
$orderby_array [] = " $wpdb->comments .comment_date_gmt $order " ;
}
// To ensure determinate sorting, always include a comment_ID clause.
if ( ! $found_orderby_comment_ID ) {
$comment_ID_order = '' ;
// Inherit order from comment_date or comment_date_gmt, if available.
foreach ( $orderby_array as $orderby_clause ) {
if ( preg_match ( '/comment_date(?:_gmt)*\ (ASC|DESC)/' , $orderby_clause , $match ) ) {
$comment_ID_order = $match [ 1 ];
break ;
}
}
// If no date-related order is available, use the date from the first available clause.
if ( ! $comment_ID_order ) {
foreach ( $orderby_array as $orderby_clause ) {
if ( false !== strpos ( 'ASC' , $orderby_clause ) ) {
$comment_ID_order = 'ASC' ;
} else {
$comment_ID_order = 'DESC' ;
}
break ;
}
}
// Default to DESC.
if ( ! $comment_ID_order ) {
$comment_ID_order = 'DESC' ;
}
$orderby_array [] = " $wpdb->comments .comment_ID $comment_ID_order " ;
}
$orderby = implode ( ', ' , $orderby_array );
} else {
$orderby = " $wpdb->comments .comment_date_gmt $order " ;
}
$number = absint ( $this -> query_vars [ 'number' ] );
$offset = absint ( $this -> query_vars [ 'offset' ] );
if ( ! empty ( $number ) ) {
if ( $offset ) {
$limits = 'LIMIT ' . $offset . ',' . $number ;
} else {
$limits = 'LIMIT ' . $number ;
}
}
if ( $this -> query_vars [ 'count' ] ) {
$fields = 'COUNT(*)' ;
} else {
2015-09-18 15:28:51 -04:00
$fields = " $wpdb->comments .comment_ID " ;
2015-08-26 00:27:21 -04:00
}
$post_id = absint ( $this -> query_vars [ 'post_id' ] );
if ( ! empty ( $post_id ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'post_id' ] = $wpdb -> prepare ( 'comment_post_ID = %d' , $post_id );
2015-08-26 00:27:21 -04:00
}
// Parse comment IDs for an IN clause.
if ( ! empty ( $this -> query_vars [ 'comment__in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'comment__in' ] = " $wpdb->comments .comment_ID IN ( " . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'comment__in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
// Parse comment IDs for a NOT IN clause.
if ( ! empty ( $this -> query_vars [ 'comment__not_in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'comment__not_in' ] = " $wpdb->comments .comment_ID NOT IN ( " . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'comment__not_in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
2015-09-15 12:23:39 -04:00
// Parse comment parent IDs for an IN clause.
if ( ! empty ( $this -> query_vars [ 'parent__in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'parent__in' ] = 'comment_parent IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'parent__in' ] ) ) . ' )' ;
2015-09-15 12:23:39 -04:00
}
// Parse comment parent IDs for a NOT IN clause.
if ( ! empty ( $this -> query_vars [ 'parent__not_in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'parent__not_in' ] = 'comment_parent NOT IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'parent__not_in' ] ) ) . ' )' ;
2015-09-15 12:23:39 -04:00
}
2015-08-26 00:27:21 -04:00
// Parse comment post IDs for an IN clause.
if ( ! empty ( $this -> query_vars [ 'post__in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'post__in' ] = 'comment_post_ID IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'post__in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
// Parse comment post IDs for a NOT IN clause.
if ( ! empty ( $this -> query_vars [ 'post__not_in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'post__not_in' ] = 'comment_post_ID NOT IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'post__not_in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
if ( '' !== $this -> query_vars [ 'author_email' ] ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'author_email' ] = $wpdb -> prepare ( 'comment_author_email = %s' , $this -> query_vars [ 'author_email' ] );
2015-08-26 00:27:21 -04:00
}
if ( '' !== $this -> query_vars [ 'karma' ] ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'karma' ] = $wpdb -> prepare ( 'comment_karma = %d' , $this -> query_vars [ 'karma' ] );
2015-08-26 00:27:21 -04:00
}
// Filtering by comment_type: 'type', 'type__in', 'type__not_in'.
$raw_types = array (
'IN' => array_merge ( ( array ) $this -> query_vars [ 'type' ], ( array ) $this -> query_vars [ 'type__in' ] ),
'NOT IN' => ( array ) $this -> query_vars [ 'type__not_in' ],
);
$comment_types = array ();
foreach ( $raw_types as $operator => $_raw_types ) {
$_raw_types = array_unique ( $_raw_types );
foreach ( $_raw_types as $type ) {
switch ( $type ) {
// An empty translates to 'all', for backward compatibility
case '' :
case 'all' :
break ;
case 'comment' :
case 'comments' :
$comment_types [ $operator ][] = " '' " ;
break ;
case 'pings' :
$comment_types [ $operator ][] = " 'pingback' " ;
$comment_types [ $operator ][] = " 'trackback' " ;
break ;
default :
$comment_types [ $operator ][] = $wpdb -> prepare ( '%s' , $type );
break ;
}
}
if ( ! empty ( $comment_types [ $operator ] ) ) {
$types_sql = implode ( ', ' , $comment_types [ $operator ] );
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'comment_type__' . strtolower ( str_replace ( ' ' , '_' , $operator ) ) ] = " comment_type $operator ( $types_sql ) " ;
2015-08-26 00:27:21 -04:00
}
}
2015-09-25 11:13:24 -04:00
if ( $this -> query_vars [ 'hierarchical' ] && ! $this -> query_vars [ 'parent' ] ) {
$this -> query_vars [ 'parent' ] = 0 ;
}
2015-08-26 00:27:21 -04:00
if ( '' !== $this -> query_vars [ 'parent' ] ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'parent' ] = $wpdb -> prepare ( 'comment_parent = %d' , $this -> query_vars [ 'parent' ] );
2015-08-26 00:27:21 -04:00
}
if ( is_array ( $this -> query_vars [ 'user_id' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'user_id' ] = 'user_id IN (' . implode ( ',' , array_map ( 'absint' , $this -> query_vars [ 'user_id' ] ) ) . ')' ;
2015-08-26 00:27:21 -04:00
} elseif ( '' !== $this -> query_vars [ 'user_id' ] ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'user_id' ] = $wpdb -> prepare ( 'user_id = %d' , $this -> query_vars [ 'user_id' ] );
2015-08-26 00:27:21 -04:00
}
if ( '' !== $this -> query_vars [ 'search' ] ) {
$search_sql = $this -> get_search_sql (
$this -> query_vars [ 'search' ],
array ( 'comment_author' , 'comment_author_email' , 'comment_author_url' , 'comment_author_IP' , 'comment_content' )
);
// Strip leading 'AND'.
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'search' ] = preg_replace ( '/^\s*AND\s*/' , '' , $search_sql );
2015-08-26 00:27:21 -04:00
}
// If any post-related query vars are passed, join the posts table.
$join_posts_table = false ;
$plucked = wp_array_slice_assoc ( $this -> query_vars , array ( 'post_author' , 'post_name' , 'post_parent' , 'post_status' , 'post_type' ) );
$post_fields = array_filter ( $plucked );
if ( ! empty ( $post_fields ) ) {
$join_posts_table = true ;
foreach ( $post_fields as $field_name => $field_value ) {
// $field_value may be an array.
$esses = array_fill ( 0 , count ( ( array ) $field_value ), '%s' );
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'post_fields' ] = $wpdb -> prepare ( " { $wpdb -> posts } . { $field_name } IN ( " . implode ( ',' , $esses ) . ')' , $field_value );
2015-08-26 00:27:21 -04:00
}
}
// Comment author IDs for an IN clause.
if ( ! empty ( $this -> query_vars [ 'author__in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'author__in' ] = 'user_id IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'author__in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
// Comment author IDs for a NOT IN clause.
if ( ! empty ( $this -> query_vars [ 'author__not_in' ] ) ) {
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'author__not_in' ] = 'user_id NOT IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'author__not_in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
// Post author IDs for an IN clause.
if ( ! empty ( $this -> query_vars [ 'post_author__in' ] ) ) {
$join_posts_table = true ;
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'post_author__in' ] = 'post_author IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'post_author__in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
// Post author IDs for a NOT IN clause.
if ( ! empty ( $this -> query_vars [ 'post_author__not_in' ] ) ) {
$join_posts_table = true ;
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'post_author__not_in' ] = 'post_author NOT IN ( ' . implode ( ',' , wp_parse_id_list ( $this -> query_vars [ 'post_author__not_in' ] ) ) . ' )' ;
2015-08-26 00:27:21 -04:00
}
2015-09-25 10:09:25 -04:00
$join = '' ;
2015-08-26 00:27:21 -04:00
if ( $join_posts_table ) {
2015-09-25 10:09:25 -04:00
$join .= " JOIN $wpdb->posts ON $wpdb->posts .ID = $wpdb->comments .comment_post_ID " ;
2015-08-26 00:27:21 -04:00
}
2015-09-18 15:28:51 -04:00
if ( ! empty ( $this -> meta_query_clauses ) ) {
$join .= $this -> meta_query_clauses [ 'join' ];
2015-08-26 00:27:21 -04:00
// Strip leading 'AND'.
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'meta_query' ] = preg_replace ( '/^\s*AND\s*/' , '' , $this -> meta_query_clauses [ 'where' ] );
2015-08-26 00:27:21 -04:00
if ( ! $this -> query_vars [ 'count' ] ) {
$groupby = " { $wpdb -> comments } .comment_ID " ;
}
}
$date_query = $this -> query_vars [ 'date_query' ];
if ( ! empty ( $date_query ) && is_array ( $date_query ) ) {
$date_query_object = new WP_Date_Query ( $date_query , 'comment_date' );
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'where' ][ 'date_query' ] = preg_replace ( '/^\s*AND\s*/' , '' , $date_query_object -> get_sql () );
2015-08-26 00:27:21 -04:00
}
2015-09-25 10:09:25 -04:00
$where = implode ( ' AND ' , $this -> sql_clauses [ 'where' ] );
2015-08-26 00:27:21 -04:00
$pieces = array ( 'fields' , 'join' , 'where' , 'orderby' , 'limits' , 'groupby' );
/**
* Filter the comment query clauses .
*
* @ since 3.1 . 0
*
* @ param array $pieces A compacted array of comment query clauses .
* @ param WP_Comment_Query & $this Current instance of WP_Comment_Query , passed by reference .
*/
$clauses = apply_filters_ref_array ( 'comments_clauses' , array ( compact ( $pieces ), & $this ) );
$fields = isset ( $clauses [ 'fields' ] ) ? $clauses [ 'fields' ] : '' ;
$join = isset ( $clauses [ 'join' ] ) ? $clauses [ 'join' ] : '' ;
$where = isset ( $clauses [ 'where' ] ) ? $clauses [ 'where' ] : '' ;
$orderby = isset ( $clauses [ 'orderby' ] ) ? $clauses [ 'orderby' ] : '' ;
$limits = isset ( $clauses [ 'limits' ] ) ? $clauses [ 'limits' ] : '' ;
$groupby = isset ( $clauses [ 'groupby' ] ) ? $clauses [ 'groupby' ] : '' ;
if ( $where ) {
$where = 'WHERE ' . $where ;
}
if ( $groupby ) {
$groupby = 'GROUP BY ' . $groupby ;
}
if ( $orderby ) {
$orderby = " ORDER BY $orderby " ;
}
2015-09-25 10:35:24 -04:00
$found_rows = '' ;
if ( ! $this -> query_vars [ 'no_found_rows' ] ) {
$found_rows = 'SQL_CALC_FOUND_ROWS' ;
}
$this -> sql_clauses [ 'select' ] = " SELECT $found_rows $fields " ;
2015-09-25 10:09:25 -04:00
$this -> sql_clauses [ 'from' ] = " FROM $wpdb->comments $join " ;
$this -> sql_clauses [ 'groupby' ] = $groupby ;
$this -> sql_clauses [ 'orderby' ] = $orderby ;
$this -> sql_clauses [ 'limits' ] = $limits ;
$this -> request = " { $this -> sql_clauses [ 'select' ] } { $this -> sql_clauses [ 'from' ] } { $where } { $this -> sql_clauses [ 'groupby' ] } { $this -> sql_clauses [ 'orderby' ] } { $this -> sql_clauses [ 'limits' ] } " ;
2015-08-26 00:27:21 -04:00
if ( $this -> query_vars [ 'count' ] ) {
2015-09-18 15:28:51 -04:00
return intval ( $wpdb -> get_var ( $this -> request ) );
} else {
$comment_ids = $wpdb -> get_col ( $this -> request );
return array_map ( 'intval' , $comment_ids );
2015-08-26 00:27:21 -04:00
}
}
2015-09-25 11:13:24 -04:00
/**
* Fetch descendants for located comments .
*
* Instead of calling `get_children()` separately on each child comment , we do a single set of queries to fetch
* the descendant trees for all matched top - level comments .
*
* @ since 4.4 . 0
*
* @ param array $comments Array of top - level comments whose descendants should be filled in .
* @ return array
*/
protected function fill_descendants ( $comments ) {
global $wpdb ;
$levels = array (
0 => wp_list_pluck ( $comments , 'comment_ID' ),
);
$where_clauses = $this -> sql_clauses [ 'where' ];
unset (
$where_clauses [ 'parent' ],
$where_clauses [ 'parent__in' ],
$where_clauses [ 'parent__not_in' ]
);
// Fetch an entire level of the descendant tree at a time.
$level = 0 ;
do {
$parent_ids = $levels [ $level ];
$where = 'WHERE ' . implode ( ' AND ' , $where_clauses ) . ' AND comment_parent IN (' . implode ( ',' , array_map ( 'intval' , $parent_ids ) ) . ')' ;
$comment_ids = $wpdb -> get_col ( " { $this -> sql_clauses [ 'select' ] } { $this -> sql_clauses [ 'from' ] } { $where } { $this -> sql_clauses [ 'groupby' ] } " );
$level ++ ;
$levels [ $level ] = $comment_ids ;
} while ( $comment_ids );
// Prime comment caches for non-top-level comments.
$descendant_ids = array ();
for ( $i = 1 ; $i < count ( $levels ); $i ++ ) {
$descendant_ids = array_merge ( $descendant_ids , $levels [ $i ] );
}
_prime_comment_caches ( $descendant_ids , $this -> query_vars [ 'update_comment_meta_cache' ] );
// Assemble a flat array of all comments + descendants.
$all_comments = $comments ;
foreach ( $descendant_ids as $descendant_id ) {
$all_comments [] = get_comment ( $descendant_id );
}
// If a threaded representation was requested, build the tree.
if ( 'threaded' === $this -> query_vars [ 'hierarchical' ] ) {
$threaded_comments = $ref = array ();
foreach ( $all_comments as $k => $c ) {
$_c = get_comment ( $c -> comment_ID );
// If the comment isn't in the reference array, it goes in the top level of the thread.
if ( ! isset ( $ref [ $c -> comment_parent ] ) ) {
$threaded_comments [ $_c -> comment_ID ] = $_c ;
$ref [ $_c -> comment_ID ] = $threaded_comments [ $_c -> comment_ID ];
// Otherwise, set it as a child of its parent.
} else {
$ref [ $_c -> comment_parent ] -> add_child ( $_c );
// $ref[ $c->comment_parent ]->children[ $c->comment_ID ] = $c;
$ref [ $_c -> comment_ID ] = $ref [ $_c -> comment_parent ] -> get_child ( $_c -> comment_ID );
}
}
$comments = $threaded_comments ;
} else {
$comments = $all_comments ;
}
return $comments ;
}
2015-08-26 00:27:21 -04:00
/**
* Used internally to generate an SQL string for searching across multiple columns
*
* @ since 3.1 . 0
* @ access protected
*
* @ global wpdb $wpdb
*
* @ param string $string
* @ param array $cols
* @ return string
*/
protected function get_search_sql ( $string , $cols ) {
global $wpdb ;
$like = '%' . $wpdb -> esc_like ( $string ) . '%' ;
$searches = array ();
foreach ( $cols as $col ) {
$searches [] = $wpdb -> prepare ( " $col LIKE %s " , $like );
}
return ' AND (' . implode ( ' OR ' , $searches ) . ')' ;
}
/**
* Parse and sanitize 'orderby' keys passed to the comment query .
*
* @ since 4.2 . 0
* @ access protected
*
* @ global wpdb $wpdb WordPress database abstraction object .
*
* @ param string $orderby Alias for the field to order by .
* @ return string | false Value to used in the ORDER clause . False otherwise .
*/
protected function parse_orderby ( $orderby ) {
global $wpdb ;
$allowed_keys = array (
'comment_agent' ,
'comment_approved' ,
'comment_author' ,
'comment_author_email' ,
'comment_author_IP' ,
'comment_author_url' ,
'comment_content' ,
'comment_date' ,
'comment_date_gmt' ,
'comment_ID' ,
'comment_karma' ,
'comment_parent' ,
'comment_post_ID' ,
'comment_type' ,
'user_id' ,
);
if ( ! empty ( $this -> query_vars [ 'meta_key' ] ) ) {
$allowed_keys [] = $this -> query_vars [ 'meta_key' ];
$allowed_keys [] = 'meta_value' ;
$allowed_keys [] = 'meta_value_num' ;
}
$meta_query_clauses = $this -> meta_query -> get_clauses ();
if ( $meta_query_clauses ) {
$allowed_keys = array_merge ( $allowed_keys , array_keys ( $meta_query_clauses ) );
}
$parsed = false ;
if ( $orderby == $this -> query_vars [ 'meta_key' ] || $orderby == 'meta_value' ) {
$parsed = " $wpdb->commentmeta .meta_value " ;
} elseif ( $orderby == 'meta_value_num' ) {
$parsed = " $wpdb->commentmeta .meta_value+0 " ;
2015-09-15 12:35:44 -04:00
} elseif ( $orderby == 'comment__in' ) {
$comment__in = implode ( ',' , array_map ( 'absint' , $this -> query_vars [ 'comment__in' ] ) );
$parsed = " FIELD( { $wpdb -> comments } .comment_ID, $comment__in ) " ;
2015-08-26 00:27:21 -04:00
} elseif ( in_array ( $orderby , $allowed_keys ) ) {
if ( isset ( $meta_query_clauses [ $orderby ] ) ) {
$meta_clause = $meta_query_clauses [ $orderby ];
$parsed = sprintf ( " CAST(%s.meta_value AS %s) " , esc_sql ( $meta_clause [ 'alias' ] ), esc_sql ( $meta_clause [ 'cast' ] ) );
} else {
$parsed = " $wpdb->comments . $orderby " ;
}
}
return $parsed ;
}
/**
* Parse an 'order' query variable and cast it to ASC or DESC as necessary .
*
* @ since 4.2 . 0
* @ access protected
*
* @ param string $order The 'order' query variable .
* @ return string The sanitized 'order' query variable .
*/
protected function parse_order ( $order ) {
if ( ! is_string ( $order ) || empty ( $order ) ) {
return 'DESC' ;
}
if ( 'ASC' === strtoupper ( $order ) ) {
return 'ASC' ;
} else {
return 'DESC' ;
}
}
}